Lines Matching refs:socket_
69 explicit TcpTransport(std::unique_ptr<Socket> sock) : socket_(std::move(sock)) {} in TcpTransport()
75 std::unique_ptr<Socket> socket_; member in tcp::TcpTransport
96 if (!socket_->Send(handshake_message.c_str(), kHandshakeLength)) { in InitializeProtocol()
104 if (socket_->ReceiveAll(buffer, kHandshakeLength, kHandshakeTimeoutMs) != kHandshakeLength) { in InitializeProtocol()
128 if (socket_ == nullptr) { in Read()
135 if (socket_->ReceiveAll(buffer, 8, 0) != 8) { in Read()
146 ssize_t bytes_read = socket_->ReceiveAll(data, length, 0); in Read()
156 if (socket_ == nullptr) { in Write()
163 if (!socket_->Send(std::vector<cutils_socket_buffer_t>{{header, 8}, {data, length}})) { in Write()
172 if (socket_ == nullptr) { in Close()
176 int result = socket_->Close(); in Close()
177 socket_.reset(); in Close()