task_app.c

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

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

/*Extern functions*/
extern BOOL InitSystemProc( VOID );
extern VOID StartSystemProc( VOID );
extern VOID SystemProc( VOID *data );

extern VOID InitDbmsFlashFsm( VOID );
extern VOID DbmsManagerProc( VOID *data );

extern BOOL InitLeaSystem( VOID );
extern VOID LeaSysProc( VOID *data );

extern BOOL InitCcSysProc(VOID);
extern VOID CcSysProc( VOID *data );

/*Functions defined in this file*/
VOID SystemTask(UNSIGNED argc, VOID *argv);
VOID LapvTask(UNSIGNED argc, VOID *argv);
VOID DbmsManagerTask(UNSIGNED argc, VOID *argv);
VOID LeaSysTask(UNSIGNED argc, VOID *argv);
VOID CcSysTask(UNSIGNED argc, VOID *argv);
VOID CommTask(UNSIGNED argc, VOID *argv);



VOID SystemTask(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;

	StartSystemProc();

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

		if( status==NU_SUCCESS )
		{
			SystemProc( msg );
		}

		NU_Relinquish();
	}
}


VOID DbmsManagerTask(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;
	
	InitDbmsFlashFsm( );
	while(1)
	{
		 status=NU_Receive_From_Pipe(&Pipe_DbmsManager,msg,1,&msg_len,NU_SUSPEND);

		 if( status==NU_SUCCESS )
		 {
			DbmsManagerProc( msg );
		 }
		 NU_Relinquish();
	}
}

VOID LeaSysTask(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;

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

		 if( status==NU_SUCCESS )
			LeaSysProc( msg );

		 NU_Relinquish();
	}
}

VOID CcSysTask(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;

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

		 if( status==NU_SUCCESS )
		 {
			CcSysProc( msg );
		 }
		 NU_Relinquish();
	}
}