Definition at line 295 of file IOBufferChannel.h. References Impala::Util::Channel::Buffer(), Impala::Util::IOBuffer::GetPosition(), ILOG_ERROR, Impala::Util::Channel::LastSendHadError(), mId, mMyChannel, Impala::Util::Channel::SendRequest(), and Impala::Util::IOBuffer::SetPosition(). Referenced by DoNativeTypeRead(), Gets(), Read(), ReadLine(), and Write(). 00296 { 00297 if (GetPosition() == position) 00298 return; 00299 00300 char* buf = mMyChannel->Buffer(); 00301 sprintf(buf, "seekfilebuffer %d %lld %d\0", mId, position, SEEK_SET); 00302 mMyChannel->SendRequest(strlen(buf)+1); 00303 if (mMyChannel->LastSendHadError()) 00304 { 00305 ILOG_ERROR("Failed to seek"); 00306 return; 00307 } 00308 PositionType newPos; 00309 sscanf(buf, "%lld", &newPos); 00310 IOBuffer::SetPosition(newPos); 00311 }
Here is the call graph for this function: ![]()
|