| /third_party/glib/gio/tests/ |
| 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()
|
| /third_party/grpc/src/core/lib/iomgr/ |
| D | tcp_server_custom.cc | 267 grpc_custom_socket* new_socket = static_cast<grpc_custom_socket*>( in custom_accept_callback() local
269 new_socket->endpoint = nullptr; in custom_accept_callback()
270 new_socket->listener = nullptr; in custom_accept_callback()
271 new_socket->connector = nullptr; in custom_accept_callback()
272 new_socket->refs = 1; in custom_accept_callback()
273 grpc_custom_socket_vtable->accept(sp->socket, new_socket, in custom_accept_callback()
439 grpc_custom_socket* new_socket = static_cast<grpc_custom_socket*>( in tcp_server_start() local
441 new_socket->endpoint = nullptr; in tcp_server_start()
442 new_socket->listener = nullptr; in tcp_server_start()
443 new_socket->connector = nullptr; in tcp_server_start()
[all …]
|
| D | tcp_uv.cc | 249 grpc_custom_socket* new_socket = uv_socket->accept_socket; in accept_new_connection() local
257 uv_socket->accept_cb(socket, new_socket, error); in accept_new_connection()
264 new_socket->impl = uv_new_socket; in accept_new_connection()
265 uv_new_socket->handle->data = new_socket; in accept_new_connection()
266 uv_socket->accept_cb(socket, new_socket, error); in accept_new_connection()
287 grpc_custom_socket* new_socket, in uv_socket_accept() argument
292 uv_socket->accept_socket = new_socket; in uv_socket_accept()
|
| D | tcp_server_windows.cc | 60 SOCKET new_socket; member
290 port->new_socket = sock; in start_accept_locked()
304 SOCKET sock = sp->new_socket; in on_accept()
438 sp->new_socket = INVALID_SOCKET; in add_socket_to_server()
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/porthopper/ |
| 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 boost::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 boost::asio::placeholders::error, new_socket)); in handle_accept()
|
| /third_party/boost/libs/asio/example/cpp03/porthopper/ |
| 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 boost::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 boost::asio::placeholders::error, new_socket)); in handle_accept()
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/fork/ |
| D | process_per_connection.cpp | 60 [this](boost::system::error_code ec, tcp::socket new_socket) in accept()
65 socket_ = std::move(new_socket); in accept()
|
| /third_party/boost/libs/asio/example/cpp11/fork/ |
| D | process_per_connection.cpp | 60 [this](boost::system::error_code ec, tcp::socket new_socket) in accept()
65 socket_ = std::move(new_socket); in accept()
|
| /third_party/boost/libs/asio/include/boost/asio/detail/ |
| D | reactive_socket_accept_op.hpp | 59 socket_type new_socket = invalid_socket; in do_perform() local
62 o->peer_endpoint_ ? &o->addrlen_ : 0, o->ec_, new_socket) in do_perform()
64 o->new_socket_.reset(new_socket); in do_perform()
|
| D | win_iocp_socket_service.hpp | 472 socket_holder new_socket(socket_ops::sync_accept(impl.socket_, in accept() local
477 if (new_socket.get() != invalid_socket) in accept()
481 peer.assign(impl.protocol_, new_socket.get(), ec); in accept()
483 new_socket.release(); in accept()
508 start_accept_op(impl, peer.is_open(), p.p->new_socket(), in async_accept()
537 start_accept_op(impl, false, p.p->new_socket(), in async_move_accept()
|
| D | reactive_socket_service.hpp | 422 socket_holder new_socket(socket_ops::sync_accept(impl.socket_, in accept() local
427 if (new_socket.get() != invalid_socket) in accept()
431 peer.assign(impl.protocol_, new_socket.get(), ec); in accept()
433 new_socket.release(); in accept()
|
| D | win_iocp_socket_accept_op.hpp | 62 socket_holder& new_socket() in new_socket() function in boost::asio::detail::win_iocp_socket_accept_op
193 socket_holder& new_socket() in new_socket() function in boost::asio::detail::win_iocp_socket_move_accept_op
|
| D | socket_ops.hpp | 79 socket_type new_socket, boost::system::error_code& ec);
85 boost::system::error_code& ec, socket_type& new_socket);
|
| D | win_iocp_socket_service_base.hpp | 468 socket_holder& new_socket, int family, int type, int protocol,
510 bool peer_is_open, socket_holder& new_socket, int family, int type,
|
| /third_party/boost/boost/asio/detail/ |
| D | reactive_socket_accept_op.hpp | 59 socket_type new_socket = invalid_socket; in do_perform() local
62 o->peer_endpoint_ ? &o->addrlen_ : 0, o->ec_, new_socket) in do_perform()
64 o->new_socket_.reset(new_socket); in do_perform()
|
| D | win_iocp_socket_service.hpp | 472 socket_holder new_socket(socket_ops::sync_accept(impl.socket_, in accept() local
477 if (new_socket.get() != invalid_socket) in accept()
481 peer.assign(impl.protocol_, new_socket.get(), ec); in accept()
483 new_socket.release(); in accept()
508 start_accept_op(impl, peer.is_open(), p.p->new_socket(), in async_accept()
537 start_accept_op(impl, false, p.p->new_socket(), in async_move_accept()
|
| D | reactive_socket_service.hpp | 422 socket_holder new_socket(socket_ops::sync_accept(impl.socket_, in accept() local
427 if (new_socket.get() != invalid_socket) in accept()
431 peer.assign(impl.protocol_, new_socket.get(), ec); in accept()
433 new_socket.release(); in accept()
|
| D | win_iocp_socket_accept_op.hpp | 62 socket_holder& new_socket() in new_socket() function in boost::asio::detail::win_iocp_socket_accept_op
193 socket_holder& new_socket() in new_socket() function in boost::asio::detail::win_iocp_socket_move_accept_op
|
| D | socket_ops.hpp | 79 socket_type new_socket, boost::system::error_code& ec);
85 boost::system::error_code& ec, socket_type& new_socket);
|
| D | win_iocp_socket_service_base.hpp | 468 socket_holder& new_socket, int family, int type, int protocol,
510 bool peer_is_open, socket_holder& new_socket, int family, int type,
|
| /third_party/boost/libs/asio/include/boost/asio/detail/impl/ |
| D | win_iocp_socket_service_base.ipp | 519 bool peer_is_open, socket_holder& new_socket, int family, int type,
532 new_socket.reset(socket_ops::socket(family, type, protocol, ec));
533 if (new_socket.get() == invalid_socket)
538 BOOL result = ::AcceptEx(impl.socket_, new_socket.get(), output_buffer,
550 socket_type s, socket_holder& new_socket, int family, int type,
553 new_socket.reset();
557 new_socket.reset(socket_ops::socket(family, type, protocol, ec));
558 if (new_socket.get() == invalid_socket)
563 BOOL result = ::AcceptEx(s, new_socket.get(), output_buffer,
|
| /third_party/boost/boost/asio/detail/impl/ |
| D | win_iocp_socket_service_base.ipp | 519 bool peer_is_open, socket_holder& new_socket, int family, int type,
532 new_socket.reset(socket_ops::socket(family, type, protocol, ec));
533 if (new_socket.get() == invalid_socket)
538 BOOL result = ::AcceptEx(impl.socket_, new_socket.get(), output_buffer,
550 socket_type s, socket_holder& new_socket, int family, int type,
553 new_socket.reset();
557 new_socket.reset(socket_ops::socket(family, type, protocol, ec));
558 if (new_socket.get() == invalid_socket)
563 BOOL result = ::AcceptEx(s, new_socket.get(), output_buffer,
|
| D | socket_ops.ipp | 144 socket_type new_socket = socket_ops::accept(s, addr, addrlen, ec);
147 if (new_socket != invalid_socket)
148 return new_socket;
186 socket_type new_socket, boost::system::error_code& ec)
220 socket_ops::setsockopt(new_socket, state,
230 boost::system::error_code& ec, socket_type& new_socket)
235 new_socket = socket_ops::accept(s, addr, addrlen, ec);
238 if (new_socket != invalid_socket)
|
| /third_party/python/Lib/ |
| D | smtplib.py | 1056 new_socket = super()._get_socket(host, port, timeout)
1057 new_socket = self.context.wrap_socket(new_socket,
1059 return new_socket
|
| /third_party/libuv/src/unix/ |
| D | tcp.c | 31 static int new_socket(uv_tcp_t* handle, int domain, unsigned long flags) { in new_socket() function
110 return new_socket(handle, domain, flags); in maybe_new_socket()
|