Lines Matching defs:NbdProxyServer
201 struct NbdProxyServer : std::enable_shared_from_this<NbdProxyServer> struct
203 NbdProxyServer(crow::websocket::Connection& connIn, in NbdProxyServer() function
218 ~NbdProxyServer() in ~NbdProxyServer()
239 std::string getEndpointId() const in getEndpointId()
244 static void afterMount(const std::weak_ptr<NbdProxyServer>& weak, in afterMount()
263 static void afterAccept(const std::weak_ptr<NbdProxyServer>& weak, in afterAccept()
287 void run() in run()
301 void send(std::string_view buffer, std::function<void()>&& onDone) in send()
311 static void afterSendEx(const std::weak_ptr<NbdProxyServer>& weak) in afterSendEx()
321 void afterRead(const std::weak_ptr<NbdProxyServer>& weak, in afterRead()
344 void doRead() in doRead()
352 static void afterWrite(const std::weak_ptr<NbdProxyServer>& weak, in afterWrite()
382 void doWrite(std::function<void()>&& onDone) in doWrite()
404 const std::string socketId;
405 const std::string endpointId;
406 const std::string path;
408 bool uxWriteInProgress = false;
411 boost::beast::flat_static_buffer<nbdBufferSize> ux2wsBuf;
414 boost::beast::flat_static_buffer<nbdBufferSize> ws2uxBuf;
417 stream_protocol::socket peerSocket;
420 stream_protocol::acceptor acceptor;
422 crow::websocket::Connection& connection;