#include <stdio.h>
#include <stdlib.h>
#include <assert.h>
#include <unistd.h>
#include <time.h>
#include "MESA_prof_load.h"
#include "MESA_handle_logger.h"
#include "Maat_rule.h"
#include "Maat_command.h"
#include "ir_mctrl.h"
#include "MESA_htable.h"

struct mctrl_glocal_info mctrl_g;

void s_d_start_cb(int update_type,void* u_para)
{
	if(update_type==MAAT_RULE_UPDATE_TYPE_FULL)
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_INFO,(char*)"maat_rule_type", "table_name:%d,Maat rule type is full",*(int*)u_para);
		switch(*(int*)u_para)
		{
			case DYNAMIC_NOMINEE_FLAG:
				mctrl_g.update_type_d=MAAT_RULE_UPDATE_TYPE_FULL;
				mctrl_g.version_d++;
				MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_INFO,(char*)"maat_rule_type", "table_name:%d,version:%d",*(int*)u_para,mctrl_g.version_d);
				break;
			case STATIC_NOMINEE_FLAG:
				mctrl_g.update_type_s=MAAT_RULE_UPDATE_TYPE_FULL;
				mctrl_g.version_s++;
				MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_INFO,(char*)"maat_rule_type", "table_name:%d,version:%d",*(int*)u_para,mctrl_g.version_s);
				break;
			case DNAT_POLICY_FLAG:	
				mctrl_g.update_type_dp=MAAT_RULE_UPDATE_TYPE_FULL;
				mctrl_g.version_dp++;
				MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_INFO,(char*)"maat_rule_type", "table_name:%d,version:%d",*(int*)u_para,mctrl_g.version_dp);
				break;
			default:
				MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_INFO,(char*)"maat_start_cb", "maat_start_cb table name error!!!");
				assert(0);
				break;
		}
	}
	else
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_INFO,(char*)"maat_rule_type", "table_name:%d,Maat rule type is inc",*(int*)u_para);
	}
	return;
}


void n_i_c_start_cb(int update_type,void* u_para)
{
	if(update_type==MAAT_RULE_UPDATE_TYPE_FULL)
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_INFO,(char*)"maat_rule_type", "table_name:%d,Maat rule type is full",*(int*)u_para);
	}
	else
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_INFO,(char*)"maat_rule_type", "table_name:%d,Maat rule type is inc",*(int*)u_para);
	}
	return;
}

void mctrl_get_cur_time(char *date)
{   
	time_t t;
    struct tm *lt;
    time(&t);
    lt = localtime(&t);
    snprintf(date, MAX_TIME_LEN,"%d/%d/%d/%d:%d:%d",lt->tm_year+1900, lt->tm_mon+1, lt->tm_mday, lt->tm_hour, lt->tm_min, lt->tm_sec);
}


int set_ir_line(Maat_feather_t feather,const char *ir_table_name,const char *table_line,int rule_id)
{
	const struct Maat_line_t *p_line;
	struct Maat_line_t line_rule;
	int ret = 0;
	char m_table_line[HTABLE_DATA_LEN];
	struct IR_MCTRL_INFO nom_info;
	memset(&nom_info,0,sizeof(nom_info));
	memset(&line_rule, 0,sizeof(line_rule));

	line_rule.label_id=0;
	line_rule.rule_id=rule_id;
	line_rule.table_name=ir_table_name;

	sscanf(table_line, "%d\t%d\t%d\t%d\t%d\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%d\t%d\t%d\t%d\t%d\t%d\t%s\t%s\t%s", 
		&nom_info.htable_flag,&nom_info.version,&nom_info.region_id,&nom_info.group_id,&nom_info.addr_type,
		nom_info.src_ip,nom_info.mask_src_ip,nom_info.src_port,nom_info.mask_src_port,nom_info.dst_ip,nom_info.mask_dst_ip,
		nom_info.dst_port,nom_info.mask_dst_port,&nom_info.procotol,&nom_info.direction,&nom_info.addr_pool_id,&nom_info.is_valid,
		&nom_info.action,&nom_info.service,nom_info.user_region,nom_info.effective_range,nom_info.op_time);

	mctrl_get_cur_time(nom_info.op_time);
	
	if(!memcmp(ir_table_name,NOMINEE_TABLE_NAME,strlen(NOMINEE_TABLE_NAME)))
	{
		snprintf(m_table_line,sizeof(m_table_line),"%d\t%d\t%d\t%s\t%d\t%s\t%s",
			rule_id,nom_info.addr_pool_id,nom_info.addr_type,nom_info.src_ip,nom_info.is_valid,nom_info.effective_range,nom_info.op_time);
	}
	else 
	{
		snprintf(m_table_line,sizeof(m_table_line),"%d\t%d\t%d\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%d\t%d\t%d\t%d\t%d\t%s\t%s\t%s",
			rule_id,nom_info.group_id,nom_info.addr_type,
			nom_info.src_ip,nom_info.mask_src_ip,nom_info.src_port,nom_info.mask_src_port,nom_info.dst_ip,nom_info.mask_dst_ip,
			nom_info.dst_port,nom_info.mask_dst_port,nom_info.procotol,nom_info.direction,
			nom_info.is_valid,nom_info.action,nom_info.service,nom_info.user_region,nom_info.effective_range,nom_info.op_time);
	}
	
	line_rule.table_line=m_table_line;
	line_rule.expire_after=0;
	p_line=&line_rule;

	ret=Maat_cmd_set_line(feather, p_line, MAAT_OP_ADD);

	MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_FATAL, (char*)"maat_update", "set_table_name:%s  set_table_line:%s",ir_table_name,m_table_line);
	
	if(ret==-1)
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_FATAL, (char*)"SET_LINE","%s:set redis line error",ir_table_name);
	}
	else
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_FATAL, (char*)"SET_LINE","%s:set redis line success",ir_table_name);
	}
	return ret;
}


