C语言 Cygwin:由于 stdio putc + 线路缓冲而丢失流数据

Question

以下程序的预期输出为：

received REQUEST
 from client
received REPLY
 from server

例如，在GNU/Linux上可以看到这一点。但是，在Cygwin上，实际输出是这样的：

received REQUEST
 from client
received 
 from server

从客户端的流接收空行（"n"字符串），而不是"REPLYn"。

问题源于putc和线路缓冲的组合。

• 在server函数中，如果我们用 fprintf 替换my_puts ，则产生预期的输出。
• 在server中，如果我们去掉将流切换到线路缓冲的setvbuf调用，也会产生预期的输出。
• 如果我们更改my_puts以便它使用 fprintf(f, "%c", ch) 而不是 putc(ch, f) 输出每个字符 ，则会产生预期的输出。
• 用fputc代替putc没有区别。
• 在服务器中，添加文件定位操作，例如按照 ISO C 的要求在输入和输出之间fseek(cli_stream, 0, SEEK_CUR)（因此就在my_puts调用之前）没有区别。这包含在下面的代码中。

这个

程序是否做错了什么来带来这个奇怪的问题？

法典：

#include <stdio.h>
#include <stdlib.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/wait.h>
#include <errno.h>
#include <unistd.h>
#include <signal.h>
int my_puts(FILE *f, const char *str)
{
   int ch;
   while ((ch = *str++))
     if (putc(ch, f) == EOF) {
       perror("putc");
       return EOF;
     }
   return 0;
}
int client(struct sockaddr_in *srv_addr)
{
  int srv_fd = socket(AF_INET, SOCK_STREAM, 0);
  FILE *srv_stream;
  char buf[256];
  if (srv_fd == -1) {
    perror("socket");
    return EXIT_FAILURE;
  }
  if (connect(srv_fd, (struct sockaddr *) srv_addr, sizeof *srv_addr) == -1) {
    perror("connect");
    close(srv_fd);
    return EXIT_FAILURE;
  }
  if ((srv_stream = fdopen(srv_fd, "r+")) == 0) {
    perror("fdopen");
    close(srv_fd);
    return EXIT_FAILURE;
  }
   setvbuf(srv_stream, (char *) NULL, _IOLBF, 0);
  my_puts(srv_stream, "REQUESTn");
  fflush(srv_stream);
  shutdown(srv_fd, SHUT_WR);
  if (fgets(buf, sizeof buf, srv_stream) == 0) {
    printf("short fread");
    fclose(srv_stream);
    return EXIT_FAILURE;
  }
  printf("received %s from servern", buf);
  return 0;
}
void server(int acc_fd)
{
  struct sockaddr_in claddr;
  socklen_t claddrlen = sizeof claddr;
  int cli_fd = accept(acc_fd, (struct sockaddr *) &claddr, &claddrlen);
  FILE *cli_stream = fdopen(cli_fd, "r+");;
  char buf[256];
  if (cli_fd == -1) {
    perror("accept");
    if (cli_stream)
      fclose(cli_stream);
    return;
  }
  if (cli_stream == 0) {
    perror("fdopen");
    close(cli_fd);
    return;
  }
  setvbuf(cli_stream, (char *) NULL, _IOLBF, 0);
  if (fgets(buf, sizeof buf, cli_stream) == 0) {
    printf("short fread");
    fclose(cli_stream);
    return;
  }
  printf("received %s from clientn", buf);
  fseek(cli_stream, 0, SEEK_CUR);
  my_puts(cli_stream, "REPLYn");
  fflush(cli_stream);
  fclose(cli_stream);
}
int main(void)
{
  struct sockaddr_in saddr = { 0 };
  int acc_fd = socket(AF_INET, SOCK_STREAM, 0);
  pid_t child;
  saddr.sin_family = AF_INET;
  saddr.sin_port = htons(12345);
  saddr.sin_addr.s_addr = htons(INADDR_ANY);
  if (acc_fd == -1) {
    perror("socket");
    return EXIT_FAILURE;
  }
  if (bind(acc_fd, (struct sockaddr *) &saddr, sizeof saddr) == -1) {
    perror("bind");
    return EXIT_FAILURE;
  }
  if (listen(acc_fd, 1) == -1) {
    perror("listen");
    return EXIT_FAILURE;
  }
  child = fork();
  if (child == -1) {
    perror("fork");
    return EXIT_FAILURE;
  } else if (child == 0) {
    server(acc_fd);
    _exit(0);
  } else {
    int status;
    int result = client(&saddr);
    kill(child, SIGKILL);
    if (wait(&status) != child) {
      printf("wait problem");
      return EXIT_FAILURE;
    }
    return result;
  }
  return 0;
}

Answer 1

Cygwin git 现在有修复程序，从 OpenBSD 向后移植。

一个较小的重现测试用例被发布到邮件列表中。