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

Diff of /innwebd/bbsd.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.7 by sysadm, Thu Sep 16 15:38:59 2004 UTC
# Line 1  Line 1 
1  /*******************************************************/  /*******************************************************/
2  /*                                                     */  /*                                                     */
3  /*  LeafOK Innd                                        */  /*  LeafOK Innbbsd                                     */
4  /*  Copyright (C) LeafOK.com, 2003-2004                */  /*  Copyright (C) LeafOK.com, 2003-2004                */
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 34  int bbsd::Accept(void) Line 34  int bbsd::Accept(void)
34          CDBVariant dbVar;          CDBVariant dbVar;
35          CString sql,out,cmd;          CString sql,out,cmd;
36          char temp[256];          char temp[256];
         HANDLE hThreadCurrent;  
37          long u_online,u_anonymous,u_total;          long u_online,u_anonymous,u_total;
38    
39          try          try
40          {          {
                 hThreadCurrent = GetCurrentThread();  
   
41                  u_online = 0;                  u_online = 0;
42                  sql = "select SID as cc from user_online group by SID";                  sql = "select SID as cc from user_online where current_action not in"
43                            " ('max_user_limit','max_ip_limit','max_session_limit','exit')"
44                            " group by SID";
45                  RS.Open(CRecordset::snapshot,sql,CRecordset::forwardOnly | CRecordset::readOnly);                  RS.Open(CRecordset::snapshot,sql,CRecordset::forwardOnly | CRecordset::readOnly);
46                  while(!RS.IsEOF())                  while(!RS.IsEOF())
47                  {                  {
# Line 52  int bbsd::Accept(void) Line 51  int bbsd::Accept(void)
51                  RS.Close();                  RS.Close();
52    
53                  u_anonymous = 0;                  u_anonymous = 0;
54                  sql = "select SID as cc from user_online where UID=0 group by SID";                  sql = "select SID as cc from user_online where UID=0 and current_action not in"
55                            " ('max_user_limit','max_ip_limit','max_session_limit','exit')"
56                            " group by SID";
57                  RS.Open(CRecordset::snapshot,sql,CRecordset::forwardOnly | CRecordset::readOnly);                  RS.Open(CRecordset::snapshot,sql,CRecordset::forwardOnly | CRecordset::readOnly);
58                  while(!RS.IsEOF())                  while(!RS.IsEOF())
59                  {                  {
# Line 87  int bbsd::Accept(void) Line 88  int bbsd::Accept(void)
88                  this->s_send(out);                  this->s_send(out);
89                  while(!this->thread_terminate)                  while(!this->thread_terminate)
90                  {                  {
91                          this->GetParentThread()->GetThreadPool()->SetThreadStatus(hThreadCurrent,thread_pool::S_WAITING);                          this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WAITING);
92    
93                          if (this->s_receive(out) == 0)  //Connection closed                          if (this->s_receive(out) == 0)  //Connection closed
94                                  break;                                  break;
95                          out.Trim();                          out.Trim();
96    
97                          this->GetParentThread()->GetThreadPool()->SetThreadStatus(hThreadCurrent,thread_pool::S_WORKING);                          this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WORKING);
98    
99                          if (sscanf(out,"%20s",temp) ==1)                          if (sscanf(out,"%20s",temp) ==1)
100                                  cmd = strupr(temp);                                  cmd = strupr(temp);
# Line 166  int bbsd::db_env_init(void) Line 167  int bbsd::db_env_init(void)
167          }          }
168          return 0;          return 0;
169  }  }
170    
171    bool bbsd::check_priv(void)
172    {
173            return true;
174    }

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