| /system/connectivity/shill/ |
| H A D | async_connection.cc | 27 #include "shill/net/sockets.h"
38 Sockets* sockets,
42 sockets_(sockets),
36 AsyncConnection(const string& interface_name, EventDispatcher* dispatcher, Sockets* sockets, const Callback<void(bool, int)>& callback) argument
|
| H A D | async_connection_unittest.cc | 67 EXPECT_CALL(sockets(), Close(kSocketFD))
107 EXPECT_CALL(sockets(), Connect(kSocketFD, _, _))
121 StrictMock<MockSockets>& sockets() { return sockets_; } function in class:shill::AsyncConnectionTest
146 EXPECT_CALL(sockets(), Socket(_, _, _))
148 EXPECT_CALL(sockets(), Error())
156 EXPECT_CALL(sockets(), Socket(_, _, _))
158 EXPECT_CALL(sockets(), SetNonBlocking(kSocketFD))
160 EXPECT_CALL(sockets(), Error())
162 EXPECT_CALL(sockets(), Close(kSocketFD))
170 EXPECT_CALL(sockets(), Socke
[all...] |
| H A D | device_info.h | 299 void set_sockets(Sockets* sockets) { sockets_.reset(sockets); } argument
|
| H A D | dns_client.cc | 311 ares_socket_t sockets[ARES_GETSOCK_MAXNUM]; local
312 int action_bits = ares_->GetSock(resolver_state_->channel, sockets,
321 if (ContainsKey(old_read, sockets[i])) {
322 resolver_state_->read_handlers[sockets[i]] = old_read[sockets[i]];
324 resolver_state_->read_handlers[sockets[i]] =
326 dispatcher_->CreateReadyHandler(sockets[i],
332 if (ContainsKey(old_write, sockets[i])) {
333 resolver_state_->write_handlers[sockets[i]] = old_write[sockets[
[all...] |
| H A D | http_proxy.cc | 40 #include "shill/net/sockets.h"
105 Sockets* sockets) {
113 proxy_socket_ = sockets->Socket(PF_INET, SOCK_STREAM, 0);
124 if (sockets->Bind(proxy_socket_,
127 sockets->GetSockName(proxy_socket_,
130 sockets->SetNonBlocking(proxy_socket_) < 0 ||
131 sockets->Listen(proxy_socket_, kMaxClientQueue) < 0) {
132 sockets->Close(proxy_socket_);
150 new AsyncConnection(connection_->interface_name(), dispatcher, sockets,
152 sockets_ = sockets;
104 Start(EventDispatcher* dispatcher, Sockets* sockets) argument
[all...] |
| H A D | http_proxy_unittest.cc | 184 MockSockets& sockets() { return sockets_; } function in class:shill::HTTPProxyTest
218 EXPECT_CALL(sockets(), Socket(_, _, _))
220 EXPECT_CALL(sockets(), Bind(kProxyFD, _, _))
222 EXPECT_CALL(sockets(), GetSockName(kProxyFD, _, _))
224 EXPECT_CALL(sockets(), SetNonBlocking(kProxyFD))
226 EXPECT_CALL(sockets(), Listen(kProxyFD, _))
248 EXPECT_CALL(sockets(), Accept(kProxyFD, _, _))
250 EXPECT_CALL(sockets(), SetNonBlocking(fd))
350 EXPECT_CALL(sockets(), Close(kClientFD))
352 EXPECT_CALL(sockets(), Clos
[all...] |
| H A D | http_request.cc | 33 #include "shill/net/sockets.h"
58 Sockets* sockets)
61 sockets_(sockets),
82 dispatcher_, sockets,
56 HTTPRequest(ConnectionRefPtr connection, EventDispatcher* dispatcher, Sockets* sockets) argument
|
| H A D | http_request_unittest.cc | 159 MockSockets& sockets() { return sockets_; } function in class:shill::HTTPRequestTest
187 EXPECT_CALL(sockets(), Close(kServerFD))
444 EXPECT_CALL(sockets(), Send(kServerFD, _, request_data.GetLength(), 0))
448 EXPECT_CALL(sockets(), Send(kServerFD, _, 1, 0))
457 EXPECT_CALL(sockets(), Send(kServerFD, _, request_data.GetLength(), 0))
469 EXPECT_CALL(sockets(), Send(kServerFD, _, request_data.GetLength(), 0))
|
| /system/connectivity/shill/net/ |
| H A D | netlink_socket.h | 56 // for documentation on how netlink sockets work (note that most of the rest of
87 virtual const Sockets* sockets() const { return sockets_.get(); } function in class:shill::NetlinkSocket
|
| H A D | sockets.cc | 17 #include "shill/net/sockets.h"
173 ScopedSocketCloser::ScopedSocketCloser(Sockets* sockets, int fd) argument
174 : sockets_(sockets),
|
| /system/connectivity/shill/vpn/ |
| H A D | openvpn_management_server.cc | 37 #include "shill/net/sockets.h"
78 Sockets* sockets,
85 int socket = sockets->Socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
96 if (sockets->Bind(
98 sockets->Listen(socket, 1) < 0 ||
99 sockets->GetSockName(
102 sockets->Close(socket);
107 sockets_ = sockets;
77 Start(EventDispatcher* dispatcher, Sockets* sockets, vector<vector<string>>* options) argument
|
| /system/core/adb/ |
| H A D | shell_service.cpp | 140 int sockets[2]; local
141 if (adb_socketpair(sockets) < 0) {
145 fd1->Reset(sockets[0]);
146 fd2->Reset(sockets[1]);
|
| H A D | sysdeps_test.cpp | 222 std::vector<int> sockets; local
224 sockets.resize(num_sockets * 2);
226 ASSERT_EQ(0, adb_socketpair(&sockets[i * 2])) << strerror(errno);
227 ASSERT_TRUE(WriteFdExactly(sockets[i * 2], &i, sizeof(i)));
230 pfd.fd = sockets[i * 2 + 1];
243 for (int fd : sockets) {
|
| H A D | sysdeps_win32.cpp | 34 #include <cutils/sockets.h>
636 // non-blocking sockets can cause an error code of WSAEWOULDBLOCK and
667 std::vector<WSAPOLLFD> sockets; local
680 sockets.push_back(wsapollfd);
685 if (sockets.empty()) {
689 int result = WSAPoll(sockets.data(), sockets.size(), timeout);
696 for (size_t i = 0; i < sockets.size(); ++i) {
697 original[i]->revents = sockets[i].revents;
|