Impala Documentation

virtual void Impala::Util::IOBufferChannel::SetPosition ( PositionType position ) [inline, virtual]

Definition at line 269 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().

00270     {
00271         if (GetPosition() == position)
00272             return;
00273 
00274         char* buf = mMyChannel->Buffer();
00275         sprintf(buf, "seekfilebuffer %d %lld %d\0", mId, position, SEEK_SET);
00276         mMyChannel->SendRequest(strlen(buf)+1);
00277         if (mMyChannel->LastSendHadError())
00278         {
00279             ILOG_ERROR("Failed to seek");
00280             return;
00281         }
00282         PositionType newPos;
00283         sscanf(buf, "%lld", &newPos);
00284         IOBuffer::SetPosition(newPos);
00285     }

Here is the call graph for this function: