Home
last modified time | relevance | path

Searched refs:client_socket (Results 1 – 9 of 9) sorted by relevance

/third_party/gstreamer/gstplugins_base/gst/tcp/
Dgsttcpserversrc.c179 src->client_socket = NULL; in gst_tcp_server_src_init()
196 if (src->client_socket) in gst_tcp_server_src_finalize()
197 g_object_unref (src->client_socket); in gst_tcp_server_src_finalize()
198 src->client_socket = NULL; in gst_tcp_server_src_finalize()
223 if (!src->client_socket) { in gst_tcp_server_src_create()
225 src->client_socket = in gst_tcp_server_src_create()
227 if (!src->client_socket) in gst_tcp_server_src_create()
242 avail = g_socket_get_available_bytes (src->client_socket); in gst_tcp_server_src_create()
248 if (!g_socket_condition_wait (src->client_socket, in gst_tcp_server_src_create()
253 g_socket_condition_check (src->client_socket, in gst_tcp_server_src_create()
[all …]
Dgsttcpserversink.c159 GSocket *client_socket; in gst_tcp_server_sink_handle_server_read() local
163 client_socket = in gst_tcp_server_sink_handle_server_read()
165 if (!client_socket) in gst_tcp_server_sink_handle_server_read()
168 handle.socket = client_socket; in gst_tcp_server_sink_handle_server_read()
175 G_INET_SOCKET_ADDRESS (g_socket_get_remote_address (client_socket, in gst_tcp_server_sink_handle_server_read()
182 ip, g_inet_socket_address_get_port (addr), client_socket); in gst_tcp_server_sink_handle_server_read()
189 client_socket); in gst_tcp_server_sink_handle_server_read()
194 g_object_unref (client_socket); in gst_tcp_server_sink_handle_server_read()
Dgsttcpserversrc.h61 GSocket *client_socket; member
/third_party/node/test/cctest/
Dtest_inspector_socket.cc190 static uv_tcp_t server, client_socket; variable
248 uv_write(&req, reinterpret_cast<uv_stream_t*>(&client_socket), in do_write()
310 uv_stream_t* stream = reinterpret_cast<uv_stream_t*>(&client_socket); in expect_nothing_on_client()
320 client_socket.data = &expectation; in expect_on_client()
321 uv_read_start(reinterpret_cast<uv_stream_t*>(&client_socket), in expect_on_client()
354 client_socket = uv_tcp_t(); in SetUp()
357 uv_tcp_init(&loop, &client_socket); in SetUp()
364 GTEST_ASSERT_EQ(0, uv_tcp_connect(&connect, &client_socket, in SetUp()
367 uv_tcp_nodelay(&client_socket, 1); // The buffering messes up the test in SetUp()
373 really_close(reinterpret_cast<uv_handle_t*>(&client_socket)); in TearDown()
[all …]
/third_party/skia/third_party/externals/microhttpd/src/microhttpd/
Ddaemon.c1237 MHD_socket client_socket, in internal_add_connection() argument
1258 worker = &daemon->worker_pool[(i + client_socket) % daemon->worker_pool_size]; in internal_add_connection()
1261 client_socket, in internal_add_connection()
1266 if (0 != MHD_socket_close_ (client_socket)) in internal_add_connection()
1275 if ( (client_socket >= FD_SETSIZE) && in internal_add_connection()
1281 client_socket, in internal_add_connection()
1284 if (0 != MHD_socket_close_ (client_socket)) in internal_add_connection()
1298 client_socket); in internal_add_connection()
1309 if (0 != MHD_socket_close_ (client_socket)) in internal_add_connection()
1328 if (0 != MHD_socket_close_ (client_socket)) in internal_add_connection()
[all …]
/third_party/alsa-lib/src/pcm/
Dpcm_share.c113 int client_socket; member
295 write(share->client_socket, buf, 1); in _snd_pcm_share_missing()
300 read(share->client_socket, buf, 1); in _snd_pcm_share_missing()
1279 close(share->client_socket); in snd_pcm_share_close()
1525 share->client_socket = sd[0]; in snd_pcm_share_open()
1532 pcm->poll_fd = share->client_socket; in snd_pcm_share_open()
/third_party/skia/third_party/externals/microhttpd/src/include/
Dmicrohttpd.h1555 MHD_socket client_socket,
/third_party/skia/third_party/externals/microhttpd/doc/
Dlibmicrohttpd.texi1483 @deftypefun void MHD_add_connection (struct MHD_Daemon *daemon, int client_socket, const struct soc…
1503 @item client_socket
Dlibmicrohttpd.info1287 client_socket, const struct sockaddr *addr, socklen_t addrlen)