Lines Matching refs:socket_
70 explicit TcpTransport(std::unique_ptr<Socket> sock) : socket_(std::move(sock)) {} in TcpTransport()
76 std::unique_ptr<Socket> socket_; member in tcp::TcpTransport
97 if (!socket_->Send(handshake_message.c_str(), kHandshakeLength)) { in InitializeProtocol()
105 if (socket_->ReceiveAll(buffer, kHandshakeLength, kHandshakeTimeoutMs) != kHandshakeLength) { in InitializeProtocol()
129 if (socket_ == nullptr) { in Read()
136 if (socket_->ReceiveAll(buffer, 8, 0) != 8) { in Read()
147 ssize_t bytes_read = socket_->ReceiveAll(data, length, 0); in Read()
157 if (socket_ == nullptr) { in Write()
164 if (!socket_->Send(std::vector<cutils_socket_buffer_t>{{header, 8}, {data, length}})) { in Write()
173 if (socket_ == nullptr) { in Close()
177 int result = socket_->Close(); in Close()
178 socket_.reset(); in Close()