| int Impala::Util::Channel::SendRequest | ( | int | len | ) | [inline] |
Sends the message of len bytes in THE buffer to the server and puts the answer in THE buffer.
Returns the length of the answer.
Definition at line 302 of file Channel.h.
References Buffer(), CTR_HEADER_SIZE, HandleError(), mNrError, mServerName, mSock, RecvLarge(), and SendLarge().
Referenced by Impala::Application::FileClient::DoGet(), Impala::Util::Database::DoMkDirPathServer(), Impala::Persistency::FileSystem::DoMkDirPathServer(), Impala::Application::Util::DoPing(), Impala::Application::FileClient::DoPut(), Impala::Application::Client::ExampleReadRaw(), Impala::Application::Client::ExampleRgbDataSrc(), Impala::Util::ChannelPool::Get(), Impala::Util::Database::GetReadableFileServer(), Impala::Persistency::FileSystem::GetReadableFileServer(), Impala::Util::Database::GetWritableFileServer(), Impala::Persistency::FileSystem::GetWritableFileServer(), Impala::Util::IOBufferChannel::IOBufferChannel(), Impala::Util::IOBufferChannel::Read(), Impala::Util::ReadIOBufferFromChannel(), Impala::Util::ChannelProxy::Send(), Impala::Util::IOBufferChannel::SetPosition(), Impala::Application::Client::TestBandwidth(), Impala::Application::Client::TestMpg(), Impala::Util::IOBufferChannel::Write(), Impala::Util::IOBuffer::WriteIOBufferToChannel(), and Impala::Util::IOBufferChannel::~IOBufferChannel().
00303 { 00304 int rval; 00305 rval = SendLarge(mSock[0], len); 00306 rval = RecvLarge(mSock[0]); 00307 if ((rval > 5) && (strncmp(Buffer(), "ERROR", 5) == 0)) 00308 { 00309 HandleError("SendRequest to " + mServerName + " got " + 00310 String(Buffer()), false); 00311 mNrError--; // this was not a Channel error so stay Valid() 00312 } 00313 return rval - CTR_HEADER_SIZE; 00314 }
Here is the call graph for this function:
