Home
last modified time | relevance | path

Searched refs:writeBufferPos_ (Results 1 – 2 of 2) sorted by relevance

/thrift-3.4.0/lib/cpp/src/thrift/server/
DTNonblockingServer.cpp158 uint32_t writeBufferPos_; member in apache::thrift::server::TNonblockingServer::TConnection
385 writeBufferPos_ = 0; in init()
542 assert(writeBufferPos_ <= writeBufferSize_); in workSocket()
545 if (writeBufferPos_ == writeBufferSize_) { in workSocket()
552 left = writeBufferSize_ - writeBufferPos_; in workSocket()
553 sent = tSocket_->write_partial(writeBuffer_ + writeBufferPos_, left); in workSocket()
560 writeBufferPos_ += sent; in workSocket()
563 assert(writeBufferPos_ <= writeBufferSize_); in workSocket()
566 if (writeBufferPos_ == writeBufferSize_) { in workSocket()
697 writeBufferPos_ = 0; in transition()
[all …]
/thrift-3.4.0/lib/d/src/thrift/server/
Dnonblocking.d889 writeBufferPos_ = 0; in init()
1009 writeBufferPos_ = 0; in transition()
1033 writeBufferPos_ = 0; in transition()
1166 assert(writeBufferPos_ <= writeBuffer_.length); in workSocket()
1168 if (writeBufferPos_ == writeBuffer_.length) { in workSocket()
1177 bytesSent = socket_.writeSome(writeBuffer_[writeBufferPos_ .. $]); in workSocket()
1184 writeBufferPos_ += bytesSent; in workSocket()
1185 assert(writeBufferPos_ <= writeBuffer_.length); in workSocket()
1187 if (writeBufferPos_ == writeBuffer_.length) { in workSocket()
1310 size_t writeBufferPos_; variable