/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/services/network/ |
H A D | tls_client_socket_unittest.cc | 341 SocketHandle client_socket; in TEST_P() local 354 ResetSocket(&client_socket); in TEST_P() 379 SocketHandle client_socket; in TEST_P() local 419 SocketHandle client_socket; in TEST_P() local 487 SocketHandle client_socket; in TEST_P() local 541 SocketHandle client_socket; in TEST_P() local 587 SocketHandle client_socket; in TEST_P() local 628 SocketHandle client_socket; in TEST_P() local 671 SocketHandle client_socket; in TEST_P() local 717 SocketHandle client_socket; in TEST_P() local [all …]
|
H A D | tcp_socket_unittest.cc | 429 client_socket.BindNewPipeAndPassReceiver(), in TEST_F() 904 client_socket.BindNewPipeAndPassReceiver(), in TEST_P() 956 client_socket.BindNewPipeAndPassReceiver(), in TEST_P() 1001 client_socket.BindNewPipeAndPassReceiver(), in TEST_P() 1037 client_socket.BindNewPipeAndPassReceiver(), in TEST_P() 1255 client_socket->SetNoDelay(false /* no_delay */, in TEST_F() 1265 client_socket->SetNoDelay(true /* no_delay */, in TEST_F() 1331 client_socket->SetNoDelay(false /* no_delay */, in TEST_F() 1382 client_socket->UpgradeToTLS( in TEST_F() 1410 client_socket->SetNoDelay(false /* no_delay */, in TEST_F() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/services/network/ |
H A D | tls_client_socket_unittest.cc | 342 SocketHandle client_socket; in TEST_P() local 355 ResetSocket(&client_socket); in TEST_P() 380 SocketHandle client_socket; in TEST_P() local 420 SocketHandle client_socket; in TEST_P() local 488 SocketHandle client_socket; in TEST_P() local 542 SocketHandle client_socket; in TEST_P() local 588 SocketHandle client_socket; in TEST_P() local 629 SocketHandle client_socket; in TEST_P() local 672 SocketHandle client_socket; in TEST_P() local 718 SocketHandle client_socket; in TEST_P() local [all …]
|
H A D | tcp_socket_unittest.cc | 429 client_socket.BindNewPipeAndPassReceiver(), in TEST_F() 904 client_socket.BindNewPipeAndPassReceiver(), in TEST_P() 956 client_socket.BindNewPipeAndPassReceiver(), in TEST_P() 1001 client_socket.BindNewPipeAndPassReceiver(), in TEST_P() 1037 client_socket.BindNewPipeAndPassReceiver(), in TEST_P() 1255 client_socket->SetNoDelay(false /* no_delay */, in TEST_F() 1265 client_socket->SetNoDelay(true /* no_delay */, in TEST_F() 1331 client_socket->SetNoDelay(false /* no_delay */, in TEST_F() 1382 client_socket->UpgradeToTLS( in TEST_F() 1410 client_socket->SetNoDelay(false /* no_delay */, in TEST_F() [all …]
|
/dports/comms/py-pyserial/pyserial-3.5/examples/ |
H A D | tcp_serial_redirect.py | 172 client_socket = socket.socket() variable 174 client_socket.connect((host, int(port))) 180 client_socket.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) 184 client_socket, addr = srv.accept() variable 191 client_socket.setsockopt(socket.IPPROTO_TCP, socket.TCP_KEEPIDLE, 1) 193 client_socket.setsockopt(socket.IPPROTO_TCP, socket.TCP_KEEPCNT, 3) 194 client_socket.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) 197 client_socket.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1) 199 ser_to_net.socket = client_socket 203 data = client_socket.recv(1024) [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/tools/android/forwarder2/ |
H A D | daemon.cc | 57 std::unique_ptr<Socket> client_socket(new Socket()); in RunServerAcceptLoop() local 58 if (!server_socket->Accept(client_socket.get())) { in RunServerAcceptLoop() 65 if (!client_socket->Write(welcome_message.c_str(), in RunServerAcceptLoop() 71 server_delegate->OnClientConnected(std::move(client_socket)); in RunServerAcceptLoop() 151 std::unique_ptr<Socket> client_socket = ConnectToUnixDomainSocket( in SpawnIfNeeded() local 153 if (!client_socket) { in SpawnIfNeeded() 176 if (client_socket.get()) { in SpawnIfNeeded() 211 if (!client_socket) { in SpawnIfNeeded() 212 client_socket = ConnectToUnixDomainSocket( in SpawnIfNeeded() 214 if (!client_socket) { in SpawnIfNeeded() [all …]
|
H A D | host_controllers_manager.h | 39 std::unique_ptr<Socket> client_socket); 65 Socket* client_socket); 71 Socket* client_socket); 76 Socket* client_socket); 88 std::unique_ptr<Socket> client_socket); 90 void LogExistingControllers(Socket* client_socket); 98 bool SendMessage(const std::string& msg, Socket* client_socket);
|
H A D | device_forwarder_main.cc | 72 void OnClientConnected(std::unique_ptr<Socket> client_socket) override { in OnClientConnected() argument 74 client_socket->WriteString("OK"); in OnClientConnected() 80 GetExitNotifierFD(), std::move(client_socket))); in OnClientConnected() 86 std::unique_ptr<Socket> client_socket) { in StartController() argument 91 client_socket->WriteString( in StartController() 99 client_socket->WriteString("OK"); in StartController() 100 client_socket->Close(); in StartController()
|
/dports/games/warmux/warmux-11.04/lib/warmux/net/ |
H A D | network.cpp | 287 bool WNet::Server_HandShake(WSocket& client_socket, in Server_HandShake() argument 299 if (!client_socket.AddToTmpSocketSet()) in Server_HandShake() 303 if (!client_socket.ReceiveStr(version, 40)) in Server_HandShake() 306 if (!client_socket.SendStr(WARMUX_VERSION)) in Server_HandShake() 316 if (!client_socket.ReceiveStr(_password, 100)) in Server_HandShake() 322 client_socket.SendInt(1); in Server_HandShake() 327 if (!client_socket.SendInt(0)) in Server_HandShake() 335 if (!client_socket.ReceiveStr(nickname, 100)) in Server_HandShake() 339 if (!client_socket.SendStr(game_name)) in Server_HandShake() 343 if (!client_socket.SendInt(client_player_id)) in Server_HandShake() [all …]
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/mock_server/src/ |
H A D | mysql_protocol_utils.cc | 63 void send_packet(socket_t client_socket, const uint8_t *data, size_t size, in send_packet() argument 68 if ((sent = send(client_socket, in send_packet() 77 void send_packet(socket_t client_socket, in send_packet() argument 80 send_packet(client_socket, buffer.data(), buffer.size(), flags); in send_packet() 121 void read_packet(socket_t client_socket, uint8_t *data, size_t size, in read_packet() argument 127 if (socket_has_data(client_socket, 100)) break; in read_packet() 131 recv(client_socket, reinterpret_cast<char *>(data) + buffer_offset, in read_packet()
|
/dports/devel/libspice-server/spice-0.15.0/server/tests/ |
H A D | test-smartcard.cpp | 44 static int client_socket = -1; variable 195 send_data(client_socket, VSC_ReaderAdd, 0); in next_test() 196 send_data(client_socket, VSC_APDU, 0); in next_test() 197 send_data(client_socket, VSC_ReaderRemove, 0); in next_test() 209 send_data(client_socket, VSC_Init, 0); in next_test() 211 send_data(client_socket, VSC_ReaderRemove, 0); in next_test() 251 send_data(client_socket, VSC_ReaderRemove, 5); in next_test() 277 send_data(client_socket, 0xabcd, 0); in next_test() 279 send_data(client_socket, VSC_APDU, 0); in next_test() 315 send_data(client_socket, VSC_APDU, 0xabcd); in next_test() [all …]
|
/dports/devel/ptypes/ptypes-2.1.1/wshare/ |
H A D | wshare.cxx | 28 class client_socket: public ipstream class 31 client_socket(); 35 client_socket::client_socket() in client_socket() function in client_socket 54 client_socket* client = new client_socket(); in run_server() 116 client = new client_socket(); in run_server()
|
/dports/astro/stellarium/stellarium-0.21.3/src/external/libindi/libs/indibase/ |
H A D | baseclientqt.cpp | 153 client_socket.close(); in disconnectServer() 525 client_socket.write(prop.toLatin1()); in sendNewText() 572 client_socket.write(prop.toLatin1()); in sendNewNumber() 630 client_socket.write(prop.toLatin1()); in sendNewSwitch() 664 client_socket.write(prop.toLatin1()); in startBlob() 682 client_socket.write(prop.toLatin1()); in sendOneBlob() 694 client_socket.write("\n"); in sendOneBlob() 698 client_socket.write("\n"); in sendOneBlob() 734 client_socket.write("\n"); in sendOneBlob() 738 client_socket.write("\n"); in sendOneBlob() [all …]
|
/dports/security/ossec-hids-server/ossec-hids-3.6.0/src/remoted/ |
H A D | syslogtcp.c | 34 static void HandleClient(int client_socket, char *srcip) in HandleClient() argument 58 if ((r_sz = OS_RecvTCPBuffer(client_socket, buffer, OS_MAXSTR - 2)) < 0) { in HandleClient() 59 close(client_socket); in HandleClient() 191 int client_socket = OS_AcceptTCP(sock, srcip, IPSIZE); in HandleSyslogTCP() local 192 if (client_socket < 0) { in HandleSyslogTCP() 200 close(client_socket); in HandleSyslogTCP() 206 HandleClient(client_socket, srcip); in HandleSyslogTCP() 212 close(client_socket); in HandleSyslogTCP()
|
/dports/security/ossec-hids-agent/ossec-hids-3.6.0/src/remoted/ |
H A D | syslogtcp.c | 34 static void HandleClient(int client_socket, char *srcip) in HandleClient() argument 58 if ((r_sz = OS_RecvTCPBuffer(client_socket, buffer, OS_MAXSTR - 2)) < 0) { in HandleClient() 59 close(client_socket); in HandleClient() 191 int client_socket = OS_AcceptTCP(sock, srcip, IPSIZE); in HandleSyslogTCP() local 192 if (client_socket < 0) { in HandleSyslogTCP() 200 close(client_socket); in HandleSyslogTCP() 206 HandleClient(client_socket, srcip); in HandleSyslogTCP() 212 close(client_socket); in HandleSyslogTCP()
|
/dports/security/ossec-hids-local/ossec-hids-3.6.0/src/remoted/ |
H A D | syslogtcp.c | 34 static void HandleClient(int client_socket, char *srcip) in HandleClient() argument 58 if ((r_sz = OS_RecvTCPBuffer(client_socket, buffer, OS_MAXSTR - 2)) < 0) { in HandleClient() 59 close(client_socket); in HandleClient() 191 int client_socket = OS_AcceptTCP(sock, srcip, IPSIZE); in HandleSyslogTCP() local 192 if (client_socket < 0) { in HandleSyslogTCP() 200 close(client_socket); in HandleSyslogTCP() 206 HandleClient(client_socket, srcip); in HandleSyslogTCP() 212 close(client_socket); in HandleSyslogTCP()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/net/socket/ |
H A D | tcp_client_socket_unittest.cc | 120 EXPECT_TRUE((*client_socket)->IsConnected()); in CreateConnectedSockets() 551 std::unique_ptr<TCPClientSocket> client_socket; in TEST_F() local 564 EXPECT_FALSE(client_socket->IsConnected()); in TEST_F() 593 std::unique_ptr<TCPClientSocket> client_socket; in TEST_F() local 606 client_socket->OnSuspend(); in TEST_F() 610 EXPECT_FALSE(client_socket->IsConnected()); in TEST_F() 640 client_socket->OnSuspend(); in TEST_F() 644 EXPECT_FALSE(client_socket->IsConnected()); in TEST_F() 689 client_socket.reset(); in TEST_F() 692 client_socket->Disconnect(); in TEST_F() [all …]
|
/dports/devel/gnulib/gnulib-20140202-stable/tests/ |
H A D | socket-client.h | 28 int client_socket; in create_client_socket() local 31 client_socket = socket (PF_INET, SOCK_STREAM, IPPROTO_TCP); in create_client_socket() 32 ASSERT (client_socket >= 0); in create_client_socket() 51 ASSERT (connect (client_socket, in create_client_socket() 56 return client_socket; in create_client_socket()
|
/dports/security/pkcs11-tools/pkcs11-tools-2.5.0/.gnulib/tests/ |
H A D | socket-client.h | 28 int client_socket; in create_client_socket() local 31 client_socket = socket (PF_INET, SOCK_STREAM, IPPROTO_TCP); in create_client_socket() 32 ASSERT (client_socket >= 0); in create_client_socket() 51 ASSERT (connect (client_socket, in create_client_socket() 56 return client_socket; in create_client_socket()
|
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/java/src/main/java/com/facebook/thrift/server/ |
H A D | TRpcConnectionContext.java | 26 protected TTransport client_socket; field in TRpcConnectionContext 29 TTransport client_socket, TProtocol input_protocol, TProtocol output_protocol) { in TRpcConnectionContext() argument 31 this.client_socket = client_socket; in TRpcConnectionContext() 36 TSocketIf socket = (TSocketIf) client_socket; in getPeerAddress()
|
/dports/devel/tinygo/tinygo-0.14.1/llvm-project/lldb/unittests/debugserver/ |
H A D | RNBSocketTest.cpp | 29 Socket *client_socket; in ServerCallbackv4() local 32 Status err = Socket::TcpConnect(addr_buffer, false, client_socket); in ServerCallbackv4() 37 err = client_socket->Read((void *)&buffer[0], read_size); in ServerCallbackv4() 44 err = client_socket->Write(goodbye.c_str(), write_size); in ServerCallbackv4() 49 delete client_socket; in ServerCallbackv4() 112 RNBSocket client_socket; in TestSocketConnect() local 113 auto result = client_socket.Connect(addr, port); in TestSocketConnect() 115 result = client_socket.Write(hello.c_str(), hello.length()); in TestSocketConnect() 118 result = client_socket.Read(bye); in TestSocketConnect()
|
/dports/misc/amanda-client/amanda-3.3.9/common-src/ |
H A D | stream.c | 209 int client_socket = 0; in stream_client_addr() local 239 if (client_socket < 0) { in stream_client_addr() 247 try_socksize(client_socket, SO_SNDBUF, sendsize); in stream_client_addr() 248 try_socksize(client_socket, SO_RCVBUF, recvsize); in stream_client_addr() 251 return client_socket; in stream_client_addr() 266 int client_socket = 0; in stream_client_internal() local 310 if (client_socket > 0) in stream_client_internal() 316 if (client_socket > 0) in stream_client_internal() 326 try_socksize(client_socket, SO_SNDBUF, sendsize); in stream_client_internal() 327 try_socksize(client_socket, SO_RCVBUF, recvsize); in stream_client_internal() [all …]
|
/dports/misc/amanda-server/amanda-3.3.9/common-src/ |
H A D | stream.c | 209 int client_socket = 0; in stream_client_addr() local 239 if (client_socket < 0) { in stream_client_addr() 247 try_socksize(client_socket, SO_SNDBUF, sendsize); in stream_client_addr() 248 try_socksize(client_socket, SO_RCVBUF, recvsize); in stream_client_addr() 251 return client_socket; in stream_client_addr() 266 int client_socket = 0; in stream_client_internal() local 310 if (client_socket > 0) in stream_client_internal() 316 if (client_socket > 0) in stream_client_internal() 326 try_socksize(client_socket, SO_SNDBUF, sendsize); in stream_client_internal() 327 try_socksize(client_socket, SO_RCVBUF, recvsize); in stream_client_internal() [all …]
|
/dports/www/h2o-devel/h2o-dcc7134/t/ |
H A D | 80one-byte-window.t | 23 my $client_socket = $socket->accept(); 24 close($client_socket); 38 $client_socket = $socket->accept(); 39 $client_socket->recv($req, 1024); 40 $client_socket->send("HTTP/1.1 200 Ok\r\nConnection:close\r\n\r\n$msg"); 41 close($client_socket);
|
/dports/multimedia/gstreamer1-plugins/gst-plugins-base-1.16.2/gst/tcp/ |
H A D | gsttcpserversrc.c | 150 src->client_socket = NULL; in gst_tcp_server_src_init() 167 if (src->client_socket) in gst_tcp_server_src_finalize() 168 g_object_unref (src->client_socket); in gst_tcp_server_src_finalize() 169 src->client_socket = NULL; in gst_tcp_server_src_finalize() 192 if (!src->client_socket) { in gst_tcp_server_src_create() 194 src->client_socket = in gst_tcp_server_src_create() 196 if (!src->client_socket) in gst_tcp_server_src_create() 217 if (!g_socket_condition_wait (src->client_socket, in gst_tcp_server_src_create() 516 if (src->client_socket) { in gst_tcp_server_src_stop() 523 g_object_unref (src->client_socket); in gst_tcp_server_src_stop() [all …]
|