EnterCriticalSection(&(pipex->CriticalSection));
(pipex->state)|=PIPEX_EOF;
LeaveCriticalSection(&(pipex->CriticalSection));
- // not quit the right place
- my_log("%s->Adapter: EOF\n",pipex->name);
-
-}
+ }
// pipex_active()
WaitForSingleObject(pipex->hEvent,INFINITE);
}
}
+ my_log("%s->Adapter: EOF\n",pipex->name);
szLineStr[0]='\0';
return FALSE;
}
void pipex_writeln(pipex_t *pipex, const char *szLineStr) {
DWORD dwBytes;
DWORD dwLengthWriteBuffer;
- my_log("Adapter->%s: %s\n",pipex->name,pipex->szWriteBuffer);
pipex_write(pipex, szLineStr);
+ my_log("Adapter->%s: %s\n",pipex->name,pipex->szWriteBuffer);
if(pipex->bPipe){
dwLengthWriteBuffer = strlen(pipex->szWriteBuffer);
if(dwLengthWriteBuffer>=sizeof(pipex->szWriteBuffer)-3){