| /dports/devel/p5-IO-Multiplex/IO-Multiplex-1.16/t/ |
| H A D | 110_ntest.t | 32 my $client_socket;
58 $client_socket = IO::Socket::INET->new(PeerAddr => "127.0.0.1",
62 print $client_socket ? "ok 5\n" : "not ok 5\n";
75 syswrite($client_socket, $test_msg, length $test_msg);
|
| /dports/multimedia/gstreamer1-plugins/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gsttcpserversink.c | 157 GSocket *client_socket; in gst_tcp_server_sink_handle_server_read() local
161 client_socket = in gst_tcp_server_sink_handle_server_read()
163 if (!client_socket) in gst_tcp_server_sink_handle_server_read()
166 handle.socket = client_socket; in gst_tcp_server_sink_handle_server_read()
173 G_INET_SOCKET_ADDRESS (g_socket_get_remote_address (client_socket, in gst_tcp_server_sink_handle_server_read()
179 ip, g_inet_socket_address_get_port (addr), client_socket); in gst_tcp_server_sink_handle_server_read()
186 g_object_unref (client_socket); in gst_tcp_server_sink_handle_server_read()
|
| /dports/audio/gstreamer1-plugins-ogg/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gsttcpserversink.c | 157 GSocket *client_socket; in gst_tcp_server_sink_handle_server_read() local
161 client_socket = in gst_tcp_server_sink_handle_server_read()
163 if (!client_socket) in gst_tcp_server_sink_handle_server_read()
166 handle.socket = client_socket; in gst_tcp_server_sink_handle_server_read()
173 G_INET_SOCKET_ADDRESS (g_socket_get_remote_address (client_socket, in gst_tcp_server_sink_handle_server_read()
179 ip, g_inet_socket_address_get_port (addr), client_socket); in gst_tcp_server_sink_handle_server_read()
186 g_object_unref (client_socket); in gst_tcp_server_sink_handle_server_read()
|
| /dports/audio/gstreamer1-plugins-vorbis/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gsttcpserversink.c | 157 GSocket *client_socket; in gst_tcp_server_sink_handle_server_read() local
161 client_socket = in gst_tcp_server_sink_handle_server_read()
163 if (!client_socket) in gst_tcp_server_sink_handle_server_read()
166 handle.socket = client_socket; in gst_tcp_server_sink_handle_server_read()
173 G_INET_SOCKET_ADDRESS (g_socket_get_remote_address (client_socket, in gst_tcp_server_sink_handle_server_read()
179 ip, g_inet_socket_address_get_port (addr), client_socket); in gst_tcp_server_sink_handle_server_read()
186 g_object_unref (client_socket); in gst_tcp_server_sink_handle_server_read()
|
| /dports/audio/gstreamer1-plugins-opus/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gsttcpserversink.c | 157 GSocket *client_socket; in gst_tcp_server_sink_handle_server_read() local
161 client_socket = in gst_tcp_server_sink_handle_server_read()
163 if (!client_socket) in gst_tcp_server_sink_handle_server_read()
166 handle.socket = client_socket; in gst_tcp_server_sink_handle_server_read()
173 G_INET_SOCKET_ADDRESS (g_socket_get_remote_address (client_socket, in gst_tcp_server_sink_handle_server_read()
179 ip, g_inet_socket_address_get_port (addr), client_socket); in gst_tcp_server_sink_handle_server_read()
186 g_object_unref (client_socket); in gst_tcp_server_sink_handle_server_read()
|
| /dports/audio/gstreamer1-plugins-cdparanoia/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gsttcpserversink.c | 157 GSocket *client_socket; in gst_tcp_server_sink_handle_server_read() local
161 client_socket = in gst_tcp_server_sink_handle_server_read()
163 if (!client_socket) in gst_tcp_server_sink_handle_server_read()
166 handle.socket = client_socket; in gst_tcp_server_sink_handle_server_read()
173 G_INET_SOCKET_ADDRESS (g_socket_get_remote_address (client_socket, in gst_tcp_server_sink_handle_server_read()
179 ip, g_inet_socket_address_get_port (addr), client_socket); in gst_tcp_server_sink_handle_server_read()
186 g_object_unref (client_socket); in gst_tcp_server_sink_handle_server_read()
|
| /dports/x11-toolkits/gstreamer1-plugins-pango/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gsttcpserversink.c | 157 GSocket *client_socket; in gst_tcp_server_sink_handle_server_read() local
161 client_socket = in gst_tcp_server_sink_handle_server_read()
163 if (!client_socket) in gst_tcp_server_sink_handle_server_read()
166 handle.socket = client_socket; in gst_tcp_server_sink_handle_server_read()
173 G_INET_SOCKET_ADDRESS (g_socket_get_remote_address (client_socket, in gst_tcp_server_sink_handle_server_read()
179 ip, g_inet_socket_address_get_port (addr), client_socket); in gst_tcp_server_sink_handle_server_read()
186 g_object_unref (client_socket); in gst_tcp_server_sink_handle_server_read()
|
| /dports/graphics/gstreamer1-plugins-libvisual/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gsttcpserversink.c | 157 GSocket *client_socket; in gst_tcp_server_sink_handle_server_read() local
161 client_socket = in gst_tcp_server_sink_handle_server_read()
163 if (!client_socket) in gst_tcp_server_sink_handle_server_read()
166 handle.socket = client_socket; in gst_tcp_server_sink_handle_server_read()
173 G_INET_SOCKET_ADDRESS (g_socket_get_remote_address (client_socket, in gst_tcp_server_sink_handle_server_read()
179 ip, g_inet_socket_address_get_port (addr), client_socket); in gst_tcp_server_sink_handle_server_read()
186 g_object_unref (client_socket); in gst_tcp_server_sink_handle_server_read()
|
| /dports/graphics/gstreamer1-plugins-gl/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gsttcpserversink.c | 157 GSocket *client_socket; in gst_tcp_server_sink_handle_server_read() local
161 client_socket = in gst_tcp_server_sink_handle_server_read()
163 if (!client_socket) in gst_tcp_server_sink_handle_server_read()
166 handle.socket = client_socket; in gst_tcp_server_sink_handle_server_read()
173 G_INET_SOCKET_ADDRESS (g_socket_get_remote_address (client_socket, in gst_tcp_server_sink_handle_server_read()
179 ip, g_inet_socket_address_get_port (addr), client_socket); in gst_tcp_server_sink_handle_server_read()
186 g_object_unref (client_socket); in gst_tcp_server_sink_handle_server_read()
|
| /dports/x11/gstreamer1-plugins-x/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gsttcpserversink.c | 157 GSocket *client_socket; in gst_tcp_server_sink_handle_server_read() local
161 client_socket = in gst_tcp_server_sink_handle_server_read()
163 if (!client_socket) in gst_tcp_server_sink_handle_server_read()
166 handle.socket = client_socket; in gst_tcp_server_sink_handle_server_read()
173 G_INET_SOCKET_ADDRESS (g_socket_get_remote_address (client_socket, in gst_tcp_server_sink_handle_server_read()
179 ip, g_inet_socket_address_get_port (addr), client_socket); in gst_tcp_server_sink_handle_server_read()
186 g_object_unref (client_socket); in gst_tcp_server_sink_handle_server_read()
|
| /dports/multimedia/gstreamer1-plugins-theora/gst-plugins-base-1.16.2/gst/tcp/ |
| H A D | gsttcpserversink.c | 157 GSocket *client_socket; in gst_tcp_server_sink_handle_server_read() local
161 client_socket = in gst_tcp_server_sink_handle_server_read()
163 if (!client_socket) in gst_tcp_server_sink_handle_server_read()
166 handle.socket = client_socket; in gst_tcp_server_sink_handle_server_read()
173 G_INET_SOCKET_ADDRESS (g_socket_get_remote_address (client_socket, in gst_tcp_server_sink_handle_server_read()
179 ip, g_inet_socket_address_get_port (addr), client_socket); in gst_tcp_server_sink_handle_server_read()
186 g_object_unref (client_socket); in gst_tcp_server_sink_handle_server_read()
|
| /dports/www/py-tornado/tornado-6.1/tornado/test/ |
| H A D | util.py | 74 client_socket = socket.socket()
75 client_socket.connect(("127.0.0.1", port))
79 return (client_socket.close, client_addr[1])
|
| /dports/devel/grpc130/grpc-1.30.2/src/python/grpcio_tests/tests/unit/ |
| H A D | _tcp_proxy.py | 79 client_socket, client_address = socket_to_read.accept()
80 self._client_sockets.append(client_socket)
118 for client_socket in self._client_sockets:
119 client_socket.close()
|
| /dports/devel/grpc134/grpc-1.34.1/src/python/grpcio_tests/tests/unit/ |
| H A D | _tcp_proxy.py | 79 client_socket, client_address = socket_to_read.accept()
80 self._client_sockets.append(client_socket)
118 for client_socket in self._client_sockets:
119 client_socket.close()
|
| /dports/devel/grpc/grpc-1.42.0/src/python/grpcio_tests/tests/unit/ |
| H A D | _tcp_proxy.py | 79 client_socket, client_address = socket_to_read.accept()
80 self._client_sockets.append(client_socket)
118 for client_socket in self._client_sockets:
119 client_socket.close()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/services/network/ |
| H A D | udp_socket_unittest.cc | 270 mojo::Remote<mojom::UDPSocket> client_socket; in TEST_F() local
274 test::UDPSocketTestHelper client_helper(&client_socket); in TEST_F()
446 mojo::Remote<mojom::UDPSocket> client_socket; in TEST_F() local
450 test::UDPSocketTestHelper client_helper(&client_socket); in TEST_F()
481 client_socket->Close(); in TEST_F()
482 client_socket.FlushForTesting(); in TEST_F()
514 mojo::Remote<mojom::UDPSocket> client_socket; in TEST_F() local
518 test::UDPSocketTestHelper client_helper(&client_socket); in TEST_F()
523 client_socket->ReceiveMore(kDatagramCount); in TEST_F()
552 client_socket->ReceiveMore(1); in TEST_F()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/services/network/ |
| H A D | udp_socket_unittest.cc | 270 mojo::Remote<mojom::UDPSocket> client_socket; in TEST_F() local
274 test::UDPSocketTestHelper client_helper(&client_socket); in TEST_F()
446 mojo::Remote<mojom::UDPSocket> client_socket; in TEST_F() local
450 test::UDPSocketTestHelper client_helper(&client_socket); in TEST_F()
481 client_socket->Close(); in TEST_F()
482 client_socket.FlushForTesting(); in TEST_F()
514 mojo::Remote<mojom::UDPSocket> client_socket; in TEST_F() local
518 test::UDPSocketTestHelper client_helper(&client_socket); in TEST_F()
523 client_socket->ReceiveMore(kDatagramCount); in TEST_F()
552 client_socket->ReceiveMore(1); in TEST_F()
[all …]
|
| /dports/sysutils/moosefs2-cgiserv/moosefs-2.0.91/mfsscripts/ |
| H A D | mfscgiserv.py.in | 64 def __init__(self, server, client_socket, client_address): argument
67 self.client_socket = client_socket
68 self.client_socket.setblocking(0)
81 buff = self.client_socket.recv(1024)
124 sent = self.client_socket.send(self.outgoing)
141 del client_handlers[self.client_socket]
142 self.client_socket.close()
167 client_socket,client_address = server.socket.accept()
168 client_handlers[client_socket] = handler(server,client_socket,client_address)
|
| /dports/sysutils/moosefs2-master/moosefs-2.0.91/mfsscripts/ |
| H A D | mfscgiserv.py.in | 64 def __init__(self, server, client_socket, client_address): argument
67 self.client_socket = client_socket
68 self.client_socket.setblocking(0)
81 buff = self.client_socket.recv(1024)
124 sent = self.client_socket.send(self.outgoing)
141 del client_handlers[self.client_socket]
142 self.client_socket.close()
167 client_socket,client_address = server.socket.accept()
168 client_handlers[client_socket] = handler(server,client_socket,client_address)
|
| /dports/sysutils/moosefs2-metalogger/moosefs-2.0.91/mfsscripts/ |
| H A D | mfscgiserv.py.in | 64 def __init__(self, server, client_socket, client_address): argument
67 self.client_socket = client_socket
68 self.client_socket.setblocking(0)
81 buff = self.client_socket.recv(1024)
124 sent = self.client_socket.send(self.outgoing)
141 del client_handlers[self.client_socket]
142 self.client_socket.close()
167 client_socket,client_address = server.socket.accept()
168 client_handlers[client_socket] = handler(server,client_socket,client_address)
|
| /dports/sysutils/moosefs2-netdump/moosefs-2.0.91/mfsscripts/ |
| H A D | mfscgiserv.py.in | 64 def __init__(self, server, client_socket, client_address): argument
67 self.client_socket = client_socket
68 self.client_socket.setblocking(0)
81 buff = self.client_socket.recv(1024)
124 sent = self.client_socket.send(self.outgoing)
141 del client_handlers[self.client_socket]
142 self.client_socket.close()
167 client_socket,client_address = server.socket.accept()
168 client_handlers[client_socket] = handler(server,client_socket,client_address)
|
| /dports/sysutils/moosefs2-client/moosefs-2.0.91/mfsscripts/ |
| H A D | mfscgiserv.py.in | 64 def __init__(self, server, client_socket, client_address): argument
67 self.client_socket = client_socket
68 self.client_socket.setblocking(0)
81 buff = self.client_socket.recv(1024)
124 sent = self.client_socket.send(self.outgoing)
141 del client_handlers[self.client_socket]
142 self.client_socket.close()
167 client_socket,client_address = server.socket.accept()
168 client_handlers[client_socket] = handler(server,client_socket,client_address)
|
| /dports/sysutils/moosefs2-cgi/moosefs-2.0.91/mfsscripts/ |
| H A D | mfscgiserv.py.in | 64 def __init__(self, server, client_socket, client_address): argument
67 self.client_socket = client_socket
68 self.client_socket.setblocking(0)
81 buff = self.client_socket.recv(1024)
124 sent = self.client_socket.send(self.outgoing)
141 del client_handlers[self.client_socket]
142 self.client_socket.close()
167 client_socket,client_address = server.socket.accept()
168 client_handlers[client_socket] = handler(server,client_socket,client_address)
|
| /dports/sysutils/moosefs2-chunkserver/moosefs-2.0.91/mfsscripts/ |
| H A D | mfscgiserv.py.in | 64 def __init__(self, server, client_socket, client_address): argument
67 self.client_socket = client_socket
68 self.client_socket.setblocking(0)
81 buff = self.client_socket.recv(1024)
124 sent = self.client_socket.send(self.outgoing)
141 del client_handlers[self.client_socket]
142 self.client_socket.close()
167 client_socket,client_address = server.socket.accept()
168 client_handlers[client_socket] = handler(server,client_socket,client_address)
|
| /dports/sysutils/moosefs2-cli/moosefs-2.0.91/mfsscripts/ |
| H A D | mfscgiserv.py.in | 64 def __init__(self, server, client_socket, client_address): argument
67 self.client_socket = client_socket
68 self.client_socket.setblocking(0)
81 buff = self.client_socket.recv(1024)
124 sent = self.client_socket.send(self.outgoing)
141 del client_handlers[self.client_socket]
142 self.client_socket.close()
167 client_socket,client_address = server.socket.accept()
168 client_handlers[client_socket] = handler(server,client_socket,client_address)
|