LeafOK_CVS/innwebd/outd.cpp

/*******************************************************/
/*                                                     */
/*  LeafOK Innbbsd                                     */
/*                                                     */
/*  Copyright (C) LeafOK.com, 2003-2008                */
/*                                                     */
/*  http://www.leafok.com                              */
/*                                                     */
/*******************************************************/

#include "StdAfx.h"
#include ".\outd.h"

using namespace std;

bool outd::thread_terminate = true;

outd::outd(void)
{
}

outd::~outd(void)
{
}

int outd::work()
{
        HANDLE hThreadCurrent;
        ULONG ulThreadId;
        base_active* p;
        int t_count = 0;

        if (this->running)
                return 1;

        this->running = true;

        this->thread_terminate = false;

        while(!this->IsShutdown())
        {
                this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WORKING);

                if (t_count >= 600 && base_active::uThreadCount == 0)
                {
                        p = new base_active();
                        p->configure(this->innd_id,this->innd_name,this->innd_server,this->innd_uid,this->w_address,this->w_port,this->w_conn_str);

                        if (hThreadCurrent = CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)base_active::SendThread,(LPVOID)p,0,&ulThreadId))
                        {
                                base_active::uThreadCount++;
                                CloseHandle(hThreadCurrent);
//                              syslog << logfile::log_head << "Create send thread ... OK" << endl;
                        }
                        else
                        {
                                delete(p);
                                syslog << logfile::log_head << "Create send thread ... Failed" << endl;
                        }
                        t_count = 0;
                }
                Sleep(100);
                t_count++;

                //Terminate if timeout(5 minutes) or stopped
                if ((t_count >= 3000 || this->thread_terminate) && base_active::uThreadCount > 0)
                {
                        if ((hThreadCurrent = OpenThread(THREAD_TERMINATE,FALSE,ulThreadId)) == NULL)
                        {
                                syslog << logfile::log_head << "Get thread handle error in outd::work()" << endl;
                        }
                        else
                        {
                                if (TerminateThread(hThreadCurrent,-1))
                                {
                                        syslog << logfile::log_head << "Terminate send thread ... OK" << endl;
                                }
                                else
                                {
                                        syslog << logfile::log_head << "Terminate send thread ... Failed" << endl;
                                }
                                CloseHandle(hThreadCurrent);
                        }
                        base_active::uThreadCount--;
                }
        }

        this->running = false;

        return 0;
}

int outd::Shutdown(void)
{
        if (this->thread_terminate)
                return 1;

        this->thread_terminate = true;

        return 0;
}

bool outd::IsShutdown(void)
{
        return this->thread_terminate;
}

int outd::Startup(void)
{
        if (!this->thread_terminate)
                return 1;

        this->thread_terminate = false;

        return 0;
}

int outd::w_call(void)
{
        this->work();
        return 0;
}
1	sysadm	1.1	/*******************************************************/
2			/* */
3	sysadm	1.4	/* LeafOK Innbbsd */
4	sysadm	1.1	/* */
5	sysadm	1.9	/* Copyright (C) LeafOK.com, 2003-2008 */
6	sysadm	1.1	/* */
7	sysadm	1.9	/* http://www.leafok.com */
8	sysadm	1.1	/* */
9			/*******************************************************/
10
11			#include "StdAfx.h"
12			#include ".\outd.h"
13
14			using namespace std;
15
16			bool outd::thread_terminate = true;
17
18			outd::outd(void)
19			{
20			}
21
22			outd::~outd(void)
23			{
24			}
25
26			int outd::work()
27			{
28			HANDLE hThreadCurrent;
29			ULONG ulThreadId;
30	sysadm	1.2	base_active* p;
31	sysadm	1.1	int t_count = 0;
32
33			if (this->running)
34			return 1;
35
36			this->running = true;
37
38	sysadm	1.4	this->thread_terminate = false;
39
40			while(!this->IsShutdown())
41			{
42			this->GetParentThread()->GetThreadPool()->SetThreadStatus(GetCurrentThreadId(),thread_pool::S_WORKING);
43	sysadm	1.1
44	sysadm	1.4	if (t_count >= 600 && base_active::uThreadCount == 0)
45	sysadm	1.1	{
46	sysadm	1.4	p = new base_active();
47			p->configure(this->innd_id,this->innd_name,this->innd_server,this->innd_uid,this->w_address,this->w_port,this->w_conn_str);
48	sysadm	1.3
49	sysadm	1.4	if (hThreadCurrent = CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)base_active::SendThread,(LPVOID)p,0,&ulThreadId))
50	sysadm	1.1	{
51	sysadm	1.4	base_active::uThreadCount++;
52	sysadm	1.5	CloseHandle(hThreadCurrent);
53	sysadm	1.7	// syslog << logfile::log_head << "Create send thread ... OK" << endl;
54	sysadm	1.4	}
55			else
56			{
57			delete(p);
58			syslog << logfile::log_head << "Create send thread ... Failed" << endl;
59			}
60			t_count = 0;
61			}
62			Sleep(100);
63			t_count++;
64	sysadm	1.1
65	sysadm	1.4	//Terminate if timeout(5 minutes) or stopped
66			if ((t_count >= 3000 \|\| this->thread_terminate) && base_active::uThreadCount > 0)
67			{
68	sysadm	1.6	if ((hThreadCurrent = OpenThread(THREAD_TERMINATE,FALSE,ulThreadId)) == NULL)
69	sysadm	1.4	{
70	sysadm	1.6	syslog << logfile::log_head << "Get thread handle error in outd::work()" << endl;
71	sysadm	1.1	}
72	sysadm	1.4	else
73	sysadm	1.1	{
74	sysadm	1.6	if (TerminateThread(hThreadCurrent,-1))
75			{
76			syslog << logfile::log_head << "Terminate send thread ... OK" << endl;
77			}
78			else
79			{
80			syslog << logfile::log_head << "Terminate send thread ... Failed" << endl;
81			}
82			CloseHandle(hThreadCurrent);
83	sysadm	1.1	}
84	sysadm	1.4	base_active::uThreadCount--;
85	sysadm	1.1	}
86	sysadm	1.4	}
87	sysadm	1.1
88			this->running = false;
89
90			return 0;
91			}
92
93			int outd::Shutdown(void)
94			{
95			if (this->thread_terminate)
96			return 1;
97
98			this->thread_terminate = true;
99
100			return 0;
101			}
102
103			bool outd::IsShutdown(void)
104			{
105			return this->thread_terminate;
106			}
107
108			int outd::Startup(void)
109			{
110			if (!this->thread_terminate)
111			return 1;
112
113			this->thread_terminate = false;
114
115			return 0;
116			}
117
118			int outd::w_call(void)
119			{
120			this->work();
121			return 0;
122			}
webmaster@leafok.com	ViewVC Help
Powered by ViewVC 1.3.0-beta1