int del_ir_line(Maat_feather_t feather,const char *ir_table_name,const char *table_line,int rule_id)
{
	int ret=0;
	
	const struct Maat_line_t *p_line;
	struct Maat_line_t line_rule;
	memset(&line_rule,0,sizeof(line_rule));
	
	line_rule.label_id=0;
	line_rule.rule_id=rule_id;
	line_rule.table_name=ir_table_name;
	line_rule.table_line=NULL;
	if(!memcmp(ir_table_name,NOMINEE_TABLE_NAME,strlen(NOMINEE_TABLE_NAME)))
	{
		line_rule.expire_after=0;
		p_line=&line_rule;
		ret=Maat_cmd_set_line(feather, p_line, MAAT_OP_DEL);
	}
	else
	{
		line_rule.expire_after=TIME_OUT;
		p_line=&line_rule;
		ret=Maat_cmd_set_line(feather, p_line, MAAT_OP_RENEW_TIMEOUT);
	}

	MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_FATAL, (char*)"maat_update", "del_table_name:%s  del_table_line:%s",ir_table_name,table_line);

	if(ret==-1)
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_FATAL, (char*)"DEL_LINE","%s:del redis line error",ir_table_name);
	}
	else 
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_FATAL, (char*)"DEL_LINE","%s:del redis line success",ir_table_name);
	}
	return ret;
	
}

long del_update_search_htable_cb(void *data, const uchar *key, uint size, void *user_arg)
{
	int htable_flag=0;
	char *htable_data=(char*)data;
	if(htable_data!=NULL)
	{
		sscanf(htable_data,"%d\t",&htable_flag);
	}
	return htable_flag;
}

long set_update_search_htable_cb(void *data, const uchar *key, uint size, void *user_arg)
{
	struct IR_MCTRL_INFO nom_info;
	char *htable_data=(char*)data;
	
	if(htable_data!=NULL)
	{
		sscanf(htable_data,"%d\t%d\t%d\t%d\t%d\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%d\t%d\t%d\t%d\t%d\t%d\t%s\t%s\t%s", 
			&nom_info.htable_flag,&nom_info.version,&nom_info.region_id,&nom_info.group_id,&nom_info.addr_type,
			nom_info.src_ip,nom_info.mask_src_ip,nom_info.src_port,nom_info.mask_src_port,nom_info.dst_ip,nom_info.mask_dst_ip,
			nom_info.dst_port,nom_info.mask_dst_port,&nom_info.procotol,&nom_info.direction,&nom_info.addr_pool_id,&nom_info.is_valid,
			&nom_info.action,&nom_info.service,nom_info.user_region,nom_info.effective_range,nom_info.op_time);
		
		if(nom_info.htable_flag & DYNAMIC_NOMINEE_FLAG)
		{
			nom_info.version=mctrl_g.version_d; 	
			MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_DEBUG, (char*)"set_update_search_htable_cb","get htable flag:%d! version:%d!",nom_info.htable_flag,nom_info.version);
		}
		else if(nom_info.htable_flag & STATIC_NOMINEE_FLAG)
		{
			nom_info.version=mctrl_g.version_s; 
			MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_DEBUG, (char*)"set_update_search_htable_cb","get htable flag:%d! version:%d!",nom_info.htable_flag,nom_info.version);
		}
		else if(nom_info.htable_flag & DNAT_POLICY_FLAG)
		{
			nom_info.version=mctrl_g.version_dp;
			MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_DEBUG, (char*)"set_update_search_htable_cb","get htable flag:%d! version:%d!",nom_info.htable_flag,nom_info.version);
		}
		else
		{
			MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_DEBUG, (char*)"set_update_search_htable_cb","get htable flag:%d!",nom_info.htable_flag);
		}
	
		snprintf(htable_data,HTABLE_DATA_LEN, "%d\t%d\t%d\t%d\t%d\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%d\t%d\t%d\t%d\t%d\t%d\t%s\t%s\t%s", 
			nom_info.htable_flag,nom_info.version,nom_info.region_id,nom_info.group_id,nom_info.addr_type,
			nom_info.src_ip,nom_info.mask_src_ip,nom_info.src_port,nom_info.mask_src_port,nom_info.dst_ip,nom_info.mask_dst_ip,
			nom_info.dst_port,nom_info.mask_dst_port,nom_info.procotol,nom_info.direction,nom_info.addr_pool_id,nom_info.is_valid,
			nom_info.action,nom_info.service,nom_info.user_region,nom_info.effective_range,nom_info.op_time);
	}
	else
	{	
		MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_INFO, (char*)"set_update_search_htable_cb","htable info not exist！,set error!!!");
		assert(0);
	}
	return nom_info.htable_flag;
}


