--- innwebd/controld.cpp 2004/07/03 15:10:23 1.5 +++ innwebd/controld.cpp 2004/07/04 22:15:09 1.9 @@ -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 */ @@ -35,23 +35,20 @@ int controld::Accept(void) CString out,cmd; char temp[256]; int result; - HANDLE hThreadCurrent; try { - hThreadCurrent = GetCurrentThread(); - out.Format("200 %s ready.",App_common::GetVersion()); this->s_send(out); while(!this->thread_terminate) { - this->GetParentThread()->GetThreadPool()->SetThreadStatus(hThreadCurrent,thread_pool::S_WAITING); + this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WAITING); if (this->s_receive(out) == 0) //Connection closed break; out.Trim(); - this->GetParentThread()->GetThreadPool()->SetThreadStatus(hThreadCurrent,thread_pool::S_WORKING); + this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WORKING); syslog << logfile::log_head << "Cmd: " << out << endl; @@ -142,16 +139,16 @@ int controld::Accept(void) } else { - this>s_send("501 service"); + this->s_send("501 service"); } - contiinue; + continue; } if (cmd == "SHUTDOWN") { if (this->access.control) { - this->_send("Shutting down ... ",falsse); + this->s_send("Shutting down ... ",false); ((controld*)(this->GetParentThread()))->ShutdownChild(); @@ -182,7 +179,7 @@ int controld::Accept(void) if (cmd == "ACTIVE") { - if (sscanf(out,"%*s %0s",temp) == 1) + if (sscanf(out,"%*s %20s",temp) == 1) cmd = strupr(temp); else cmd = ""; @@ -195,6 +192,9 @@ int controld::Accept(void) this->s_send("201 Entering native mode"); base_active nntpClient; nntpClient.configure(this->innd_id,this->innd_name,this->innd_server,this->innd_uid,"",0,this->w_conn_str); + + this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WAITING); + if (cmd == "POST") // Get & Post { nntpClient.work(true,false); @@ -203,6 +203,9 @@ int controld::Accept(void) { nntpClient.work(false,true); } + + this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WORKING); + this->s_send("Entering passive mode\r\n."); } else