| /device/generic/goldfish-opengl/system/hals/ |
| D | host_connection_session.h | 24 explicit HostConnectionSession(HostConnection* hc) : conn(hc) { in HostConnectionSession()
29 if (conn) { in ~HostConnectionSession()
30 conn->unlock(); in ~HostConnectionSession()
34 HostConnectionSession(HostConnectionSession&& rhs) : conn(rhs.conn) { in HostConnectionSession()
35 rhs.conn = nullptr; in HostConnectionSession()
40 std::swap(conn, rhs.conn);
49 return conn->rcEncoder(); in getRcEncoder()
53 HostConnection* conn;
|
| D | mapper3.cpp | 117 const HostConnectionSession conn = getHostConnectionSession(); in freeBuffer() local
118 ExtendedRCEncoderContext *const rcEnc = conn.getRcEncoder(); in freeBuffer()
243 const HostConnectionSession conn = getHostConnectionSession(); in importBufferImpl() local
244 ExtendedRCEncoderContext *const rcEnc = conn.getRcEncoder(); in importBufferImpl()
375 const HostConnectionSession conn = getHostConnectionSession(); in lockHostImpl() local
376 ExtendedRCEncoderContext *const rcEnc = conn.getRcEncoder(); in lockHostImpl()
518 const HostConnectionSession conn = getHostConnectionSession(); in unlockHostImpl() local
519 ExtendedRCEncoderContext *const rcEnc = conn.getRcEncoder(); in unlockHostImpl()
|
| D | allocator3.cpp | 333 const HostConnectionSession conn = getHostConnectionSession(); in allocateCb() local
334 ExtendedRCEncoderContext *const rcEnc = conn.getRcEncoder(); in allocateCb()
|
| /device/google/cuttlefish/host/frontend/vnc_server/ |
| D | blackboard.cpp | 51 void BlackBoard::Register(const VncClientConnection* conn) { in Register() argument
54 CHECK(!clients_.count(conn)); in Register()
55 clients_[conn]; // constructs new state in place in Register()
60 void BlackBoard::Unregister(const VncClientConnection* conn) { in Unregister() argument
62 CHECK(clients_.count(conn)); in Unregister()
63 clients_.erase(clients_.find(conn)); in Unregister()
79 const VncClientConnection* conn) { in WaitForSenderWork() argument
81 auto& state = GetStateForClient(conn); in WaitForSenderWork()
87 DLOG(INFO) << "At least one new stripe is available, should unblock " << conn; in WaitForSenderWork()
104 void BlackBoard::SetOrientation(const VncClientConnection* conn, in SetOrientation() argument
[all …]
|
| D | blackboard.h | 51 Registerer(BlackBoard* bb, const VncClientConnection* conn) in Registerer() argument
52 : bb_{bb}, conn_{conn} { in Registerer()
53 bb->Register(conn);
70 void Register(const VncClientConnection* conn);
71 void Unregister(const VncClientConnection* conn);
73 StripePtrVec WaitForSenderWork(const VncClientConnection* conn);
77 void FrameBufferUpdateRequestReceived(const VncClientConnection* conn);
79 void SetOrientation(const VncClientConnection* conn,
81 void SignalClientNeedsEntireScreen(const VncClientConnection* conn);
83 void StopWaiting(const VncClientConnection* conn);
[all …]
|
| /device/google/cuttlefish/tools/play_audio/ |
| D | play_audio.cpp | 42 auto conn = cfp::ClientSocket{port}; in Connect()
43 if (!conn.valid()) { in Connect()
46 return conn; in Connect()
49 std::tuple<std::uint16_t, std::uint16_t> RecvHeader(cfp::ClientSocket* conn) { in RecvHeader() argument
51 auto num_channels = conn->RecvUInt16(); in RecvHeader()
52 auto frame_rate = conn->RecvUInt16(); in RecvHeader()
60 cfp::ClientSocket* conn) { in RecvEncodedAudio() argument
61 auto length = conn->RecvUInt32(); in RecvEncodedAudio()
62 auto frame_size = conn->RecvUInt32(); in RecvEncodedAudio()
63 auto encoded = conn->RecvAll(length); in RecvEncodedAudio()
[all …]
|
| /device/google/cuttlefish/host/libs/screen_connector/ |
| D | socket_based_screen_connector.cpp | 69 auto conn = SharedFD::Accept(*server); in ServerLoop() local
70 if (!conn->IsOpen()) { in ServerLoop()
74 while (conn->IsOpen()) { in ServerLoop()
76 if (conn->Read(&size, sizeof(size)) < 0) { in ServerLoop()
77 LOG(ERROR) << "Failed to read from hwcomposer: " << conn->StrError(); in ServerLoop()
82 auto read = conn->Read(buff, size); in ServerLoop()
84 LOG(ERROR) << "Failed to read from hwcomposer: " << conn->StrError(); in ServerLoop()
85 conn->Close(); in ServerLoop()
|
| /device/google/cuttlefish/host/commands/config_server/ |
| D | main.cpp | 44 auto conn = cuttlefish::SharedFD::Accept(*server_fd); in main() local
47 bool succeeded = device_config->SendRawData(conn); in main()
52 << conn->StrError(); in main()
|
| /device/google/cuttlefish/host/commands/modem_simulator/ |
| D | main.cpp | 132 auto conn = cuttlefish::SharedFD::Accept(*monitor_socket); in main() local
134 auto read = cuttlefish::ReadExact(conn, &buf); in main()
136 conn->Close(); in main()
146 cuttlefish::WriteAll(conn, "OK"); // Ignore the return value. Exit anyway. in main()
154 modem_simulators[id]->SetRemoteClient(conn, true); in main()
|
| /device/generic/goldfish-opengl/system/gralloc/ |
| D | gralloc_30.cpp | 90 explicit HostConnectionSession(HostConnection* hc) : conn(hc) { in HostConnectionSession()
95 if (conn) { in ~HostConnectionSession()
96 conn->unlock(); in ~HostConnectionSession()
100 HostConnectionSession(HostConnectionSession&& rhs) : conn(rhs.conn) { in HostConnectionSession()
101 rhs.conn = nullptr; in HostConnectionSession()
106 std::swap(conn, rhs.conn); in operator =()
115 return conn->rcEncoder(); in getRcEncoder()
119 HostConnection* conn; member in __anon1242cbb90111::HostConnectionSession
298 const HostConnectionSession conn = getHostConnectionSession(); in lock_impl() local
299 ExtendedRCEncoderContext *const rcEnc = conn.getRcEncoder(); in lock_impl()
[all …]
|
| /device/google/cuttlefish/host/commands/tombstone_receiver/ |
| D | main.cpp | 72 auto conn = cuttlefish::SharedFD::Accept(*server_fd); in main() local
78 auto bytes_read = conn->Read(buff, sizeof(buff)); in main()
|
| /device/generic/goldfish/gnss/ |
| D | gnss.cpp | 165 auto conn = std::make_unique<GnssHwConn>(&m_dataSink); in open() local
166 if (conn->ok()) { in open()
167 m_gnssHwConn = std::move(conn); in open()
|
| /device/google/cuttlefish/host/frontend/webrtc/lib/ |
| D | ws_connection.cpp | 200 void* raw, std::weak_ptr<WsConnectionImpl> conn) { in RememberConnection() argument
203 std::pair<void*, std::weak_ptr<WsConnectionImpl>>(raw, conn)); in RememberConnection()
|