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