summaryrefslogtreecommitdiff
path: root/Build/source/utils/asymptote/LspCpp/LibLsp/JsonRpc/WebSocketServer.h
diff options
context:
space:
mode:
Diffstat (limited to 'Build/source/utils/asymptote/LspCpp/LibLsp/JsonRpc/WebSocketServer.h')
-rw-r--r--Build/source/utils/asymptote/LspCpp/LibLsp/JsonRpc/WebSocketServer.h87
1 files changed, 0 insertions, 87 deletions
diff --git a/Build/source/utils/asymptote/LspCpp/LibLsp/JsonRpc/WebSocketServer.h b/Build/source/utils/asymptote/LspCpp/LibLsp/JsonRpc/WebSocketServer.h
deleted file mode 100644
index 5206525cebe..00000000000
--- a/Build/source/utils/asymptote/LspCpp/LibLsp/JsonRpc/WebSocketServer.h
+++ /dev/null
@@ -1,87 +0,0 @@
-#pragma once
-
-#include <boost/asio.hpp>
-#include <string>
-#include <boost/beast/core/tcp_stream.hpp>
-#include <boost/beast/websocket/stream.hpp>
-
-
-#include "RemoteEndPoint.h"
-#include "stream.h"
-#include "threaded_queue.h"
-
-namespace lsp {
- class Log;
-}
-
-
-namespace lsp
-{
-
-
-
- class websocket_stream_wrapper :public istream, public ostream
- {
- public:
-
- websocket_stream_wrapper(boost::beast::websocket::stream<boost::beast::tcp_stream>& _w);
-
- boost::beast::websocket::stream<boost::beast::tcp_stream>& ws_;
- std::atomic<bool> quit{};
- std::shared_ptr < MultiQueueWaiter> request_waiter;
- ThreadedQueue< char > on_request;
- std::string error_message;
- bool fail() override;
-
- bool eof() override;
-
- bool good() override;
-
- websocket_stream_wrapper& read(char* str, std::streamsize count) override;
-
- int get() override;
-
- bool bad() override;
-
- websocket_stream_wrapper& write(const std::string& c) override;
-
- websocket_stream_wrapper& write(std::streamsize _s) override;
-
- websocket_stream_wrapper& flush() override;
-
- void clear() override;
-
- std::string what() override;
- };
-
- /// The top-level class of the HTTP server.
- class WebSocketServer
- {
- public:
- WebSocketServer(const WebSocketServer&) = delete;
- WebSocketServer& operator=(const WebSocketServer&) = delete;
- ~WebSocketServer();
- /// Construct the server to listen on the specified TCP address and port, and
- /// serve up files from the given directory.
- explicit WebSocketServer(const std::string& user_agent, const std::string& address, const std::string& port,
- std::shared_ptr < MessageJsonHandler> json_handler,
- std::shared_ptr < Endpoint> localEndPoint, lsp::Log& ,uint32_t _max_workers = 2);
-
- /// Run the server's io_context loop.
- void run();
- void stop();
-
- RemoteEndPoint point;
- private:
- struct Data;
- /// Perform an asynchronous accept operation.
- void do_accept();
-
- /// Wait for a request to stop the server.
- void do_stop();
- Data* d_ptr = nullptr;
-
-
- };
-
- } // namespace