long n_i_c_update_search_htable_cb(void *data, const uchar *key, uint size, void *user_arg)
{
	int htable_flag=0;
	struct IR_MCTRL_INFO nom_info;
	char *htable_data=(char*)data;
	
	if(htable_data==NULL)
	{
		return htable_flag;
	}
	
	sscanf((char*)data, "%d\t%d\t%d\t%d\t%d\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%d\t%d\t%d\t%d\t%d\t%d\t%s\t%s\t%s", 
		&htable_flag,&nom_info.version,&nom_info.region_id,&nom_info.group_id,&nom_info.addr_type,
		nom_info.src_ip,nom_info.mask_src_ip,nom_info.src_port,nom_info.mask_src_port,nom_info.dst_ip,nom_info.mask_dst_ip,
		nom_info.dst_port,nom_info.mask_dst_port,&nom_info.procotol,&nom_info.direction,&nom_info.addr_pool_id,&nom_info.is_valid,
		&nom_info.action,&nom_info.service,nom_info.user_region,nom_info.effective_range,nom_info.op_time);

	switch(*(int*)user_arg)
	{
		case INTERCEPT_FLAG:
			if(!(htable_flag & INTERCEPT_FLAG))	
			{	
				htable_flag+=INTERCEPT_FLAG;
			}
			break;
		case NOMINEE_FLAG:
			if(!(htable_flag & NOMINEE_FLAG))
			{
				htable_flag+=NOMINEE_FLAG;
			}
			break;
		case CANDIDATE_FLAG:
			if(!(htable_flag & CANDIDATE_FLAG))
			{
				htable_flag+=CANDIDATE_FLAG;
			}
			break;
		default:
			MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_DEBUG, (char*)"n_i_c_update_search_htable_cb","htable flag is:%d",htable_flag);	
			break;
	}
	
	snprintf(htable_data,HTABLE_DATA_LEN, "%d\t%d\t%d\t%d\t%d\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%d\t%d\t%d\t%d\t%d\t%d\t%s\t%s\t%s", 
		htable_flag,nom_info.version,nom_info.region_id,nom_info.group_id,nom_info.addr_type,
		nom_info.src_ip,nom_info.mask_src_ip,nom_info.src_port,nom_info.mask_src_port,nom_info.dst_ip,nom_info.mask_dst_ip,
		nom_info.dst_port,nom_info.mask_dst_port,nom_info.procotol,nom_info.direction,nom_info.addr_pool_id,nom_info.is_valid,
		nom_info.action,nom_info.service,nom_info.user_region,nom_info.effective_range,nom_info.op_time);
		
	MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_DEBUG, (char*)"n_i_c_update_search_htable_cb","htable flag change:%d",htable_flag);	
	
	
	return htable_flag;
}

void del_redis_info(int flag,const char* table_line,int rule_id)
{

	if(flag & INTERCEPT_FLAG)
	{
		del_ir_line(mctrl_g.i_feather,(char*)INTERCEPT_TABLE_NAME,table_line,rule_id);
	}

	if(flag & NOMINEE_FLAG)
	{
		del_ir_line(mctrl_g.n_feather,(char*)NOMINEE_TABLE_NAME,table_line,rule_id);
	}

	if(flag & CANDIDATE_FLAG)
	{
		del_ir_line(mctrl_g.n_feather,(char*)CANDIDATE_TABLE_NAME,table_line,rule_id);
	}
	
	return;
}

void n_i_c_table_update_cb(int table_id,const char* table_line,void* u_para)
{
	int rule_id=0;
	void *htable_data=NULL;
	int is_valid=-1;
	long search_ret=0;

	switch(*(int*)u_para)
	{
		case NOMINEE_FLAG:
			sscanf(table_line,"%d\t%*d\t%*d\t%*s\t%d",&rule_id,&is_valid);
			if(rule_id<DNAT_NUMBER)
			{
				del_ir_line(mctrl_g.n_feather,(char*)NOMINEE_TABLE_NAME,table_line,rule_id);
			}
			break;
		case INTERCEPT_FLAG:
			sscanf(table_line,"%d\t%*d\t%*d\t%*s\t%*s\t%*s\t%*s\t%*s\t%*s\t%*s\t%*s\t%*d\t%*d\t%d",&rule_id,&is_valid);
			break;
		case CANDIDATE_FLAG:
			sscanf(table_line,"%d\t%*d\t%*d\t%*s\t%*d\t%d",&rule_id,&is_valid);
			break;
		default:	
			MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_FATAL, (char*)"READ_TABLE_UPDATA","read n_i_c_table error!!!");
			assert(0);
			break;
	}

	unsigned char *key_id=(unsigned char*)&rule_id;

	if(is_valid==0)
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_FATAL, (char*)"READ_TABLE_UPDATA"," del table_name:%d,data:%s is_valid==0,del succeed",*(int*)u_para,table_line);
		return;
	}
	
	htable_data=MESA_htable_search_cb(mctrl_g.s_d_htable,key_id,sizeof(rule_id), n_i_c_update_search_htable_cb,u_para,&search_ret);

	if(htable_data==NULL)
	{
		del_redis_info(*(int*)u_para,table_line,rule_id);
	}
	else
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_DEBUG, (char*)"READ_TABLE_UPDATA","already exist!");
	}
	return;
}

