我正在努力用类管道实现一个 shell.
typedef struct {
    char** cmd;
    int in[2];
    int out[2];
} cmdio;

cmdio cmds[MAX_PIPE + 1];

读取管道中的命令并将其存储在cmds中.

cmdio [i] .in是pipe()返回的输入管道的文件描述符对.对于从终端输入读取的第一个命令,它只是{fileno(stdin),– 1}. cmdin [i] .out对输出管道/终端输出类似. cmdio [i] .in与cmd [i-1] .out相同.例如:

$ls -l | sort | wc

CMD: ls -l 
IN: 0 -1
OUT: 3 4

CMD: sort 
IN: 3 4
OUT: 5 6

CMD: wc 
IN: 5 6
OUT: -1 1

我们将每个命令传递给process_command,它执行许多操作:

for (cmdi = 0; cmds[cmdi].cmd != NULL; cmdi++) {
    process_command(&cmds[cmdi]);
}

现在,在process_command中:

if (!(pid_fork = fork())) {
    dup2(cmd->in[0],fileno(stdin));
    dup2(cmd->out[1],fileno(stdout));    
    if (cmd->in[1] >= 0) {
        if (close(cmd->in[1])) {
            perror(NULL);
        }
    }
    if (cmd->out[0] >= 0) {
        if (close(cmd->out[0])) {
            perror(NULL);
        }
    }
    execvp(cmd->cmd[0],cmd->cmd);
    exit(-1);
}

问题是永远从管道中读取:

COMMAND $ls | wc
Created pipe,in: 5 out: 6
Foreground pid: 9042,command: ls,Exited,info: 0
[blocked running read() within wc]

如果,而不是与execvp交换过程,我只是这样做:

if (!(pid_fork = fork())) {
    dup2(cmd->in[0],fileno(stdout));
    if (cmd->in[1] >= 0) {
        if (close(cmd->in[1])) {
            perror(NULL);
        }
    }
    if (cmd->out[0] >= 0) {
        if (close(cmd->out[0])) {
            perror(NULL);
        }
    }

    char buf[6];
    read(fileno(stdin),buf,5);
    buf[5] = '\0';

    printf("%s\n",buf);
    exit(0);
}

它碰巧工作:

COMMAND $cmd1 | cmd2 | cmd3 | cmd4 | cmd5 
Pipe creada,in: 11 out: 12
Pipe creada,in: 13 out: 14
Pipe creada,in: 15 out: 16
Pipe creada,in: 17 out: 18
hola!
Foreground pid: 9251,command: cmd1,info: 0
Foreground pid: 9252,command: cmd2,info: 0
Foreground pid: 9253,command: cmd3,info: 0
Foreground pid: 9254,command: cmd4,info: 0
hola!
Foreground pid: 9255,command: cmd5,info: 0

可能是什么问题呢?

解决方法

你没有足够的关闭.在代码中:
if (!(pid_fork = fork())) {
    dup2(cmd->in[0],cmd->cmd);
    exit(-1);
}

在将管道复制到stdin和stdout(通过fileno())之后,需要关闭管道:

if (!(pid_fork = fork())) {
    dup2(cmd->in[0],fileno(stdout));    
    if (cmd->in[1] >= 0) {
        if (close(cmd->in[1])) {
            perror(NULL);
        }
    }
    if (cmd->out[0] >= 0) {
        if (close(cmd->out[0])) {
            perror(NULL);
        }
    }
    close(cmd->in[0]);  // Or your error checked version,but I'd use a function
    close(cmd->out[1]);     
    execvp(cmd->cmd[0],cmd->cmd);
    exit(-1);
}

程序没有完成,因为文件的写入结束仍然打开.另外,不要忘记,如果父进程(shell)创建管道,它必须关闭管道的两端.在开始学习管道管道时,没有关闭足够的管道可能是最常见的错误.

读取C块上的UNIX管道的更多相关文章

  1. unix 编程进程控制详细介绍

    这篇文章主要介绍了unix 编程进程控制详细介绍的相关资料,需要的朋友可以参考下

  2. 解决Java执行Cmd命令出现的死锁问题

    这篇文章主要介绍了关于Java执行Cmd命令出现的死锁问题解决,解决方法就是在waitfor()方法之前读出窗口的标准输出、输出、错误缓冲区中的内容,本文给大家介绍的非常详细,需要的朋友可以参考下

  3. php UNIX时间戳用法详解

    这篇文章主要介绍了php UNIX时间戳用法,结合实例形式分析了php Unix时间戳相关函数与使用技巧,需要的朋友可以参考下

  4. Laravel timestamps 设置为unix时间戳的方法

    今天小编就为大家分享一篇Laravel timestamps 设置为unix时间戳的方法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧

  5. 在unix中基于当前日期添加新列

    我试图在unix中基于时间戳列在最后一个单元格中添加一个状态列。我不确定如何继续。

  6. 你如何杀死thunar过程?

    如果我想杀死该文件管理器的所有实例,我会这给了我但这个FM肯定在运行!类似地,psaux|grepthunar找不到任何东西,结果是:

  7. 如何在BusyBox容器中打印unix工具版本?

    我无法确定如何在BusyBox容器中打印版本:有什么建议吗?许多热的容器都建在BusyBox的顶部,我最好能做到这一点。

  8. Linux需要帮助了解%s的功能

    使用touch命令,我需要创建一个名为:Hello$s的文件,但我收到一个错误:“”不匹配。需要帮助修复错误。

  9. 如何解决超级终端中的错误?

    每当我尝试运行超级终端时,我都会收到这个错误消息,然后它只显示一个黑色窗口,没有任何内容。错误图像我重新安装了它,也尝试重新安装git并下载了node.js,但没有任何变化。

  10. 如何在Windows XP / 7上的Python 3中将文件打印到纸上?

    对于我正在进行的项目,我需要能够写入文本文件,然后将该文件发送到打印机.我对编程很新而且在我的时间里从来不需要这样做.所以,我的问题是如何将文件发送到打印机?.我需要该程序在WindowsXP和Windows7上工作,我遇到了一些名为lpronline的东西,但我找不到任何实质性内容,这似乎与基于UNIX的操作系统有关.我有一种感觉,我可能需要在某处使用os.system(),但我不确定我会怎么做.一个简单的方法是让记事本打印文本文件:

