?? pipe.c
字號(hào):
/*
本實(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;
}
?? 快捷鍵說(shuō)明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號(hào)
Ctrl + =
減小字號(hào)
Ctrl + -