void htable_data_free(void *data)
{
	if(data!=NULL)
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_INFO, (char*)"DATA_FREE","htable_data_free!");
		free(data);
		data=NULL;
	}
	return;
}

void set_redis_info(int flag,const char* table_line,int rule_id)
{
	if(!(flag & INTERCEPT_FLAG))
	{
		set_ir_line(mctrl_g.i_feather, (char*)INTERCEPT_TABLE_NAME,table_line,rule_id);
	}

	if((!(flag & NOMINEE_FLAG))&&(!(flag & DNAT_POLICY_FLAG)))
	{
		set_ir_line(mctrl_g.n_feather,(char*)NOMINEE_TABLE_NAME,table_line,rule_id);
	}

	return;
}

void s_d_table_update_cb(int table_id,const char* table_line,void* u_para)
{
	int add_ret=0;
	struct IR_MCTRL_INFO nom_info;
	memset(&nom_info,0,sizeof(nom_info));
	char *htable_data=NULL;
	void *search_result=NULL;
	int rule_id=0;
	int del_ret=0;
	long cb_ret=0;
	switch(*(int*)u_para)
	{
		case DYNAMIC_NOMINEE_FLAG:
			nom_info.addr_pool_id=0;
			nom_info.group_id=nom_info.region_id;
			memcpy(nom_info.src_port,"0",sizeof("0"));
			memcpy(nom_info.mask_src_ip,"0.0.0.0",sizeof("0.0.0.0"));
			memcpy(nom_info.mask_src_port,"0",sizeof("0"));
			memcpy(nom_info.dst_ip,"0.0.0.0",sizeof("0.0.0.0"));
			memcpy(nom_info.mask_dst_ip,"0.0.0.0",sizeof("0.0.0.0"));
			memcpy(nom_info.dst_port,"0",sizeof("0"));
			memcpy(nom_info.mask_dst_port,"0",sizeof("0"));
			memcpy(nom_info.effective_range,"{}",sizeof("{}"));
			nom_info.action=96;
			nom_info.service=832;
			nom_info.htable_flag=DYNAMIC_NOMINEE_FLAG;
			sscanf(table_line,"%d\t%d\t%d\t%s\t%*s\t%d\t%s\t%*d\t%d\t%d\t%*d\t%*s\t%*s", 
				&nom_info.region_id,&nom_info.addr_type,&nom_info.procotol,nom_info.src_ip,
				&nom_info.direction,nom_info.user_region,&nom_info.is_valid,&nom_info.service);
			nom_info.region_id=(nom_info.region_id%SNAT_DYNAMIC_NUMBER)+SNAT_DYNAMIC_NUMBER;
			break;
		case STATIC_NOMINEE_FLAG:
			memcpy(nom_info.user_region,"0",sizeof("0"));
			memcpy(nom_info.effective_range,"{}",sizeof("{}"));
			nom_info.service=832;	
			nom_info.htable_flag=STATIC_NOMINEE_FLAG;
			sscanf(table_line,"%d\t%d\t%d\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%d\t%d\t%d\t%d\t%d\t%*d\t%*s\t%*s", 
				&nom_info.region_id,&nom_info.group_id,&nom_info.addr_type,
				nom_info.src_ip,nom_info.mask_src_ip,nom_info.src_port,nom_info.mask_src_port,nom_info.dst_ip,nom_info.mask_dst_ip,
				nom_info.dst_port,nom_info.mask_dst_port,&nom_info.procotol,&nom_info.direction,&nom_info.addr_pool_id,&nom_info.is_valid,
				&nom_info.action);
			nom_info.region_id=(nom_info.region_id%DNAT_NUMBER)+DNAT_NUMBER;
			break;
		case DNAT_POLICY_FLAG:
			memcpy(nom_info.src_ip,"0.0.0.0",sizeof("0.0.0.0"));
			memcpy(nom_info.src_port,"0",sizeof("0"));
			memcpy(nom_info.mask_src_ip,"0.0.0.0",sizeof("0.0.0.0"));
			memcpy(nom_info.mask_src_port,"0",sizeof("0"));
			memcpy(nom_info.mask_dst_ip,"0.0.0.0",sizeof("0.0.0.0"));
			memcpy(nom_info.mask_dst_port,"0",sizeof("0"));
			memcpy(nom_info.user_region,"0",sizeof("0"));
			memcpy(nom_info.effective_range,"{}",sizeof("{}"));
			nom_info.direction=0;
			nom_info.action=96;
			nom_info.service=832;
			nom_info.htable_flag=DNAT_POLICY_FLAG;
			sscanf(table_line,"%d\t%d\t%s\t%s\t%d\t%*s\t%*s\t%d\t%*d\t%*d\t%d\t%*s\t%*s", 
				&nom_info.region_id,&nom_info.addr_type,nom_info.dst_ip,nom_info.dst_port,&nom_info.procotol,
				&nom_info.do_log,&nom_info.is_valid);
			nom_info.group_id=nom_info.region_id;
			nom_info.region_id=nom_info.region_id%DNAT_NUMBER;
			break;
		default:	
			MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_DEBUG, (char*)"read_snat_dnat","read_snat_or_dnat table error!!");
			assert(0);
			break;
	}

	unsigned char *key_id=(unsigned char*)&nom_info.region_id;
	rule_id=nom_info.region_id;

	if(nom_info.is_valid==1) 
	{
		htable_data=(char*)malloc(HTABLE_DATA_LEN);
		snprintf(htable_data,HTABLE_DATA_LEN,"%d\t%d\t%d\t%d\t%d\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%d\t%d\t%d\t%d\t%d\t%d\t%s\t%s\t%s", 
			nom_info.htable_flag,nom_info.version,nom_info.region_id,nom_info.group_id,nom_info.addr_type,
			nom_info.src_ip,nom_info.mask_src_ip,nom_info.src_port,nom_info.mask_src_port,nom_info.dst_ip,nom_info.mask_dst_ip,
			nom_info.dst_port,nom_info.mask_dst_port,nom_info.procotol,nom_info.direction,nom_info.addr_pool_id,nom_info.is_valid,
			nom_info.action,nom_info.service,nom_info.user_region,nom_info.effective_range,nom_info.op_time);
		
		add_ret=MESA_htable_add(mctrl_g.s_d_htable,key_id,sizeof(rule_id),htable_data);

		if(add_ret<0)
		{
			MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_DEBUG, (char*)"ADD_S_AND_D_NOMINEE_HASH","add htable error:%d",add_ret);
		}
		else
		{
			MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_DEBUG, (char*)"ADD_S_AND_D_NOMINEE_HASH","add htable succeed:%d",add_ret);
		}

		
		MESA_htable_search_cb(mctrl_g.s_d_htable,key_id,sizeof(rule_id),set_update_search_htable_cb,NULL,&cb_ret);

		set_redis_info(cb_ret,htable_data,rule_id);
		
	}
	else if(nom_info.is_valid==0)
	{
		search_result=MESA_htable_search_cb(mctrl_g.s_d_htable,key_id,sizeof(rule_id),del_update_search_htable_cb,NULL,&cb_ret);
		
		if(search_result==NULL)
		{
			MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_FATAL, (char*)"write_update", "already del!!!");
			return;
		}

		del_redis_info(cb_ret,table_line,rule_id);
		
		del_ret=MESA_htable_del(mctrl_g.s_d_htable,key_id,sizeof(rule_id),htable_data_free);
		
		if(del_ret<0)
		{
			MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_DEBUG, (char*)"DEL_S_AND_D_NOMINEE","del htable error:%d",del_ret);
		}
	}
	else
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_FATAL, (char*)"write_update", "is_valid default !!!");
		assert(0);
	}

	return;
}

