/*
本實(shí)驗(yàn)將給出一個(gè)兩個(gè)任務(wù)間通過(guò)管道進(jìn)行通信的簡(jiǎn)單例子，用來(lái)說(shuō)明管道得使用方法：
1）  progStart()、progStop()分別用來(lái)啟動(dòng)、停止本演示程序，給出了管道的創(chuàng)建與刪除的方法。
2）  tTask1負(fù)責(zé)通過(guò)管道tTask2發(fā)送消息。
3）  tTask2負(fù)責(zé)從管道中接受來(lái)自tTask1的消息，并將收到的消息顯示出來(lái)*
*/


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

/*管道中最大消息個(gè)數(shù)*/
#define MAX_MSGS (10)

/*每個(gè)消息最大長(zhǎng)度*/
#define MAX_MSG_LEN 100

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

/*向管道寫入消息的時(shí)間延遲*/
#define DELAY_TICKS 50

/*消息內(nèi)容*/
#define MESSAGE "Greeting from Task1"

/*任務(wù)ID定義*/
int tidTask1;
int tidTask2;

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

/*函數(shù)聲明*/
STATUS progStart(void);
STATUS task1(void);
STATUS task2(void);
void progStop(void);

STATUS progStart(void)
{
	int result;/*記錄函數(shù)返回的結(jié)果*/

	/*創(chuàng)建一個(gè)名為“/pipe/demo”的管道*/
	result = pipeDevCreate("/pipe/demo", MAX_MSGS, MAX_MSG_LEN);

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

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

	/*創(chuàng)建任務(wù)*/
	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
	{	
		/*初始化數(shù)據(jù)*/
		memset(msgBuf, 0, MAX_MSG_LEN);
		len =0;

		/*讀出消息，當(dāng)管道為空時(shí)，阻塞在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);
			}
		
			/*從管道中讀數(shù)據(jù)*/
			len += read(demoPipeFd, msgBuf, sizeof(MESSAGE) - len);
		}
		printf("Message from task1: %s \n", msgBuf);
	}

	return OK;
}

void progStop(void)
{

	/*刪除創(chuàng)建的任務(wù)*/
	taskDelete(tidTask1);
	taskDelete(tidTask2);

	/*關(guān)閉打開(kāi)的管道并刪除管道設(shè)備*/
	close(demoPipeFd);
	pipeDevDelete("/pipe/demo",TRUE);

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