signal.c

vxworkws消信号通信

#include "vxworks.h"
#include "semLib.h"
#include "errnoLib.h"
#include "sigLib.h"

/*定义堆栈大小*/
#define STACK_SIZE 20000

/*定义任务ID*/
int tidSigReceiver;
int tidSigSend;

/*定义信号量ID*/
SEM_ID semId;

/*启动任务*/
STATUS progStart(void);

/*接受信号功能函数*/
STATUS sigReceiver(void);

/*发送信号功能处理，ID为tidSigSend任务的功能函数*/
STATUS sigSend(void);

/*发送信号函数*/
STATUS txSignal(void);

/*信号处理函数*/
void sigHandler(int sig);

/*任务终止函数*/
void progStop(void);

STATUS progStart(void)
{
	/*创建信号量，初始化为SEM_EMPTY*/
	semId = semBCreate(SEM_Q_FIFO, SEM_EMPTY);
	

	if (semId == NULL)
	{
		return(ERROR);
	}

	/*启动发送信号和接受信号任务*/
	tidSigReceiver = taskSpawn("tSigReceiver", 200 , 0, STACK_SIZE, (FUNCPTR)sigReceiver, 0,0,0,0,0,0,0,0,0,0);
	tidSigSend = taskSpawn("tSigSend", 200 , 0, STACK_SIZE, (FUNCPTR)sigSend, 0,0,0,0,0,0,0,0,0,0);

	printf("\nRun cmd \"txSignal()\" is shell to send a signal\n");

	return OK;
}

STATUS sigReceiver(void)
{
	/*将信号SIGUSR1与处理函数sigHandler相关联*/
	signal(SIGUSR1, sigHandler);

	/*将信号SIGUSR2与处理函数sigHandler相关联*/
	signal(SIGUSR2, sigHandler);

	 /*将自己阻塞*/
	semTake(semId, WAIT_FOREVER);

	return OK;
}

STATUS sigSend(void)
{

	FOREVER
	{	
	     /*任务延迟5秒*/		
	     taskDelay(sysClkRateGet()*5);	
	
	      /*发送 SIGUSR2 信号给tidSigReceiver任务*/
	     kill(tidSigReceiver, SIGUSR2);

	}

	return OK;
}

void sigHandler(int sig)
{
	 /*收到信号，但既不是SIGUSR1也不是SIGUSR2*/
	if ( (sig != SIGUSR1) && (sig != SIGUSR2) )
	{
		logMsg("\n sigHandler: Invalid sig %d \n", sig ,0, 0, 0, 0 , 0);
	}

	 /*收到信号SIGUSR1，打印出执行信号处理的任务的名称，名称获取函数为taskName(taskIdSelf())*/
	if(sig == SIGUSR1)
	{
	
	logMsg("\n sigHandler is running in %s 's context !\n", taskName(taskIdSelf()), 0 ,0 ,0 ,0 ,0);

	logMsg("\n sigHandler is handling sig : %d!\n\n", sig ,0 ,0 ,0 ,0 ,0);
	
	}

	/*收到信号SIGUSR2，打印出执行信号处理的任务的名称，名称获取函数为taskName(taskIdSelf())*/
	if(sig == SIGUSR2)
	{
	
	logMsg("\n sigHandler is running in %s 's context !\n", taskName(taskIdSelf()), 0 ,0 ,0 ,0 ,0);

	logMsg("\n sigHandler is handling sig : %d!\n\n", sig ,0 ,0 ,0 ,0 ,0);
	
	}

	return ;
}

STATUS txSignal(void)
{
	/*发送信号SIGUSR1*/
	kill(tidSigReceiver, SIGUSR1);

	return OK;
}


void progStop(void)
{
	/*删除任务tidSigReceiver和tidSigSend*/
	taskDelete(tidSigReceiver);
	taskDelete(tidSigSend);
	
	/*删除信号量*/
	semDelete(semId);

	printf("\n BYE \n");
	return;
}