我是靠谱客的博主 爱笑荷花,最近开发中收集的这篇文章主要介绍linux编程—管道编程,Linux 平台管道编程笔记,觉得挺不错的,现在分享给大家,希望可以做个参考。

概述

commit f24da015d79edf4b8d5a1cec5aec37103d4b6626

Author: weijiaqiang

Date:   Sat Feb 22 16:43:48 2014 +0800

测试:如果使用 O_ASYNC 和 信号处理机制。

测试结果:

如果管道描述符的状态发生改变时(可以在fd[0]上读取到数据或可以往fd[1]上写入数据)

进程会收到信号。

commit b7de551beea93ddf05da4da7281349ecfcf18c9c

Author: weijiaqiang

Date:   Sat Feb 22 16:26:26 2014 +0800

测试: 当管道的读端处于非阻塞状态下,read 一个没有数据的管道时

会有什么影响?

测试结果:

read 函数返回 -1, errno 别设置为 EAGIN

commit bed40410ba3c14fbaec1d6f14e64e990c9bf2ef7

Author: weijiaqiang

Date:   Sat Feb 22 16:06:52 2014 +0800

测试:在Linux 下,宏定义 PIPE_BUF 的值

测试结果:

PIPE_BUF 宏定义在 /usr/include/linux/limits.h 头文件中定义

它的值为4096, 这个值的含义为当多个往同一个管道写时,写入的

数据小于PIPE_BUF 所定义的字节数,系统可以保证这次该写操作是

原子的。

commit e637dd4f551b14badca5110a47590280f4b87a6f

Author: weijiaqiang

Date:   Sat Feb 22 16:01:31 2014 +0800

测试: 当管道所有的写端都已经关闭时, 调用read

从管道的读端读数据会有什么应影响?

测试结果:

当read读出管道内所有数据之后,会返回0(end of

file)的意思,读端可以通过这个返回值看看,管道是否还有写端

commit 27814d9c694b7cd630ceecd04b5c7df0b5367c85

Author: weijiaqiang

Date:   Sat Feb 22 15:53:36 2014 +0800

测试管道的读端关闭后,往管道上写数据会有如何影响。

测试的结果是:

进程会收到SIGPIPE信号,同时 errno 被设置为 EPIPE

commit ecc0da3180274217e45fb83f3738c5160b6c03f5

Author: weijiaqiang

Date:   Sat Feb 22 15:45:37 2014 +0800

测试管道的默认缓冲区大小, 测试结果为65535个字节

commit f390ae0d9c2b90a9f6eecbe9e4da0efe568c0a68

Author: weijiaqiang

Date:   Sat Feb 22 15:41:50 2014 +0800

创建 读写会阻塞的 管道

点击(此处)折叠或打开

#include

#include

#include

#include

#include

#include

#include

#include

using namespace std;

void sig_pipe(int signo, siginfo_t* info, void* context)

{

cout << "[INFO] ############## in sigal SIGPIPE handler .!" << endl;

}

int main(int argc, char* argv[])

{

/*==================== 注册信号处理函数 ========================*/

struct sigaction act;

act.sa_flags = SA_SIGINFO;

act.sa_sigaction = sig_pipe;

sigemptyset(&act.sa_mask);

if (sigaction(SIGIO, &act, NULL) == -1)

{

cerr << "[ERROR] ############# failed to call sigaction to get orginal SIGIN disption info .!" << endl;

exit(EXIT_FAILURE);

}

/* =================== 创建管道,并将管道读端的设置为读非阻塞、管道数据后信号通知 ================== */

int fd[2];

if (pipe(fd) != 0)

{

cerr << "[ERROR] ########### faile to create pipe, error message .!" << endl;

exit(EXIT_FAILURE);

}

/*======================= 将管道的读端设置为读非阻塞 ===================== */

long cur_flag = fcntl(fd[0], F_GETFL);

if (cur_flag == -1)

{

cerr << "[ERROR] ######### failed to call fcntl .!" << endl;

exit(EXIT_FAILURE);

}

cur_flag |= (O_NONBLOCK | O_ASYNC);

if (fcntl(fd[0], F_SETFL, cur_flag) == -1)

{

cerr << "[ERROR] ######### failed to call fcntl to F_SETFL, error message: " << strerror(errno) << endl;

exit(EXIT_FAILURE);

}

/* ====================== 管道有数据可读,进程接收到SIGIO 信号 ========== */

if (fcntl(fd[0], F_SETSIG, SIGIO) == -1)

{

cerr << "[ERROR] ######### failed to call fcntl to F_SETSIG, error message: " << strerror(errno) << endl;

exit(EXIT_FAILURE);

}

if (fcntl(fd[0], F_SETOWN, getpid()) == -1)

{

cerr << "[ERROR] ######### failed to call fcntl to F_SETOWN, error message: " << strerror(errno) << endl;

exit(EXIT_FAILURE);

}

/*

* 第1次测试往管道上写东西, 将会看到

* write 函数返回之前 sig_io 信号处理函数会被调用

*/

char c = 'a';

if (write(fd[1], &c, sizeof(c)) != sizeof(c))

{

cerr << "[ERROR] ########### write to pipe failed ,error message :" << strerror(errno) << endl;

}

cout << "[INFO] ########## write to pipe ok .!" << endl;

/*

* 测试从管道读消息,我们将会看到:

* 虽然管道上现在只有一个字节的数据,因为管道的读端描述符已经设置为读非阻塞,

* 所以,循环第1次调用read 能从管道上读取一个字节,第2此调用read 会返回-1,表示出错,而错误信息为 资源不可用

*/

char buf[128];

ssize_t byte_read;

while ((byte_read = read(fd[0], buf, sizeof(buf))) > 0);

cout << "The last call to read return " << byte_read << ", error message: " << strerror(errno) << endl;

cout << "================================================================" << endl;

/*

* 第2次测试往管道上写东西, 将会看到

* write 函数返回之前 sig_io 信号处理函数会被调用

*/

write(fd[1], &c, 1);

cout << "[INFO] ########## write to pipe ok .!" << endl;

// 这里没有必要显示调用close来关闭描述符,因为在main函数返回值,进程退出函数会自动

// 关闭所有打开着的文件描述符

return 0;

}

管道测试:

读端 调用open(file_name, O_RDONY | O_NONBLOCK) 来获取管道描述。 因为指定 O_NONBLOCK, 所以即使没有任何进程打开该管道写, open 都不会堵塞。

接下来,调用 read 尝试从管道读取数据,会由一下的情景。

1)当前还没有任何进程打开该管道用于写, read 的返回值是 0

2)当前有进程在打开该管道用于写, <1>管道上由数据可读,read 返回读取的数据大小;<2> 管道上没有数据, read 返回-1,errno 的值为 EAGAIN。

最后

以上就是爱笑荷花为你收集整理的linux编程—管道编程,Linux 平台管道编程笔记的全部内容,希望文章能够帮你解决linux编程—管道编程,Linux 平台管道编程笔记所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
点赞(41)

评论列表共有 0 条评论

立即
投稿
返回
顶部