/*************************************************************************
*	File name		: zjmdmdrv.c
*	Subsystem	: modem卡驅(qū)動(dòng)程序
*	Target env	: Linux
*	Author		: 謝紅偉
*	Last modified	: 2002/04/30
*	Description	: This file contains public function and macro for access zj-modem driver
*	Copyright	: zjkj
*	Note			: 
**************************************************************************/
#include <unistd.h>
#include <fcntl.h>
#include "pthread.h"
#include "../tdkio/pubdef.h"
#include "../tdkio/pubfunc.h"
#include "zjmdmfuc.h"

/************* Private macro define ********************/
#define	only_DisconnCH(fd,chl_id)															\
	ioctl((fd),IOCTL_CMD_DISCONN | ((chl_id)<<4))

/******************************************************
* type:public
* 啟動(dòng)系統(tǒng)
*******************************************************/
void zj_SystemStart()
{
	pthread_mutex_init (&mutex_comd, NULL);
}

/*******************************************************
* type:public
* 系統(tǒng)終止
*******************************************************/
void zj_SystemExit()
{
	pthread_mutex_destroy (&mutex_comd);
}

/***********************************************
* 給modem卡發(fā)送數(shù)據(jù)
**********************************************/
inline ssize_t zj_write(int fd,char *Write_buf,unsigned long size,unsigned char chl_id,time_t timeout)
{
	unsigned long len,sent_bytes = 0,ret;
	time_t start_time = time(NULL);
	if(fd<1) return -1;
	if(fd<1 || chl_id>=CHL_NUM) return -1;
	if(timeout<=0) timeout = DEF_SEND_TIMEOUT;
	while(sent_bytes<size)
	{	
		len = size-sent_bytes;
		len = (len <<3) | (chl_id & 0x07);
		ret = write(fd,Write_buf+sent_bytes,len);
		if(ret>0)
			sent_bytes += ret;
		else if(ret==0)
			sleep(1);
		else
			return sent_bytes;
		if(time(NULL) - start_time > timeout)
			return sent_bytes;
	}
	return sent_bytes;
}

/***********************************************
* 從卡上收數(shù)據(jù)
**********************************************/
inline ssize_t zj_read(int fd,char *Read_buf,unsigned long size,unsigned char chl_id)
{
	unsigned long len;
	if(fd<1 || chl_id>=CHL_NUM) return -1;
	len = size;
	len = (len <<3) | (chl_id & 0x07);
	return read(fd,Read_buf,len);
}


/************************************************************
* 清空讀緩沖
*************************************************************/
int zj_clean_read_buffer(int fd,unsigned char chl_id)
{
	int try_count;
	time_t start_time;
	char tmp_buf[1024];
#ifdef _DEBUG
	t_TdkMdmChl tdk;
	Log(&tdk,"Cleaning read buffer...\n");
#endif
	if(fd<0 || chl_id>=CHL_NUM) return;
	if(fcntl (fd, F_SETFL,fcntl (fd, F_GETFL, 0) | O_NONBLOCK)<0)
		return -1;
	time(&start_time);
	while(1)
	{
		if(zj_read(fd,tmp_buf,sizeof(tmp_buf),chl_id)<=0)
		{
			try_count++;
			if(try_count>MAX_CLEAN_TIMES)
				return 0;
			usleep(10*1000);
		}
		else
		{
			try_count = 0;
		}
		usleep(1000);
		if(time(NULL)-start_time>MAX_CLEAN_BUF_TIME)
		{
#ifdef _DEBUG
			Log(&tdk,"Fail:cleaning read buffer!\n");
#endif
			return -1;
		}
	}
	return 0;
}

/******************************************************
*得到通道的掛機(jī)狀態(tài)
******************************************************/
int zj_GetHangupState(int fd,unsigned char chl_id)
{
	int i,state_date;
	zj_QueryState(fd,chl_id);
	for(i=0; i<MAX_QUERY_TIME; i++)
	{
		usleep(1000);
		state_date = zj_GetQueryResult(fd,chl_id);
		if((unsigned char)state_date == CMD_HANGUP_BACK ||
			(unsigned char)state_date == CMD_BRINGUP_BACK)
		{
			return state_date;
		}
	}
	return -1;
}

/******************************************************
*確保通道工作正常
******************************************************/
int ValidateChannel(int fd,unsigned char chl_id)
{
	int state_date;
	pthread_mutex_lock(&mutex_comd);
	state_date = zj_GetHangupState(fd,chl_id);
	if((unsigned char)state_date == CMD_HANGUP_BACK ||
		(unsigned char)state_date == CMD_BRINGUP_BACK)
	{
		pthread_mutex_unlock(&mutex_comd);
		return 0;
	}
	//查狀態(tài)失敗，開通道
	zj_OpenCH(fd,chl_id);
	usleep(10*1000);
	state_date = zj_GetHangupState(fd,chl_id);
	if((unsigned char)state_date == CMD_HANGUP_BACK ||
		(unsigned char)state_date == CMD_BRINGUP_BACK)
	{
		pthread_mutex_unlock(&mutex_comd);
		return 1;
	}
	//開通道后查狀態(tài)仍然失敗,恢復(fù)錯(cuò)誤的序列
	zj_RecoverHead(fd,chl_id);
	state_date = zj_GetHangupState(fd,chl_id);
	if((unsigned char)state_date == CMD_HANGUP_BACK ||
		(unsigned char)state_date == CMD_BRINGUP_BACK)
	{
		pthread_mutex_unlock(&mutex_comd);
		return 2;
	}
	//仍然失敗，再開通道
	zj_OpenCH(fd,chl_id);
	usleep(10*1000);
	state_date = zj_GetHangupState(fd,chl_id);
	if((unsigned char)state_date == CMD_HANGUP_BACK ||
		(unsigned char)state_date == CMD_BRINGUP_BACK)
	{
		pthread_mutex_unlock(&mutex_comd);
		return 3;
	}
	pthread_mutex_unlock(&mutex_comd);
	return -1;
}

/******************************************************
*掛斷modem指定的通道的連接
******************************************************/
int zj_DisconnCH(int fd,unsigned char chl_id)
{
	int i;
	for(i=0;i<MAX_QUERY_TIME;i++)	//wait for command send over
	{
		if(zj_CmdSendOver(fd,chl_id))
			break;
		usleep(1000);
	}
	if(i>=MAX_QUERY_TIME)
	{
		return -1;
	}
	only_DisconnCH(fd,chl_id);
	switch(ValidateChannel(fd,chl_id))
	{
	case 0:	//正常
		return 0;
		break;
	case 1:	//開通道后正常
	case 2:	//恢復(fù)錯(cuò)誤序列后正常
	case 3:	//再開通道后正常
		return only_DisconnCH(fd,chl_id);
		break;
	default:	//錯(cuò)誤
			return -1;
	}
	return 0;
}