LeafOK_CVS/innwebd/base.h

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

#pragma once

#include "afxdb.h"
#include "winsock2.h"
#include ".\thread_pool.h"

class base
{
public:
        base(void);
        ~base(void);
        virtual void configure(const char* innd_id, const char* innd_name, const char* innd_server, unsigned long innd_uid, const char* w_address, unsigned int w_port, const char* w_conn_str);
        int begin(void);
        int end(void);
        inline bool IsRunning(void)
        {
                return (this->running && this->IsThreadActive());
        }
        inline base* GetParentThread(void)
        {
                return this->p_ParentThread;
        }
        inline void SetParentThread(base* p_ParentThread)
        {
                this->p_ParentThread = p_ParentThread;
        }
        inline thread_pool* GetThreadPool(void)
        {
                return this->p_ThreadPool;
        }
        inline void SetThreadPool(thread_pool* p_ThreadPool)
        {
                this->p_ThreadPool = p_ThreadPool;
        }
protected:
        ULONG ulMainThreadId;
        base* p_ParentThread;
        thread_pool* p_ThreadPool;
        SOCKET s;
        SOCKADDR sockaddr;
        CDatabase Db;
        bool isConnected;
        bool running;
        unsigned long innd_uid;
        char innd_id[50];
        char innd_name[50];
        char innd_server[256];
        unsigned int w_port;
        char w_address[50];
        char w_conn_str[256];
        char hostaddr[50];
        unsigned int port;
        int bbs_post(const CString& head, const CString& body, int sid, long art_id);
        long last_insert_id(void);
        int bbs_delete(long id);
        static CString addslashes(CString str);
        int db_open(const char* conn_str = "ODBC;");
        int db_close(void);
        virtual int s_connect(const char* hostname, unsigned int port) = 0;
        virtual int s_close(void) = 0;
        int s_send(const char* in_str, bool auto_endl = true);
        int s_receive(CString& out_str, char end_str[] = "\r");
        int s_exec(const char* in_str, CString& out_str, char end_str[] = "\r");
        virtual bool IsShutdown(void);
        virtual int Shutdown(void);
        virtual int Startup(void);
        virtual int w_call() = 0;
private:
        static DWORD Thread(LPVOID pParam);
public:
        bool IsThreadActive(void);
};

1	sysadm	1.1	/*******************************************************/
2			/* */
3	sysadm	1.3	/* LeafOK Innbbsd */
4	sysadm	1.1	/* */
5	sysadm	1.8	/* Copyright (C) LeafOK.com, 2003-2008 */
6	sysadm	1.1	/* */
7	sysadm	1.8	/* http://www.leafok.com */
8	sysadm	1.1	/* */
9			/*******************************************************/
10
11			#pragma once
12
13			#include "afxdb.h"
14			#include "winsock2.h"
15	sysadm	1.2	#include ".\thread_pool.h"
16	sysadm	1.1
17			class base
18			{
19			public:
20			base(void);
21			~base(void);
22			virtual void configure(const char* innd_id, const char* innd_name, const char* innd_server, unsigned long innd_uid, const char* w_address, unsigned int w_port, const char* w_conn_str);
23			int begin(void);
24			int end(void);
25	sysadm	1.2	inline bool IsRunning(void)
26			{
27	sysadm	1.3	return (this->running && this->IsThreadActive());
28	sysadm	1.2	}
29			inline base* GetParentThread(void)
30			{
31			return this->p_ParentThread;
32			}
33			inline void SetParentThread(base* p_ParentThread)
34			{
35			this->p_ParentThread = p_ParentThread;
36			}
37			inline thread_pool* GetThreadPool(void)
38			{
39			return this->p_ThreadPool;
40			}
41			inline void SetThreadPool(thread_pool* p_ThreadPool)
42			{
43			this->p_ThreadPool = p_ThreadPool;
44			}
45	sysadm	1.1	protected:
46	sysadm	1.3	ULONG ulMainThreadId;
47	sysadm	1.2	base* p_ParentThread;
48			thread_pool* p_ThreadPool;
49	sysadm	1.1	SOCKET s;
50			SOCKADDR sockaddr;
51			CDatabase Db;
52			bool isConnected;
53			bool running;
54			unsigned long innd_uid;
55			char innd_id[50];
56			char innd_name[50];
57			char innd_server[256];
58			unsigned int w_port;
59			char w_address[50];
60			char w_conn_str[256];
61			char hostaddr[50];
62			unsigned int port;
63			int bbs_post(const CString& head, const CString& body, int sid, long art_id);
64			long last_insert_id(void);
65			int bbs_delete(long id);
66			static CString addslashes(CString str);
67			int db_open(const char* conn_str = "ODBC;");
68			int db_close(void);
69			virtual int s_connect(const char* hostname, unsigned int port) = 0;
70			virtual int s_close(void) = 0;
71			int s_send(const char* in_str, bool auto_endl = true);
72	sysadm	1.6	int s_receive(CString& out_str, char end_str[] = "\r");
73			int s_exec(const char* in_str, CString& out_str, char end_str[] = "\r");
74	sysadm	1.1	virtual bool IsShutdown(void);
75			virtual int Shutdown(void);
76			virtual int Startup(void);
77			virtual int w_call() = 0;
78			private:
79			static DWORD Thread(LPVOID pParam);
80	sysadm	1.3	public:
81			bool IsThreadActive(void);
82	sysadm	1.1	};
83
webmaster@leafok.com	ViewVC Help
Powered by ViewVC 1.3.0-beta1