task_sys.c

基于vxworks操作系统的电话语音平台系统

#include "PUB\PUB_INCL.H"
#include "PUB\pub__msg.h"
#include "PUB\PUB_DEFI.H"
#include "RTOS\VXWORKS\TCPIP\NET_PROC.H"

extern VOID ClockProc(VOID);
extern VOID Drv860Proc(VOID);
extern VOID WorkLedProc(VOID);
extern VOID AccessDramProc(VOID);
extern VOID EnquiryAllTaskProc(VOID);
extern VOID ReportAllTaskProc( VOID *data );
extern VOID tcpServerSendRecv( VOID );
extern VOID LapmGetIFrameFromQueueAndSendout( VOID );
extern UC Mpc860InitCompFlag;
extern VOID InitLapm(VOID);
extern VOID LapmFsmProc(struct MSG_STRUCT * msg);

extern VOID ClearWatchDog( VOID );

extern TCPIP_SERVER_FSM	ServerFsm;

/*
UC msgforV5[512];
VOID SendMsgToV5Task(VOID)
{
	BOOL c_loop = TRUE ;
	BOOL b_send = FALSE ;
	struct MSG_STRUCT *msg ;

	msg = (struct MSG_STRUCT*)msgforV5;

	while( c_loop )
	{
		if( b_send )
		{
			SendLetterToMail( msg->sender, msg->receiver, msg->msg_type, msg->port_num, (msg->len<480)?msg->len:480, msg->data );
			b_send = FALSE;
		}
		taskDelay(10);
	}
}
*/

extern VOID TestBmtpMsgSend(VOID);
extern VOID TestSendConnectMsgToDtBrd(VOID);
UC TestPttChannelEna = 1;
extern VOID TestPttChannelConnect( VOID );
extern VOID TestTcpNetManSendMsgToDPC(VOID);
extern VOID TestDlccCall(VOID);
extern VOID TestE1AlarmEnquiry(VOID);

extern VOID TestE1BrdMsgSend(VOID);
extern VOID TestV5PstnBrdMsgSend(VOID);

extern BOOL   RestartMpu;

VOID WorkLedTask( VOID )
{
	RestartMpu = FALSE;

	while (1)
	{
		WorkLedProc(  );

		ClockProc(  );

		if ( RestartMpu == FALSE )
		{
		    ClearWatchDog();
		}

		taskDelay(60);
	}
}

VOID TcpServerSendTask(VOID)
{
	int len, sFd;
	UC buffer[1600];
	UI i;
	UC * pMsg;

	pMsg = buffer;

	while (1)
	{
		if (((len = msgQReceive(NetManCenter_Q_ID, pMsg, MAX_MSG_LEN, WAIT_FOREVER)) > 0)
			&& (len < MAX_MSG_LEN))
		{
			if (TcpIsThePacketToLocalNetManager(len, pMsg))
			{
				for (i = 0; i < MAX_CLIENT_NUM; i++)
				{
					if (ServerFsm[i].State != IN_SERVICE_SOCKET)
					{
						continue;
					}

					if ((sFd = GetTcpCurrentSocketIdFromPortNum(i)) > 0)
					{
						TcpSendMsuToLocalManager(i, sFd, len, pMsg);
					}
				}
			}
			else
			{
				TcpSendMsuToRemoteManager(len, pMsg);
			}
		}

		taskDelay(0);
	}
}