| /thrift-3.4.0/lib/cpp/src/thrift/transport/ |
| D | TShortReadTransport.h | 43 : TVirtualTransport(config), transport_(transport), fullProb_(full_prob) { in TVirtualTransport()
46 bool isOpen() const override { return transport_->isOpen(); } in isOpen()
48 bool peek() override { return transport_->peek(); } in peek()
50 void open() override { transport_->open(); } in open()
52 void close() override { transport_->close(); } in close()
63 return transport_->read(buf, len); in read()
66 void write(const uint8_t* buf, uint32_t len) { transport_->write(buf, len); } in write()
70 transport_->flush(); in flush()
73 const uint8_t* borrow(uint8_t* buf, uint32_t* len) { return transport_->borrow(buf, len); } in borrow()
77 return transport_->consume(len); in consume()
[all …]
|
| D | TWebSocketServer.h | 106 transport_->write(buffer, length); in flush()
107 transport_->flush(); in flush()
204 transport_->write(reinterpret_cast<const uint8_t*>(&buffer), 2); in failConnection()
205 transport_->flush(); in failConnection()
206 transport_->close(); in failConnection()
218 transport_->write(buffer, size); in pong()
219 transport_->flush(); in pong()
225 auto read = transport_->read(headerBuffer, 2); in readFrame()
254 read = transport_->read(headerBuffer, 2); in readFrame()
260 read = transport_->read(headerBuffer, 8); in readFrame()
[all …]
|
| D | THttpTransport.h | 43 void open() override { transport_->open(); } in open()
45 bool isOpen() const override { return transport_->isOpen(); } in isOpen()
47 bool peek() override { return transport_->peek(); } in peek()
49 void close() override { transport_->close(); } in close()
64 std::shared_ptr<TTransport> transport_;
|
| D | TBufferTransports.h | 193 transport_(transport), in TVirtualTransport()
204 transport_(transport), in TVirtualTransport()
216 transport_(transport), in TVirtualTransport()
224 void open() override { transport_->open(); } in open()
226 bool isOpen() const override { return transport_->isOpen(); } in isOpen()
230 setReadBuffer(rBuf_.get(), transport_->read(rBuf_.get(), rBufSize_)); in peek()
237 transport_->close(); in close()
249 const std::string getOrigin() const override { return transport_->getOrigin(); } in getOrigin()
264 std::shared_ptr<TTransport> getUnderlyingTransport() { return transport_; } in getUnderlyingTransport()
279 std::shared_ptr<TTransport> transport_; variable
[all …]
|
| D | THttpServer.cpp | 110 transport_->write((const uint8_t*)header.c_str(), static_cast<uint32_t>(header.size())); in parseStatusLine()
111 transport_->write(buf, len); in parseStatusLine()
112 transport_->flush(); in parseStatusLine()
134 transport_->write((const uint8_t*)header.c_str(), static_cast<uint32_t>(header.size())); in flush()
135 transport_->write(buf, len); in flush()
136 transport_->flush(); in flush()
|
| D | TBufferTransports.cpp | 54 setReadBuffer(rBuf_.get(), transport_->read(rBuf_.get(), rBufSize_)); in readSlow()
93 transport_->write(wBuf_.get(), have_bytes); in writeSlow()
95 transport_->write(buf, len); in writeSlow()
104 transport_->write(wBuf_.get(), wBufSize_); in writeSlow()
130 transport_->write(wBuf_.get(), have_bytes); in flush()
134 transport_->flush(); in flush()
185 = transport_->read(szp, static_cast<uint32_t>(sizeof(sz)) - size_bytes_read); in readFrame()
215 transport_->readAll(rBuf_.get(), sz); in readFrame()
270 transport_->write(wBuf_.get(), static_cast<uint32_t>(sizeof(sz_nbo)) + sz_hbo); in flush()
274 transport_->flush(); in flush()
|
| D | TZlibTransport.h | 89 transport_(transport), in TVirtualTransport()
146 void open() override { transport_->open(); } in open()
148 void close() override { transport_->close(); } in close()
185 std::shared_ptr<TTransport> getUnderlyingTransport() const { return transport_; } in getUnderlyingTransport()
200 std::shared_ptr<TTransport> transport_; variable
|
| D | TZlibTransport.cpp | 114 return (readAvail() > 0) || (rstream_->avail_in > 0) || transport_->isOpen(); in isOpen()
118 return (readAvail() > 0) || (rstream_->avail_in > 0) || transport_->peek(); in peek()
195 uint32_t got = transport_->read(crbuf_, crbuf_size_); in readFromZlib()
263 transport_->write(cwbuf_, cwbuf_size_ - wstream_->avail_out); in flush()
286 transport_->write(cwbuf_, cwbuf_size_ - wstream_->avail_out); in flushToTransport()
291 transport_->flush(); in flushToTransport()
305 transport_->write(cwbuf_, cwbuf_size_); in flushToZlib()
|
| D | THttpClient.cpp | 117 transport_->write((const uint8_t*)header.c_str(), static_cast<uint32_t>(header.size())); in flush()
118 transport_->write(buf, len); in flush()
119 transport_->flush(); in flush()
|
| D | THttpTransport.cpp | 36 transport_(transport), in THttpTransport()
215 uint32_t got = transport_->read((uint8_t*)(httpBuf_ + httpBufLen_), httpBufSize_ - httpBufLen_); in refill()
267 oss << transport_->getOrigin(); in getOrigin()
|
| /thrift-3.4.0/lib/php/lib/Transport/ |
| D | TFramedTransport.php | 40 private $transport_; variable in Thrift\\Transport\\TFramedTransport
77 $this->transport_ = $transport;
84 return $this->transport_->isOpen();
89 $this->transport_->open();
94 $this->transport_->close();
106 return $this->transport_->read($len);
147 $buf = $this->transport_->readAll(4);
151 $this->rBuf_ = $this->transport_->readAll($sz);
163 return $this->transport_->write($buf, $len);
179 return $this->transport_->flush();
[all …]
|
| D | TBufferedTransport.php | 42 protected $transport_; variable in Thrift\\Transport\\TBufferedTransport
77 $this->transport_ = $transport;
84 return $this->transport_->isOpen();
94 $this->transport_->open();
99 $this->transport_->close();
126 $data = $this->transport_->readAll($len);
130 $data .= $this->transport_->readAll($len - $have);
152 $this->rBuf_ = $this->transport_->read($this->rBufSize_);
184 $this->transport_->write($out);
202 $this->transport_->write($out);
[all …]
|
| /thrift-3.4.0/lib/javame/src/org/apache/thrift/transport/ |
| D | TFramedTransport.java | 35 private TTransport transport_ = null; field in TFramedTransport
61 transport_ = transport; in TFramedTransport()
65 transport_.open(); in open()
69 return transport_.isOpen(); in isOpen()
73 transport_.close(); in close()
92 transport_.readAll(i32rd, 0, 4); in readFrame()
100 transport_.readAll(buff, 0, size); in readFrame()
118 transport_.write(i32out, 0, 4); in flush()
119 transport_.write(buf, 0, len); in flush()
120 transport_.flush(); in flush()
|
| /thrift-3.4.0/lib/d/src/thrift/transport/ |
| D | buffered.d | 62 transport_ = transport; in this()
72 return transport_.isOpen(); in isOpen()
79 auto bytesRead = transport_.read(readBuffer_); in peek()
87 transport_.open(); in open()
93 transport_.close(); in close()
106 return transport_.read(buf); in read()
109 auto bytesRead = transport_.read(readBuffer_); in read()
149 transport_.write(writeBuffer_[0 .. bytesAvail]); in write()
153 transport_.write(buf); in write()
160 transport_.write(writeBuffer_); in write()
[all …]
|
| D | websocket.d | 46 transport_ = transport; in TServerWebSocketTransport()
94 transport_.write(writeBuffer_); in TServerWebSocketTransport()
95 transport_.flush(); in TServerWebSocketTransport()
166 transport_.write(nativeToBigEndian!ushort(reason)); in TServerWebSocketTransport()
167 transport_.flush(); in TServerWebSocketTransport()
168 transport_.close(); in TServerWebSocketTransport()
173 transport_.write(readBuffer_); in TServerWebSocketTransport()
174 transport_.flush(); in TServerWebSocketTransport()
180 auto read = transport_.read(headerBuffer[0..2]); in TServerWebSocketTransport()
212 read = transport_.read(headerBuffer[0..2]); in TServerWebSocketTransport()
[all …]
|
| D | framed.d | 44 transport_ = transport; in this()
51 return transport_; in underlyingTransport()
55 return transport_.isOpen; in isOpen()
59 return rBuf_.length > 0 || transport_.peek(); in peek()
63 transport_.open(); in open()
68 transport_.close(); in close()
113 transport_.write(cast(ubyte[])(&len)[0..1]); in flush()
114 transport_.write(wBuf_); in flush()
115 transport_.flush(); in flush()
143 auto read = transport_.read(data); in readFrame()
[all …]
|
| D | http.d | 45 transport_ = transport; in this()
54 return transport_.isOpen(); in isOpen()
58 return transport_.peek(); in peek()
62 transport_.open(); in open()
66 transport_.close(); in close()
110 transport_.write(cast(const(ubyte)[]) header); in flush()
111 transport_.write(data); in flush()
112 transport_.flush(); in flush()
274 auto got = transport_.read(cast(ubyte[])httpBuf_[indexEnd .. $]); in refill()
280 TTransport transport_; variable
|
| D | zlib.d | 59 transport_ = transport;
105 return transport_; in underlyingTransport()
109 return readAvail > 0 || transport_.isOpen; in isOpen()
113 return readAvail > 0 || transport_.peek(); in peek()
117 transport_.open(); in open()
121 transport_.close(); in close()
258 auto got = transport_.read(crbuf_); in readFromZlib()
281 transport_.write(cwbuf_[0 .. $ - wstream_.avail_out]); in flushToTransport()
286 transport_.flush(); in flushToTransport()
300 transport_.write(cwbuf_); in flushToZlib()
[all …]
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/transport/ |
| D | TZlibTransport.java | 34 private TTransport transport_ = null; field in TZlibTransport
65 transport_ = transport; in TZlibTransport()
66 inputStream_ = new InflaterInputStream(new TTransportInputStream(transport_), new Inflater()); in TZlibTransport()
69 new TTransportOutputStream(transport_), new Deflater(compressionLevel, false), true); in TZlibTransport()
74 return transport_.isOpen(); in isOpen()
79 transport_.open(); in open()
85 if (transport_.isOpen()) { in close()
86 transport_.close(); in close()
|
| /thrift-3.4.0/lib/php/lib/Server/ |
| D | TSimpleServer.php | 30 $this->transport_->listen();
34 $transport = $this->transport_->accept();
57 $this->transport_->close();
|
| D | TForkingServer.php | 39 $this->transport_->listen();
43 $transport = $this->transport_->accept();
122 $this->transport_->close();
|
| D | TServer.php | 28 protected $transport_; variable in Thrift\\Server\\TServer
78 $this->transport_ = $transport;
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/ |
| D | TSerializer.java | 55 TIOStreamTransport transport_ = new TIOStreamTransport(new TConfiguration(), baos_); in TSerializer() local
56 protocol_ = protocolFactory.getProtocol(transport_); in TSerializer()
|
| /thrift-3.4.0/lib/javame/src/org/apache/thrift/ |
| D | TSerializer.java | 45 private final TIOStreamTransport transport_ = new TIOStreamTransport(baos_); field in TSerializer
66 protocol_ = protocolFactory.getProtocol(transport_); in TSerializer()
|
| /thrift-3.4.0/lib/d/src/thrift/codegen/ |
| D | async_client.d | 158 transport_ = trans;
182 return transport_;
185 protected TAsyncTransport transport_;
|
