/system/core/fastboot/ |
D | tcp.cpp | 69 explicit TcpTransport(std::unique_ptr<Socket> sock) : socket_(std::move(sock)) {} in TcpTransport() 75 std::unique_ptr<Socket> socket_; member in tcp::TcpTransport 96 if (!socket_->Send(handshake_message.c_str(), kHandshakeLength)) { in InitializeProtocol() 104 if (socket_->ReceiveAll(buffer, kHandshakeLength, kHandshakeTimeoutMs) != kHandshakeLength) { in InitializeProtocol() 128 if (socket_ == nullptr) { in Read() 135 if (socket_->ReceiveAll(buffer, 8, 0) != 8) { in Read() 146 ssize_t bytes_read = socket_->ReceiveAll(data, length, 0); in Read() 156 if (socket_ == nullptr) { in Write() 163 if (!socket_->Send(std::vector<cutils_socket_buffer_t>{{header, 8}, {data, length}})) { in Write() 172 if (socket_ == nullptr) { in Close() [all …]
|
D | udp.cpp | 114 explicit UdpTransport(std::unique_ptr<Socket> socket) : socket_(std::move(socket)) {} in UdpTransport() 133 std::unique_ptr<Socket> socket_; member in udp::UdpTransport 208 if (socket_ == nullptr) { in SendData() 260 if (!socket_->Send({{header->bytes(), kHeaderSize}, {tx_data, tx_length}})) { in SendSinglePacketHelper() 268 bytes = socket_->Receive(rx_packet_.data(), rx_packet_.size(), kResponseTimeoutMs); in SendSinglePacketHelper() 270 if (socket_->ReceiveTimedOut()) { in SendSinglePacketHelper() 281 if (socket_->ReceiveTimedOut()) { in SendSinglePacketHelper() 364 if (socket_ == nullptr) { in Close() 368 int result = socket_->Close(); in Close() 369 socket_.reset(); in Close()
|
/system/bt/service/ipc/ |
D | ipc_handler_linux.cc | 69 socket_.reset(server_fd); in Run() 96 socket_.swap(server_socket); in Run() 100 CHECK(socket_.is_valid()); in Run() 124 shutdown(socket_.get(), SHUT_RDWR); in Stop() 125 socket_.reset(); in Stop() 136 CHECK(socket_.is_valid()); in StartListeningOnThread() 142 int status = listen(socket_.get(), SOMAXCONN); in StartListeningOnThread() 159 int client_socket = accept4(socket_.get(), nullptr, nullptr, SOCK_NONBLOCK); in StartListeningOnThread()
|
D | ipc_handler_linux.h | 70 base::ScopedFD socket_; variable
|
/system/netd/tests/dns_responder/ |
D | dns_tls_frontend.h | 58 return socket_ != -1; in running() 77 int socket_ = -1; variable
|
D | dns_tls_frontend.cpp | 230 socket_ = s; in startServer() 264 struct pollfd fds[1] = {{ .fd = socket_, .events = POLLIN }}; in requestHandler() 280 int client = accept(socket_, reinterpret_cast<sockaddr*>(&addr), &len); in requestHandler() 367 close(socket_); in stopServer() 370 socket_ = -1; in stopServer()
|
D | dns_responder.cpp | 535 socket_(-1), epoll_fd_(-1), terminate_(false) { } in DNSResponder() 573 return socket_ != -1; in running() 644 socket_ = s; in startServer() 667 close(socket_); in stopServer() 669 socket_ = -1; in stopServer() 699 len = recvfrom(socket_, buffer, sizeof(buffer), 0, in requestHandler() 711 len = sendto(socket_, response, response_len, 0, in requestHandler()
|
D | dns_responder.h | 130 int socket_; variable
|
/system/core/init/ |
D | subcontext.cpp | 228 if (!Socketpair(AF_UNIX, SOCK_SEQPACKET | SOCK_CLOEXEC, 0, &socket_, &subcontext_socket)) { in Fork() 238 socket_.reset(); in Fork() 271 socket_.reset(); in Restart() 276 if (auto result = SendMessage(socket_, subcontext_command); !result) { in TransmitMessage() 281 auto subcontext_message = ReadMessage(socket_); in TransmitMessage()
|
D | property_service.cpp | 272 SocketConnection(int socket, const ucred& cred) : socket_(socket), cred_(cred) {} in SocketConnection() 274 ~SocketConnection() { close(socket_); } in ~SocketConnection() 312 int result = TEMP_FAILURE_RETRY(send(socket_, &value, sizeof(value), 0)); in SendUint32() 316 int socket() { return socket_; } in socket() 322 getpeercon(socket_, &source_context); in source_context() 331 ufds[0].fd = socket_; in PollIn() 378 int result = TEMP_FAILURE_RETRY(recv(socket_, data, bytes_left, MSG_DONTWAIT)); in RecvFully() 390 int socket_; member in android::init::SocketConnection
|
D | subcontext.h | 60 android::base::unique_fd socket_; variable
|