autobuild-tools/code/sys_nicmonitor/include/db_api/odb_public.h

/*******************************************************************************
ModuleName:   ODB Real Time Database management system
FileName:	  publics.h
DESCRIPTION:  public define
FUNCTION LIST:
COMMENT:      操作相关结构定义  同odb_api_struct.h
History:                                                        
Date          Version     Modifier                Activities
2002-09-01    1.0                              modify
================================================================================
2002-09-01    1.0                              created
*******************************************************************************/

#ifndef	__ODB_PUBLIC_H__
#define	__ODB_PUBLIC_H__

//公共头文件
#ifndef _WINDOWS64
#include <sys/types.h>
#include <sys/stat.h>

#include <ctype.h>
#include <string.h>
#include <stdlib.h>
#include <stdio.h>

#include <stdarg.h>

#include <fcntl.h>
#include <signal.h>
#include <errno.h>

#include <unistd.h>

#ifndef _HPUX
#include <pthread.h>
#else
#include <sys/pthread.h>
#endif

#include <dirent.h>
#include <sys/mman.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <sys/shm.h>
#include <sys/time.h>
#include <sys/times.h>

#else
#include <winsock2.h>
#include <windows.h>
#include <direct.h>
#include <io.h>
#include <process.h>
#include <time.h>
#include <sys/timeb.h>
//#include <afxmt.h>
#endif

#include <string>
#include <vector>
#include <map>
#include <memory>
#include <algorithm>
#include <utility>
#include <iostream>
#include "ThreadKit/ThreadKit.h"

#ifndef __ODB_DEFINE_H__
#include "db_api/odb_define.h"
#endif

#include "db_api/odb_struct.h"