随机推荐

  1. 从C到C#的zlib(如何将byte []转换为流并将流转换为byte [])

    我的任务是使用zlib解压缩数据包(已接收),然后使用算法从数据中生成图片好消息是我在C中有代码,但任务是在C#中完成C我正在尝试使用zlib.NET,但所有演示都有该代码进行解压缩(C#)我的问题:我不想在解压缩后保存文件,因为我必须使用C代码中显示的算法.如何将byte[]数组转换为类似于C#zlib代码中的流来解压缩数据然后如何将流转换回字节数组?

  2. 为什么C标准使用不确定的变量未定义?

    垃圾价值存储在哪里,为什么目的?解决方法由于效率原因,C选择不将变量初始化为某些自动值.为了初始化这些数据,必须添加指令.以下是一个例子:产生:虽然这段代码:产生:你可以看到,一个完整的额外的指令用来移动1到x.这对于嵌入式系统来说至关重要.

  3. 如何使用命名管道从c调用WCF方法?

    更新:通过协议here,我无法弄清楚未知的信封记录.我在网上找不到任何例子.原版的:我有以下WCF服务我输出添加5行,所以我知道服务器是否处理了请求与否.我有一个.NET客户端,我曾经测试这一切,一切正常工作预期.现在我想为这个做一个非托管的C客户端.我想出了如何得到管道的名称,并写信给它.我从here下载了协议我可以写信给管道,但我看不懂.每当我尝试读取它,我得到一个ERROR_broKEN_P

  4. “这”是否保证指向C中的对象的开始?

    我想使用fwrite将一个对象写入顺序文件.班级就像当我将一个对象写入文件时.我正在游荡,我可以使用fwrite(this,sizeof(int),2,fo)写入前两个整数.问题是:这是否保证指向对象数据的开始,即使对象的最开始可能存在虚拟表.所以上面的操作是安全的.解决方法这提供了对象的地址,这不一定是第一个成员的地址.唯一的例外是所谓的标准布局类型.从C11标准:(9.2/20)Apointe

  5. c – 编译单元之间共享的全局const对象

    当我声明并初始化一个const对象时.两个cpp文件包含此标头.和当我构建解决方案时,没有链接错误,你会得到什么如果g_Const是一个非const基本类型!PrintInUnit1()和PrintInUnit2()表明在两个编译单元中有两个独立的“g_Const”具有不同的地址,为什么?

  6. 什么是C名称查找在这里? (&GCC对吗?)

    为什么在第三个变体找到func,但是在实例化的时候,原始变体中不合格查找找不到func?解决方法一般规则是,任何不在模板定义上下文中的内容只能通过ADL来获取.换句话说,正常的不合格查找仅在模板定义上下文中执行.因为在定义中间语句时没有声明func,并且func不在与ns::type相关联的命名空间中,所以代码形式不正确.

  7. c – 在输出参数中使用auto

    有没有办法在这种情况下使用auto关键字:当然,不可能知道什么类型的.因此,解决方案应该是以某种方式将它们合并为一个句子.这可用吗?解决方法看起来您希望默认初始化给定函数期望作为参数的类型的对象.您无法使用auto执行此操作,但您可以编写一个特征来提取函数所需的类型,然后使用它来声明您的变量:然后你就像这样使用它:当然,只要你重载函数,这一切都会失败.

  8. 在C中说“推动一切浮动”的确定性方式

    鉴于我更喜欢将程序中的数字保留为int或任何内容,那么使用这些数字的浮点数等效的任意算术最方便的方法是什么?说,我有我想写通过将转换放在解析的运算符树叶中,无需将表达式转化为混乱是否可以使用C风格的宏?应该用新的类和重载操作符完成吗?解决方法这是一个非常复杂的表达.更好地给它一个名字:现在当您使用整数参数调用它时,由于参数的类型为double,因此使用常规的算术转换将参数转换为double用C11lambda……

  9. objective-c – 如何获取未知大小的NSArray的第一个X元素?

    在objectiveC中,我有一个NSArray,我们称之为NSArray*largeArray,我想要获得一个新的NSArray*smallArray,只有第一个x对象…

  10. c – Setprecision是混乱

    我只是想问一下setprecision,因为我有点困惑.这里是代码:其中x=以下:方程的左边是x的值.1.105=1.10应为1.111.115=1.11应为1.121.125=1.12应为1.131.135=1.14是正确的1.145=1.15也正确但如果x是:2.115=2.12是正确的2.125=2.12应为2.13所以为什么在一定的价值是正确的,但有时是错误的?请启发我谢谢解决方法没有理由期望使用浮点系统可以正确地表示您的帖子中的任何常量.因此,一旦将它们存储在一个双变量中,那么你所拥有的确切的一

返回
顶部