Searched refs:offset_ (Results 1 – 4 of 4) sorted by relevance
90 offset_(0), in TFileTransport()100 offset_ = offset; in resetOutputFile()322 offset_ += readState_.lastDispatchPtr_; in writerThread()323 if (0 == THRIFT_FTRUNCATE(fd_, offset_)) { in writerThread()417 int64_t chunk1 = offset_ / chunkSize_; in writerThread()418 int64_t chunk2 = (offset_ + outEvent->eventSize_ - 1) / chunkSize_; in writerThread()423 offset_ = THRIFT_LSEEK(fd_, 0, SEEK_CUR); in writerThread()424 auto padding = (int32_t)((offset_ / chunkSize_ + 1) * chunkSize_ - offset_); in writerThread()437 offset_ += padding; in writerThread()450 offset_ += outEvent->eventSize_; in writerThread()[all …]
366 off_t offset_; variable
175 return offset_ / chunkSize_; in getCurChunk()212 offset_ = chunk * chunkSize_; in seekToChunk()226 while ((offset_ + readState_.bufferPos_) < minEndOffset) { in seekToChunk()361 offset_ += readState_.bufferLen_; in readEvent()402 if ((offset_ + readState_.bufferPos_)/chunkSize_ != in readEvent()403 ((offset_ + readState_.bufferPos_ + 3)/chunkSize_)) in readEvent()478 } else if (((offset_ + readState_.bufferPos_ - EventSize.sizeof) / chunkSize_) != in isEventCorrupted()479 ((offset_ + readState_.bufferPos_ + readState_.eventLen_ - EventSize.sizeof) / chunkSize_)) in isEventCorrupted()484 (offset_ + readState_.bufferPos_ + EventSize.sizeof) in isEventCorrupted()526 to!string(offset_ + readState_.lastDispatchPos_), in performRecovery()[all …]
107 private long offset_ = 0; field in TFileTransport.ChunkState116 offset_ += size; in skip()120 offset_ = offset; in seek()128 return ((int) (offset_ / chunk_size_)); in getChunkNum()132 return (chunk_size_ - ((int) (offset_ % chunk_size_))); in getRemaining()136 return (offset_); in getOffset()
