Home
last modified time | relevance | path

Searched refs:client_socket (Results 26 – 50 of 547) sorted by relevance

12345678910>>...22

/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/services/network/
H A Dtls_client_socket_unittest.cc341 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 Dtcp_socket_unittest.cc429 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 Dtls_client_socket_unittest.cc342 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 Dtcp_socket_unittest.cc429 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 Dtcp_serial_redirect.py172 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 Ddaemon.cc57 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 Dhost_controllers_manager.h39 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 Ddevice_forwarder_main.cc72 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 Dnetwork.cpp287 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 Dmysql_protocol_utils.cc63 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 Dtest-smartcard.cpp44 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 Dwshare.cxx28 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 Dbaseclientqt.cpp153 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 Dsyslogtcp.c34 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 Dsyslogtcp.c34 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 Dsyslogtcp.c34 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 Dtcp_client_socket_unittest.cc120 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 Dsocket-client.h28 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 Dsocket-client.h28 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 DTRpcConnectionContext.java26 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 DRNBSocketTest.cpp29 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 Dstream.c209 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 Dstream.c209 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 D80one-byte-window.t23 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 Dgsttcpserversrc.c150 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 …]

12345678910>>...22