Searched refs:_client (Results 1 – 5 of 5) sorted by relevance
42 private TcpClient _client; field in Thrift.Transport.Client.TTlsSocketTransport53 _client = client; in TTlsSocketTransport()150 set { _client.ReceiveTimeout = _client.SendTimeout = _timeout = value; }153 public TcpClient TcpClient => _client;163 if (_client == null)168 return _client.Connected;174 _client = new TcpClient(); in InitSocket()175 _client.ReceiveTimeout = _client.SendTimeout = _timeout; in InitSocket()176 _client.Client.NoDelay = true; in InitSocket()202 if (_client == null) in OpenAsync()[all …]
56 self._client = None77 self._client = self._server.accept()78 if self._client:79 self._client.read(5) # hello80 self._client.write(b"there")99 return self._client102 if self._client:103 self._client.close()
117 _client(client), in ClientThread()179 _client->echoVoid(); in loopEchoVoid()187 result = _client->echoByte(arg); in loopEchoByte()197 result = _client->echoI32(arg); in loopEchoI32()207 result = _client->echoI64(arg); in loopEchoI64()217 _client->echoString(result, arg); in loopEchoString()223 std::shared_ptr<ServiceClient> _client; member in ClientThread
118 _client(client), in ClientThread()184 _client->echoVoid(); in loopEchoVoid()192 result = _client->echoByte(arg); in loopEchoByte()202 result = _client->echoI32(arg); in loopEchoI32()212 result = _client->echoI64(arg); in loopEchoI64()222 _client->echoString(result, arg); in loopEchoString()228 std::shared_ptr<ServiceIf> _client; member in ClientThread
213 $self->_client($client);217 sub _client subroutine
