| /external/llvm-project/lldb/unittests/debugserver/ |
| D | RNBSocketTest.cpp | 69 RNBSocket server_socket; in TestSocketListen() local
71 server_socket.Listen(addr, 0, ServerCallbackv4, (const void *)addr_wrap); in TestSocketListen()
73 result = server_socket.Write(hello.c_str(), hello.length()); in TestSocketListen()
76 result = server_socket.Read(bye); in TestSocketListen()
104 Socket *server_socket; in TestSocketConnect() local
110 server_socket = socket_or_err->get(); in TestSocketConnect()
112 auto port = ((TCPSocket *)server_socket)->GetLocalPortNumber(); in TestSocketConnect()
126 Status err = server_socket->Accept(connected_socket); in TestSocketConnect()
|
| /external/adhd/cras/client/libcras/src/ |
| D | libcras.rs | 212 server_socket: CrasServerSocket, field
243 let mut server_socket = CrasServerSocket::with_type(socket_type)?; in with_type() localVariable
246 CrasClient::wait_for_message(&mut server_socket)? in with_type()
249 server_socket, in with_type()
286 self.server_socket.send_server_message_with_fds(&msg, &[])?; in set_system_volume()
308 self.server_socket.send_server_message_with_fds(&msg, &[])?; in set_system_mute()
370 self.server_socket.send_server_message_with_fds(&msg, &[])?; in get_audio_debug_info()
372 match CrasClient::wait_for_message(&mut self.server_socket)? { in get_audio_debug_info()
434 self.server_socket in create_stream()
439 let result = CrasClient::wait_for_message(&mut self.server_socket)?; in create_stream()
[all …]
|
| D | cras_shm_stream.rs | 43 server_socket: CrasServerSocket, field
78 server_socket: CrasServerSocket, in try_new()
90 server_socket, in try_new()
107 if let Err(e) = self.server_socket.disconnect_stream(self.stream_id) { in drop()
|
| D | cras_client_message.rs | 92 pub fn handle_server_message(server_socket: &CrasServerSocket) -> Result<ServerResult> { in handle_server_message()
93 let message = CrasClientMessage::try_new(&server_socket)?; in handle_server_message()
145 fn try_new(server_socket: &CrasServerSocket) -> Result<CrasClientMessage> { in try_new()
147 let (len, fd_nums) = server_socket.recv_with_fds(&mut message.data, &mut message.fds)?; in try_new()
|
| D | cras_stream.rs | 119 server_socket: CrasServerSocket, field
140 server_socket: CrasServerSocket, in try_new()
154 server_socket, in try_new()
192 if let Err(e) = self.server_socket.disconnect_stream(self.stream_id) { in drop()
|
| /external/adhd/cras/src/server/ |
| D | cras_server.c | 105 struct server_socket { struct
119 struct server_socket server_sockets[CRAS_NUM_CONN_TYPE]; argument
123 static void server_socket_cleanup(struct server_socket *socket) in server_socket_cleanup()
219 static void handle_new_connection(struct server_socket *server_socket) in handle_new_connection() argument
232 connection_fd = accept(server_socket->fd, in handle_new_connection()
233 (struct sockaddr *)&server_socket->addr, in handle_new_connection()
261 connection_fd, poll_client->id, server_socket->type); in handle_new_connection()
483 struct server_socket *server_socket) in create_and_listen_server_socket() argument
487 struct sockaddr_un *addr = &server_socket->addr; in create_and_listen_server_socket()
529 server_socket->fd = socket_fd; in create_and_listen_server_socket()
[all …]
|
| /external/webrtc/examples/stunserver/ |
| D | stunserver_main.cc | 34 rtc::AsyncUDPSocket* server_socket = in main() local
36 if (!server_socket) { in main()
41 StunServer* server = new StunServer(server_socket); in main()
|
| /external/grpc-grpc/test/core/handshake/ |
| D | client_ssl.cc | 222 int server_socket = -1; in client_ssl_test() local
224 while (server_socket == -1 && socket_retries-- > 0) { in client_ssl_test()
225 server_socket = create_socket(&port); in client_ssl_test()
226 if (server_socket == -1) { in client_ssl_test()
230 GPR_ASSERT(server_socket > 0 && port > 0); in client_ssl_test()
233 server_args args = {server_socket, server_alpn_preferred}; in client_ssl_test()
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/framework/test_app/ |
| D | server_app.py | 116 server_socket = self.channelz.find_server_socket_matching_client(
118 if not server_socket:
123 self.channelz.sock_addresses_pretty(server_socket),
125 return server_socket
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/framework/rpc/ |
| D | grpc_channelz.py | 93 for server_socket in server_sockets:
94 if server_socket.remote == client_socket.local:
95 return server_socket
|
| /external/rust/crates/tokio/tests/ |
| D | uds_datagram.rs | 29 let server_socket = UnixDatagram::bind(server_path.clone())?; in echo() localVariable
32 if let Err(e) = echo_server(server_socket).await { in echo()
55 let server_socket = UnixDatagram::bind(server_path.clone())?; in echo_from() localVariable
58 if let Err(e) = echo_server(server_socket).await { in echo_from()
|
| /external/openscreen/osp/impl/quic/ |
| D | quic_connection_factory_impl.cc | 97 std::unique_ptr<UdpSocket> server_socket = std::move(create_result.value()); in SetServerDelegate() local
98 server_socket->Bind(); in SetServerDelegate()
99 sockets_.emplace_back(std::move(server_socket)); in SetServerDelegate()
|
| /external/ImageMagick/MagickCore/ |
| D | distribute-cache.c | 902 server_socket; in DistributePixelCacheServer() local
928 server_socket=(SOCKET_TYPE) 0; in DistributePixelCacheServer()
934 server_socket=socket(p->ai_family,p->ai_socktype,p->ai_protocol); in DistributePixelCacheServer()
935 if (server_socket == -1) in DistributePixelCacheServer()
938 status=setsockopt(server_socket,SOL_SOCKET,SO_REUSEADDR, in DistributePixelCacheServer()
942 CLOSE_SOCKET(server_socket); in DistributePixelCacheServer()
945 status=bind(server_socket,p->ai_addr,(socklen_t) p->ai_addrlen); in DistributePixelCacheServer()
948 CLOSE_SOCKET(server_socket); in DistributePixelCacheServer()
956 status=listen(server_socket,DPCPendingConnections); in DistributePixelCacheServer()
971 client_socket=accept(server_socket,(struct sockaddr *) &address,&length); in DistributePixelCacheServer()
|
| /external/webrtc/p2p/base/ |
| D | turn_server.h | 75 rtc::AsyncPacketSocket* server_socket,
268 void AcceptConnection(rtc::AsyncSocket* server_socket);
|
| D | turn_server.cc | 178 void TurnServer::AcceptConnection(rtc::AsyncSocket* server_socket) { in AcceptConnection() argument
182 rtc::AsyncSocket* accepted_socket = server_socket->Accept(&accept_addr); in AcceptConnection()
184 ProtocolType proto = server_listen_sockets_[server_socket]; in AcceptConnection()
|
| /external/python/httplib2/tests/ |
| D | __init__.py | 277 def server_socket(fun, request_count=1, timeout=5, scheme="", tls=None): function
398 return server_socket(server_yield_socket_handler, **kwargs)
420 return server_socket(server_request_socket_handler, **kwargs)
|
| D | test_proxy.py | 163 with tests.server_socket(proxy_conn) as uri:
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/framework/ |
| D | xds_k8s_testcase.py | 292 client_socket, server_socket = self.getConnectedSockets(
294 server_security: grpc_channelz.Security = server_socket.security
|
| /external/compiler-rt/lib/msan/tests/ |
| D | msan_test.cc | 999 int server_socket = socket(AF_INET, SOCK_DGRAM, 0); in TEST() local
1000 ASSERT_LT(0, server_socket); in TEST()
1007 int res = bind(server_socket, (struct sockaddr *)&sai, sizeof(sai)); in TEST()
1011 res = getsockname(server_socket, (struct sockaddr *)&sai, &sz); in TEST()
1057 res = recvmsg(server_socket, &recv_msg, 0); in TEST()
1064 close(server_socket); in TEST()
|
| /external/llvm-project/compiler-rt/lib/msan/tests/ |
| D | msan_test.cpp | 1023 int server_socket = CreateSocket(SOCK_DGRAM); in TEST_P() local
1024 ASSERT_LT(0, server_socket); in TEST_P()
1027 int res = bind(server_socket, sai->ptr(), sai->size()); in TEST_P()
1031 res = getsockname(server_socket, sai->ptr(), &sz); in TEST_P()
1071 res = recvmsg(server_socket, &recv_msg, 0); in TEST_P()
1078 close(server_socket); in TEST_P()
|
| /external/python/pyopenssl/tests/ |
| D | test_ssl.py | 2711 client_socket, server_socket = socket_pair()
|