Community
Participate
Working Groups
return;
}
if (console->in) CLOSE_TPTP_HANDLE(console->in);
if (console->in) cleanPipeUp(&console->in);
if (console->out) CLOSE_TPTP_HANDLE(console->out);
if (console->out) cleanPipeUp(&console->out);
if (console->err) CLOSE_TPTP_HANDLE(console->err);
if (console->err) cleanPipeUp(&console->err);
else if (rc == TPTP_PIPE_HAS_ENDED)
{
/* this is expected and normal */
TPTP_LOG_DEBUG_MSG(pThreadData->pRequestBlk->pServerData, "Console: End of pipe recieved - exiting");
pThreadData->threadStatus = TPTP_IDLE_THREAD;
else
TPTP_LOG_DEBUG_MSG2(pThreadData->pRequestBlk->pServerData, "Console: Error reading pipe(%s) rc(%d).", uuid, rc) ;
if (rc > 0)
tptp_initializeSemaphore(& pRequestDataBlock->hasProcessIdSemaphore);
TPTP_LOG_DEBUG_MSG(pThreadData->pRequestBlk->pServerData, "Console: Closing named pipes") ;
rc = disconnectFromNamedPipe(consoleHandle);
TPTP_LOG_DEBUG_MSG2 (pThreadData->pRequestBlk->pServerData, "Disconnect from named pipe %d, error %d", rc, GetLastError());
cleanPipeUp(&consoleHandle);
disconnectFromNamedPipe(pRequestDataBlock->consoleInputPipe);
cleanPipeUp(&pRequestDataBlock->consoleInputPipe);
tptp_deleteSemaphore(&pRequestDataBlock->hasProcessIdSemaphore);
TPTP_LOG_DEBUG_MSG(pThreadData->pRequestBlk->pServerData, "Stdout/stderr listening thread exited");
free(pThreadData) ;