config.h

1)安装sp2补丁. 2)安装中文语言包. 3)关闭除系统盘除外的系统还原 4)控制面板->区域和语言选项->区域选项 选择中国,位置:选择中国.高级选项卡 非unicode程序的语

#ifndef __CONFIG_H__
#define __CONFIG_H__

#include "mgrbaseclient.h"

#define MAXDOWNTHREADS		1000

#define STATUS_READY		0
#define STATUS_PROCESS		1
#define STATUS_END			2


#define TABLE_DOWNQUE		"d_downque"
#define INDEX_DOWNQUE1		"d_downque_idx1"
#define INDEX_DOWNQUE2		"d_downque_idx2"
#define INDEX_DOWNQUE3		"d_downque_idx3"
#define INDEX_DOWNQUE4		"d_downque_idx4"




class DLConfig:public CObject
{

public:
	//members
	NetManager *m_nfm;
	//CPtrList m_db_clients;
	//CSect	 m_db_cs;
	//CSem	 *m_db_sem;

	CString	 m_db_addr;
	int		 m_db_port;
	CString  m_db_name;
	long	 m_db_maxconn;


	//NetManager *m_nfm;
	//OSFSCache  *m_osfs;
	
	CString m_dc_addr;
	int m_dc_port;
	int m_dc_maxconn;

	//CString m_workdir;
	long	 m_maxthreads;


public:
	//CString  m_helodomain;
	//int		 m_maxRCPT;
	//int		 m_maxDATA;
	//int		 m_maxsize;
	//int		 m_maxidle;
	//int		 m_timeout;


public:
	DEFINE_CLASSNEW(DLConfig)

public:
	DLConfig();
	virtual ~DLConfig();

	//methods
	BOOL init(LPCSTR profile);


	BOOL init_db(LPCSTR mgrbase_addr, int mgrbase_port, LPCSTR db_name, long maxconn);
	MGRBaseClient *take_db();
	void free_db(MGRBaseClient *client);
	
	BOOL init_dc(LPCSTR dc_addr,int dc_port,int dc_maxconn);
	BaseNetClient* take_dc();
	void free_dc(BaseNetClient *clnt);

	BaseNetClient *take_hammer(LPCSTR hammerip);
	void free_hammer(BaseNetClient *clnt);


//config file
	virtual BOOL readpf(LPCSTR profile);

	//tables
	BOOL init_tables();
	BOOL create_downque();

	//dowo que
	virtual BOOL downque_insert(int uid,LPCSTR boxid,LPCSTR mfid,LPCSTR bid,LPCSTR readkey,LPCSTR encode,
							  LPCSTR pipeid,LPCSTR pipename,int startpos,int endpos,char gettype,int size,
							  LPCSTR clntip, superint_ut& rowid);
	virtual BOOL downque_find(LPCSTR pipeid,superint_ut& rowid);
	virtual BOOL downque_remove(LPCSTR pipeid);
	virtual BOOL downque_remove(NetTable &rowids);

	virtual BOOL downque_updatestatus(superint_ut rowid,int status);
	virtual BOOL downque_updatepos(superint_ut rowid,int curpos);

	virtual int count_downque(int status);
	virtual BOOL query_downque(NetTable& downs,int num);
	virtual BOOL take_downitem(NetTable& olddata);

};


#endif