//namespace ODB
//{
	struct TABLE_PARA
	{
		char                table_name_eng[ENG_NAME_LEN];
		char                table_name_chn[CHN_NAME_LEN];
		int                 key_len;
		int                 subkey_num;
		int                 record_number;
		int                 record_size;
		short               field_sum;
		unsigned char       is_auto_generated;   //key_generate_type
	
	};
	
	struct FIELD_PARA
	{
		int                 table_id;						//表ID号		INT
		short               field_id;						//域ID号	        SHORT
		short               column_id;						//域内部ID号           	SHORT
		char                field_name_eng[ENG_NAME_LEN];			//域英文名	        STRING(32)
		char                field_name_chn[CHN_NAME_LEN];			//域中文名	        STRING(64)
		short               field_length;					//数据长度	        SHORT
		unsigned char       data_type;						//数据类型	        UCHAR
		unsigned char       is_keyword;						//是否主键	        UCHAR
		unsigned char       allow_null;						//是否允许空值	    UCHAR
			
		int                 app_type;						//应用类型	        INT
		unsigned char       is_app_syn;						//是否更新时全应用同步 	UCHAR
		unsigned char       index_order_no;					//检索器索引顺序号	UCHAR
		unsigned char       sort_order_no;					//默认排序顺序号	UCHAR
	
	//   //   //   //	//
		unsigned char       is_input;						//是否允许输入	       	UCHAR
		unsigned char       is_display;						//是否显示	        UCHAR
		short               display_order_no;					//显示顺序号	       	SHORT
		unsigned char       is_fix;						//卷滚时是否固定	UCHAR
		short               display_length;					//默认显示长度	        SHORT
		unsigned char       display_precision;					//小数显示精度	        UCHAR
		unsigned char       align_type;						//对齐方式	        UCHAR
		unsigned char       display_type;					//显示类型	        UCHAR
		char                menu_name[MENU_NAME_LEN];				//菜单名	        STRING(40)
		
		unsigned char       reference_flag;					//数据引用类型	       	UCHAR
		unsigned char       reference_mode;					//数据引用方式	       	UCHAR
		int                 reference_table;					//引用表名	        INT
		short               reference_column;					//引用域号	        SHORT
		unsigned char       reference_display;					//被引用时是否显示	UCHAR
		
		char                init_value[DEFAULT_VALUE_LEN];			//缺省值	        STRING(20)
		char                min_value[DEFAULT_VALUE_LEN];			//最小值	        STRING(20)
		char                max_value[DEFAULT_VALUE_LEN];			//最大值	        STRING(20)
		
		int                 column_special;					//域特殊属性	       	INT        
		unsigned char       auto_meas_type;					//自动生成量测类型	UCHAR
		short               gen_array_dimension;				//数组维数	        SHORT
		char                gen_array_name[ARRAY_NAME_LEN];			//数组名称	        STRING(32)
		char                column_description[DESCRIPTION_LEN];		//域描述信息   		STRING(100)
	
		unsigned char       is_index;						//	
		int                 offset;                         			//added by RTDBMS
	};
	
	
	
	////////////////////////////////////////////////////////////////////////////////
	//      for down load                                           //
	//                                                                            //
	////////////////////////////////////////////////////////////////////////////////
	
	/*============================================================================*/
	
	struct STDB_CREAT_REQ
	{
		int                 app_no;	
		int                 table_no;
		int                 table_version;
		int                 field_sum;          //short
#ifdef _APP_SYS_SUBSTATION		
		int					bit_field_sum;
		int					vir_field_sum;
#endif		
		char                table_name_eng[ENG_NAME_LEN];
		char                table_name_chn[CHN_NAME_LEN];
		int                 record_num;
		int                 record_sum;
		int                 record_length;      //short
			
		unsigned char       is_system_table;
		unsigned char       is_auto_generated;  //key_generate_type;
		unsigned char       is_record_apped;
		unsigned char       is_record_lock;
		unsigned char       is_record_resp;
		
		DB_MEDIA_T          stdb_media;                            //no used
		ACCESS_METHODS_T    access_meth;                           //
		int                 seq_field_no;                          //
		char                passwd[MAX_NAME_STRING_LEN];           //
		
		
		int                 table_type;                            //for graph, etc
		
		/******Added for index begin ************/
		int	pk_index_method;
		int	pk_storage_type;//主键存储方法，譬如共享内存或者文件映射内存。
		int	pk_mem_alloc_type;//主键内存分配方法，譬如带溢出HASH的分配方法；无溢出的HASH分配方法。
		/******Added for index end**************/

		int                 reserved_1;
		int                 reserved_2;
		int                 reserved_3;
		int                 reserved_4;
		int                 reserved_5;
		int             	area_num;
		int             	area_no[MAX_AREA_NUM];
		char             	area_name[MAX_AREA_NUM][ENG_NAME_LEN];
		int 								slice_flag;
	};
	
	struct FIELD_CREAT_REQ
	{
		int                 app_no;             //app_type
		short               field_no;
		short               r_field_no;
		short               field_id;
		short               column_id;
		short               field_length;
#ifdef _APP_SYS_SUBSTATION
		short				is_bit_field;
#endif		
		char                field_name_eng[ENG_NAME_LEN];
		char                field_name_chn[CHN_NAME_LEN];
			
		int                 column_special;
		int                 ref_tableno;        //long reference_table; 
		short               ref_fieldno;        //short reference_column;
		
		unsigned char       reference_flag;
		unsigned char       reference_mode;
		unsigned char       reference_display;
		
		unsigned char       data_type;
		unsigned char       allow_null;
		unsigned char       is_keyword;
		unsigned char       display_type;
		unsigned char       is_index;           //octet index_order_no;
		unsigned char       sort_order_no;
	
		unsigned char       is_app_syn;
		unsigned char       auto_meas_type;
		
		char                menu_name[MENU_NAME_LEN];
		char                default_asciival[DEFAULT_VALUE_LEN];  //init_value
		char                min_asciival[DEFAULT_VALUE_LEN];      //min_value
		char                max_asciival[DEFAULT_VALUE_LEN];      //max_value
	
	
		int                 search_attribute;   //  检索器的域特性           //Added 2003-09-01
		int                 statics_attribute;  //  统计的域特性
		int                 reserved_1;         //  系统保留
		int                 reserved_2;         //  系统保留
		int                 reserved_3;         //  系统保留
		int                 reserved_4;         //  系统保留
		int                 reserved_5;         //  系统保留
	};
	
