|
Lines 627-639
Link Here
|
| 627 |
//Tell the client before we start our flusher thread. |
627 |
//Tell the client before we start our flusher thread. |
| 628 |
rc = startMonitor(stateData, agent, contextID); |
628 |
rc = startMonitor(stateData, agent, contextID); |
| 629 |
|
629 |
|
|
|
630 |
baseTL_addDataConnectionEntry( stateData, connectionID, (void*)pData ); |
| 631 |
|
| 630 |
if ( !(flags & TPTP_DATA_PATH_DIRECT_SOCKET) && !(flags & TPTP_DATA_PATH_DIRECT_FILE)) |
632 |
if ( !(flags & TPTP_DATA_PATH_DIRECT_SOCKET) && !(flags & TPTP_DATA_PATH_DIRECT_FILE)) |
| 631 |
{ |
633 |
{ |
| 632 |
rc = startNewThread(doAgentListening, |
634 |
rc = startNewThread(doAgentListening, |
| 633 |
(LPVOID) pData, &threadId, &threadHandle); |
635 |
(LPVOID) pData, &threadId, &threadHandle); |
| 634 |
} |
636 |
} |
| 635 |
|
637 |
|
| 636 |
baseTL_addDataConnectionEntry( stateData, connectionID, (void*)pData ); |
|
|
| 637 |
sprintf( command, bindConnections, agent->agentID, AGENT_MANAGER, |
638 |
sprintf( command, bindConnections, agent->agentID, AGENT_MANAGER, |
| 638 |
bindContextID, partnerID, connectionID); |
639 |
bindContextID, partnerID, connectionID); |
| 639 |
rc = forwardXmlCommand( stateData, command ); |
640 |
rc = forwardXmlCommand( stateData, command ); |
