| /third_party/gstreamer/gstplugins_base/gst/tcp/ |
| D | gsttcpserversink.c | 136 this->server_socket = NULL; in gst_tcp_server_sink_init()
144 if (this->server_socket) in gst_tcp_server_sink_finalize()
145 g_object_unref (this->server_socket); in gst_tcp_server_sink_finalize()
146 this->server_socket = NULL; in gst_tcp_server_sink_finalize()
164 g_socket_accept (sink->server_socket, sink->element.cancellable, &err); in gst_tcp_server_sink_handle_server_read()
202 sink->server_socket, err->message)); in gst_tcp_server_sink_handle_server_read()
312 this->server_socket = in gst_tcp_server_sink_init_send()
317 if (!this->server_socket) in gst_tcp_server_sink_init_send()
321 this->server_socket); in gst_tcp_server_sink_init_send()
323 g_socket_set_blocking (this->server_socket, FALSE); in gst_tcp_server_sink_init_send()
[all …]
|
| D | gsttcpserversrc.c | 178 src->server_socket = NULL; in gst_tcp_server_src_init()
193 if (src->server_socket) in gst_tcp_server_src_finalize()
194 g_object_unref (src->server_socket); in gst_tcp_server_src_finalize()
195 src->server_socket = NULL; in gst_tcp_server_src_finalize()
226 g_socket_accept (src->server_socket, src->cancellable, &err); in gst_tcp_server_src_create()
231 if (!g_socket_close (src->server_socket, &err)) { in gst_tcp_server_src_create()
437 src->server_socket = in gst_tcp_server_src_start()
442 if (!src->server_socket) in gst_tcp_server_src_start()
449 if (!g_socket_bind (src->server_socket, saddr, TRUE, &err)) in gst_tcp_server_src_start()
456 g_socket_set_listen_backlog (src->server_socket, TCP_BACKLOG); in gst_tcp_server_src_start()
[all …]
|
| D | gsttcpserversink.h | 66 GSocket *server_socket; member
|
| D | gsttcpserversrc.h | 60 GSocket *server_socket; member
|
| /third_party/jerryscript/jerry-ext/debugger/ |
| D | debugger-tcp.c | 250 jerryx_debugger_tcp_configure_socket (jerryx_socket server_socket, /** < socket to configure */ in jerryx_debugger_tcp_configure_socket() argument
265 if (setsockopt (server_socket, SOL_SOCKET, SO_REUSEADDR, &opt_value, sizeof (int)) != 0) in jerryx_debugger_tcp_configure_socket()
270 if (bind (server_socket, (struct sockaddr *) &addr, sizeof (struct sockaddr_in)) != 0) in jerryx_debugger_tcp_configure_socket()
275 if (listen (server_socket, 1) != 0) in jerryx_debugger_tcp_configure_socket()
302 jerryx_socket server_socket = socket (AF_INET, SOCK_STREAM, 0); in jerryx_debugger_tcp_create() local
303 if (server_socket == JERRYX_SOCKET_INVALID) in jerryx_debugger_tcp_create()
309 if (!jerryx_debugger_tcp_configure_socket (server_socket, port)) in jerryx_debugger_tcp_create()
312 jerryx_debugger_tcp_close_socket (server_socket); in jerryx_debugger_tcp_create()
322 jerryx_socket tcp_socket = accept (server_socket, (struct sockaddr *) &addr, &sin_size); in jerryx_debugger_tcp_create()
324 jerryx_debugger_tcp_close_socket (server_socket); in jerryx_debugger_tcp_create()
|
| /third_party/boost/libs/asio/test/ |
| D | buffered_write_stream.cpp | 157 stream_type server_socket(io_context); in test_sync_operations() local
158 acceptor.accept(server_socket.lowest_layer()); in test_sync_operations()
178 bytes_read += server_socket.read_some( in test_sync_operations()
189 bytes_written += server_socket.write_some( in test_sync_operations()
191 server_socket.flush(); in test_sync_operations()
205 server_socket.close(); in test_sync_operations()
275 stream_type server_socket(io_context); in test_async_operations() local
276 acceptor.async_accept(server_socket.lowest_layer(), &handle_accept); in test_async_operations()
304 server_socket.async_read_some( in test_async_operations()
318 server_socket.async_write_some( in test_async_operations()
[all …]
|
| D | buffered_stream.cpp | 168 stream_type server_socket(io_context); in test_sync_operations() local
169 acceptor.accept(server_socket.lowest_layer()); in test_sync_operations()
189 bytes_read += server_socket.read_some( in test_sync_operations()
200 bytes_written += server_socket.write_some( in test_sync_operations()
202 server_socket.flush(); in test_sync_operations()
216 server_socket.close(); in test_sync_operations()
286 stream_type server_socket(io_context); in test_async_operations() local
287 acceptor.async_accept(server_socket.lowest_layer(), &handle_accept); in test_async_operations()
315 server_socket.async_read_some( in test_async_operations()
329 server_socket.async_write_some( in test_async_operations()
[all …]
|
| D | buffered_read_stream.cpp | 157 stream_type server_socket(io_context); in test_sync_operations() local
158 acceptor.accept(server_socket.lowest_layer()); in test_sync_operations()
177 bytes_read += server_socket.read_some( in test_sync_operations()
188 bytes_written += server_socket.write_some( in test_sync_operations()
203 server_socket.close(); in test_sync_operations()
268 stream_type server_socket(io_context); in test_async_operations() local
269 acceptor.async_accept(server_socket.lowest_layer(), &handle_accept); in test_async_operations()
293 server_socket.async_read_some( in test_async_operations()
307 server_socket.async_write_some( in test_async_operations()
328 server_socket.close(); in test_async_operations()
|
| /third_party/grpc/test/core/handshake/ |
| D | client_ssl.cc | 225 int server_socket = -1; in client_ssl_test() local
227 while (server_socket == -1 && socket_retries-- > 0) { in client_ssl_test()
228 server_socket = create_socket(&port); in client_ssl_test()
229 if (server_socket == -1) { in client_ssl_test()
233 GPR_ASSERT(server_socket > 0 && port > 0); in client_ssl_test()
236 server_args args = {server_socket, server_alpn_preferred}; in client_ssl_test()
|
| /third_party/node/src/ |
| D | inspector_socket_server.cc | 243 for (const auto& server_socket : server_sockets) { in PrintDebuggerReadyMessage() local
247 FormatWsAddress(host, server_socket->port(), id, true).c_str()); in PrintDebuggerReadyMessage()
409 auto server_socket = ServerSocketPtr(new ServerSocket(this)); in Start() local
410 err = server_socket->Listen(address->ai_addr, loop_); in Start()
412 server_sockets_.push_back(std::move(server_socket)); in Start()
466 uv_stream_t* server_socket) { in Accept() argument
475 InspectorSocket::Accept(server_socket, std::move(delegate)); in Accept()
556 ServerSocket* server_socket = ServerSocket::FromTcpSocket(tcp_socket); in SocketConnectedCallback() local
558 server_socket->server_->Accept(server_socket->port_, tcp_socket); in SocketConnectedCallback()
|
| D | inspector_socket_server.h | 67 void Accept(int server_port, uv_stream_t* server_socket);
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/invocation/ |
| D | prioritised_handlers.cpp | 149 tcp::socket server_socket(io_context); in main() local
150 acceptor.async_accept(server_socket, in main()
|
| /third_party/boost/libs/asio/example/cpp03/invocation/ |
| D | prioritised_handlers.cpp | 149 tcp::socket server_socket(io_context); in main() local
150 acceptor.async_accept(server_socket, in main()
|
| /third_party/skia/third_party/externals/tint/tools/src/cmd/remote-compile/ |
| D | main.cc | 348 auto server_socket = Socket::Listen("", port.c_str()); in RunServer() local
349 if (!server_socket) { in RunServer()
354 while (auto conn = server_socket->Accept()) { in RunServer()
|
| /third_party/boost/libs/asio/example/cpp11/invocation/ |
| D | prioritised_handlers.cpp | 181 tcp::socket server_socket(io_context); in main() local
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/invocation/ |
| D | prioritised_handlers.cpp | 181 tcp::socket server_socket(io_context); in main() local
|
| /third_party/weston/compositor/ |
| D | main.c | 3233 char *server_socket = NULL; in wet_main() local
3446 server_socket = getenv("WAYLAND_SERVER_SOCKET"); in wet_main()
3447 if (server_socket) { in wet_main()
3449 if (!safe_strtoint(server_socket, &fd)) in wet_main()
|