/[LeafOK_CVS]/innwebd/controld.cpp
ViewVC logotype

Diff of /innwebd/controld.cpp

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

Revision 1.4 by sysadm, Sat Jul 3 13:56:04 2004 UTC Revision 1.13 by sysadm, Fri May 20 14:32:36 2005 UTC
# Line 1  Line 1 
1  /*******************************************************/  /*******************************************************/
2  /*                                                     */  /*                                                     */
3  /*  LeafOK Innd                                        */  /*  LeafOK Innbbsd                                     */
4  /*  Copyright (C) LeafOK.com, 2003-2004                */  /*  Copyright (C) LeafOK.com, 2003-2005                */
5  /*                                                     */  /*                                                     */
6  /*  Programmed by Leaf                                 */  /*  Programmed by Leaf                                 */
7  /*  E-mail:leaf@leafok.com  QQ:6049044                 */  /*  E-mail:leaflet@leafok.com  QQ:6049044              */
8  /*                                                     */  /*                                                     */
9  /*  http://bbs.leafok.com                              */  /*  http://bbs.leafok.com                              */
10  /*  http://bbs.leafok.net                              */  /*  http://bbs.leafok.net                              */
# Line 35  int controld::Accept(void) Line 35  int controld::Accept(void)
35          CString out,cmd;          CString out,cmd;
36          char temp[256];          char temp[256];
37          int result;          int result;
         HANDLE hThreadCurrent;  