void s_d_htable_full_iterate(const uchar * key, uint size, void * data, void * user)
{
	struct IR_MCTRL_INFO nom_info;
	memset(&nom_info,0,sizeof(nom_info));
	char *htable_data=(char*)data;
	int del_ret=0;
	if(htable_data==NULL)
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_DEBUG, (char*)"search_s_d_htable","htable is null");
		return;
	}
	
	sscanf(htable_data, "%d\t%d\t%d\t%d\t%d\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%d\t%d\t%d\t%d\t%d\t%d\t%s\t%s\t%s", 
		&nom_info.htable_flag,&nom_info.version,&nom_info.region_id,&nom_info.group_id,&nom_info.addr_type,
		nom_info.src_ip,nom_info.mask_src_ip,nom_info.src_port,nom_info.mask_src_port,nom_info.dst_ip,nom_info.mask_dst_ip,
		nom_info.dst_port,nom_info.mask_dst_port,&nom_info.procotol,&nom_info.direction,&nom_info.addr_pool_id,&nom_info.is_valid,
		&nom_info.action,&nom_info.service,nom_info.user_region,nom_info.effective_range,nom_info.op_time);
	if((mctrl_g.update_type_s==MAAT_RULE_UPDATE_TYPE_FULL&&(nom_info.htable_flag & STATIC_NOMINEE_FLAG)&&nom_info.version!=mctrl_g.version_s)||
		(mctrl_g.update_type_d==MAAT_RULE_UPDATE_TYPE_FULL&&(nom_info.htable_flag & DYNAMIC_NOMINEE_FLAG)&&nom_info.version!=mctrl_g.version_d)||
		(mctrl_g.update_type_dp==MAAT_RULE_UPDATE_TYPE_FULL&&(nom_info.htable_flag & DNAT_POLICY_FLAG)&&nom_info.version!=mctrl_g.version_dp))
		
	{
		del_redis_info(nom_info.htable_flag,(char*)data,nom_info.region_id);
		
		unsigned char *key_id=(unsigned char*)&nom_info.region_id;
		
		del_ret=MESA_htable_del(mctrl_g.s_d_htable,key_id,sizeof(int),htable_data_free);
				
		if(del_ret<0)
		{
			MESA_handle_runtime_log(mctrl_g.logger_handle, RLOG_LV_DEBUG, (char*)"DEL_S_AND_D_NOMINEE","del htable error:%d",del_ret);
		}
	}
	return;
}


