Searched refs:_transport (Results 1 – 8 of 8) sorted by relevance
| /thrift-3.4.0/lib/dart/lib/src/transport/ |
| D | t_framed_transport.dart | 26 final TTransport _transport;
37 TFramedTransport(TTransport transport) : _transport = transport {
44 bool get isOpen => _transport.isOpen;
49 return _transport.open();
55 return _transport.close();
85 int got = _transport.read(
118 int got = _transport.read(_body, _receivedBodyBytes, remainingBodyBytes);
150 _transport.write(_headerBytes, 0, headerByteCount);
151 _transport.write(buffer, 0, length);
161 _transport.flush().then((_) {
|
| D | t_message_reader.dart | 26 final _TMessageReaderTransport _transport;
31 : _transport = _TMessageReaderTransport(),
35 _transport.reset(bytes, byteOffset);
36 TProtocol protocol = protocolFactory.getProtocol(_transport);
38 _transport.reset(null);
|
| /thrift-3.4.0/lib/py/src/transport/ |
| D | THeaderTransport.py | 91 self._transport = transport
108 return self._transport.isOpen()
111 return self._transport.open()
114 return self._transport.close()
164 return bytes_read + self._transport.read(bytes_left_to_read)
181 first_word = self._transport.readAll(I32.size)
195 rest = self._transport.read(bytes_left_to_read)
207 read_buffer = BufferIO(self._transport.readAll(frame_size))
340 self._transport.write(frame_bytes)
341 self._transport.flush()
|
| /thrift-3.4.0/tutorial/dart/console_client/bin/ |
| D | main.dart | 27 TTransport _transport;
66 _transport = new TAsyncClientSocketTransport(
68 TProtocol protocol = new TBinaryProtocol(_transport);
69 await _transport.open();
|
| /thrift-3.4.0/tutorial/dart/client/web/ |
| D | client.dart | 35 TTransport _transport;
44 if (!_transport.isOpen) {
50 _transport = new TAsyncClientSocketTransport(
53 TProtocol protocol = new TBinaryProtocol(_transport);
54 _transport.open();
|
| /thrift-3.4.0/tutorial/py.tornado/ |
| D | PythonClient.py | 98 client._transport.close()
|
| /thrift-3.4.0/test/cpp/src/ |
| D | StressTestNonBlocking.cpp | 116 : _transport(transport), in ClientThread()
136 _transport->open(); in run()
161 _transport->close(); in run()
222 std::shared_ptr<TTransport> _transport; member in ClientThread
|
| D | StressTest.cpp | 117 : _transport(transport), in ClientThread()
138 _transport->open(); in run()
165 _transport->close(); in run()
227 std::shared_ptr<TTransport> _transport; member in ClientThread
|
