Home
last modified time | relevance | path

Searched refs:sock_ (Results 1 – 19 of 19) sorted by relevance

/external/webrtc/media/sctp/
Dsctp_transport.cc483 RTC_DCHECK(!sock_); in SetDtlsTransport()
524 RTC_DCHECK(!sock_); in Start()
626 if (!sock_) { in SendMessageInternal()
658 sock_, message->data(), message->size(), NULL, 0, &spa, in SendMessageInternal()
713 RTC_DCHECK(!sock_); in Connect()
714 if (sock_) { in Connect()
730 if (usrsctp_bind(sock_, reinterpret_cast<sockaddr*>(&local_sconn), in Connect()
741 sock_, reinterpret_cast<sockaddr*>(&remote_sconn), sizeof(remote_sconn)); in Connect()
758 if (usrsctp_setsockopt(sock_, IPPROTO_SCTP, SCTP_PEER_ADDR_PARAMS, &params, in Connect()
772 if (sock_) { in OpenSctpSocket()
[all …]
Dsctp_transport.h220 struct socket* sock_ = nullptr; // The socket created by usrsctp_socket(...). variable
/external/rust/crates/quiche/deps/boringssl/src/tool/
Dtransport_common.cc381 explicit SocketWaiter(int sock) : sock_(sock) {} in SocketWaiter()
401 FD_SET(sock_, &write_fds); in Wait()
405 FD_SET(sock_, &read_fds); in Wait()
406 if (select(sock_ + 1, &read_fds, &write_fds, NULL, NULL) <= 0) { in Wait()
411 if (FD_ISSET(STDIN_FILENO, &read_fds) || FD_ISSET(sock_, &write_fds)) { in Wait()
414 if (FD_ISSET(sock_, &read_fds)) { in Wait()
443 int sock_; member in SocketWaiter
493 explicit SocketWaiter(int sock) : sock_(sock) {} in SocketWaiter()
549 WSAEventSelect(sock_, sock_read_event.get(), FD_READ | FD_CLOSE) != 0) { in Wait()
559 if (!sock_write_event || WSAEventSelect(sock_, sock_write_event.get(), in Wait()
[all …]
/external/perfetto/src/ipc/
Dclient_impl.cc60 sock_ = base::UnixSocket::AdoptConnected( in ClientImpl()
78 sock_ = base::UnixSocket::Connect(socket_name_, this, task_runner_, in TryConnect()
86 if (!sock_->is_connected()) { in BindService()
149 bool res = sock_->Send(buf.data(), buf.size(), fd); in SendFrame()
150 PERFETTO_CHECK(res || !sock_->is_connected()); in SendFrame()
203 rsize = sock_->Receive(buf.data, buf.size, &fd); in OnDataAvailable()
216 return sock_->Shutdown(true); // In turn will trigger an OnDisconnect(). in OnDataAvailable()
Dclient_impl.h70 base::UnixSocket* GetUnixSocketForTesting() { return sock_.get(); } in GetUnixSocketForTesting()
98 std::unique_ptr<base::UnixSocket> sock_; variable
Dhost_impl.h50 const base::UnixSocket* sock() const { return sock_.get(); } in sock()
86 std::unique_ptr<base::UnixSocket> sock_; // The listening socket. variable
Dhost_impl.cc76 sock_ = base::UnixSocket::Listen(std::move(socket_fd), this, task_runner_, in HostImpl()
83 sock_ = base::UnixSocket::Listen(socket_name, this, task_runner_, in HostImpl()
85 if (!sock_) { in HostImpl()
Dhost_impl_unittest.cc93 sock_ = base::UnixSocket::Connect(kTestSocket.name(), this, task_runner, in FakeClient()
134 ASSERT_EQ(sock_.get(), sock); in OnDataAvailable()
159 ASSERT_TRUE(sock_->Send(buf.data(), buf.size(), fd)); in SendFrame()
163 std::unique_ptr<base::UnixSocket> sock_; member in perfetto::ipc::__anon3cf0bd540111::FakeClient
/external/boringssl/src/tool/
Dtransport_common.cc386 explicit SocketWaiter(int sock) : sock_(sock) {} in SocketWaiter()
406 FD_SET(sock_, &write_fds); in Wait()
410 FD_SET(sock_, &read_fds); in Wait()
411 if (select(sock_ + 1, &read_fds, &write_fds, NULL, NULL) <= 0) { in Wait()
416 if (FD_ISSET(STDIN_FILENO, &read_fds) || FD_ISSET(sock_, &write_fds)) { in Wait()
419 if (FD_ISSET(sock_, &read_fds)) { in Wait()
448 int sock_; member in SocketWaiter
498 explicit SocketWaiter(int sock) : sock_(sock) {} in SocketWaiter()
554 WSAEventSelect(sock_, sock_read_event.get(), FD_READ | FD_CLOSE) != 0) { in Wait()
564 if (!sock_write_event || WSAEventSelect(sock_, sock_write_event.get(), in Wait()
[all …]
/external/perfetto/src/profiling/memory/
Dclient.cc260 sock_(std::move(sock)), in Client()
274 int fd = sock_.ReleaseFd().release(); in ~Client()
477 sock_.DcheckIsBlocking(false); in IsConnected()
479 ssize_t recv_bytes = sock_.Receive(buf, sizeof(buf), nullptr, 0); in IsConnected()
494 if (sock_.Send(kSingleByte, sizeof(kSingleByte)) == -1 && in SendControlSocketByte()
Dclient.h128 base::UnixSocketRaw sock_; variable
/external/rust/crates/quiche/deps/boringssl/src/crypto/bio/
Dbio_test.cc58 explicit ScopedSocket(int sock) : sock_(sock) {} in ScopedSocket()
60 closesocket(sock_); in ~ScopedSocket()
64 const int sock_; member in ScopedSocket
/external/boringssl/src/crypto/bio/
Dbio_test.cc58 explicit ScopedSocket(int sock) : sock_(sock) {} in ScopedSocket()
60 closesocket(sock_); in ~ScopedSocket()
64 const int sock_; member in ScopedSocket
/external/rust/crates/quiche/deps/boringssl/src/ssl/test/
Dbssl_shim.cc154 explicit SocketCloser(int sock) : sock_(sock) {} in SocketCloser()
160 shutdown(sock_, SD_SEND); in ~SocketCloser()
162 shutdown(sock_, SHUT_WR); in ~SocketCloser()
166 if (recv(sock_, buf, sizeof(buf), 0) <= 0) { in ~SocketCloser()
170 closesocket(sock_); in ~SocketCloser()
174 const int sock_; member in SocketCloser
/external/boringssl/src/ssl/test/
Dbssl_shim.cc154 explicit SocketCloser(int sock) : sock_(sock) {} in SocketCloser()
160 shutdown(sock_, SD_SEND); in ~SocketCloser()
162 shutdown(sock_, SHUT_WR); in ~SocketCloser()
166 if (recv(sock_, buf, sizeof(buf), 0) <= 0) { in ~SocketCloser()
170 closesocket(sock_); in ~SocketCloser()
174 const int sock_; member in SocketCloser
/external/stressapptest/src/
Dworker.cc268 sock_ = 0; in NetworkThread()
2063 if (-1 == ::bind(sock_, (struct sockaddr*)&sa, sizeof(struct sockaddr))) { in Listen()
2071 listen(sock_, 3); in Listen()
2083 FD_SET(sock_, &rfds); in Wait()
2088 retval = select(sock_ + 1, &rfds, NULL, NULL, &tv); in Wait()
2098 int newsock = accept(sock_, reinterpret_cast<struct sockaddr *>(&sa), &size); in GetConnection()
2312 sock_ = 0; in Work()
2313 if (!CreateSocket(&sock_)) { in Work()
2349 CloseSocket(sock_); in Work()
2361 sock_ = sock; in SetSock()
[all …]
Dworker.h511 int sock_; variable
/external/python/cpython3/Misc/NEWS.d/
D3.9.0b2.rst225 Fix asyncio ``loop.sock_*`` race condition issue
D3.8.0a1.rst2492 Use add_done_callback() in sock_* asyncio API to unsubscribe reader/writer