python - 来自 Python : sub. stdin.write IOError Broken Pipe 的 C 子进程

Question

将大量数据非常快速地写入 C 子进程时，我遇到了 Broken Pipe 错误。

所以我从 python 脚本运行一个 c 子进程:

process = subprocess.Popen("./gpiopwm", stdin=subprocess.PIPE)
while True:
    process.stdin.write("m2000\n")
    print "bytes written"

gpiopwm.c 主循环部分:

printf("1\n");
while (1) {
    fgets(input,7,stdin);  // Takes input from python script
    printf("2\n");

    numbers = input+1;      // stores all but first char of input 
    char first = input[0];  // stores first char of input

    if (first=='m') {
        printf("3\n");
        printf("%s\n",numbers);
    }
}

然而，它的输出如下:

1
bytes written
Traceback (most recent call last):
     File "serial-receive-to-pwm.py", line 20, in <module>
     process.stdin.write("m2000\n")
IOError: [Errno 32] Broken pipe

C 程序显然在 fgets 行中断，因为 2 从未被打印出来。我做错了什么？我怎样才能避免这种情况？

编辑:我已经更新了 fgets 行，因此它不包含取消引用参数，但我仍然收到 broken pipe 错误。

编辑:input 被初始化为 char *input="m2000";

Answer 1

如果您尝试从控制台运行 C 程序，您会发现它崩溃了。如果你在调试器中运行，你会看到它在这一行:

fgets(*input,7,stdin);

看起来 input 是一个字符数组，当您使用 *input 取消引用它时，您传递的不是指针而是单个 char 值(value)。这会导致未定义的行为和崩溃。

如果不是错误，那行应该给你一个来自编译器的非常大的警告消息。不要忽视警告消息，它们通常表明您做错了事情并且可能存在危险。

---

一般提示:当开发一个应该从另一个程序调用的程序时，就像您在这里所做的那样，首先测试该程序以确保它可以正常工作。如果它不起作用，请先修复它。

最后一个提示:记住 fgets 在目标字符串中包含换行符。您可能需要检查它并在存在时将其删除。

---

通过最后的编辑，显示了 input 的声明，我们知道了真正的问题:您正在尝试修改常量数据，并且您还想编写超出数据的边界也是如此。

当您使input 指向文字串时，您必须记住所有文字串都是只读，您不能修改文字串。尝试这样做是未定义的行为。更糟糕的是，您的字符串只有六个字符长，但您尝试向其中写入七个字符。

首先更改input的声明和初始化:

char input[16] = "m2000\n";

这会将其声明为一个数组，位于堆栈中并且可以修改。然后做

while (fgets(input, sizeof(input), stdin) != NULL) { ... }

这完成了两件事:首先，通过使用 sizeof(input) 作为大小，您可以确保 fgets 永远不会越界写入。其次，通过在循环条件中使用 fgets 调用，循环将在 Python 脚本被中断时结束，并且您不会永远循环无法读取任何内容然后处理您从未处理过的数据阅读。