| /external/tensorflow/tensorflow/contrib/ignite/kernels/client/ |
| ignite_plain_client_windows.cc | 37 sock_(INVALID_SOCKET) {}
65 sock_ = socket(ptr->ai_family, ptr->ai_socktype, ptr->ai_protocol);
66 if (sock_ == INVALID_SOCKET) {
71 res = connect(sock_, ptr->ai_addr, (int)ptr->ai_addrlen);
73 closesocket(sock_);
74 sock_ = INVALID_SOCKET;
81 if (sock_ == INVALID_SOCKET) {
92 int res = shutdown(sock_, SD_SEND);
93 closesocket(sock_);
102 bool PlainClient::IsConnected() { return sock_ != INVALID_SOCKET;
[all...] |
| ignite_plain_client_unix.cc | 32 : Client(big_endian), host_(std::move(host)), port_(port), sock_(-1) {}
42 if (sock_ == -1) {
43 sock_ = socket(AF_INET, SOCK_STREAM, 0);
44 if (sock_ == -1) return errors::Internal("Failed to create socket");
64 if (connect(sock_, (sockaddr*)&server, sizeof(server)) < 0)
73 int close_res = close(sock_);
74 sock_ = -1;
83 bool PlainClient::IsConnected() { return sock_ != -1; }
85 int PlainClient::GetSocketDescriptor() { return sock_; }
91 int res = recv(sock_, buf, length - received, 0)
[all...] |
| ignite_plain_client.h | 38 int sock_; member in class:tensorflow::PlainClient
|
| /external/perfetto/src/ipc/ |
| host_impl.h | 52 const base::UnixSocket* sock() const { return sock_.get(); }
88 std::unique_ptr<base::UnixSocket> sock_; // The listening socket. member in class:perfetto::ipc::HostImpl
|
| client_impl.cc | 47 sock_ = base::UnixSocket::Connect(socket_name, this, task_runner);
60 if (!sock_->is_connected()) {
125 bool res = sock_->Send(buf.data(), buf.size(), fd,
127 PERFETTO_CHECK(res || !sock_->is_connected());
161 rsize = sock_->Receive(buf.data, buf.size, &fd);
170 return sock_->Shutdown(true); // In turn will trigger an OnDisconnect().
|
| client_impl.h | 85 std::unique_ptr<base::UnixSocket> sock_; member in class:perfetto::ipc::ClientImpl
|
| host_impl_unittest.cc | 92 sock_ = base::UnixSocket::Connect(kSockName, this, task_runner);
131 ASSERT_EQ(sock_.get(), sock);
156 ASSERT_TRUE(sock_->Send(buf.data(), buf.size(), fd,
161 std::unique_ptr<base::UnixSocket> sock_; member in class:perfetto::ipc::__anon35826::FakeClient
|
| host_impl.cc | 59 sock_ = base::UnixSocket::Listen(std::move(socket_fd), this, task_runner_);
66 sock_ = base::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/perfetto/src/profiling/memory/ |
| client.h | 110 base::UnixSocketRaw sock_; member in class:perfetto::profiling::Client
|
| client.cc | 225 sock_(std::move(sock)),
358 PERFETTO_DCHECK(!sock_.IsBlocking());
360 ssize_t recv_bytes = sock_.Receive(buf, sizeof(buf), nullptr, 0);
373 if (sock_.Send(kSingleByte, sizeof(kSingleByte)) == -1 &&
|
| /external/boringssl/src/tool/ |
| transport_common.cc | 377 explicit SocketWaiter(int sock) : sock_(sock) {}
397 FD_SET(sock_, &write_fds);
401 FD_SET(sock_, &read_fds);
402 if (select(sock_ + 1, &read_fds, &write_fds, NULL, NULL) <= 0) {
407 if (FD_ISSET(STDIN_FILENO, &read_fds) || FD_ISSET(sock_, &write_fds)) {
410 if (FD_ISSET(sock_, &read_fds)) {
439 int sock_; member in class:SocketWaiter
489 explicit SocketWaiter(int sock) : sock_(sock) {}
545 WSAEventSelect(sock_, sock_read_event.get(), FD_READ | FD_CLOSE) != 0) {
555 if (!sock_write_event || WSAEventSelect(sock_, sock_write_event.get()
637 int sock_; member in class:SocketWaiter
860 const int sock_; member in class:SocketLineReader
[all...] |
| /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/ssl/test/ |
| bssl_shim.cc | 154 explicit SocketCloser(int sock) : sock_(sock) {}
160 shutdown(sock_, SD_SEND);
162 shutdown(sock_, SHUT_WR);
166 if (recv(sock_, buf, sizeof(buf), 0) <= 0) {
170 closesocket(sock_);
174 const int sock_; member in class:SocketCloser
[all...] |
| /external/stressapptest/src/ |
| worker.cc | 268 sock_ = 0;
[all...] |
| worker.h | 511 int sock_; member in class:NetworkThread
|
