- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
我正在使用 libuv。我读过 http://nikhilm.github.com/uvbook/processes.html并且仍然无法弄清楚如何捕获子进程的标准输出,以便它在父进程中可用(但不能代替父进程的标准输入)。
我的代码目前是:
#include <stdio.h>
#include <stdlib.h>
#include "../../libuv/include/uv.h"
uv_loop_t *loop;
uv_process_t child_req;
uv_process_options_t options;
uv_pipe_t apipe;
void on_child_exit(uv_process_t *req, int exit_status, int term_signal) {
fprintf(stderr, "Process exited with status %d, signal %d\n", exit_status, term_signal);
uv_close((uv_handle_t*) req, NULL);
}
uv_buf_t alloc_buffer(uv_handle_t *handle, size_t len) {
printf("alloc_buffer called\n");
uv_buf_t buf;
buf.base = malloc(len);
buf.len = len;
return buf;
}
void read_apipe(uv_stream_t* stream, ssize_t nread, uv_buf_t buf) {
printf("read %li bytes from the child process\n", nread);
}
int main(int argc, char *argv[]) {
printf("spawn_test\n");
loop = uv_default_loop();
char* args[3];
args[0] = "dummy";
args[1] = NULL;
args[2] = NULL;
uv_pipe_init(loop, &apipe, 0);
uv_pipe_open(&apipe, 0);
options.stdio_count = 3;
uv_stdio_container_t child_stdio[3];
child_stdio[0].flags = UV_IGNORE;
child_stdio[1].flags = UV_INHERIT_STREAM;
child_stdio[1].data.stream = (uv_stream_t *) &apipe;
child_stdio[2].flags = UV_IGNORE;
options.stdio = child_stdio;
options.exit_cb = on_child_exit;
options.file = args[0];
options.args = args;
uv_read_start((uv_stream_t*)&apipe, alloc_buffer, read_apipe);
if (uv_spawn(loop, &child_req, options)) {
fprintf(stderr, "%s\n", uv_strerror(uv_last_error(loop)));
return 1;
}
return uv_run(loop, UV_RUN_DEFAULT);
}
虚拟.c:
#include <unistd.h>
#include <stdio.h>
int main() {
printf("child starting\n");
sleep(1);
printf("child running\n");
sleep(2);
printf("child ending\n");
return 0;
}
我有一种挥之不去的感觉,我还不太明白 libuv 管道的意义。
最佳答案
我找到了解决方案:
UV_CREATE_PIPE | UV_READABLE_PIPE
不是 UV_INHERIT_STREAM
。uv_spawn
之后调用 uv_read_start
。我假设没有数据丢失的可能性,因为尚未调用 uv_run。dummy
的所有输出同时到达,而不是分成三 block (就像在命令行上那样)。 dummy.c
中的 fflush
解决了这个问题。生成测试:
#include <stdio.h>
#include <stdlib.h>
#include "../../libuv/include/uv.h"
uv_loop_t *loop;
uv_process_t child_req;
uv_process_options_t options;
uv_pipe_t apipe;
void on_child_exit(uv_process_t *req, int exit_status, int term_signal) {
fprintf(stderr, "Process exited with status %d, signal %d\n", exit_status, term_signal);
uv_close((uv_handle_t*) req, NULL);
}
uv_buf_t alloc_buffer(uv_handle_t *handle, size_t len) {
printf("alloc_buffer called, requesting a %lu byte buffer\n");
uv_buf_t buf;
buf.base = malloc(len);
buf.len = len;
return buf;
}
void read_apipe(uv_stream_t* stream, ssize_t nread, uv_buf_t buf) {
printf("read %li bytes in a %lu byte buffer\n", nread, buf.len);
if (nread + 1 > buf.len) return;
buf.base[nread] = '\0'; // turn it into a cstring
printf("read: |%s|", buf.base);
}
int main(int argc, char *argv[]) {
printf("spawn_test\n");
loop = uv_default_loop();
char* args[3];
args[0] = "dummy";
args[1] = NULL;
args[2] = NULL;
uv_pipe_init(loop, &apipe, 0);
uv_pipe_open(&apipe, 0);
options.stdio_count = 3;
uv_stdio_container_t child_stdio[3];
child_stdio[0].flags = UV_IGNORE;
child_stdio[1].flags = UV_CREATE_PIPE | UV_READABLE_PIPE;
child_stdio[1].data.stream = (uv_stream_t *) &apipe;
child_stdio[2].flags = UV_IGNORE;
options.stdio = child_stdio;
options.exit_cb = on_child_exit;
options.file = args[0];
options.args = args;
if (uv_spawn(loop, &child_req, options)) {
fprintf(stderr, "%s\n", uv_strerror(uv_last_error(loop)));
return 1;
}
uv_read_start((uv_stream_t*)&apipe, alloc_buffer, read_apipe);
return uv_run(loop, UV_RUN_DEFAULT);
}
虚拟.c:
#include <unistd.h>
#include <stdio.h>
int main() {
printf("child starting\n");
fflush(stdout);
sleep(1);
printf("child running\n");
fflush(stdout);
sleep(2);
printf("child ending\n");
fflush(stdout);
return 0;
}
关于使用 libuv 捕获子进程的标准输出,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/14751504/
我正在尝试运行来自 https://github.com/aspnet/home 的示例 我遵循了 documentation 中的所有步骤但我无法让它发挥作用。 我正在运行 dnx 。 kestre
我真的很困惑 libev 和 libuv。 libuv 只是 POSIX 系统上 libev 的包装器吗? 如果不是,它的区别在哪里? 最佳答案 不再,因为 libuv-v0.9 Here is th
我想尝试在 dlang 中使用 libuv。我下载了这样的 dlang 绑定(bind): git clone git@github.com:tamediadigital/libuv.git 现在我接
我知道事件循环在单个进程(因此,在单个内核)上运行,但是我想知道从那里启动线程时会发生什么。 如果我使用uv_thread_create或uv_queue_work启动多个线程,它们是否可以在多个内核
我想知道需要采取什么预防措施,以便能够安全地从C++中的多个线程向libuv事件循环添加回调。 更多详细信息 我有一些多线程C++ 11代码,我想对其进行修改以使用libuv的网络通信API。我不想每
我正在 libuv 中初始化一个循环,但是如果我需要在初始化循环之后但在调用 uv_run 之前返回,如何正确清理所有内存和文件描述符?这是我的示例代码,loop 为 uv_loop_t*,serve
如果我有这个功能,你会如何在字节码虚拟机中使用libuv void vm_run(vm_t* vm); 它启动虚拟机来执行代码,只要用户的代码这样做,它就会继续运行,现在我想在VM语言中添加异步内容,
要求:UDP 服务器在接收到 UDP 数据包后,将接收到的数据包存储到两个队列之一。每个队列都关联一个工作线程,关联的线程从队列前端拾取数据包,对其进行处理并将其写入内存缓存系统。 约束:解决方案必须
当我尝试发送一些基本的 UDP 消息时,它看起来好像没有发送。我尝试运行我在网上找到的几个示例。我正在使用 SocketTest v3.0.0 来测试服务器/客户端。当我测试 TCP 发送时,一切都按
uv_write 的文档指出 [ 1 ]: Note The memory pointed to by the buffers must remain valid until the callback
我正在使用 libsourcey,它使用 libuv 作为其底层 I/O 网络层。一切都已设置并且似乎正在运行(因为我只是在制作原型(prototype)和试验,所以还没有测试任何东西)。但是,我要求
我正在尝试为 C++ 库编写 nodejs 绑定(bind),但我似乎遇到了障碍。 我正在尝试使对 C++ 库的所有调用都是异步的,这就是我使用 libuv 的原因。我基本上是在关注 this教程。
在 libuv 中,您最终可能会因过多的工作或错误代码而占用工作线程。是否有一个简单的函数可以检查工作线程或线程队列的健康状况?它不必是 100% 确定性的,毕竟不可能确定工作线程是卡在慢速代码上还是
server 将在调用 start 后在新线程中启动(服务器有自己的循环)。问题是程序立即结束,因为默认循环中没有注册事件。我想要的是通过 uv_default_loop 模拟 pthread_joi
我正在尝试找出如何修复我在使用 Valgrind 运行此程序时遇到的这些内存泄漏。泄漏发生在 nShell_client_main 中的两个分配。但我不是确定如何正确释放它们。 我已经尝试在 nShe
我正在使用 libuv。我读过 http://nikhilm.github.com/uvbook/processes.html并且仍然无法弄清楚如何捕获子进程的标准输出,以便它在父进程中可用(但不能代
我有一个使用 libuv 库的应用程序。它运行默认循环: uv_run(uv_default_loop()); 应用出现故障时如何优雅退出?目前我正在按照以下示例进行操作: uv_tcp_t* tcp
我正在评估 libuv 作为我正在编写的 C/c++ 服务器的库。该协议(protocol)以长度为前缀,所以一旦我可以从流中读取一个 32 位整数,我就应该能够知道我应该分配多大的缓冲区。文档说 u
例如我有 2 个线程 .我要从主线程(线程 1)停止服务器。 线程1:主程序 线程 2:TcpServer 来自 libuv 库: /* * This function will stop the
我正在尝试运行与 LWS 库一起安装的“libwebsockets-test-server”,但它无法运行,因为“lwsts[31616]: libuv 支持未编译”。 我已经检查过是否安装了 lib
我是一名优秀的程序员,十分优秀!