38    
39          try          try
40          {          {
                 hThreadCurrent = GetCurrentThread();  
   
41                  out.Format("200 %s ready.",App_common::GetVersion());                  out.Format("200 %s ready.",App_common::GetVersion());
42                  this->s_send(out);                  this->s_send(out);
43                  while(!this->thread_terminate)                  while(!this->thread_terminate)
44                  {                  {
45                          this->GetParentThread()->GetThreadPool()->SetThreadStatus(hThreadCurrent,thread_pool::S_WAITING);                          this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WAITING);
46    
47                          if (this->s_receive(out) == 0)  //Connection closed                          if (this->s_receive(out) == 0)  //Connection closed
48                                  break;                                  break;
49                          out.Trim();                          out.Trim();
50    
51                          this->GetParentThread()->GetThreadPool()->SetThreadStatus(hThreadCurrent,thread_pool::S_WORKING);                          this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WORKING);
52    
53                          syslog << logfile::log_head << "Cmd: " << out << endl;                          syslog << logfile::log_head << "Cmd: " << out << endl;
54    
# Line 92  int controld::Accept(void) Line 89  int controld::Accept(void)
89                                                  }                                                  }
90    
91                                                  this->s_send(result == 0 ? "OK" : "Failed");                                                  this->s_send(result == 0 ? "OK" : "Failed");
92    
93                                                    syslog << logfile::log_head << "Begin " << cmd << " ... " << (result == 0 ? "OK" : "Failed") << endl;
94                                          }                                          }
95                                          else                                          else
96                                          {                                          {
# Line 134  int controld::Accept(void) Line 133  int controld::Accept(void)
133                                                  }                                                  }
134    
135                                                  this->s_send(result == 0 ? "OK" : "Failed");                                                  this->s_send(result == 0 ? "OK" : "Failed");
136    
137                                                    syslog << logfile::log_head << "End " << cmd << " ... " << (result == 0 ? "OK" : "Failed") << endl;
138                                          }                                          }
139                                          else                                          else
140                                          {                                          {
# Line 142  int controld::Accept(void) Line 143  int controld::Accept(void)
143                                  }                                  }
144                                  else                                  else
145                                  {                                  {
146                                          this>s_send("501 service");                                          this->s_send("501 service");
147                                  }                                  }
148                                  contiinue;                                  continue;
149                          }                          }
150    
151                          if (cmd == "SHUTDOWN")                          if (cmd == "SHUTDOWN")
152                          {                          {
153                                  if (this->access.control)                                  if (this->access.control)
154                                  {                                  {
155                                          this->_send("Shutting down ... ",falsse);                                          this->s_send("Shutting down ... ",false);
156    
157                                          ((controld*)(this->GetParentThread()))->ShutdownChild();                                          ((controld*)(this->GetParentThread()))->ShutdownChild();
158    
# Line 182  int controld::Accept(void) Line 183  int controld::Accept(void)
183    
184                          if (cmd == "ACTIVE")                          if (cmd == "ACTIVE")
185                          {                          {
186                                  if (sscanf(out,"%*s %0s",temp) == 1)                                  if (sscanf(out,"%*s %20s",temp) == 1)
187                                          cmd = strupr(temp);                                          cmd = strupr(temp);
188                                  else                                  else
189                                          cmd = "";                                          cmd = "";
# Line 195  int controld::Accept(void) Line 196  int controld::Accept(void)
196                                                  this->s_send("201 Entering native mode");                                                  this->s_send("201 Entering native mode");
197                                                  base_active nntpClient;                                                  base_active nntpClient;
198                                                  nntpClient.configure(this->innd_id,this->innd_name,this->innd_server,this->innd_uid,"",0,this->w_conn_str);                                                  nntpClient.configure(this->innd_id,this->innd_name,this->innd_server,this->innd_uid,"",0,this->w_conn_str);
199    
200                                                    this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WAITING);
201    
202                                                  if (cmd == "POST") // Get & Post                                                  if (cmd == "POST") // Get & Post
203                                                  {                                                  {
204                                                          nntpClient.work(true,false);                                                          nntpClient.work(true,false);
# Line 203  int controld::Accept(void) Line 207  int controld::Accept(void)
207                                                  {                                                  {
208                                                          nntpClient.work(false,true);                                                          nntpClient.work(false,true);
209                                                  }                                                  }
210    
211                                                    this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WORKING);
212    
213                                                  this->s_send("Entering passive mode\r\n.");                                                  this->s_send("Entering passive mode\r\n.");
214                                          }                                          }
215                                          else                                          else
# Line 379  int controld::load_conf(const char* conf Line 386  int controld::load_conf(const char* conf
386          this->innd.configure(innd_id,innd_name,innd_server,innd_uid,innd_address,innd_port,conn_str);          this->innd.configure(innd_id,innd_name,innd_server,innd_uid,innd_address,innd_port,conn_str);
387          this->outd.configure(innd_id,innd_name,innd_server,innd_uid,innd_address,0,conn_str);          this->outd.configure(innd_id,innd_name,innd_server,innd_uid,innd_address,0,conn_str);
388    
         base* p_ParentThread;  
   
         p_ParentThread = new base_active();  
   
         this->SetParentThread(p_ParentThread);  
         this->bbsd.SetParentThread(p_ParentThread);  
         this->innd.SetParentThread(p_ParentThread);  
         this->outd.SetParentThread(p_ParentThread);  
   
         p_ParentThread->SetThreadPool(new thread_pool(TS_MAX_THREAD));  
   
         if (p_ParentThread->GetThreadPool()->GetLastError() != 0)  
         {  
                 syslog << logfile::log_head << "Create Thread Pool ... failed" << endl;  
         }  
   
389          return 0;          return 0;
390  }  }
391    
# Line 439  void controld::StartupChild(void) Line 430  void controld::StartupChild(void)
430    
431  void controld::StartupDelay(void)  void controld::StartupDelay(void)
432  {  {
433            syslog << logfile::log_head << "Startup delay for " <<
434                    this->startup_delay << " seconds"<< endl;
435    
436          Sleep(this->startup_delay * 1000);          Sleep(this->startup_delay * 1000);
437  }  }
438    
439  void controld::ShutdownChild(void)  void controld::ShutdownChild(void)
440  {  {
441          if (this->bbsd.end() == 0)          if (this->bbsd.IsRunning())
         {  
                 syslog << logfile::log_head << "End BBSD ... OK" << endl;  
         }  
         else  
442          {          {
443                  syslog << logfile::log_head << "End BBSD ... Failed" << endl;                  if (this->bbsd.end() == 0)
444                    {
445                            syslog << logfile::log_head << "End BBSD ... OK" << endl;
446                    }
447                    else
448                    {
449                            syslog << logfile::log_head << "End BBSD ... Failed" << endl;
450                    }
451          }          }
452    
453          if (this->innd.end() == 0)          if (this->innd.IsRunning())
         {  
                 syslog << logfile::log_head << "End INND ... OK" << endl;  
         }  
         else  
454          {          {
455                  syslog << logfile::log_head << "End INND ... Failed" << endl;                  if (this->innd.end() == 0)
456                    {
457                            syslog << logfile::log_head << "End INND ... OK" << endl;
458                    }
459                    else
460                    {
461                            syslog << logfile::log_head << "End INND ... Failed" << endl;
462                    }
463          }          }
464    
465          if (this->outd.end() == 0)          if (this->outd.IsRunning())
466          {          {
467                  syslog << logfile::log_head << "End OUTD ... OK" << endl;                  if (this->outd.end() == 0)
468                    {
469                            syslog << logfile::log_head << "End OUTD ... OK" << endl;
470                    }
471                    else
472                    {
473                            syslog << logfile::log_head << "End OUTD ... Failed" << endl;
474                    }
475          }          }
476          else  }
477    
478    int controld::InitThreadPool(void)
479    {
480            base* p_ParentThread;
481    
482            p_ParentThread = new controld();
483    
484            this->SetParentThread(p_ParentThread);
485            this->bbsd.SetParentThread(p_ParentThread);
486            this->innd.SetParentThread(p_ParentThread);
487            this->outd.SetParentThread(p_ParentThread);
488    
489            p_ParentThread->SetThreadPool(new thread_pool(TS_MAX_THREAD));
490    
491            if (p_ParentThread->GetThreadPool()->GetLastError() != 0)
492          {          {
493                  syslog << logfile::log_head << "End OUTD ... Failed" << endl;                  syslog << logfile::log_head << "Create Thread Pool ... failed" << endl;
494          }          }
495    
496            return 0;
497    }
498    
499    int controld::CleanupThreadPool(void)
500    {
501            delete(this->GetParentThread());
502    
503            return 0;
504    }
505    
506    bool controld::check_priv(void)
507    {
508            return this->access.control;
509  }  }

Legend:
Removed lines/characters  
Changed lines/characters
  Added lines/characters
webmaster@leafok.com
 ViewVC Help
Powered by ViewVC 1.3.0-beta1