【发布时间】:2016-05-09 07:07:28
【问题描述】:
我正在尝试在我的 C 程序中创建一个聊天界面。
该程序使用两个fifo与同时运行命令cat fifo_out和tee fifo_in > /dev/null的分叉xterm进行通信。
然后打开一个线程来读取 *fifo_in 中的输入
感谢tee,来自终端,同时另一个线程在 fifo_out 中打印消息,并在 xterm 中显示内容。
一切似乎都运行良好...除了在终端中写入一些文本时打印了一条消息,将输入的文本分成两部分。这会导致段错误!
你知道为什么会这样吗?
这是一个最小的例子:
int open_terminal(pid_t *pid, int *pipe)
{
mkfifo("fifo_in", 0600);
mkfifo("fifo_out", 0600);
pid_t p = fork();
int fd_in, fd_out;
switch (p) {
case -1:
return -1;
case 0:
execlp("xterm", "xterm", "-e", "cat fifo_out & tee fifo_in > /dev/null", NULL);
exit(EXIT_FAILURE);
break;
default:
if ((fd_in = open("fifo_in", O_RDONLY)) == - 1)
return -1;
if ((fd_out = open("fifo_out", O_WRONLY)) == - 1)
return -1;
*pid = p;
pipe[0] = fd_in; pipe[1] = fd_out;
return 0;
}
return -1;
}
void *message_thread(void *args)
{
int *fd_out = (int *)args;
while (1) {
dprintf(*fd_out, "You're awesome!\n");
sleep(5);
}
}
void *input_thread(void *args)
{
int *fd_in = (int *)args;
FILE *f = fdopen(*fd_in, "r");
while (1) {
size_t n;
char *line;
getline(&line, &n, f);
printf("Read: %s", line);
free(line);
if(strcmp(line, "exit\n") == 0)
return NULL;
}
}
int main(int argc, char *argv[])
{
pid_t pid;
int pipe[2];
if (open_terminal(&pid, pipe) == -1) {
printf("Can't open terminal.\n");
return 1;
}
pthread_t mt, it;
pthread_create(&mt, NULL, message_thread, &pipe[1]);
pthread_create(&it, NULL, input_thread, &pipe[0]);
pthread_join(it, NULL);
return 0;
}
要重现我的情况,运行程序输入一些文本,等到在你的文本之后打印一些文本,然后再次输入并输入。
【问题讨论】:
-
您可能还想查看
unlink命令以在退出程序时清理fifos。如果有任何区别,您可能还想从getline的输入中修剪尾随'\n'。由于getline返回读取的字符数(包括'\n'),您可以简单地使用返回(例如nchr = getline (...然后line[--nchr] = 0;删除'\n'。然后您不需要看起来很奇怪的测试喜欢strcmp(line, "exit\n")
标签: c multithreading cat fifo tee