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