Buffer() | Impala::Util::Channel | [inline] |
Channel(int port, int nrPorts, ChannelListener *listener=0) | Impala::Util::Channel | [inline] |
Channel(String serverName, int port) | Impala::Util::Channel | [inline] |
Close() | Impala::Util::Channel | [inline] |
CloseSocket(SOCKET sock) | Impala::Util::Channel | [inline, private] |
CTR_HEADER_SIZE | Impala::Util::Channel | [private, static] |
DATA_BUFFER_SIZE | Impala::Util::Channel | [static] |
FP_ERROR typedef | Impala::Util::Channel | |
FP_IDLE typedef | Impala::Util::Channel | |
FP_INFO typedef | Impala::Util::Channel | |
FP_REQUEST typedef | Impala::Util::Channel | |
GetCurRequestConnection() const | Impala::Util::Channel | [inline] |
GetCurRequestPort() const | Impala::Util::Channel | [inline] |
GetNrPorts() const | Impala::Util::Channel | [inline] |
GetPortNumber(int idx) const | Impala::Util::Channel | [inline] |
GetServerInfo() | Impala::Util::Channel | [inline] |
HandleDisconnect(int port) | Impala::Util::Channel | [inline, private] |
HandleError(CString msg, bool isSockError) | Impala::Util::Channel | [inline, private] |
HandleIdle() | Impala::Util::Channel | [inline, private] |
HandleInfo(CString msg) | Impala::Util::Channel | [inline, private] |
HandleRequest(char *buf, int len, int bufSize) | Impala::Util::Channel | [inline, private] |
ILOG_VAR_DECL | Impala::Util::Channel | [private] |
in_addr_t typedef | Impala::Util::Channel | [private] |
InitSocket() | Impala::Util::Channel | [inline, private] |
LastSendHadError() | Impala::Util::Channel | [inline] |
MaximizeSendRecvBuffer() | Impala::Util::Channel | [inline] |
mBuffer | Impala::Util::Channel | [private] |
mCallbackOnIdle | Impala::Util::Channel | [private] |
mConnection | Impala::Util::Channel | [private] |
mCurRequestSock | Impala::Util::Channel | [private] |
mFpError | Impala::Util::Channel | [private] |
mFpIdle | Impala::Util::Channel | [private] |
mFpInfo | Impala::Util::Channel | [private] |
mFpRequest | Impala::Util::Channel | [private] |
mIsServer | Impala::Util::Channel | [private] |
mListener | Impala::Util::Channel | [private] |
mMsgSock | Impala::Util::Channel | [private] |
mMsgSockEvent | Impala::Util::Channel | [private] |
mNrError | Impala::Util::Channel | [private] |
mNrPorts | Impala::Util::Channel | [private] |
mPort | Impala::Util::Channel | [private] |
mServerName | Impala::Util::Channel | [private] |
mSock | Impala::Util::Channel | [private] |
mSockConnected | Impala::Util::Channel | [private] |
mSockEvent | Impala::Util::Channel | [private] |
RecvLarge(SOCKET sock) | Impala::Util::Channel | [inline, private] |
SendLarge(SOCKET sock, int nrData) | Impala::Util::Channel | [inline, private] |
SendRequest(int len) | Impala::Util::Channel | [inline] |
Serve(FP_REQUEST fpRequest, FP_IDLE fpIdle=0) | Impala::Util::Channel | [inline] |
Serve(bool callbackOnIdle=false) | Impala::Util::Channel | [inline] |
SetListener(ChannelListener *listener) | Impala::Util::Channel | [inline] |
SetMessageFunc(FP_INFO fpInfo, FP_ERROR fpError) | Impala::Util::Channel | [inline] |
socklen_t typedef | Impala::Util::Channel | [private] |
Valid() | Impala::Util::Channel | [inline] |
WaitForSocketEvent() | Impala::Util::Channel | [inline, private] |
~Channel() | Impala::Util::Channel | [inline] |