Lines Matching defs:NbdProxyServer
186 struct NbdProxyServer : std::enable_shared_from_this<NbdProxyServer> struct
188 NbdProxyServer(crow::websocket::Connection& connIn, in NbdProxyServer() argument
203 ~NbdProxyServer() in ~NbdProxyServer()
224 std::string getEndpointId() const in getEndpointId()
229 static void afterMount(const std::weak_ptr<NbdProxyServer>& weak, in afterMount()
248 static void afterAccept(const std::weak_ptr<NbdProxyServer>& weak, in afterAccept()
272 void run() in run()
286 void send(std::string_view buffer, std::function<void()>&& onDone) in send()
296 static void afterSendEx(const std::weak_ptr<NbdProxyServer>& weak) in afterSendEx()
306 void afterRead(const std::weak_ptr<NbdProxyServer>& weak, in afterRead()
329 void doRead() in doRead()
337 static void afterWrite(const std::weak_ptr<NbdProxyServer>& weak, in afterWrite()
367 void doWrite(std::function<void()>&& onDone) in doWrite()
389 const std::string socketId;
390 const std::string endpointId;
391 const std::string path;
393 bool uxWriteInProgress = false;
396 boost::beast::flat_static_buffer<nbdBufferSize> ux2wsBuf;
399 boost::beast::flat_static_buffer<nbdBufferSize> ws2uxBuf;
402 stream_protocol::socket peerSocket;
405 stream_protocol::acceptor acceptor;
407 crow::websocket::Connection& connection;