| /device/google/cuttlefish/host/frontend/webrtc/libdevice/ |
| D | streamer.cpp | 143 std::shared_ptr<ClientHandler> CreateClientHandler(int client_id);
147 void SendMessageToClient(int client_id, const Json::Value& msg);
148 void DestroyClientHandler(int client_id);
149 void SetupCameraForClient(int client_id);
558 auto client_id = in HandleClientMessage() local
566 if (clients_.count(client_id) == 0) { in HandleClientMessage()
567 auto client_handler = CreateClientHandler(client_id); in HandleClientMessage()
572 clients_.emplace(client_id, client_handler); in HandleClientMessage()
574 auto client_handler = clients_[client_id]; in HandleClientMessage()
617 auto client_id = in OnReceive() local
[all …]
|
| D | lights_observer.cpp | 108 int client_id = -1; in Subscribe() local
111 client_id = ++last_client_channel_id_; in Subscribe()
112 client_message_senders_[client_id] = lights_message_sender; in Subscribe()
119 return client_id; in Subscribe()
|
| D | client_handler.cpp | 65 int client_id, std::shared_ptr<ConnectionObserver> observer, in Create() argument
70 new ClientHandler(client_id, observer, connection_builder, in Create()
75 int client_id, std::shared_ptr<ConnectionObserver> observer, in ClientHandler() argument
79 : client_id_(client_id), in ClientHandler()
|
| D | client_handler.h | 59 int client_id, std::shared_ptr<ConnectionObserver> observer,
98 ClientHandler(int client_id, std::shared_ptr<ConnectionObserver> observer,
|
| /device/google/cuttlefish/host/frontend/webrtc_operator/ |
| D | device_handler.cpp | 85 size_t client_id = message[webrtc_signaling::kClientIdField].asInt(); in HandleForward() local
91 if (client_id <= 0 || client_id > clients_.size()) { in HandleForward()
93 std::to_string(client_id)); in HandleForward()
96 auto client_index = client_id - 1; in HandleForward()
99 SendClientDisconnectMessage(client_id); in HandleForward()
106 void DeviceHandler::SendClientMessage(size_t client_id, in SendClientMessage() argument
110 msg[webrtc_signaling::kClientIdField] = static_cast<Json::UInt>(client_id); in SendClientMessage()
115 void DeviceHandler::SendClientDisconnectMessage(size_t client_id) { in SendClientDisconnectMessage() argument
118 msg[webrtc_signaling::kClientIdField] = static_cast<Json::UInt>(client_id); in SendClientDisconnectMessage()
|
| D | client_handler.cpp | 170 void SetClientId(size_t client_id) { client_id_ = client_id; } in SetClientId() argument
172 size_t client_id() const { return client_id_; } in client_id() function in cuttlefish::PollConnectionHandler
315 auto client_id = poll_handler->client_id(); in DoPostInner() local
316 if (client_id == 0) { in DoPostInner()
329 device_handler->SendClientMessage(client_id, in DoPostInner()
|
| D | Readme.md | 26 * {"message_type": "forward", "client_id": <Integer>, "payload": <Any>}
33 * {"message_type": "client_msg", "client_id": <Integer>, "payload": <Any>}
35 * {"message_type": "client_disconnected", "client_id": <Integer>}
|
| D | device_handler.h | 42 void SendClientMessage(size_t client_id, const Json::Value& message);
43 void SendClientDisconnectMessage(size_t client_id);
|
| /device/linaro/dragonboard/shared/utils/rmtfs/ |
| D | sharedmem.c | 53 static int rmtfs_mem_open_rfsa(struct rmtfs_mem *rmem, int client_id) in rmtfs_mem_open_rfsa() argument
63 sprintf(path, "/dev/qcom_rmtfs_mem%d", client_id); in rmtfs_mem_open_rfsa()
123 static int rmtfs_mem_open_uio(struct rmtfs_mem *rmem, int client_id) in rmtfs_mem_open_uio() argument
133 snprintf(path, sizeof(path), "/dev/qcom_rmtfs_uio%d", client_id); in rmtfs_mem_open_uio()
204 static int rmtfs_mem_open_rfsa(struct rmtfs_mem *rmem, int client_id) in rmtfs_mem_open_rfsa() argument
214 snprintf(path, sizeof(path), "/dev/qcom_rmtfs_mem%d", client_id); in rmtfs_mem_open_rfsa()
222 snprintf(path, sizeof(path), "/sys/class/rmtfs/qcom_rmtfs_mem%d/phys_addr", client_id); in rmtfs_mem_open_rfsa()
237 snprintf(path, sizeof(path), "/sys/class/rmtfs/qcom_rmtfs_mem%d/size", client_id); in rmtfs_mem_open_rfsa()
259 static int rmtfs_mem_open_uio(struct rmtfs_mem *rmem __unused, int client_id __unused) in rmtfs_mem_open_uio()
|
| /device/google/cuttlefish/host/commands/modem_simulator/ |
| D | call_service.cpp | 192 auto client_id = ClientId(); in HandleDial() local
204 client_id = channel_monitor_->SetRemoteClient(remote_client, false); in HandleDial()
211 SendCommandToRemote(client_id, "REM0"); in HandleDial()
212 SendCommandToRemote(client_id, ss.str()); in HandleDial()
218 call_status.remote_client = client_id; in HandleDial()
|
| /device/google/coral-kernel/sm8150/original-kernel-headers/linux/ |
| D | ipa_qmi_service_v01.h | 1982 uint32_t client_id; member
2044 uint32_t client_id; member
|
| /device/google/coral-kernel/sm8150/kernel-headers/linux/ |
| D | ipa_qmi_service_v01.h | 545 uint32_t client_id; member
557 uint32_t client_id; member
|
| /device/google/sunfish-kernel/sm7150/original-kernel-headers/linux/ |
| D | ipa_qmi_service_v01.h | 1982 uint32_t client_id; member
2044 uint32_t client_id; member
|
| /device/google/redbull-kernel/sm7250/kernel-headers/linux/ |
| D | ipa_qmi_service_v01.h | 533 uint32_t client_id; member
545 uint32_t client_id; member
|
| /device/google/sunfish-kernel/sm7150/kernel-headers/linux/ |
| D | ipa_qmi_service_v01.h | 545 uint32_t client_id; member
557 uint32_t client_id; member
|
| /device/google/redbull-kernel/sm7250/original-kernel-headers/linux/ |
| D | ipa_qmi_service_v01.h | 1975 uint32_t client_id; member
2037 uint32_t client_id; member
|