--- innwebd/innd.cpp 2004/07/02 11:32:20 1.3 +++ innwebd/innd.cpp 2004/07/04 06:45:23 1.6 @@ -1,10 +1,10 @@ /*******************************************************/ /* */ -/* LeafOK Innd */ +/* LeafOK Innbbsd */ /* Copyright (C) LeafOK.com, 2003-2004 */ /* */ /* Programmed by Leaf */ -/* E-mail:leaf@leafok.com QQ:6049044 */ +/* E-mail:leaflet@leafok.com QQ:6049044 */ /* */ /* http://bbs.leafok.com */ /* http://bbs.leafok.net */ @@ -14,7 +14,7 @@ #include "StdAfx.h" #include ".\innd.h" -#include ".\nntp_active.h" +#include ".\base_active.h" #include ".\App_common.h" using namespace std; @@ -40,10 +40,14 @@ int innd::Accept(void) this->s_send(out); while(!this->thread_terminate) { + this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WAITING); + if (this->s_receive(out) == 0) //Connection closed break; out.Trim(); + this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WORKING); + syslog << logfile::log_head << "Cmd: " << out << endl; if (sscanf(out,"%20s",temp) ==1) @@ -361,7 +365,7 @@ int innd::cmd_ihave(const char* msg_id) int innd::Shutdown(void) { - nntp_active nntpClient; + base_active nntpClient; if (this->thread_terminate) return 1;