Searched refs:readBufferPos_ (Results 1 – 2 of 2) sorted by relevance
143 uint32_t readBufferPos_; member in apache::thrift::server::TNonblockingServer::TConnection380 readBufferPos_ = 0; in init()438 fetch = tSocket_->read(&framing.buf[readBufferPos_], in workSocket()439 uint32_t(sizeof(framing.size) - readBufferPos_)); in workSocket()445 readBufferPos_ += fetch; in workSocket()457 if (readBufferPos_ < sizeof(framing.size)) { in workSocket()496 if (!(readBufferPos_ < readWant_)) { in workSocket()504 fetch = readWant_ - readBufferPos_; in workSocket()505 got = tSocket_->read(readBuffer_ + readBufferPos_, fetch); in workSocket()519 readBufferPos_ += got; in workSocket()[all …]
885 readBufferPos_ = 0; in init()958 inputTransport_.reset(readBuffer_[0 .. readBufferPos_]); in transition()1036 readBufferPos_ = 0; in transition()1063 readBufferPos_= 0; in transition()1098 (cast(ubyte[])((&frameSize)[0 .. 1]))[readBufferPos_ .. $]); in workSocket()1106 readBufferPos_ += bytesRead; in workSocket()1113 if (readBufferPos_ < frameSize.sizeof) { in workSocket()1137 assert(readBufferPos_ < readWant_); in workSocket()1142 bytesRead = socket_.read(readBuffer_[readBufferPos_ .. readWant_]); in workSocket()1156 readBufferPos_ += bytesRead; in workSocket()[all …]
