| /external/sandboxed-api/sandboxed_api/sandbox2/network_proxy/ |
| D | server.cc | 73 int new_socket = socket(saddr->sa_family, SOCK_STREAM, 0); in ProcessConnectRequest() local
74 if (new_socket < 0) { in ProcessConnectRequest()
79 file_util::fileops::FDCloser new_socket_closer(new_socket); in ProcessConnectRequest()
82 new_socket, reinterpret_cast<const sockaddr*>(addr.data()), addr.size()); in ProcessConnectRequest()
90 if (!fatal_error_ && !comms_->SendFD(new_socket)) { in ProcessConnectRequest()
|
| /external/parameter-framework/asio-1.10.6/include/asio/detail/ |
| D | reactive_socket_accept_op.hpp | 51 socket_type new_socket = invalid_socket; in do_perform() local
54 o->peer_endpoint_ ? &addrlen : 0, o->ec_, new_socket); in do_perform()
57 if (new_socket != invalid_socket) in do_perform()
59 socket_holder new_socket_holder(new_socket); in do_perform()
62 if (!o->peer_.assign(o->protocol_, new_socket, o->ec_)) in do_perform()
|
| D | reactive_socket_service.hpp | 375 socket_holder new_socket(socket_ops::sync_accept(impl.socket_, in accept() local
380 if (new_socket.get() != invalid_socket) in accept()
384 if (!peer.assign(impl.protocol_, new_socket.get(), ec)) in accept()
385 new_socket.release(); in accept()
|
| /external/sdv/vsomeip/third_party/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()
|
| /external/cronet/stable/net/dns/ |
| D | mock_mdns_socket_factory.cc | 82 auto new_socket = in CreateSocket() local
86 ON_CALL(*new_socket, SendToInternal(_, _, _)) in CreateSocket()
91 ON_CALL(*new_socket, RecvFrom(_, _, _, _)) in CreateSocket()
94 sockets->push_back(std::move(new_socket)); in CreateSocket()
|
| /external/cronet/tot/net/dns/ |
| D | mock_mdns_socket_factory.cc | 82 auto new_socket = in CreateSocket() local
86 ON_CALL(*new_socket, SendToInternal(_, _, _)) in CreateSocket()
91 ON_CALL(*new_socket, RecvFrom(_, _, _, _)) in CreateSocket()
94 sockets->push_back(std::move(new_socket)); in CreateSocket()
|
| /external/grpc-grpc/test/core/event_engine/test_suite/posix/ |
| D | oracle_event_engine_posix.cc | 394 int new_socket; in Bind() local
405 if ((new_socket = socket(AF_INET6, SOCK_STREAM, 0)) <= 0) { in Bind()
411 if (setsockopt(new_socket, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt))) { in Bind()
415 if (setsockopt(new_socket, SOL_SOCKET, SO_REUSEPORT, &opt, sizeof(opt))) { in Bind()
421 if (bind(new_socket, reinterpret_cast<const struct sockaddr*>(addr.address()), in Bind()
427 if (listen(new_socket, 1) < 0) { in Bind()
431 listener_fds_.push_back(new_socket); in Bind()
|
| /external/rust/android-crates-io/crates/mio/src/sys/unix/uds/ |
| D | datagram.rs | 5 use crate::sys::unix::net::new_socket;
19 let fd = new_socket(libc::AF_UNIX, libc::SOCK_DGRAM)?; in unbound()
|
| D | stream.rs | 5 use crate::sys::unix::net::new_socket;
9 let fd = new_socket(libc::AF_UNIX, libc::SOCK_STREAM)?; in connect_addr()
|
| D | listener.rs | 9 use crate::sys::unix::net::new_socket;
13 let fd = new_socket(libc::AF_UNIX, libc::SOCK_STREAM)?; in bind_addr()
|
| /external/webrtc/rtc_base/ |
| D | async_tcp_socket.cc | 338 rtc::Socket* new_socket = socket->Accept(&address); in OnReadEvent() local
339 if (!new_socket) { in OnReadEvent()
346 HandleIncomingConnection(new_socket); in OnReadEvent()
349 new_socket->SignalReadEvent(new_socket); in OnReadEvent()
|
| /external/sdv/vsomeip/implementation/helper/1.66/boost/asio/detail/ |
| D | reactive_socket_service_ext_local.hpp | 395 socket_holder new_socket(socket_ops::sync_accept(impl.socket_, in accept() local
400 if (new_socket.get() != invalid_socket) in accept()
404 peer.assign(impl.protocol_, new_socket.get(), ec); in accept()
406 new_socket.release(); in accept()
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 | reactive_socket_service_ext.hpp | 397 socket_holder new_socket(socket_ops::sync_accept(impl.socket_, in accept() local
402 if (new_socket.get() != invalid_socket) in accept()
406 peer.assign(impl.protocol_, new_socket.get(), ec); in accept()
408 new_socket.release(); in accept()
424 socket_holder new_socket(socket_ops::sync_accept(impl.socket_, in accept() local
429 if (new_socket.get() != invalid_socket) in accept()
433 peer.assign(impl.protocol_, new_socket.get(), ec); in accept()
435 new_socket.release(); in accept()
|
| /external/sdv/vsomeip/third_party/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()
|
| /external/webrtc/p2p/base/ |
| D | async_stun_tcp_socket_unittest.cc | 112 rtc::AsyncPacketSocket* new_socket) { in OnNewConnection() argument
113 recv_socket_ = absl::WrapUnique(new_socket); in OnNewConnection()
114 new_socket->SignalReadPacket.connect(this, in OnNewConnection()
|
| D | tcp_port.cc | 283 rtc::AsyncPacketSocket* new_socket) { in OnNewConnection() argument
287 new_socket->SetOption(option.first, option.second); in OnNewConnection()
290 incoming.addr = new_socket->GetRemoteAddress(); in OnNewConnection()
291 incoming.socket = new_socket; in OnNewConnection()
|
| /external/sdv/vsomeip/third_party/boost/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()
|
| /external/rust/android-crates-io/crates/mio/src/sys/windows/ |
| D | net.rs | 30 new_socket(domain.into(), socket_type) in new_ip_socket()
33 pub(crate) fn new_socket(domain: u32, socket_type: i32) -> io::Result<SOCKET> { in new_socket() function
|
| /external/rust/android-crates-io/crates/mio/src/sys/unix/ |
| D | tcp.rs | 12 use crate::sys::unix::net::{new_socket, socket_addr, to_socket_addr};
19 new_socket(domain, libc::SOCK_STREAM) in new_for_addr()
|
| D | net.rs | 11 new_socket(domain, socket_type) in new_ip_socket()
15 pub(crate) fn new_socket(domain: libc::c_int, socket_type: libc::c_int) -> io::Result<libc::c_int> { in new_socket() function
|
| /external/sdv/vsomeip/third_party/boost/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,
|
| /external/sdv/vsomeip/implementation/helper/1.55/boost/asio/detail/ |
| D | reactive_socket_service_ext_local.hpp | 383 socket_holder new_socket(socket_ops::sync_accept(impl.socket_, in accept() local
388 if (new_socket.get() != invalid_socket) in accept()
392 if (!peer.assign(impl.protocol_, new_socket.get(), ec)) in accept()
393 new_socket.release(); in accept()
|
| D | reactive_socket_service_ext.hpp | 383 socket_holder new_socket(socket_ops::sync_accept(impl.socket_, in accept() local
388 if (new_socket.get() != invalid_socket) in accept()
392 if (!peer.assign(impl.protocol_, new_socket.get(), ec)) in accept()
393 new_socket.release(); in accept()
|
| /external/rust/android-crates-io/crates/vsock/src/ |
| D | lib.rs | 48 fn new_socket() -> Result<OwnedFd> { in new_socket() function
86 let socket = new_socket()?; in bind()
215 let socket = new_socket()?; in connect()
|