--- innwebd/bbsd.cpp 2004/07/03 08:47:07 1.3 +++ innwebd/bbsd.cpp 2004/07/03 13:56:04 1.4 @@ -34,10 +34,13 @@ int bbsd::Accept(void) CDBVariant dbVar; CString sql,out,cmd; char temp[256]; + HANDLE hThreadCurrent; long u_online,u_anonymous,u_total; try { + hThreadCurrent = GetCurrentThread(); + u_online = 0; sql = "select SID as cc from user_online group by SID"; RS.Open(CRecordset::snapshot,sql,CRecordset::forwardOnly | CRecordset::readOnly); @@ -84,10 +87,14 @@ int bbsd::Accept(void) this->s_send(out); while(!this->thread_terminate) { + this->GetParentThread()->GetThreadPool()->SetThreadStatus(hThreadCurrent,thread_pool::S_WAITING); + if (this->s_receive(out) == 0) //Connection closed break; out.Trim(); + this->GetParentThread()->GetThreadPool()->SetThreadStatus(hThreadCurrent,thread_pool::S_WORKING); + if (sscanf(out,"%20s",temp) ==1) cmd = strupr(temp); else