| /system/connectivity/shill/ |
| H A D | eap_listener.cc | 41 socket_(-1) {}
54 socket_,
64 socket_ = -1;
74 socket_ = socket;
75 socket_closer_.reset(new ScopedSocketCloser(sockets_.get(), socket_));
77 if (sockets_->SetNonBlocking(socket_) != 0) {
88 if (sockets_->Bind(socket_,
107 socket_, &payload, sizeof(payload), 0,
|
| H A D | icmp.cc | 31 socket_(-1) {}
42 socket_ = socket;
43 socket_closer_.reset(new ScopedSocketCloser(sockets_.get(), socket_));
45 if (sockets_->SetNonBlocking(socket_) != 0) {
56 socket_ = -1;
96 socket_,
|
| H A D | arp_client.cc | 42 socket_(-1) {}
74 socket_ = socket;
75 socket_closer_.reset(new ScopedSocketCloser(sockets_.get(), socket_));
91 if (sockets_->AttachFilter(socket_, &pf) != 0) {
96 if (sockets_->SetNonBlocking(socket_) != 0) {
107 if (sockets_->Bind(socket_,
123 socket_,
176 socket_,
|
| H A D | arp_client.h | 60 virtual int socket() const { return socket_; }
80 int socket_; member in class:shill::ArpClient
|
| H A D | icmp.h | 59 int socket() { return socket_; }
70 int socket_; member in class:shill::Icmp
|
| H A D | connection_health_checker_unittest.cc | 87 socket_(nullptr) {}
146 socket_ = new StrictMock<MockSockets>();
150 health_checker_->socket_.reset(socket_);
162 return health_checker_->socket_.get();
245 EXPECT_EQ(socket_, health_checker_->socket_.get());
246 EXPECT_FALSE(socket_ == nullptr);
262 EXPECT_CALL(*socket_, GetSockName(kProxyFD, _, _))
283 EXPECT_CALL(*socket_, Clos
320 StrictMock<MockSockets>* socket_; member in class:shill::ConnectionHealthCheckerTest
[all...] |
| H A D | eap_listener.h | 61 // Creates |socket_|. Returns true on succes, false on failure.
64 // Retrieves an EAP packet from |socket_|. This is the callback method
81 int socket_; member in class:shill::EapListener
83 // Scoped socket closer for the receive |socket_|.
86 // Input handler for |socket_|. Calls ReceiveRequest().
|
| H A D | connection_health_checker.cc | 92 socket_(new Sockets()),
99 socket_.get(),
214 socket_.get(),
328 if (socket_->Send(sock_fd_, &buf, sizeof(buf), 0) == -1) {
329 SLOG(connection_.get(), 2) << __func__ << ": " << socket_->ErrorString();
390 if (socket_->GetSockName(sock_fd,
463 socket_->Close(sock_fd_);
|
| H A D | eap_listener_unittest.cc | 76 int GetSocket() { return listener_.socket_; }
131 EXPECT_EQ(fd, listener_.socket_);
|
| H A D | icmp_unittest.cc | 76 int GetSocket() { return icmp_.socket_; }
84 EXPECT_EQ(fd, icmp_.socket_);
|
| H A D | connection_health_checker.h | 199 std::unique_ptr<Sockets> socket_; member in class:shill::ConnectionHealthChecker
|
| H A D | arp_client_unittest.cc | 77 int GetSocket() { return client_.socket_; }
147 EXPECT_EQ(fd, client_.socket_);
|
| /system/core/fastboot/ |
| H A D | tcp.cpp | 69 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 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.cpp | 71 socket_.reset(server_fd);
98 socket_.swap(server_socket);
102 CHECK(socket_.is_valid());
127 shutdown(socket_.get(), SHUT_RDWR);
128 socket_.reset();
139 CHECK(socket_.is_valid());
145 int status = listen(socket_.get(), SOMAXCONN);
163 int client_socket = accept4(socket_.get(), nullptr, nullptr, SOCK_NONBLOCK);
|
| H A D | ipc_handler_linux.h | 67 base::ScopedFD socket_; member in class:ipc::IPCHandlerLinux
69 // The file path to |socket_|. This is only set if we create and manage the
|
| /system/connectivity/dhcp_client/ |
| H A D | dhcpv4.cc | 90 socket_(kInvalidSocketDescriptor),
152 socket_,
160 if (socket_ != kInvalidSocketDescriptor) {
161 sockets_->Close(socket_);
209 socket_ = socket_closer.Release();
299 size_t result = sockets_->SendTo(socket_,
|
| H A D | dhcpv4.h | 94 int socket_; member in class:dhcp_client::DHCPV4
|
| /system/connectivity/shill/vpn/ |
| H A D | openvpn_management_server.cc | 67 socket_(-1),
108 socket_ = socket;
145 if (socket_ >= 0) {
146 sockets_->Close(socket_);
147 socket_ = -1;
|
| H A D | openvpn_management_server.h | 154 int socket_; member in class:shill::OpenVPNManagementServer
|
| H A D | openvpn_management_server_unittest.cc | 215 EXPECT_EQ(kSocket, server_.socket_);
238 server_.socket_ = kSocket;
246 EXPECT_EQ(-1, server_.socket_);
|
| /system/netd/tests/ |
| H A D | dns_responder.h | 126 int socket_; member in class:test::DNSResponder
|
| H A D | dns_responder.cpp | 525 socket_(-1), epoll_fd_(-1), terminate_(false) { }
563 return socket_ != -1;
634 socket_ = s;
657 close(socket_);
659 socket_ = -1;
689 len = recvfrom(socket_, buffer, sizeof(buffer), 0,
701 len = sendto(socket_, response, response_len, 0,
|