void s_d_finish_cb(void* u_para)
{
	if((*(int*)u_para==DYNAMIC_NOMINEE_FLAG)&&mctrl_g.update_type_d==MAAT_RULE_UPDATE_TYPE_FULL)
	{
		MESA_htable_iterate(mctrl_g.s_d_htable, s_d_htable_full_iterate,NULL);
		mctrl_g.update_type_d=MAAT_RULE_UPDATE_TYPE_INC;
		MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_INFO, (char*)"maat_finish", "table_name:%d,update_type:%d,finish succeed",*(int*)u_para,mctrl_g.update_type_d);
	}
	else if((*(int*)u_para==STATIC_NOMINEE_FLAG)&&mctrl_g.update_type_s==MAAT_RULE_UPDATE_TYPE_FULL)
	{
		MESA_htable_iterate(mctrl_g.s_d_htable, s_d_htable_full_iterate,NULL);
		mctrl_g.update_type_s=MAAT_RULE_UPDATE_TYPE_INC;	
		MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_INFO, (char*)"maat_finish", "table_name:%d,update_type:%d,finish succeed",*(int*)u_para,mctrl_g.update_type_s);
	}
	else if((*(int*)u_para==DNAT_POLICY_FLAG)&&mctrl_g.update_type_dp==MAAT_RULE_UPDATE_TYPE_FULL)
	{
		
		MESA_htable_iterate(mctrl_g.s_d_htable, s_d_htable_full_iterate,NULL);
		mctrl_g.update_type_dp=MAAT_RULE_UPDATE_TYPE_INC;	
		MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_INFO, (char*)"maat_finish", "table_name:%d,update_type:%d,finish succeed",*(int*)u_para,mctrl_g.update_type_dp);
	}
	else
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_INFO, (char*)"maat_finish", "table_name:%d,finish succeed",*(int*)u_para);
	}
	return;
}


void n_i_c_finish_cb(void* u_para)
{
	MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_INFO, (char*)"maat_finish", "table_name:%d,finish succeed",*(int*)u_para);
	return;
}


int read_plugin_table(Maat_feather_t feather,const char* table_name,
							Maat_start_callback_t *start,Maat_update_callback_t *update,Maat_finish_callback_t *finish,
							void *u_para,void* logger,int table_id)
{
	int ret=0;

	ret=Maat_table_callback_register(feather, table_id,
								start,
								update, 
								finish,
								u_para);
	if(ret<0)
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_FATAL, (char*)"REGISTER_TABLE", "Maat callback register table %s error.\n",table_name);
		assert(0);
	}
	
	return ret;
}


void htable_iterate(const uchar * key, uint size, void * data, void * user)
{
	int htable_flag=0;
	int rule_id=0;
	char *table_line=(char*)data;
	
	sscanf(table_line,"%d\t%*d\t%d",&htable_flag,&rule_id);

	set_redis_info(htable_flag,table_line,rule_id);
	
	return;
}

