| /device/google/cuttlefish/host/frontend/gcastv2/libsource/ |
| D | HostToGuestComms.cpp | 29 : mRunLoop(runLoop), in HostToGuestComms()
51 : mRunLoop(runLoop), in HostToGuestComms()
105 mRunLoop->cancelSocket(mSock); in ~HostToGuestComms()
112 mRunLoop->cancelSocket(mServerSock); in ~HostToGuestComms()
121 mRunLoop->postSocketRecv( in start()
125 mRunLoop->postWithDelay( in start()
157 mRunLoop->postSocketSend( in send()
179 mRunLoop->postSocketRecv( in onServerConnection()
188 mRunLoop->postSocketSend( in onServerConnection()
196 mRunLoop->postSocketRecv( in onServerConnection()
[all …]
|
| D | InputSink.cpp | 61 : mRunLoop(runLoop), in InputSink()
73 mRunLoop->cancelSocket(mClientFd); in ~InputSink()
80 mRunLoop->cancelSocket(mServerFd); in ~InputSink()
92 mRunLoop->postSocketRecv( in start()
126 mRunLoop->postSocketRecv( in onServerConnection()
131 mRunLoop->postSocketRecv( in onServerConnection()
151 mRunLoop->postSocketSend(mClientFd, in sendRawEvents()
163 mRunLoop->postSocketRecv( in onSocketRecv()
171 mRunLoop->cancelSocket(mClientFd); in onSocketRecv()
204 mRunLoop->cancelSocket(mClientFd); in onSocketSend()
[all …]
|
| /device/google/cuttlefish/host/frontend/gcastv2/https/ |
| D | BufferedSocket.cpp | 23 : mRunLoop(rl), in BufferedSocket()
29 mRunLoop->cancelSocket(mSock); in ~BufferedSocket()
40 return mRunLoop.get(); in runLoop()
|
| D | ServerSocket.cpp | 117 if (mRunLoop) { in run()
121 mRunLoop = rl; in run()
122 mRunLoop->postSocketRecv( in run()
153 std::make_shared<ClientSocket>(mRunLoop, mServer, this, addr, s); in acceptIncomingConnection()
160 mRunLoop->postSocketRecv( in acceptIncomingConnection()
|
| D | HTTPClientConnection.cpp | 43 mRunLoop(rl), in HTTPClientConnection()
64 mRunLoop, sock, 0 /* flags */, *trusted_pem_path); in HTTPClientConnection()
66 mImpl = std::make_shared<PlainSocket>(mRunLoop, sock); in HTTPClientConnection()
115 CHECK(mRunLoop->isCurrentThread()); in sendRequest()
236 CHECK(mRunLoop->isCurrentThread()); in queueOutputData()
|
| D | ClientSocket.cpp | 34 : mRunLoop(rl), in ClientSocket()
43 mRunLoop, in ClientSocket()
48 mImplPlain = std::make_shared<PlainSocket>(mRunLoop, sock); in ClientSocket()
|
| D | BaseConnection.cpp | 23 : mRunLoop(runLoop), in BaseConnection()
24 mSocket(std::make_unique<PlainSocket>(mRunLoop, sock)), in BaseConnection()
|
| /device/google/cuttlefish/host/frontend/gcastv2/webrtc/ |
| D | ServerState.cpp | 38 mRunLoop(runLoop), in ServerState()
75 mRunLoop, FLAGS_touch_fd, FLAGS_write_virtio_input); in ServerState()
82 mRunLoop, FLAGS_keyboard_fd, FLAGS_write_virtio_input); in ServerState()
95 mRunLoop->postAndAwait([this, data]() { in MonitorScreenConnector()
111 mRunLoop, mFrameBufferSource); in getVideoPacketizer()
130 packetizer = std::make_shared<OpusPacketizer>(mRunLoop, mAudioSource); in getAudioPacketizer()
|
| D | STUNClient.cpp | 31 : mRunLoop(runLoop), in STUNClient()
61 mSocket = std::make_shared<PlainSocket>(mRunLoop, sock); in STUNClient()
146 mRunLoop->cancelToken(mTimeoutToken); in onReceiveResponse()
158 mTimeoutToken = mRunLoop->postWithDelay( in scheduleRequest()
|
| D | Packetizer.cpp | 26 mRunLoop(runLoop), in Packetizer()
53 mRunLoop->post([weak_source](){ in addSender()
71 me->mRunLoop->post( in run()
|
| D | RTPSocketHandler.cpp | 106 : mRunLoop(runLoop), in RTPSocketHandler()
135 auto tmp = std::make_shared<PlainSocket>(mRunLoop, sock); in RTPSocketHandler()
151 mRunLoop, in RTPSocketHandler()
209 mSocket = std::make_shared<PlainSocket>(mRunLoop, sock); in onTCPConnect()
420 mRunLoop, in onPacketReceived()
511 mRunLoop, in pingRemote()
542 mRunLoop->post( in queueDatagram()
557 mRunLoop->post( in queueDatagram()
686 mSCTPHandler = std::make_shared<SCTPHandler>(mRunLoop, mDTLS); in notifyDTLSConnected()
|
| D | AdbWebSocketHandler.cpp | 142 : mRunLoop(runLoop), in AdbWebSocketHandler()
149 mAdbConnection = std::make_shared<AdbConnection>(this, mRunLoop, mSocket); in AdbWebSocketHandler()
|
| /device/google/cuttlefish/host/frontend/gcastv2/webrtc/include/webrtc/ |
| D | OpusPacketizer.h | 40 std::shared_ptr<RunLoop> mRunLoop; member
|
| D | AdbWebSocketHandler.h | 42 std::shared_ptr<RunLoop> mRunLoop; member
|
| D | G711Packetizer.h | 46 std::shared_ptr<RunLoop> mRunLoop; member
|
| D | STUNClient.h | 42 std::shared_ptr<RunLoop> mRunLoop; member
|
| D | SCTPHandler.h | 35 std::shared_ptr<RunLoop> mRunLoop;
|
| D | Packetizer.h | 61 std::shared_ptr<RunLoop> mRunLoop; member
|
| D | ServerState.h | 59 std::shared_ptr<RunLoop> mRunLoop; member
|
| /device/google/cuttlefish/host/frontend/gcastv2/https/include/https/ |
| D | BaseConnection.h | 47 std::shared_ptr<RunLoop> mRunLoop;
|
| D | BufferedSocket.h | 61 std::shared_ptr<RunLoop> mRunLoop;
|
| D | ServerSocket.h | 66 std::shared_ptr<RunLoop> mRunLoop; member
|
| D | HTTPClientConnection.h | 48 std::shared_ptr<RunLoop> mRunLoop; member
|
| /device/google/cuttlefish/host/frontend/gcastv2/libsource/include/source/ |
| D | InputSink.h | 46 std::shared_ptr<RunLoop> mRunLoop;
|
| D | HostToGuestComms.h | 49 std::shared_ptr<RunLoop> mRunLoop;
|