#include <TaoClientTask.h>
|
| TaoClientTask (int remotePort, UtlString remoteHost, TaoServerTask *pTaoServerTask=NULL, const UtlString &name="TaoClientTask-%d", const int maxRequestQMsgs=DEF_MAX_MSGS) |
|
| TaoClientTask (TaoServerTask *pTaoServerTask=NULL, const UtlString &name="TaoClientTask-%d", void *pArg=NULL, const int maxRequestQMsgs=DEF_MAX_MSGS, const int priority=DEF_PRIO, const int options=DEF_OPTIONS, const int stackSize=DEF_STACKSIZE) |
|
| TaoClientTask (const int maxIncomingQMsgs, TaoServerTask *pTaoServerTask=NULL) |
|
| TaoClientTask (const TaoClientTask &rTaoClientTask) |
|
virtual | ~TaoClientTask () |
|
virtual void | requestShutdown (void) |
|
int | sendRequest (TaoMessage &rMsg, OsMutex *pMutex=0, const OsTime &rTimeout=OsTime::OS_INFINITY) |
|
virtual UtlBoolean | handleMessage (OsMsg &rMsg) |
|
void | addEventListener (PtEventListener *pListener, const char *callId=NULL) |
|
void | removeEventListener (PtEventListener &rListener) |
|
int | resetConnectionSocket (int transactionId) |
|
TaoObjHandle | getEventServer () |
|
TaoClientTask |
( |
int |
remotePort, |
|
|
UtlString |
remoteHost, |
|
|
TaoServerTask * |
pTaoServerTask = NULL , |
|
|
const UtlString & |
name = "TaoClientTask-%d" , |
|
|
const int |
maxRequestQMsgs = DEF_MAX_MSGS |
|
) |
| |
TaoClientTask |
( |
TaoServerTask * |
pTaoServerTask = NULL , |
|
|
const UtlString & |
name = "TaoClientTask-%d" , |
|
|
void * |
pArg = NULL , |
|
|
const int |
maxRequestQMsgs = DEF_MAX_MSGS , |
|
|
const int |
priority = DEF_PRIO , |
|
|
const int |
options = DEF_OPTIONS , |
|
|
const int |
stackSize = DEF_STACKSIZE |
|
) |
| |
void addEventListener |
( |
PtEventListener * |
pListener, |
|
|
const char * |
callId = NULL |
|
) |
| |
UtlBoolean handleMessage |
( |
OsMsg & |
rMsg | ) |
|
|
virtual |
int readUntilDone |
( |
OsConnectionSocket * |
pSocket, |
|
|
char * |
pBuf, |
|
|
int |
iLength |
|
) |
| |
|
private |
void requestShutdown |
( |
void |
| ) |
|
|
virtual |
int resetConnectionSocket |
( |
int |
transactionId | ) |
|
int sendRequest |
( |
TaoMessage & |
rMsg, |
|
|
OsMutex * |
pMutex = 0 , |
|
|
const OsTime & |
rTimeout = OsTime::OS_INFINITY |
|
) |
| |
OsConnectionSocket* mpConnectionSocket |
|
private |