/[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.1 by sysadm, Fri Jul 2 11:28:46 2004 UTC Revision 1.5 by sysadm, Sat Jul 3 15:10:23 2004 UTC
# Line 14  Line 14 
14    
15  #include "StdAfx.h"  #include "StdAfx.h"
16  #include ".\controld.h"  #include ".\controld.h"
17  #include ".\nntp_active.h"  #include ".\base_active.h"
18  #include ".\App_common.h"  #include ".\App_common.h"
19    
20  using namespace std;  using namespace std;
# 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;
38            HANDLE hThreadCurrent;
39    
40          try          try
41          {          {
42                    hThreadCurrent = GetCurrentThread();
43    
44                  out.Format("200 %s ready.",App_common::GetVersion());                  out.Format("200 %s ready.",App_common::GetVersion());
45                  this->s_send(out);                  this->s_send(out);
46                  while(!this->thread_terminate)                  while(!this->thread_terminate)
47                  {                  {
48                            this->GetParentThread()->GetThreadPool()->SetThreadStatus(hThreadCurrent,thread_pool::S_WAITING);
49    
50                          if (this->s_receive(out) == 0)  //Connection closed                          if (this->s_receive(out) == 0)  //Connection closed
51                                  break;                                  break;
52                          out.Trim();                          out.Trim();
53    
54                            this->GetParentThread()->GetThreadPool()->SetThreadStatus(hThreadCurrent,thread_pool::S_WORKING);
55    
56                          syslog << logfile::log_head << "Cmd: " << out << endl;                          syslog << logfile::log_head << "Cmd: " << out << endl;
57    
58                          if (sscanf(out,"%20s",temp) ==1)                          if (sscanf(out,"%20s",temp) ==1)
# Line 73  int controld::Accept(void) Line 80  int controld::Accept(void)
80    
81                                                  if (cmd == "BBSD")                                                  if (cmd == "BBSD")
82                                                  {                                                  {
83                                                          result = ((controld*)(this->p_ParentThread))->bbsd.begin();                                                          result = ((controld*)(this->GetParentThread()))->bbsd.begin();
84                                                  }                                                  }
85                                                  if (cmd == "INND")                                                  if (cmd == "INND")
86                                                  {                                                  {
87                                                          result = ((controld*)(this->p_ParentThread))->innd.begin();                                                          result = ((controld*)(this->GetParentThread()))->innd.begin();
88                                                  }                                                  }
89                                                  if (cmd == "OUTD")                                                  if (cmd == "OUTD")
90                                                  {                                                  {
91                                                          result = ((controld*)(this->p_ParentThread))->outd.begin();                                                          result = ((controld*)(this->GetParentThread()))->outd.begin();
92                                                  }                                                  }
93    
94                                                  this->s_send(result == 0 ? "OK" : "Failed");                                                  this->s_send(result == 0 ? "OK" : "Failed");
# Line 115  int controld::Accept(void) Line 122  int controld::Accept(void)
122    
123                                                  if (cmd == "BBSD")                                                  if (cmd == "BBSD")
124                                                  {                                                  {
125                                                          result = ((controld*)(this->p_ParentThread))->bbsd.end();                                                          result = ((controld*)(this->GetParentThread()))->bbsd.end();
126                                                  }                                                  }
127                                                  if (cmd == "INND")                                                  if (cmd == "INND")
128                                                  {                                                  {
129                                                          result = ((controld*)(this->p_ParentThread))->innd.end();                                                          result = ((controld*)(this->GetParentThread()))->innd.end();
130                                                  }                                                  }
131                                                  if (cmd == "OUTD")                                                  if (cmd == "OUTD")
132                                                  {                                                  {
133                                                          result = ((controld*)(this->p_ParentThread))->outd.end();                                                          result = ((controld*)(this->GetParentThread()))->outd.end();
134                                                  }                                                  }
135    
136                                                  this->s_send(result == 0 ? "OK" : "Failed");                                                  this->s_send(result == 0 ? "OK" : "Failed");
# Line 146  int controld::Accept(void) Line 153  int controld::Accept(void)
153                                  {                                  {
154                                          this->_send("Shutting down ... ",falsse);                                          this->_send("Shutting down ... ",falsse);
155    
156                                          ((controld*)(this->p_ParentThread))->ShutdownChild();                                          ((controld*)(this->GetParentThread()))->ShutdownChild();
157    
158                                          this->s_send("OK");                                          this->s_send("OK");
159    
160                                          ((controld*)(this->p_ParentThread))->Shutdown();                                          ((controld*)(this->GetParentThread()))->Shutdown();
161                                          break;                                          break;
162                                  }                                  }
163                                  else                                  else
# Line 164  int controld::Accept(void) Line 171  int controld::Accept(void)
171                          {                          {
172                                  this->s_send("Reloading prev_list ... ",false);                                  this->s_send("Reloading prev_list ... ",false);
173    
174                                  ((controld*)(this->p_ParentThread))->unload_priv();                                  ((controld*)(this->GetParentThread()))->unload_priv();
175                                  if (((controld*)(this->p_ParentThread))->load_priv() == 0)                                  if (((controld*)(this->GetParentThread()))->load_priv() == 0)
176                                          this->s_send("OK");                                          this->s_send("OK");
177                                  else                                  else
178                                          this->s_send("Failed");                                          this->s_send("Failed");
# Line 176  int controld::Accept(void) Line 183  int controld::Accept(void)
183                          if (cmd == "ACTIVE")                          if (cmd == "ACTIVE")
184                          {                          {
185                                  if (sscanf(out,"%*s %0s",temp) == 1)                                  if (sscanf(out,"%*s %0s",temp) == 1)
186                                          cmd = struupr(temp);                                          cmd = strupr(temp);
187                                  else                                  else
188                                          cmd = "";                                          cmd = "";
189                                  cmd.Trim();                                  cmd.Trim();
# Line 186  int controld::Accept(void) Line 193  int controld::Accept(void)
193                                          if (this->access.control)                                          if (this->access.control)
194                                          {                                          {
195                                                  this->s_send("201 Entering native mode");                                                  this->s_send("201 Entering native mode");
196                                                  nntp_active nntpClient;                                                  base_active nntpClient;
197                                                  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);
198                                                  if (cmd == "POST") // Get & Post                                                  if (cmd == "POST") // Get & Post
199                                                  {                                                  {
# Line 241  bool controld::IsShutdown(void) Line 248  bool controld::IsShutdown(void)
248    
249  int controld::Shutdown(void)  int controld::Shutdown(void)
250  {  {
251          nntp_active nntpClient;          base_active nntpClient;
252    
253          if (this->thread_terminate)          if (this->thread_terminate)
254                  return 1;                  return 1;
# Line 448  void controld::ShutdownChild(void) Line 455  void controld::ShutdownChild(void)
455                  syslog << logfile::log_head << "End OUTD ... Failed" << endl;                  syslog << logfile::log_head << "End OUTD ... Failed" << endl;
456          }          }
457  }  }
458    
459    int controld::InitThreadPool(void)
460    {
461            base* p_ParentThread;
462    
463            p_ParentThread = new controld();
464    
465            this->SetParentThread(p_ParentThread);
466            this->bbsd.SetParentThread(p_ParentThread);
467            this->innd.SetParentThread(p_ParentThread);
468            this->outd.SetParentThread(p_ParentThread);
469    
470            p_ParentThread->SetThreadPool(new thread_pool(TS_MAX_THREAD));
471    
472            if (p_ParentThread->GetThreadPool()->GetLastError() != 0)
473            {
474                    syslog << logfile::log_head << "Create Thread Pool ... failed" << endl;
475            }
476    
477            return 0;
478    }
479    
480    int controld::CleanupThreadPool(void)
481    {
482            delete(this->GetParentThread());
483    
484            return 0;
485    }

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