pipe.c

vxworkws管道通信

/*
本实验将给出一个两个任务间通过管道进行通信的简单例子，用来说明管道得使用方法：
1）  progStart()、progStop()分别用来启动、停止本演示程序，给出了管道的创建与删除的方法。
2）  tTask1负责通过管道tTask2发送消息。
3）  tTask2负责从管道中接受来自tTask1的消息，并将收到的消息显示出来*
*/


#include "vxworks.h"
#include "ioLib.h"
#include "pipeDrv.h"

/*管道中最大消息个数*/
#define MAX_MSGS (10)

/*每个消息最大长度*/
#define MAX_MSG_LEN 100

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

/*向管道写入消息的时间延迟*/
#define DELAY_TICKS 50

/*消息内容*/
#define MESSAGE "Greeting from Task1"

/*任务ID定义*/
int tidTask1;
int tidTask2;

/*管道ID定义*/
int demoPipeFd;

/*函数声明*/
STATUS progStart(void);
STATUS task1(void);
STATUS task2(void);
void progStop(void);

STATUS progStart(void)
{
	int result;/*记录函数返回的结果*/

	/*创建一个名为“/pipe/demo”的管道*/
	result = pipeDevCreate("/pipe/demo", MAX_MSGS, MAX_MSG_LEN);

	if (result == ERROR)
	{
		return(ERROR);
	}
	
	/*打开管道，并将管道的文件描述符保存在demoPipeFd*/
	demoPipeFd = open("/pipe/demo", O_RDWR, 0 );

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

	/*创建任务*/
	tidTask1 = taskSpawn("tTask1", 220 , 0, STACK_SIZE, (FUNCPTR)task1, 0,0,0,0,0,0,0,0,0,0);
	tidTask2 = taskSpawn("tTask2", 220 , 0, STACK_SIZE, (FUNCPTR)task2, 0,0,0,0,0,0,0,0,0,0);

	return OK;
}

STATUS task1(void)
{

	FOREVER
	{
		/*向管道写消息*/
		write(demoPipeFd, MESSAGE, sizeof(MESSAGE));
		taskDelay(DELAY_TICKS);
	}

	return OK;
}

STATUS task2(void)
{
	char msgBuf[MAX_MSG_LEN];
	int len = 0;
	int result;
	fd_set readFd;

	FOREVER
	{	
		/*初始化数据*/
		memset(msgBuf, 0, MAX_MSG_LEN);
		len =0;

		/*读出消息，当管道为空时，阻塞在select上等待*/
		while (len < sizeof(MESSAGE))
		{
			FD_ZERO(&readFd);
			FD_SET(demoPipeFd, &readFd);

			result = select(sizeof(fd_set), &readFd, NULL, NULL, NULL);
			if(result <= 0)
			{
				return (ERROR);
			}
		
			/*从管道中读数据*/
			len += read(demoPipeFd, msgBuf, sizeof(MESSAGE) - len);
		}
		printf("Message from task1: %s \n", msgBuf);
	}

	return OK;
}

void progStop(void)
{

	/*删除创建的任务*/
	taskDelete(tidTask1);
	taskDelete(tidTask2);

	/*关闭打开的管道并删除管道设备*/
	close(demoPipeFd);
	pipeDevDelete("/pipe/demo",TRUE);

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