| /device/google/cuttlefish_common/common/commands/wifi_relay/ |
| nl_client.cpp | 25 sock_(nullptr, [](nl_sock* sock) { free(sock); }) {}
44 sock_.reset(nl_socket_alloc_cb(callback_.get()));
45 if (!sock_) {
50 if (nl_connect(sock_.get(), nl_type_) < 0) {
63 nl_send_auto(sock_.get(), msg->Msg());
93 nl_sock* NlClient::Sock() const { return sock_.get(); }
|
| nl_client.h | 57 std::unique_ptr<nl_sock, void (*)(nl_sock*)> sock_; member in class:cvd::NlClient
|
| /system/core/fastboot/ |
| socket.cpp | 34 Socket::Socket(cutils_socket_t sock) : sock_(sock) {}
43 if (sock_ != INVALID_SOCKET) {
44 ret = socket_close(sock_);
45 sock_ = INVALID_SOCKET;
70 return socket_get_local_port(sock_);
87 if (sock_ == INVALID_SOCKET) {
93 FD_SET(sock_, &read_set);
99 int result = TEMP_FAILURE_RETRY(select(sock_ + 1, &read_set, nullptr, nullptr, &timeout));
136 return TEMP_FAILURE_RETRY(sendto(sock_, reinterpret_cast<const char*>(data), length, 0,
148 sock_, buffers.data(), buffers.size())) == static_cast<ssize_t>(total_length)
[all...] |
| socket.h | 109 // Blocks up to |timeout_ms| until a read is possible on |sock_|, and sets |receive_timed_out_|
111 // a subsequent recv() on |sock_| will complete without blocking or if |timeout_ms| <= 0.
114 cutils_socket_t sock_ = INVALID_SOCKET; member in class:Socket
|
| /external/perfetto/src/ipc/ |
| host_impl.h | 52 const UnixSocket* sock() const { return sock_.get(); }
88 std::unique_ptr<UnixSocket> sock_; // The listening socket. member in class:perfetto::ipc::HostImpl
|
| client_impl.cc | 47 sock_ = UnixSocket::Connect(socket_name, this, task_runner);
59 if (!sock_->is_connected())
122 bool res = sock_->Send(buf.data(), buf.size(), fd,
124 PERFETTO_CHECK(res || !sock_->is_connected());
158 rsize = sock_->Receive(buf.data, buf.size, &fd);
167 return sock_->Shutdown(true); // In turn will trigger an OnDisconnect().
|
| client_impl.h | 85 std::unique_ptr<UnixSocket> sock_; member in class:perfetto::ipc::ClientImpl
|
| host_impl_unittest.cc | 91 sock_ = UnixSocket::Connect(kSockName, this, task_runner);
130 ASSERT_EQ(sock_.get(), sock);
155 ASSERT_TRUE(sock_->Send(buf.data(), buf.size(), fd));
159 std::unique_ptr<UnixSocket> sock_; member in class:perfetto::ipc::__anon31999::FakeClient
|
| host_impl.cc | 59 sock_ = UnixSocket::Listen(std::move(socket_fd), this, task_runner_);
66 sock_ = UnixSocket::Listen(socket_name, this, task_runner_);
|
| /external/webrtc/talk/media/sctp/ |
| sctpdataengine.cc | 370 sock_(NULL),
398 if (sock_) {
409 sock_ = usrsctp_socket(AF_CONN, SOCK_STREAM, IPPROTO_SCTP,
413 if (!sock_) {
420 if (usrsctp_set_non_blocking(sock_, 1) < 0) {
431 if (usrsctp_setsockopt(sock_, SOL_SOCKET, SO_LINGER, &linger_opt,
441 if (usrsctp_setsockopt(sock_, IPPROTO_SCTP, SCTP_ENABLE_STREAM_RESET,
450 if (usrsctp_setsockopt(sock_, IPPROTO_SCTP, SCTP_NODELAY, &nodelay,
461 if (usrsctp_setsockopt(sock_, IPPROTO_SCTP, SCTP_PEER_ADDR_PARAMS, ¶ms,
479 if (usrsctp_setsockopt(sock_, IPPROTO_SCTP, SCTP_EVENT, &event
[all...] |
| sctpdataengine.h | 186 const struct socket* socket() const { return sock_; }
201 // Sets sending_ to false and sock_ to NULL.
232 struct socket* sock_; // The socket created by usrsctp_socket(...). member in class:cricket::SctpDataMediaChannel
|
| /external/boringssl/src/crypto/bio/ |
| bio_test.cc | 58 explicit ScopedSocket(int sock) : sock_(sock) {}
60 closesocket(sock_);
64 const int sock_; member in class:ScopedSocket
|
| /external/boringssl/src/tool/ |
| transport_common.cc | 478 explicit SocketLineReader(int sock) : sock_(sock) {}
509 n = recv(sock_, &buf_[buf_len_], sizeof(buf_) - buf_len_, 0);
581 const int sock_; member in class:SocketLineReader
|
| /external/stressapptest/src/ |
| worker.cc | 268 sock_ = 0;
[all...] |
| worker.h | 511 int sock_; member in class:NetworkThread
|
| /external/boringssl/src/ssl/test/ |
| bssl_shim.cc | 1177 const int sock_; member in class:SocketCloser
[all...] |
