| /dports/devel/py-thriftpy2/thriftpy2-0.4.14/tests/ |
| H A D | test_socket.py | 17 client_socket.open()
22 client_socket.write(buff)
31 client_socket.close()
77 client_socket.open()
86 client_socket.close()
100 client_socket.open()
104 client_socket.close()
112 client_socket.open()
115 client_socket.close()
133 client_socket.open()
[all …]
|
| H A D | test_sslsocket.py | 26 def _test_socket(server_socket, client_socket): argument
33 client_socket.open()
34 client_socket.write(buff)
35 buff2 = client_socket.read(1024)
40 client_socket.close()
47 client_socket = TSSLSocket(
51 _test_socket(server_socket, client_socket)
59 _test_socket(server_socket, client_socket)
69 client_socket = TSSLSocket(
77 client_socket = TSSLSocket(
[all …]
|
| /dports/devel/py-gevent/gevent-21.8.0/src/gevent/tests/ |
| H A D | test__makefile_ref.py | 199 client_socket.close()
219 client_socket.close()
249 client_socket.close()
336 client_socket = closer(
341 client_socket.close()
356 client_socket = closer(
363 client_socket.close()
390 client_socket.close()
409 client_socket.close()
434 client_socket = None
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/remoting/host/security_key/ |
| H A D | security_key_auth_handler_posix_unittest.cc | 206 WriteRequestData(&client_socket); in TEST_F()
217 WaitForResponseData(&client_socket); in TEST_F()
234 WriteRequestData(&client_socket); in TEST_F()
279 WriteRequestData(&client_socket); in TEST_F()
294 WriteRequestData(&client_socket); in TEST_F()
322 WriteRequestData(&client_socket); in TEST_F()
337 client_socket.Disconnect(); in TEST_F()
344 WriteRequestData(&client_socket); in TEST_F()
372 WaitForErrorData(&client_socket); in TEST_F()
389 WriteRequestData(&client_socket); in TEST_F()
[all …]
|
| /dports/security/ossec-hids-server/ossec-hids-3.6.0/src/tests/ |
| H A D | test_os_net.c | 28 int server_root_socket, server_client_socket, client_socket; in START_TEST() local
55 OS_CloseSocket(client_socket); in START_TEST()
90 OS_CloseSocket(client_socket); in START_TEST()
125 OS_CloseSocket(client_socket); in START_TEST()
160 OS_CloseSocket(client_socket); in START_TEST()
184 int server_socket, client_socket; in START_TEST() local
208 OS_CloseSocket(client_socket); in START_TEST()
215 int server_socket, client_socket; in START_TEST() local
239 OS_CloseSocket(client_socket); in START_TEST()
268 int server_socket, client_socket; in START_TEST() local
[all …]
|
| /dports/security/ossec-hids-agent/ossec-hids-3.6.0/src/tests/ |
| H A D | test_os_net.c | 28 int server_root_socket, server_client_socket, client_socket; in START_TEST() local
55 OS_CloseSocket(client_socket); in START_TEST()
90 OS_CloseSocket(client_socket); in START_TEST()
125 OS_CloseSocket(client_socket); in START_TEST()
160 OS_CloseSocket(client_socket); in START_TEST()
184 int server_socket, client_socket; in START_TEST() local
208 OS_CloseSocket(client_socket); in START_TEST()
215 int server_socket, client_socket; in START_TEST() local
239 OS_CloseSocket(client_socket); in START_TEST()
268 int server_socket, client_socket; in START_TEST() local
[all …]
|
| /dports/security/ossec-hids-local/ossec-hids-3.6.0/src/tests/ |
| H A D | test_os_net.c | 28 int server_root_socket, server_client_socket, client_socket; in START_TEST() local
55 OS_CloseSocket(client_socket); in START_TEST()
90 OS_CloseSocket(client_socket); in START_TEST()
125 OS_CloseSocket(client_socket); in START_TEST()
160 OS_CloseSocket(client_socket); in START_TEST()
184 int server_socket, client_socket; in START_TEST() local
208 OS_CloseSocket(client_socket); in START_TEST()
215 int server_socket, client_socket; in START_TEST() local
239 OS_CloseSocket(client_socket); in START_TEST()
268 int server_socket, client_socket; in START_TEST() local
[all …]
|
| /dports/emulators/pcsxr/pcsxr-codeplex-final/pcsxr/libpcsxcore/ |
| H A D | socket.c | 35 static int client_socket = 0; variable
110 if (client_socket) in GetClient()
112 client_socket = new_socket; in GetClient()
128 if (client_socket) { in CloseClient()
134 close(client_socket); in CloseClient()
136 client_socket = 0; in CloseClient()
148 if (!client_socket) in ReadSocket()
154 client_socket = 0; in ReadSocket()
196 if (!client_socket) in RawReadSocket()
209 client_socket = 0; in RawReadSocket()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/socket/ |
| H A D | unix_domain_client_socket_posix_unittest.cc | 151 EXPECT_FALSE(client_socket.IsConnected()); in TEST_F()
154 EXPECT_TRUE(client_socket.IsConnected()); in TEST_F()
178 EXPECT_FALSE(client_socket.IsConnected()); in TEST_F()
181 EXPECT_TRUE(client_socket.IsConnected()); in TEST_F()
216 EXPECT_FALSE(client_socket.IsConnected()); in TEST_F()
230 EXPECT_TRUE(client_socket.IsConnected()); in TEST_F()
281 EXPECT_TRUE(client_socket.IsConnected()); in TEST_F()
293 client_socket.Disconnect(); in TEST_F()
315 EXPECT_TRUE(client_socket.IsConnected()); in TEST_F()
323 client_socket.Read( in TEST_F()
[all …]
|
| H A D | tcp_client_socket_unittest.cc | 116 EXPECT_TRUE((*client_socket)->IsConnected()); in CreateConnectedSockets()
540 std::unique_ptr<TCPClientSocket> client_socket; in TEST_F() local
553 EXPECT_FALSE(client_socket->IsConnected()); in TEST_F()
582 std::unique_ptr<TCPClientSocket> client_socket; in TEST_F() local
595 client_socket->OnSuspend(); in TEST_F()
599 EXPECT_FALSE(client_socket->IsConnected()); in TEST_F()
629 client_socket->OnSuspend(); in TEST_F()
633 EXPECT_FALSE(client_socket->IsConnected()); in TEST_F()
678 client_socket.reset(); in TEST_F()
681 client_socket->Disconnect(); in TEST_F()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/net/socket/ |
| H A D | unix_domain_client_socket_posix_unittest.cc | 151 EXPECT_FALSE(client_socket.IsConnected()); in TEST_F()
154 EXPECT_TRUE(client_socket.IsConnected()); in TEST_F()
178 EXPECT_FALSE(client_socket.IsConnected()); in TEST_F()
181 EXPECT_TRUE(client_socket.IsConnected()); in TEST_F()
216 EXPECT_FALSE(client_socket.IsConnected()); in TEST_F()
230 EXPECT_TRUE(client_socket.IsConnected()); in TEST_F()
281 EXPECT_TRUE(client_socket.IsConnected()); in TEST_F()
293 client_socket.Disconnect(); in TEST_F()
315 EXPECT_TRUE(client_socket.IsConnected()); in TEST_F()
323 client_socket.Read( in TEST_F()
[all …]
|
| /dports/games/libretro-pcsx_rearmed/pcsx_rearmed-c2d67cd/libpcsxcore/ |
| H A D | socket.c | 51 static int client_socket = 0; variable
126 if (client_socket) in GetClient()
128 client_socket = new_socket; in GetClient()
144 if (client_socket) { in CloseClient()
150 close(client_socket); in CloseClient()
152 client_socket = 0; in CloseClient()
164 if (!client_socket) in ReadSocket()
170 client_socket = 0; in ReadSocket()
212 if (!client_socket) in RawReadSocket()
225 client_socket = 0; in RawReadSocket()
[all …]
|
| /dports/games/kodi-addon-game.libretro.pcsx-rearmed/game.libretro.pcsx-rearmed-22.0.0.19-Matrix/depends/common/pcsx-rearmed/libpcsxcore/ |
| H A D | socket.c | 51 static int client_socket = 0; variable
126 if (client_socket) in GetClient()
128 client_socket = new_socket; in GetClient()
144 if (client_socket) { in CloseClient()
150 close(client_socket); in CloseClient()
152 client_socket = 0; in CloseClient()
164 if (!client_socket) in ReadSocket()
170 client_socket = 0; in ReadSocket()
212 if (!client_socket) in RawReadSocket()
225 client_socket = 0; in RawReadSocket()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/tools/qfe/ |
| H A D | qfe-cli.py | 18 client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
19 client_socket.connect((QFE_HOST, QFE_SOCK))
23 client_socket.send(lenstruct)
24 client_socket.send(defschem)
27 client_socket.send(lenstruct)
28 client_socket.send(query)
32 rowlen = client_socket.recv(4)
38 client_socket.send(lenstruct)
40 row = client_socket.recv(rowval)
43 client_socket.close()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/tools/qfe/ |
| H A D | qfe-cli.py | 18 client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
19 client_socket.connect((QFE_HOST, QFE_SOCK))
23 client_socket.send(lenstruct)
24 client_socket.send(defschem)
27 client_socket.send(lenstruct)
28 client_socket.send(query)
32 rowlen = client_socket.recv(4)
38 client_socket.send(lenstruct)
40 row = client_socket.recv(rowval)
43 client_socket.close()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/tools/android/forwarder2/ |
| H A D | host_controllers_manager.cc | 37 std::unique_ptr<Socket> client_socket) { in HandleRequest() argument
99 client_socket); in Map()
112 LogExistingControllers(client_socket); in Map()
120 if (!SendMessage(msg, client_socket)) in Map()
141 SendMessage("OK", client_socket); in Unmap()
168 SendMessage("OK", client_socket); in UnmapAll()
183 client_socket.get()); in HandleRequestOnInternalThread()
189 client_socket.get()); in HandleRequestOnInternalThread()
193 client_socket.get()); in HandleRequestOnInternalThread()
201 client_socket.get()); in HandleRequestOnInternalThread()
[all …]
|
| /dports/japanese/uim-mozc/mozc-2.23.2815.102.01/src/server/ |
| H A D | mozc_rpc_server_main.cc | 115 void CloseSocket(int client_socket) { in CloseSocket() argument
117 ::closesocket(client_socket); in CloseSocket()
118 ::shutdown(client_socket, SD_BOTH); in CloseSocket()
120 ::close(client_socket); in CloseSocket()
189 CloseSocket(client_socket); in Loop()
198 if (!Recv(client_socket, in Loop()
201 CloseSocket(client_socket); in Loop()
209 CloseSocket(client_socket); in Loop()
231 CloseSocket(client_socket); in Loop()
323 CHECK(Recv(client_socket, in Call()
[all …]
|
| /dports/japanese/mozc-server/mozc-2.23.2815.102.01/src/server/ |
| H A D | mozc_rpc_server_main.cc | 115 void CloseSocket(int client_socket) { in CloseSocket() argument
117 ::closesocket(client_socket); in CloseSocket()
118 ::shutdown(client_socket, SD_BOTH); in CloseSocket()
120 ::close(client_socket); in CloseSocket()
189 CloseSocket(client_socket); in Loop()
198 if (!Recv(client_socket, in Loop()
201 CloseSocket(client_socket); in Loop()
209 CloseSocket(client_socket); in Loop()
231 CloseSocket(client_socket); in Loop()
323 CHECK(Recv(client_socket, in Call()
[all …]
|
| /dports/japanese/mozc-tool/mozc-2.23.2815.102.01/src/server/ |
| H A D | mozc_rpc_server_main.cc | 115 void CloseSocket(int client_socket) { in CloseSocket() argument
117 ::closesocket(client_socket); in CloseSocket()
118 ::shutdown(client_socket, SD_BOTH); in CloseSocket()
120 ::close(client_socket); in CloseSocket()
189 CloseSocket(client_socket); in Loop()
198 if (!Recv(client_socket, in Loop()
201 CloseSocket(client_socket); in Loop()
209 CloseSocket(client_socket); in Loop()
231 CloseSocket(client_socket); in Loop()
323 CHECK(Recv(client_socket, in Call()
[all …]
|
| /dports/japanese/ibus-mozc/mozc-2.23.2815.102.01/src/server/ |
| H A D | mozc_rpc_server_main.cc | 115 void CloseSocket(int client_socket) { in CloseSocket() argument
117 ::closesocket(client_socket); in CloseSocket()
118 ::shutdown(client_socket, SD_BOTH); in CloseSocket()
120 ::close(client_socket); in CloseSocket()
189 CloseSocket(client_socket); in Loop()
198 if (!Recv(client_socket, in Loop()
201 CloseSocket(client_socket); in Loop()
209 CloseSocket(client_socket); in Loop()
231 CloseSocket(client_socket); in Loop()
323 CHECK(Recv(client_socket, in Call()
[all …]
|
| /dports/japanese/mozc-el/mozc-2.23.2815.102.01/src/server/ |
| H A D | mozc_rpc_server_main.cc | 115 void CloseSocket(int client_socket) { in CloseSocket() argument
117 ::closesocket(client_socket); in CloseSocket()
118 ::shutdown(client_socket, SD_BOTH); in CloseSocket()
120 ::close(client_socket); in CloseSocket()
189 CloseSocket(client_socket); in Loop()
198 if (!Recv(client_socket, in Loop()
201 CloseSocket(client_socket); in Loop()
209 CloseSocket(client_socket); in Loop()
231 CloseSocket(client_socket); in Loop()
323 CHECK(Recv(client_socket, in Call()
[all …]
|
| /dports/japanese/fcitx-mozc/mozc-2.23.2815.102.01/src/server/ |
| H A D | mozc_rpc_server_main.cc | 115 void CloseSocket(int client_socket) { in CloseSocket() argument
117 ::closesocket(client_socket); in CloseSocket()
118 ::shutdown(client_socket, SD_BOTH); in CloseSocket()
120 ::close(client_socket); in CloseSocket()
189 CloseSocket(client_socket); in Loop()
198 if (!Recv(client_socket, in Loop()
201 CloseSocket(client_socket); in Loop()
209 CloseSocket(client_socket); in Loop()
231 CloseSocket(client_socket); in Loop()
323 CHECK(Recv(client_socket, in Call()
[all …]
|
| /dports/games/exult/exult-snapshot-v1.7.0.20211128/server/ |
| H A D | server.cc | 102 if (client_socket > highest_fd) in Set_highest_fd()
103 highest_fd = client_socket; in Set_highest_fd()
542 if (client_socket >= 0) in Server_delay()
550 if (client_socket >= 0) in Server_delay()
551 close(client_socket); in Server_delay()
554 client_socket << endl; in Server_delay()
560 if (client_socket >= 0 && FD_ISSET(client_socket, &rfds)) { in Server_delay()
563 if (client_socket == -1) in Server_delay()
571 if (client_socket == -1) { in Server_delay()
577 else client_socket = 1; in Server_delay()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/test/ |
| H A D | tcp_socket_proxy_unittest.cc | 52 *client_socket = std::make_unique<TCPClientSocket>( in MakeConnection()
64 EXPECT_TRUE((*client_socket)->IsConnected()); in MakeConnection()
116 std::unique_ptr<StreamSocket> client_socket; in TEST_F() local
118 MakeConnection(&client_socket, &server_socket); in TEST_F()
119 SendAndReceiveData(client_socket.get(), server_socket.get()); in TEST_F()
147 std::unique_ptr<StreamSocket> client_socket; in TEST_F() local
149 MakeConnection(&client_socket, &server_socket); in TEST_F()
151 ExpectClosed(client_socket.get()); in TEST_F()
163 std::unique_ptr<StreamSocket> client_socket; in TEST_F() local
165 MakeConnection(&client_socket, &server_socket); in TEST_F()
[all …]
|
| /dports/multimedia/kodi/xbmc-19.3-Matrix/xbmc/network/ |
| H A D | UdpClient.cpp | 37 client_socket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP); in Create()
38 if (client_socket == SOCKET_ERROR) in Create()
47 …if ( setsockopt( client_socket, SOL_SOCKET, SO_BROADCAST, (char*) &value, sizeof( unsigned int ) )… in Create()
56 ioctlsocket(client_socket, FIONBIO, &nonblocking); in Create()
69 closesocket(client_socket); in Destroy()
144 FD_ZERO(&readset); FD_SET(client_socket, &readset); in Process()
145 FD_ZERO(&exceptset); FD_SET(client_socket, &exceptset); in Process()
147 int nfds = (int)(client_socket); in Process()
157 ioctlsocket(client_socket, FIONREAD, &dataAvailable); in Process()
192 ioctlsocket(client_socket, FIONREAD, &dataAvailable); in Process()
[all …]
|