| /dports/devel/lion/lion/ |
| H A D | sockets.c | 250 if (new_socket < 0 ) in sockets_make()
291 new_socket = sockets_setnonblocking(new_socket); in sockets_make()
361 return new_socket; in sockets_make()
436 new_socket = sockets_setnonblocking(new_socket); in sockets_accept()
439 return new_socket; in sockets_accept()
485 if (new_socket < 0) in sockets_connect()
589 new_socket = sockets_setnonblocking(new_socket); in sockets_connect()
638 return new_socket; in sockets_connect()
1135 new_socket = sockets_setnonblocking(new_socket); in sockets_udp()
1184 close(new_socket); in sockets_udp()
[all …]
|
| /dports/science/paje/Paje_1.97/Tracers/JRastro/libRastro/src/ |
| H A D | rastro_timesync.c | 166 int new_socket, size; in wait_connection() local
168 new_socket = accept(sock, (struct sockaddr *) &connection, &size); in wait_connection()
169 return new_socket; in wait_connection()
176 int new_socket; in establish_connection() local
178 new_socket = socket(AF_INET, SOCK_STREAM, 0); in establish_connection()
183 while ( (connect(new_socket, (struct sockaddr *) in establish_connection()
185 return new_socket; in establish_connection()
237 int new_socket; in sincroniza() local
244 new_socket = wait_connection(com_socket); in sincroniza()
245 ping(new_socket, &local, &remote, remotename); in sincroniza()
[all …]
|
| /dports/biology/wise/wise2.4.1/src/socket/ |
| H A D | functionserver.dy | 47 int new_socket;
85 new_socket = accept(fs->socket,0,0);
103 if ((bytes_in = read(new_socket,buf,sizeof(buf))) == -1) {
129 write(new_socket,buf,9);
130 close(new_socket);
141 write(new_socket,buf,6);
146 ifp = fdopen(new_socket,"r");
173 ws = WriteStream_from_socket(new_socket);
183 write(new_socket,buf,5);
194 close(new_socket);
[all …]
|
| H A D | functionserver.c | 25 int new_socket; in main_loop_forking_FunctionServer() local
63 new_socket = accept(fs->socket,0,0); in main_loop_forking_FunctionServer()
81 if ((bytes_in = read(new_socket,buf,sizeof(buf))) == -1) { in main_loop_forking_FunctionServer()
107 write(new_socket,buf,9); in main_loop_forking_FunctionServer()
108 close(new_socket); in main_loop_forking_FunctionServer()
119 write(new_socket,buf,6); in main_loop_forking_FunctionServer()
124 ifp = fdopen(new_socket,"r"); in main_loop_forking_FunctionServer()
151 ws = WriteStream_from_socket(new_socket); in main_loop_forking_FunctionServer()
161 write(new_socket,buf,5); in main_loop_forking_FunctionServer()
172 close(new_socket); in main_loop_forking_FunctionServer()
[all …]
|
| /dports/net/asterisk-chan_sccp/chan-sccp-4.3.3/src/ |
| H A D | sccp_netsock.c | 481 SCCP_NETSOCK_SETOPTION(new_socket, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)); in sccp_netsock_setoptions()
483 SCCP_NETSOCK_SETOPTION(new_socket, SOL_SOCKET, SO_REUSEPORT, &reuse, sizeof(reuse)); in sccp_netsock_setoptions()
488 SCCP_NETSOCK_SETOPTION(new_socket, IPPROTO_TCP, TCP_NODELAY, &on, sizeof(on)); in sccp_netsock_setoptions()
492 SCCP_NETSOCK_SETOPTION(new_socket, IPPROTO_IP, IP_TOS, &value, sizeof(value)); in sccp_netsock_setoptions()
495 SCCP_NETSOCK_SETOPTION(new_socket, SOL_SOCKET, SO_PRIORITY, &value, sizeof(value)); in sccp_netsock_setoptions()
500 SCCP_NETSOCK_SETOPTION(new_socket, SOL_SOCKET, SO_RCVBUF, &so_rcvbuf, sizeof(int)); in sccp_netsock_setoptions()
501 SCCP_NETSOCK_SETOPTION(new_socket, SOL_SOCKET, SO_SNDBUF, &so_sndbuf, sizeof(int)); in sccp_netsock_setoptions()
517 SCCP_NETSOCK_SETOPTION(new_socket, SOL_SOCKET, SO_SNDTIMEO, &mytv, sizeof(mytv)); in sccp_netsock_setoptions()
522 SCCP_NETSOCK_SETOPTION(new_socket, SOL_SOCKET, SO_RCVTIMEO, &mytv, sizeof(mytv)); in sccp_netsock_setoptions()
532 SCCP_NETSOCK_SETOPTION(new_socket, SOL_TCP, TCP_KEEPCNT, &ip_keepcnt, sizeof(int)); in sccp_netsock_setoptions()
[all …]
|
| /dports/www/squid/squid-4.15/src/ |
| H A D | comm.cc | 338 int new_socket; in comm_openex() local
369 if (new_socket < 0) { in comm_openex()
391 conn->fd = new_socket; in comm_openex()
413 return new_socket; in comm_openex()
443 comm_apply_flags(int new_socket, in comm_apply_flags() argument
448 assert(new_socket >= 0); in comm_apply_flags()
480 comm_close(new_socket); in comm_apply_flags()
500 return new_socket; in comm_apply_flags()
1878 int new_socket; local
1919 assert(!isOpen(new_socket));
[all …]
|
| /dports/devel/grpc/grpc-1.42.0/src/core/lib/iomgr/ |
| H A D | tcp_server_custom.cc | 255 grpc_custom_socket* new_socket = static_cast<grpc_custom_socket*>( in custom_accept_callback() local
257 new_socket->endpoint = nullptr; in custom_accept_callback()
258 new_socket->listener = nullptr; in custom_accept_callback()
259 new_socket->connector = nullptr; in custom_accept_callback()
260 new_socket->refs = 1; in custom_accept_callback()
261 grpc_custom_socket_vtable->accept(sp->socket, new_socket, in custom_accept_callback()
429 new_socket->endpoint = nullptr; in tcp_server_start()
430 new_socket->listener = nullptr; in tcp_server_start()
431 new_socket->connector = nullptr; in tcp_server_start()
432 new_socket->refs = 1; in tcp_server_start()
[all …]
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/lib/iomgr/ |
| H A D | tcp_server_custom.cc | 255 grpc_custom_socket* new_socket = static_cast<grpc_custom_socket*>( in custom_accept_callback() local
257 new_socket->endpoint = nullptr; in custom_accept_callback()
258 new_socket->listener = nullptr; in custom_accept_callback()
259 new_socket->connector = nullptr; in custom_accept_callback()
260 new_socket->refs = 1; in custom_accept_callback()
261 grpc_custom_socket_vtable->accept(sp->socket, new_socket, in custom_accept_callback()
429 new_socket->endpoint = nullptr; in tcp_server_start()
430 new_socket->listener = nullptr; in tcp_server_start()
431 new_socket->connector = nullptr; in tcp_server_start()
432 new_socket->refs = 1; in tcp_server_start()
[all …]
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/lib/iomgr/ |
| H A D | tcp_server_custom.cc | 245 grpc_custom_socket* new_socket = static_cast<grpc_custom_socket*>( in custom_accept_callback() local
247 new_socket->endpoint = nullptr; in custom_accept_callback()
248 new_socket->listener = nullptr; in custom_accept_callback()
249 new_socket->connector = nullptr; in custom_accept_callback()
250 new_socket->refs = 1; in custom_accept_callback()
251 grpc_custom_socket_vtable->accept(sp->socket, new_socket, in custom_accept_callback()
419 new_socket->endpoint = nullptr; in tcp_server_start()
420 new_socket->listener = nullptr; in tcp_server_start()
421 new_socket->connector = nullptr; in tcp_server_start()
422 new_socket->refs = 1; in tcp_server_start()
[all …]
|
| /dports/devel/glib20/glib-2.70.4/gio/tests/ |
| H A D | socket-server.c | 52 GSocket *socket, *new_socket, *recv_socket; in main() local
173 new_socket = g_socket_accept (socket, cancellable, &error); in main()
174 if (!new_socket) in main()
182 g_socket_set_blocking (new_socket, FALSE); in main()
184 g_socket_set_timeout (new_socket, read_timeout); in main()
186 address = g_socket_get_remote_address (new_socket, &error); in main()
199 recv_socket = new_socket; in main()
202 g_object_unref (new_socket); in main()
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/lib/iomgr/ |
| H A D | tcp_server_custom.cc | 271 grpc_custom_socket* new_socket = in custom_accept_callback() local
273 new_socket->endpoint = nullptr; in custom_accept_callback()
274 new_socket->listener = nullptr; in custom_accept_callback()
275 new_socket->connector = nullptr; in custom_accept_callback()
276 new_socket->refs = 1; in custom_accept_callback()
277 grpc_custom_socket_vtable->accept(sp->socket, new_socket, in custom_accept_callback()
441 grpc_custom_socket* new_socket = in tcp_server_start() local
443 new_socket->endpoint = nullptr; in tcp_server_start()
444 new_socket->listener = nullptr; in tcp_server_start()
445 new_socket->connector = nullptr; in tcp_server_start()
[all …]
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/lib/iomgr/ |
| H A D | tcp_server_custom.cc | 265 grpc_custom_socket* new_socket = in custom_accept_callback() local
267 new_socket->endpoint = nullptr; in custom_accept_callback()
268 new_socket->listener = nullptr; in custom_accept_callback()
269 new_socket->connector = nullptr; in custom_accept_callback()
270 new_socket->refs = 1; in custom_accept_callback()
271 grpc_custom_socket_vtable->accept(sp->socket, new_socket, in custom_accept_callback()
433 grpc_custom_socket* new_socket = in tcp_server_start() local
435 new_socket->endpoint = nullptr; in tcp_server_start()
436 new_socket->listener = nullptr; in tcp_server_start()
437 new_socket->connector = nullptr; in tcp_server_start()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/lib/iomgr/ |
| H A D | tcp_server_custom.cc | 260 grpc_custom_socket* new_socket = in custom_accept_callback() local
262 new_socket->endpoint = nullptr; in custom_accept_callback()
263 new_socket->listener = nullptr; in custom_accept_callback()
264 new_socket->connector = nullptr; in custom_accept_callback()
265 new_socket->refs = 1; in custom_accept_callback()
266 grpc_custom_socket_vtable->accept(sp->socket, new_socket, in custom_accept_callback()
430 grpc_custom_socket* new_socket = in tcp_server_start() local
432 new_socket->endpoint = nullptr; in tcp_server_start()
433 new_socket->listener = nullptr; in tcp_server_start()
434 new_socket->connector = nullptr; in tcp_server_start()
[all …]
|
| /dports/emulators/mess/mame-mame0226/3rdparty/asio/src/examples/cpp03/porthopper/ |
| H A D | server.cpp | 39 tcp_socket_ptr new_socket( in server() local
41 acceptor_.async_accept(*new_socket, in server()
43 asio::placeholders::error, new_socket)); in server()
63 tcp_socket_ptr new_socket( in handle_accept() local
65 acceptor_.async_accept(*new_socket, in handle_accept()
67 asio::placeholders::error, new_socket)); in handle_accept()
|
| /dports/emulators/mame/mame-mame0226/3rdparty/asio/src/examples/cpp03/porthopper/ |
| H A D | server.cpp | 39 tcp_socket_ptr new_socket( in server() local
41 acceptor_.async_accept(*new_socket, in server()
43 asio::placeholders::error, new_socket)); in server()
63 tcp_socket_ptr new_socket( in handle_accept() local
65 acceptor_.async_accept(*new_socket, in handle_accept()
67 asio::placeholders::error, new_socket)); in handle_accept()
|
| /dports/net/asio/asio-1.16.0/src/examples/cpp03/porthopper/ |
| H A D | server.cpp | 39 tcp_socket_ptr new_socket(new tcp::socket(acceptor_.get_executor())); in server() local
40 acceptor_.async_accept(*new_socket, in server()
42 asio::placeholders::error, new_socket)); in server()
62 tcp_socket_ptr new_socket(new tcp::socket(acceptor_.get_executor())); in handle_accept() local
63 acceptor_.async_accept(*new_socket, in handle_accept()
65 asio::placeholders::error, new_socket)); in handle_accept()
|
| /dports/www/restbed/restbed-4.8/dependency/asio/asio/src/examples/cpp03/porthopper/ |
| H A D | server.cpp | 39 tcp_socket_ptr new_socket(new tcp::socket(acceptor_.get_executor())); in server() local
40 acceptor_.async_accept(*new_socket, in server()
42 asio::placeholders::error, new_socket)); in server()
62 tcp_socket_ptr new_socket(new tcp::socket(acceptor_.get_executor())); in handle_accept() local
63 acceptor_.async_accept(*new_socket, in handle_accept()
65 asio::placeholders::error, new_socket)); in handle_accept()
|
| /dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/link/modules/asio-standalone/asio/src/examples/cpp03/porthopper/ |
| H A D | server.cpp | 39 tcp_socket_ptr new_socket( in server() local
41 acceptor_.async_accept(*new_socket, in server()
43 asio::placeholders::error, new_socket)); in server()
63 tcp_socket_ptr new_socket( in handle_accept() local
65 acceptor_.async_accept(*new_socket, in handle_accept()
67 asio::placeholders::error, new_socket)); in handle_accept()
|
| /dports/multimedia/obs-websocket/obs-websocket-4.8.0/deps/asio/asio/src/examples/cpp03/porthopper/ |
| H A D | server.cpp | 39 tcp_socket_ptr new_socket( in server() local
41 acceptor_.async_accept(*new_socket, in server()
43 asio::placeholders::error, new_socket)); in server()
63 tcp_socket_ptr new_socket( in handle_accept() local
65 acceptor_.async_accept(*new_socket, in handle_accept()
67 asio::placeholders::error, new_socket)); in handle_accept()
|
| /dports/games/frogatto/frogatto-1.3.1/MacOSJet/boost/include/boost/asio/detail/ |
| H A D | reactive_socket_accept_op.hpp | 55 socket_type new_socket = invalid_socket; in do_perform() local
58 o->peer_endpoint_ ? &addrlen : 0, o->ec_, new_socket); in do_perform()
61 if (new_socket >= 0) in do_perform()
63 socket_holder new_socket_holder(new_socket); in do_perform()
66 if (!o->peer_.assign(o->protocol_, new_socket, o->ec_)) in do_perform()
|
| /dports/devel/rpclib/rpclib-2.2.1/dependencies/include/asio/detail/ |
| H A D | reactive_socket_accept_op.hpp | 54 socket_type new_socket = invalid_socket; in do_perform() local
57 o->peer_endpoint_ ? &addrlen : 0, o->ec_, new_socket); in do_perform()
60 if (new_socket != invalid_socket) in do_perform()
62 socket_holder new_socket_holder(new_socket); in do_perform()
65 if (!o->peer_.assign(o->protocol_, new_socket, o->ec_)) in do_perform()
|
| /dports/databases/percona57-pam-for-mysql/boost_1_59_0/boost/asio/detail/ |
| H A D | reactive_socket_accept_op.hpp | 55 socket_type new_socket = invalid_socket; in do_perform() local
58 o->peer_endpoint_ ? &addrlen : 0, o->ec_, new_socket); in do_perform()
61 if (new_socket != invalid_socket) in do_perform()
63 socket_holder new_socket_holder(new_socket); in do_perform()
66 if (!o->peer_.assign(o->protocol_, new_socket, o->ec_)) in do_perform()
|
| /dports/databases/galera/galera-release_25.3.35/asio/asio/detail/ |
| H A D | reactive_socket_accept_op.hpp | 54 socket_type new_socket = invalid_socket; in do_perform() local
57 o->peer_endpoint_ ? &addrlen : 0, o->ec_, new_socket); in do_perform()
60 if (new_socket != invalid_socket) in do_perform()
62 socket_holder new_socket_holder(new_socket); in do_perform()
65 if (!o->peer_.assign(o->protocol_, new_socket, o->ec_)) in do_perform()
|
| /dports/databases/xtrabackup/boost_1_59_0/boost/asio/detail/ |
| H A D | reactive_socket_accept_op.hpp | 55 socket_type new_socket = invalid_socket; in do_perform() local
58 o->peer_endpoint_ ? &addrlen : 0, o->ec_, new_socket); in do_perform()
61 if (new_socket != invalid_socket) in do_perform()
63 socket_holder new_socket_holder(new_socket); in do_perform()
66 if (!o->peer_.assign(o->protocol_, new_socket, o->ec_)) in do_perform()
|
| /dports/databases/percona57-server/boost_1_59_0/boost/asio/detail/ |
| H A D | reactive_socket_accept_op.hpp | 55 socket_type new_socket = invalid_socket; in do_perform() local
58 o->peer_endpoint_ ? &addrlen : 0, o->ec_, new_socket); in do_perform()
61 if (new_socket != invalid_socket) in do_perform()
63 socket_holder new_socket_holder(new_socket); in do_perform()
66 if (!o->peer_.assign(o->protocol_, new_socket, o->ec_)) in do_perform()
|