| /external/openscreen/cast/common/channel/ |
| D | virtual_connection_router.cc | 27 auto& socket_map = connections_[virtual_connection.socket_id]; in AddConnection()
44 auto socket_entry = connections_.find(virtual_connection.socket_id); in RemoveConnection()
83 void VirtualConnectionRouter::RemoveConnectionsBySocketId(int socket_id) { in RemoveConnectionsBySocketId() argument
84 auto entry = connections_.find(socket_id); in RemoveConnectionsBySocketId()
93 auto socket_entry = connections_.find(virtual_connection.socket_id); in GetConnectionData()
124 int id = socket->socket_id(); in TakeSocket()
151 auto it = sockets_.find(virtual_conn.socket_id); in Send()
186 const int id = socket->socket_id(); in OnError()
224 socket->socket_id()})) { in OnMessage()
|
| D | connection_namespace_handler_unittest.cc | 157 VirtualConnection{receiver_id_, sender_id_, socket_->socket_id()})); in TEST_F()
172 VirtualConnection{receiver_id_, sender_id_, socket_->socket_id()})); in TEST_F()
185 VirtualConnection{receiver_id_, sender_id_, socket_->socket_id()})); in TEST_F()
200 VirtualConnection{receiver_id_, sender_id_, socket_->socket_id()})); in TEST_F()
207 VirtualConnection{receiver_id_, sender_id_, socket_->socket_id()})); in TEST_F()
212 VirtualConnection{receiver_id_, sender_id_, socket_->socket_id()})); in TEST_F()
219 VirtualConnection{receiver_id_, sender_id_, socket_->socket_id()})); in TEST_F()
224 VirtualConnection{receiver_id_, sender_id_, socket_->socket_id()})); in TEST_F()
|
| D | virtual_connection.h | 104 int socket_id; member
109 a.socket_id == b.socket_id;
|
| D | virtual_connection_router_unittest.cc | 167 local_socket_->socket_id()}, in TEST_F()
195 local_socket_->socket_id()}, in TEST_F()
219 local_socket_->socket_id()}, in TEST_F()
225 remote_socket_->socket_id()}, in TEST_F()
246 local_socket_->socket_id()}, in TEST_F()
252 local_socket_->socket_id()}, in TEST_F()
257 int id = local_socket_->socket_id(); in TEST_F()
|
| D | cast_socket_message_port.cc | 72 socket_->socket_id()}; in PostMessage()
|
| D | virtual_connection_router.h | 75 void RemoveConnectionsBySocketId(int socket_id);
|
| D | connection_namespace_handler.cc | 225 << virtual_conn.peer_id << ", " << virtual_conn.socket_id; in HandleConnect()
247 << conn.socket_id; in HandleClose()
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/framework/rpc/ |
| D | grpc_channelz.py | 106 listen_socket = self.get_socket(listen_socket_ref.socket_id)
164 start = max(start, socket_ref.socket_id)
166 yield self.get_socket(socket_ref.socket_id)
183 yield self.get_socket(socket_ref.socket_id)
192 def get_socket(self, socket_id) -> Socket: argument
195 rpc='GetSocket', req=_GetSocketRequest(socket_id=socket_id))
|
| /external/llvm-project/lldb/tools/lldb-server/ |
| D | lldb-gdbserver.cpp | 168 Status writeSocketIdToPipe(Pipe &port_pipe, const std::string &socket_id) { in writeSocketIdToPipe() argument
171 return port_pipe.Write(socket_id.c_str(), socket_id.size() + 1, in writeSocketIdToPipe()
176 const std::string &socket_id) { in writeSocketIdToPipe() argument
183 return writeSocketIdToPipe(port_name_pipe, socket_id); in writeSocketIdToPipe()
187 const std::string &socket_id) { in writeSocketIdToPipe() argument
189 return writeSocketIdToPipe(port_pipe, socket_id); in writeSocketIdToPipe()
286 const std::string socket_id = acceptor_up->GetLocalSocketId(); in ConnectToRemote() local
287 if (!socket_id.empty()) { in ConnectToRemote()
290 error = writeSocketIdToPipe(named_pipe_path, socket_id); in ConnectToRemote()
298 error = writeSocketIdToPipe(unnamed_pipe, socket_id); in ConnectToRemote()
|
| D | lldb-platform.cpp | 97 static Status save_socket_id_to_file(const std::string &socket_id, in save_socket_id_to_file() argument
112 temp_file_path, file_spec.GetPath(), socket_id), in save_socket_id_to_file()
|
| /external/openscreen/cast/sender/channel/ |
| D | sender_socket_factory.cc | 21 return a && a->socket->socket_id() < b; in operator <()
26 return b && a < b->socket->socket_id(); in operator <()
135 [id = socket->socket_id()]( in OnError()
137 return pending_auth->socket->socket_id() == id; in OnError()
150 [id = socket->socket_id()]( in OnMessage()
152 return pending_auth->socket->socket_id() == id; in OnMessage()
|
| /external/openscreen/cast/sender/ |
| D | cast_platform_client.cc | 58 int socket_id = entry->second; in RequestAppAvailability() local
73 VirtualConnection virtual_conn{sender_id_, kPlatformReceiverId, socket_id}; in RequestAppAvailability()
86 int socket_id) { in AddOrUpdateReceiver() argument
87 socket_id_by_device_id_[device.unique_id] = socket_id; in AddOrUpdateReceiver()
141 [socket_id = in OnMessage()
143 return entry.second == socket_id; in OnMessage()
|
| D | cast_app_discovery_service_impl_unittest.cc | 29 socket_id_ = fake_cast_socket_pair_.socket->socket_id(); in SetUp()
45 void AddOrUpdateReceiver(const ServiceInfo& receiver, int32_t socket_id) { in AddOrUpdateReceiver() argument
46 platform_client_.AddOrUpdateReceiver(receiver, socket_id); in AddOrUpdateReceiver()
282 AddOrUpdateReceiver(receiver2, socket2->socket_id()); in TEST_F()
|
| D | cast_platform_client.h | 51 void AddOrUpdateReceiver(const ServiceInfo& device, int socket_id);
|
| D | cast_platform_client_unittest.cc | 38 platform_client_.AddOrUpdateReceiver(receiver_, socket_->socket_id()); in SetUp()
|
| /external/llvm-project/lldb/test/API/tools/lldb-server/platform-process-connect/ |
| D | TestPlatformProcessConnect.py | 58 socket_id = lldbutil.wait_for_file_on_target(self, port_file)
66 connect_url = "%s://%s%s" % (protocol, hostname, socket_id)
68 connect_url = "%s://%s:%s" % (protocol, hostname, socket_id)
|
| /external/openscreen/cast/common/public/ |
| D | cast_socket.h | 53 int socket_id() const { return socket_id_; } in socket_id() function
84 return socket ? socket->socket_id() : 0; in ToCastSocketId()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/ |
| D | channelz_registry.cc | 258 char* grpc_channelz_get_socket(intptr_t socket_id) { in grpc_channelz_get_socket() argument
260 grpc_core::channelz::ChannelzRegistry::Get(socket_id); in grpc_channelz_get_socket()
|
| /external/grpc-grpc-java/services/src/main/proto/grpc/channelz/v1/ |
| D | channelz.proto | 180 int64 socket_id = 3; field
478 // ascending socket_id order.
509 // socket_id is the the identifier of the specific socket to get.
510 int64 socket_id = 1; field
514 // The Socket that corresponds to the requested socket_id. This field
|
| /external/grpc-grpc/src/proto/grpc/channelz/ |
| D | channelz.proto | 180 int64 socket_id = 3; field
478 // ascending socket_id order.
509 // socket_id is the identifier of the specific socket to get.
510 int64 socket_id = 1; field
514 // The Socket that corresponds to the requested socket_id. This field
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/channelz/ |
| D | channelz_service.cc | 141 char* json_str = grpc_channelz_get_socket(request->socket_id()); in GetSocket()
|
| /external/openscreen/cast/receiver/channel/ |
| D | device_auth_namespace_handler.cc | 84 message.destination_id(), message.source_id(), socket->socket_id()}; in OnMessage()
|
| /external/ltp/testcases/kernel/power_management/lib/ |
| D | pm_sched_mc.py | 60 socket_id = open(phy_pkg_file).read().rstrip()
61 if socket_id not in socket_list:
62 socket_list.append(socket_id)
|
| /external/rust/crates/grpcio-sys/grpc/src/proto/grpc/channelz/ |
| D | channelz.proto | 181 int64 socket_id = 3; field
519 // ascending socket_id order.
551 // socket_id is the identifier of the specific socket to get.
552 int64 socket_id = 1; field
561 // The Socket that corresponds to the requested socket_id. This field
|
| /external/rust/crates/grpcio-sys/grpc/include/grpc/ |
| D | grpc.h | 542 GRPCAPI char* grpc_channelz_get_socket(intptr_t socket_id);
|