Home
last modified time | relevance | path

Searched refs:RunLoop (Results 1 – 25 of 52) sorted by relevance

123

/device/google/cuttlefish/host/frontend/gcastv2/https/
DRunLoop.cpp31 bool RunLoop::QueueElem::operator<=(const QueueElem &other) const { in operator <=()
49 RunLoop::RunLoop() in RunLoop() function in RunLoop
59 RunLoop::RunLoop(std::string_view name) in RunLoop() function in RunLoop
60 : RunLoop() { in RunLoop()
66 RunLoop::~RunLoop() { in ~RunLoop()
76 void RunLoop::stop() { in stop()
85 RunLoop::Token RunLoop::post(AsyncFunction fn) { in post()
94 bool RunLoop::postAndAwait(AsyncFunction fn) { in postAndAwait()
123 RunLoop::Token RunLoop::postWithDelay( in postWithDelay()
133 bool RunLoop::cancelToken(Token token) { in cancelToken()
[all …]
DPlainSocket.cpp21 PlainSocket::PlainSocket(std::shared_ptr<RunLoop> rl, int sock) in PlainSocket()
25 void PlainSocket::postRecv(RunLoop::AsyncFunction fn) { in postRecv()
29 void PlainSocket::postSend(RunLoop::AsyncFunction fn) { in postSend()
52 void PlainSocket::postFlush(RunLoop::AsyncFunction fn) { in postFlush()
DBufferedSocket.cpp22 BufferedSocket::BufferedSocket(std::shared_ptr<RunLoop> rl, int sock) in BufferedSocket()
39 RunLoop *BufferedSocket::runLoop() { in runLoop()
DSSLSocket.cpp43 std::shared_ptr<RunLoop> rl, Mode mode, int sock, uint32_t flags) in SSLSocket()
84 std::shared_ptr<RunLoop> rl, in SSLSocket()
99 std::shared_ptr<RunLoop> rl, in SSLSocket()
117 void SSLSocket::postRecv(RunLoop::AsyncFunction fn) { in postRecv()
296 void SSLSocket::postSend(RunLoop::AsyncFunction fn) { in postSend()
559 void SSLSocket::postFlush(RunLoop::AsyncFunction fn) { in postFlush()
/device/google/cuttlefish/host/frontend/gcastv2/https/include/https/
DRunLoop.h37 struct RunLoop { struct
38 explicit RunLoop(std::string_view name);
39 ~RunLoop();
41 static std::shared_ptr<RunLoop> main();
47 RunLoop(const RunLoop &) = delete;
48 RunLoop &operator=(const RunLoop &) = delete; argument
116 explicit RunLoop(); // constructor for the main RunLoop. argument
DBufferedSocket.h24 explicit BufferedSocket(std::shared_ptr<RunLoop> rl, int sock);
30 virtual void postRecv(RunLoop::AsyncFunction fn) = 0;
31 virtual void postSend(RunLoop::AsyncFunction fn) = 0;
53 virtual void postFlush(RunLoop::AsyncFunction fn) = 0;
58 RunLoop *runLoop();
61 std::shared_ptr<RunLoop> mRunLoop;
DSSLSocket.h37 std::shared_ptr<RunLoop> rl,
44 std::shared_ptr<RunLoop> rl,
54 void postRecv(RunLoop::AsyncFunction fn) override;
55 void postSend(RunLoop::AsyncFunction fn) override;
69 void postFlush(RunLoop::AsyncFunction fn) override;
91 RunLoop::AsyncFunction mRecvCallback;
99 RunLoop::AsyncFunction mFlushFn;
102 std::shared_ptr<RunLoop> rl, Mode mode, int sock, uint32_t flags);
DPlainSocket.h22 explicit PlainSocket(std::shared_ptr<RunLoop> rl, int sock);
27 void postRecv(RunLoop::AsyncFunction fn) override;
28 void postSend(RunLoop::AsyncFunction fn) override;
42 void postFlush(RunLoop::AsyncFunction fn) override;
DServerSocket.h27 struct RunLoop;
52 int run(std::shared_ptr<RunLoop> rl);
66 std::shared_ptr<RunLoop> mRunLoop;
DClientSocket.h29 struct RunLoop;
34 std::shared_ptr<RunLoop> rl,
55 std::shared_ptr<RunLoop> mRunLoop;
DBaseConnection.h26 explicit BaseConnection(std::shared_ptr<RunLoop> runLoop, int sock);
47 std::shared_ptr<RunLoop> mRunLoop;
DHTTPClientConnection.h32 std::shared_ptr<RunLoop> rl,
48 std::shared_ptr<RunLoop> mRunLoop;
/device/google/cuttlefish/host/frontend/gcastv2/webrtc/include/webrtc/
DSTUNClient.h29 std::shared_ptr<RunLoop> runLoop,
42 std::shared_ptr<RunLoop> mRunLoop;
48 RunLoop::Token mTimeoutToken;
DRTPSession.h58 std::shared_ptr<RunLoop> runLoop,
59 RunLoop::AsyncFunction cb,
73 RunLoop::Token mPingToken;
DOpusPacketizer.h32 std::shared_ptr<RunLoop> runLoop,
40 std::shared_ptr<RunLoop> mRunLoop;
DAdbWebSocketHandler.h29 std::shared_ptr<RunLoop> runLoop,
42 std::shared_ptr<RunLoop> mRunLoop;
DG711Packetizer.h37 std::shared_ptr<RunLoop> runLoop,
46 std::shared_ptr<RunLoop> mRunLoop;
DSCTPHandler.h27 std::shared_ptr<RunLoop> runLoop,
35 std::shared_ptr<RunLoop> mRunLoop;
DPacketizer.h34 explicit Packetizer(std::shared_ptr<RunLoop> runLoop,
61 std::shared_ptr<RunLoop> mRunLoop;
DServerState.h43 std::shared_ptr<RunLoop> runLoop,
59 std::shared_ptr<RunLoop> mRunLoop;
DRTPSender.h33 std::shared_ptr<RunLoop> runLoop,
66 std::shared_ptr<RunLoop> mRunLoop;
DMyWebSocketHandler.h40 std::shared_ptr<RunLoop> runLoop,
61 std::shared_ptr<RunLoop> mRunLoop;
/device/google/cuttlefish/host/frontend/gcastv2/libsource/include/source/
DHostToGuestComms.h30 std::shared_ptr<RunLoop> runLoop,
37 std::shared_ptr<RunLoop> runLoop,
49 std::shared_ptr<RunLoop> mRunLoop;
DInputSink.h37 explicit InputSink(std::shared_ptr<RunLoop> runLoop, int serverFd,
46 std::shared_ptr<RunLoop> mRunLoop;
/device/google/cuttlefish/host/frontend/gcastv2/webrtc/
DAdbWebSocketHandler.cpp33 std::shared_ptr<RunLoop> runLoop,
50 std::shared_ptr<RunLoop> runLoop, in AdbConnection()
140 std::shared_ptr<RunLoop> runLoop, in AdbWebSocketHandler()

123