#ifdef _APP_SYS_SUBSTATION	
	struct VIR_FIELD_CREAT_REQ
	{
		short               v_field_no;  //rtdbms
		short               vr_field_no;
		short               r_field_no; //bit field no
		short				bit_no;
		char                vir_field_name_eng[ENG_NAME_LEN];
		char                vir_field_name_chn[CHN_NAME_LEN];
	};
#endif
	
	struct STDB_DELETE_REQ 
	{
		int  app_no;
		int  table_no;
		char passwd[MAX_PASSWD_LEN];
	};
	
	
	//struct FIELD_TYPE
	//{
	//	short field_no;
	//	short field_type;                   //data type for get; byte len for write
	//};
	
	struct FIELD_BASE_INFO
	{
		int             offset;
		int             field_length;
		short           field_no;
		unsigned char   data_type;
		unsigned char   is_keyword;
	};
	
	
#ifndef __i386	
	static char strFILE[100];
	static int iLINE;
#endif
	
#ifndef __i386	
//	#define TRACE  strFILE =  __FILE__; iLINE = __LINE__;  odb_trace
	#define TRACE  strcpy(strFILE, __FILE__); iLINE = __LINE__;  printf("\t%s:%d-->",strFILE,iLINE); odb_trace
#else
	#define TRACE(...)   odb_trace(__FILE__, __LINE__, __VA_ARGS__)
#endif

#ifndef _WINDOWS64
#ifndef __i386
	inline void odb_trace(const char *p,...)
	{
#else
	inline void odb_trace(const char *strFILE, const int iLINE, const char *p,...)
	{
		printf("\t%s:%d-->",strFILE,iLINE);
#endif
/*
#ifndef __i386	
	static char strFILE[100];
	static int iLINE;
	//	#define TRACE  strFILE =  __FILE__; iLINE = __LINE__;  odb_trace
	#define TRACE  strcpy(strFILE, __FILE__); iLINE = __LINE__;  printf("\t%s:%d-->",strFILE,iLINE); odb_trace
	inline void odb_trace(const char *p,...)
	{
#else
	#define TRACE(...)   odb_trace(__FILE__, __LINE__, __VA_ARGS__)
	inline void odb_trace(const char *strFILE, const int iLINE, const char *p,...)
	{
		printf("\t%s:%d-->",strFILE,iLINE);
#endif
*/
		static pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER;
		va_list va;
		va_start(va,p);
		
		pthread_mutex_lock(&lock);
		vfprintf(stdout,p,va);
		fflush(stdout);
		pthread_mutex_unlock(&lock);
		va_end(va);
	}
#else
    inline void odb_trace(const char *p,...)
    {
		/*
        //printf("\t%s:%d-->",strFILE,iLINE);
		static CRITICAL_SECTION cs; //定义临界区
		InitializeCriticalSection(&cs);//初始化临界区

        va_list va;
        va_start(va,p);
        
		EnterCriticalSection(&cs);//加锁
        vfprintf(stdout,p,va);
        fflush(stdout);
		LeaveCriticalSection(&cs);//解锁
        va_end(va);
		*/
		 //printf("\t%s:%d-->",strFILE,iLINE);
		THREADKIT::Mutex g_mutex;
        va_list va;
        va_start(va,p);
        
		{
			THREADKIT::Guard<THREADKIT::Mutex> guard(g_mutex);
			vfprintf(stdout,p,va);
			fflush(stdout);
    }
        va_end(va);
		
    }

#endif

class SecClock
{
public:
	SecClock(int time_out):timer(time(NULL)),time_out(time_out){}
	bool TimeOut(){return time(NULL)-timer>time_out;}
private:
	time_t timer;
	int time_out;	

};		
	
	/*============================================================================*/
	
	extern "C"
	{
		void do_nothing1(int nn);
		void do_nothing2(int nn);
	}
//}	
#endif