void Maat_init()
{
// load conf
	const char *section = "Mctrl";
    const char *section_d = "Mctrl_D";
	const char *section_s = "Mctrl_S";
    const char *section_i = "Mctrl_I";
	const char *section_n = "Mctrl_N";
    char table_info_path[MAX_PATH_LEN];
	char logger_path[MAX_PATH_LEN];
    int max_thread_num=0;
	int logger_level=0;
	
    char Maat_redis_ip_d[MAX_STRING_LEN];
    int Maat_redis_port_d=0;
	int Maat_redis_index_d=0;
	
	char Maat_redis_ip_s[MAX_STRING_LEN];
    int Maat_redis_port_s=0;
	int Maat_redis_index_s=0;
	
	char Maat_redis_ip_i[MAX_STRING_LEN];
    int Maat_redis_port_i=0;
	int Maat_redis_index_i=0;
	
	char Maat_redis_ip_n[MAX_STRING_LEN];
    int Maat_redis_port_n=0;
	int Maat_redis_index_n=0;
		
    MESA_load_profile_string_def((char*)MCTRL_CONF_FILE, section,"table_info_path", table_info_path, sizeof(table_info_path), "./conf/table_info.conf");
	MESA_load_profile_string_def((char*)MCTRL_CONF_FILE, section,"logger_path", logger_path, sizeof(logger_path), "./log/ir_mctrl.log");
	MESA_load_profile_int_def((char*)MCTRL_CONF_FILE, section,"logger_level", &logger_level,RLOG_LV_FATAL);
    MESA_load_profile_int_def((char*)MCTRL_CONF_FILE, section,"max_thread_num", &max_thread_num, 1);
//dynamic server conf	
    MESA_load_profile_string_def((char*)MCTRL_CONF_FILE, section_d,"Maat_redis_ip", Maat_redis_ip_d, sizeof(Maat_redis_ip_d), "127.0.0.1");
    MESA_load_profile_int_def((char*)MCTRL_CONF_FILE, section_d,"Maat_redis_port", &Maat_redis_port_d,6379);
	MESA_load_profile_int_def((char*)MCTRL_CONF_FILE, section_d,"Maat_redis_index", &Maat_redis_index_d,1);
//static server conf
	MESA_load_profile_string_def((char*)MCTRL_CONF_FILE, section_s, "Maat_redis_ip", Maat_redis_ip_s, sizeof(Maat_redis_ip_s), "127.0.0.1");
	MESA_load_profile_int_def((char*)MCTRL_CONF_FILE, section_s,"Maat_redis_port", &Maat_redis_port_s,6379);
	MESA_load_profile_int_def((char*)MCTRL_CONF_FILE, section_s,"Maat_redis_index", &Maat_redis_index_s,0);
//nominee and candate conf
	MESA_load_profile_string_def((char*)MCTRL_CONF_FILE, section_n,"Maat_redis_ip", Maat_redis_ip_n, sizeof(Maat_redis_ip_n), "127.0.0.1");
	MESA_load_profile_int_def((char*)MCTRL_CONF_FILE, section_n,"Maat_redis_port", &Maat_redis_port_n,6379);
	MESA_load_profile_int_def((char*)MCTRL_CONF_FILE, section_n,"Maat_redis_index", &Maat_redis_index_n,0);
//intercept conf
	MESA_load_profile_string_def((char*)MCTRL_CONF_FILE, section_i,"Maat_redis_ip", Maat_redis_ip_i, sizeof(Maat_redis_ip_i), "127.0.0.1");
	MESA_load_profile_int_def((char*)MCTRL_CONF_FILE, section_i,"Maat_redis_port", &Maat_redis_port_i,6379);
	MESA_load_profile_int_def((char*)MCTRL_CONF_FILE, section_i,"Maat_redis_index", &Maat_redis_index_i,0);

//log
	mctrl_g.logger_handle=MESA_create_runtime_log_handle(logger_path,logger_level);
	if(mctrl_g.logger_handle == NULL)
	{
		printf("IR MESA_create_runtime_log_handle() error!\n");
		assert(0);
	}

//redis	
	mctrl_g.d_feather = Maat_feather(max_thread_num, table_info_path,mctrl_g.logger_handle);
	mctrl_g.s_feather = Maat_feather(max_thread_num, table_info_path,mctrl_g.logger_handle);
	mctrl_g.n_feather = Maat_feather(max_thread_num, table_info_path,mctrl_g.logger_handle);
	mctrl_g.i_feather = Maat_feather(max_thread_num, table_info_path,mctrl_g.logger_handle);
	
	if(mctrl_g.d_feather==NULL||mctrl_g.s_feather==NULL||mctrl_g.n_feather==NULL||mctrl_g.i_feather==NULL)
	{
	   MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_FATAL,(char*)"MAAT","IR maat_feather error!");
	   assert(0);
	}
		   
	Maat_set_feather_opt(mctrl_g.d_feather,MAAT_OPT_REDIS_IP,Maat_redis_ip_d,MAX_STRING_LEN);
	Maat_set_feather_opt(mctrl_g.d_feather,MAAT_OPT_REDIS_PORT,&Maat_redis_port_d,sizeof(Maat_redis_port_d));
	Maat_set_feather_opt(mctrl_g.d_feather,MAAT_OPT_REDIS_INDEX,&Maat_redis_index_d,sizeof(Maat_redis_index_d));
	Maat_set_feather_opt(mctrl_g.d_feather, MAAT_OPT_INSTANCE_NAME, DYNAMIC_NOMINEE_TABLE_NAME, strlen(DYNAMIC_NOMINEE_TABLE_NAME)+1);
	
	Maat_set_feather_opt(mctrl_g.s_feather,MAAT_OPT_REDIS_IP,Maat_redis_ip_s,MAX_STRING_LEN);
	Maat_set_feather_opt(mctrl_g.s_feather,MAAT_OPT_REDIS_PORT,&Maat_redis_port_s,sizeof(Maat_redis_port_s));
	Maat_set_feather_opt(mctrl_g.s_feather,MAAT_OPT_REDIS_INDEX,&Maat_redis_index_s,sizeof(Maat_redis_index_s));
	Maat_set_feather_opt(mctrl_g.s_feather, MAAT_OPT_INSTANCE_NAME, STATIC_NOMINEE_TABLE_NAME, strlen(STATIC_NOMINEE_TABLE_NAME)+1);
	
	Maat_set_feather_opt(mctrl_g.i_feather,MAAT_OPT_REDIS_IP,Maat_redis_ip_i,MAX_STRING_LEN);
	Maat_set_feather_opt(mctrl_g.i_feather,MAAT_OPT_REDIS_PORT,&Maat_redis_port_i,sizeof(Maat_redis_port_i));
	Maat_set_feather_opt(mctrl_g.i_feather,MAAT_OPT_REDIS_INDEX,&Maat_redis_index_i,sizeof(Maat_redis_index_i));
	Maat_set_feather_opt(mctrl_g.i_feather, MAAT_OPT_INSTANCE_NAME, INTERCEPT_TABLE_NAME, strlen(INTERCEPT_TABLE_NAME)+1);

	Maat_set_feather_opt(mctrl_g.n_feather,MAAT_OPT_REDIS_IP,Maat_redis_ip_n,MAX_STRING_LEN);
	Maat_set_feather_opt(mctrl_g.n_feather,MAAT_OPT_REDIS_PORT,&Maat_redis_port_n,sizeof(Maat_redis_port_n));
	Maat_set_feather_opt(mctrl_g.n_feather,MAAT_OPT_REDIS_INDEX,&Maat_redis_index_n,sizeof(Maat_redis_index_n));
	Maat_set_feather_opt(mctrl_g.n_feather, MAAT_OPT_INSTANCE_NAME, NOMINEE_TABLE_NAME, strlen(NOMINEE_TABLE_NAME)+1);
	Maat_set_feather_opt(mctrl_g.n_feather, MAAT_OPT_INSTANCE_NAME, CANDIDATE_TABLE_NAME, strlen(CANDIDATE_TABLE_NAME)+1);
	
	Maat_initiate_feather(mctrl_g.d_feather);
	Maat_initiate_feather(mctrl_g.s_feather);
	Maat_initiate_feather(mctrl_g.i_feather);
	Maat_initiate_feather(mctrl_g.n_feather);
	
}


