| 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 */ |
| 14 |
|
|
| 15 |
#include "StdAfx.h" |
#include "StdAfx.h" |
| 16 |
#include ".\innd.h" |
#include ".\innd.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; |
| 40 |
this->s_send(out); |
this->s_send(out); |
| 41 |
while(!this->thread_terminate) |
while(!this->thread_terminate) |
| 42 |
{ |
{ |
| 43 |
|
this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WAITING); |
| 44 |
|
|
| 45 |
if (this->s_receive(out) == 0) //Connection closed |
if (this->s_receive(out) == 0) //Connection closed |
| 46 |
break; |
break; |
| 47 |
out.Trim(); |
out.Trim(); |
| 48 |
|
|
| 49 |
|
this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WORKING); |
| 50 |
|
|
| 51 |
syslog << logfile::log_head << "Cmd: " << out << endl; |
syslog << logfile::log_head << "Cmd: " << out << endl; |
| 52 |
|
|
| 53 |
if (sscanf(out,"%20s",temp) ==1) |
if (sscanf(out,"%20s",temp) ==1) |
| 365 |
|
|
| 366 |
int innd::Shutdown(void) |
int innd::Shutdown(void) |
| 367 |
{ |
{ |
| 368 |
nntp_active nntpClient; |
base_active nntpClient; |
| 369 |
|
|
| 370 |
if (this->thread_terminate) |
if (this->thread_terminate) |
| 371 |
return 1; |
return 1; |