| 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] |