int htable_init()
{
	int htable_ret=0;
	mctrl_g.s_d_htable = MESA_htable_born();
	if(mctrl_g.s_d_htable == NULL)
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_FATAL,(char*)"htable","htable born failed");
		assert(0);
		return -1;
	}
	
	htable_ret = MESA_htable_mature(mctrl_g.s_d_htable);
	
	if(0 == htable_ret)
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_INFO,(char*)"htable","htable mature succ");
		return 0;
	}
	else
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_FATAL,(char*)"htable","htable mature failed");
		assert(0);
		return -1;
	}
}

int main(int argc, char * argv [ ])
{
	
	Maat_init();
	htable_init();

	int static_flag=STATIC_NOMINEE_FLAG;
	int	dynamic_flag=DYNAMIC_NOMINEE_FLAG;
	int dnat_policy_flag=DNAT_POLICY_FLAG;
	int nominee_flag=NOMINEE_FLAG;
	int candidate_flag=CANDIDATE_FLAG;
	int intercept_flag=INTERCEPT_FLAG;

	int static_id=-1;
	int	dynamic_id=-1;
	int dnat_policy_id=-1;
	int nominee_id=-1;
	int candidate_id=-1;
	int intercept_id=-1;

	static_id=Maat_table_register(mctrl_g.s_feather,STATIC_NOMINEE_TABLE_NAME);
	dynamic_id=Maat_table_register(mctrl_g.d_feather,DYNAMIC_NOMINEE_TABLE_NAME);
	dnat_policy_id=Maat_table_register(mctrl_g.s_feather,DNAT_POLICY_TABLE_NAME);
	
	if(static_id==-1||dynamic_id==-1||dnat_policy_id==-1)
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_FATAL,(char*)"REGISTER_TABLE","S_D_DP Database table register failed\n");
		assert(0);
	}

	read_plugin_table(mctrl_g.s_feather,STATIC_NOMINEE_TABLE_NAME,s_d_start_cb,s_d_table_update_cb,s_d_finish_cb,
		&static_flag,mctrl_g.logger_handle,static_id);
	read_plugin_table(mctrl_g.d_feather,DYNAMIC_NOMINEE_TABLE_NAME,s_d_start_cb,s_d_table_update_cb,s_d_finish_cb,
		&dynamic_flag,mctrl_g.logger_handle,dynamic_id);
	read_plugin_table(mctrl_g.s_feather,DNAT_POLICY_TABLE_NAME,s_d_start_cb,s_d_table_update_cb,s_d_finish_cb,
		&dnat_policy_flag,mctrl_g.logger_handle,dnat_policy_id);

	nominee_id=Maat_table_register(mctrl_g.n_feather,NOMINEE_TABLE_NAME);
	candidate_id=Maat_table_register(mctrl_g.n_feather,CANDIDATE_TABLE_NAME);
	intercept_id=Maat_table_register(mctrl_g.i_feather,INTERCEPT_TABLE_NAME);
	
	if(nominee_id==-1||candidate_id==-1||intercept_id==-1)
	{
		MESA_handle_runtime_log(mctrl_g.logger_handle,RLOG_LV_FATAL,(char*)"REGISTER_TABLE","N_C_I Database table register failed\n");
		assert(0);
	}
	
	read_plugin_table(mctrl_g.i_feather,INTERCEPT_TABLE_NAME,n_i_c_start_cb,n_i_c_table_update_cb,n_i_c_finish_cb,
		&intercept_flag,mctrl_g.logger_handle,intercept_id);
	read_plugin_table(mctrl_g.n_feather,NOMINEE_TABLE_NAME,n_i_c_start_cb,n_i_c_table_update_cb,n_i_c_finish_cb,
		&nominee_flag,mctrl_g.logger_handle,nominee_id);
	read_plugin_table(mctrl_g.n_feather,CANDIDATE_TABLE_NAME,n_i_c_start_cb,n_i_c_table_update_cb,n_i_c_finish_cb,
		&candidate_flag,mctrl_g.logger_handle,candidate_id);

	while(1)
	{
		MESA_htable_iterate(mctrl_g.s_d_htable, htable_iterate, NULL);
		sleep(SLEEP_TIME);
	}
		
	Maat_burn_feather(mctrl_g.d_feather);
	Maat_burn_feather(mctrl_g.s_feather);
	Maat_burn_feather(mctrl_g.i_feather);
	Maat_burn_feather(mctrl_g.n_feather);
	MESA_destroy_runtime_log_handle(mctrl_g.logger_handle);
	MESA_htable_destroy(mctrl_g.s_d_htable,htable_data_free);
	return 0;
	
}