| 144 |
break; |
break; |
| 145 |
} |
} |
| 146 |
|
|
| 147 |
this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),tread_pool::S_WORKING); |
this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WORKING); |
| 148 |
|
|
| 149 |
|
|
| 150 |
strcpy(p->hostaddr,inet_ntoa(sin.sin_addr)); |
strcpy(p->hostaddr,inet_ntoa(sin.sin_addr)); |
| 152 |
p->isConnected = true; |
p->isConnected = true; |
| 153 |
|
|
| 154 |
// strcpy(p->w_conn_str,this->w_conn_str); |
// strcpy(p->w_conn_str,this->w_conn_str); |
| 155 |
if (this->>get_priv(p)!=0) |
|
| 156 |
if (this->get_priv(p)!=0) |
if (this->get_priv(p)!=0) |
| 157 |
{ |
{ |
| 158 |
p->s_send("502 Load access file failed.\r\n"); |
p->s_send("502 Load access file failed.\r\n"); |
| 171 |
if (this->GetThreadPool()->GetThreadCount() < MAX_CLIENT) |
if (this->GetThreadPool()->GetThreadCount() < MAX_CLIENT) |
| 172 |
{ |
{ |
| 173 |
if (hThreadCurrent = CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)base_passive::AcceptThread,(LPVOID)p,0,&ulThreadId)) |
if (hThreadCurrent = CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)base_passive::AcceptThread,(LPVOID)p,0,&ulThreadId)) |
| 174 |
// base_passive::uThreadCount++; |
{ |
| 175 |
CloseHandle(hThreadCurrent); |
CloseHandle(hThreadCurrent); |
| 176 |
syslog << logfile::log_head << "Create accept thread ... OK" << endl; |
syslog << logfile::log_head << "Create accept thread ... OK" << endl; |
| 177 |
} |
} |