task_com.c

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

#include "RTOS\NUCLEUS\TASK\TASK_NUC.H"
#include "PUB\PUB_INCL.H"
#include "PUB\PUB_DEFI.H"
#include "PUB\PUB__MSG.H"


/*Extern functions*/
extern VOID LapvGetIFrameFromQueueAndSendout( VOID );
extern BOOL InitLapv(VOID);
extern VOID LapvFsmProc( VOID *data );
extern VOID DbmsManagerProc( VOID *data );

extern VOID InitNetCtrlFsm( VOID );
extern VOID NetCtrlProc( VOID *data );


VOID LapvTask(UNSIGNED argc, VOID *argv);
VOID CommNetCtrlTask(UNSIGNED argc, VOID *argv);



VOID LapvTask(UNSIGNED argc, VOID *argv)
{
	STATUS      status;
	UC 			msg[MAX_MSG_LEN];
	UNSIGNED 	msg_len;

	/* Access argc and argv just to avoid compilation warnings.  */
	status =  (STATUS)argc + (STATUS)argv;

	InitLapv();

	while(1)
	{
		 status=NU_Receive_From_Pipe(&Pipe_Lapv,msg,1,&msg_len,NU_SUSPEND);

		 if( status==NU_SUCCESS )
		 {
			LapvFsmProc(msg);
		 }
		 LapvGetIFrameFromQueueAndSendout();

		 NU_Relinquish();
	}
}


VOID CommNetCtrlTask(UNSIGNED argc, VOID *argv)
{
	STATUS 				status;
	STRUCT MSG_STRUCT 	msg;
	UNSIGNED 	   		msg_len;
	

	/* Access argc and argv just to avoid compilation warnings.  */
	status =  (STATUS) argc + (STATUS) argv;

	InitNetCtrlFsm();

	while(1)
	{
		status=NU_Receive_From_Pipe(&Pipe_CommNetCtrl,&msg,1,&msg_len,NU_SUSPEND);
		if( status == NU_SUCCESS )
			NetCtrlFsm( &msg );

		NU_Relinquish();
	}
}