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

Diff of /innwebd/base.cpp

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

Revision 1.1 by sysadm, Fri Jul 2 11:22:07 2004 UTC Revision 1.3 by sysadm, Sat Jul 3 15:10:23 2004 UTC
# Line 21  Line 21 
21  using namespace std;  using namespace std;
22    
23  base::base(void)  base::base(void)
24  : innd_uid(0)  : p_ParentThread(NULL)
25    , innd_uid(0)
26  , isConnected(false)  , isConnected(false)
27  , running(false)  , running(false)
28  {  {
# Line 280  int base::bbs_post(const CString& head, Line 281  int base::bbs_post(const CString& head,
281                                                  RS.GetFieldValue("UID",dbVar,SQL_C_SLONG);                                                  RS.GetFieldValue("UID",dbVar,SQL_C_SLONG);
282                                                  sql.Format("insert into bbs_msg(fromUID,toUID,ntent,send_dt,send_ip)"                                                  sql.Format("insert into bbs_msg(fromUID,toUID,ntent,send_dt,send_ip)"
283                                                                  " valulues(%ld,%ld,'%s',now(),'%s')",                                                                  " valulues(%ld,%ld,'%s',now(),'%s')",
284                                                                  this->innd_uid,dbVar.m_lVal,addslashes(msg_connt),ththis->hostaddr);                                                                  this->innd_uid,dbVar.m_lVal,addslashes(msg_content),this->hostaddr);
285                                                  this->Db.ExecuteSQL(sql);                                                  this->Db.ExecuteSQL(sql);
286                                          }                                          }
287                                  }                                  }
# Line 452  int base::s_receive(CString& out_str, co Line 453  int base::s_receive(CString& out_str, co
453          return total_read;          return total_read;
454  }  }
455    
 bool base::IsRunning(void)  
 {  
         return this->running;  
 }  
   
456  int base::begin(void)  int base::begin(void)
457  {  {
458          ULONG ulThreadId;          ULONG ulThreadId;
# Line 493  int base::begin(void) Line 489  int base::begin(void)
489    
490  DWORD base::Thread(LPVOID pParam)  DWORD base::Thread(LPVOID pParam)
491  {  {
492            HANDLE hThreadCurrent;
493          base* p;          base* p;
494    
495          syslog << logfile::log_head << "Thread started." << endl;          syslog << logfile::log_head << "Thread started." << endl;
496    
497          p = (base*)pParam;          p = (base*)pParam;
498            hThreadCurrent = GetCurrentThread();
499    
500            if (p->GetParentThread()->GetThreadPool()->AddThread(hThreadCurrent, CLOCKS_PER_SEC * 30) != 0)
501            {
502                    syslog << logfile::log_head << "Register thread ... Failed" << endl;
503            }
504            p->GetParentThread()->GetThreadPool()->SetThreadStatus(hThreadCurrent,thread_pool::S_WORKING);
505    
506          p->w_call();          p->w_call();
507    
508            if (p->GetParentThread()->GetThreadPool()->RemoveThread(hThreadCurrent) != 0)
509            {
510                    syslog << logfile::log_head << "Unregister thread ... Failed" << endl;
511            }
512    
513          syslog << logfile::log_head << "Thread stopped." << endl;          syslog << logfile::log_head << "Thread stopped." << endl;
514    
515          return 0;          return 0;

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