Только одно сообщение проходит через канал - PullRequest
Новая
       3

Только одно сообщение проходит через канал

2 голосов
/ 25 декабря 2011

Я выполняю это задание снова и снова, это примерно десятая версия. Проблема в том, что через канал проходит только одно сообщение, и вычисляется правильный результат. Следующие строки вообще не передаются, или после того, как они возились с буферами, только некоторые символы. Пожалуйста, помогите, я действительно потерял много времени на этом, и мне нужно изучить этот материал для предстоящего теста. 

#include <ctype.h>
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/wait.h>
#include <string.h>
#include <stdio_ext.h>

/* Prototypes */

void usage(void);
void calchild(void);

char command[] = "<not yet set>";

int main(int argc, char **argv)
{
  char input1[512];
  char input2[512];
  char tmp[512];
  char *endptr;
  char c = 0;
  int a, b, result;
  pid_t cpid;
  int status = 0;
  int stocpipe[2]; /* Server to client pipe. [0] -read; [1]- write*/
  int ctospipe[2]; /* Client to server pipe.       - || -         */
  int i = 0;
  FILE *send, *receive;

  if(argc > 1)
    {
      usage();
    }

  /* Pipe Setup */
  if(pipe(stocpipe) != 0 || pipe(ctospipe) != 0)
    {
      fprintf(stderr, "ERROR: Can't create unnamed pipe! \n");
      exit(EXIT_FAILURE);
    }

  switch(cpid = fork())
    {
    case -1:
      fprintf(stderr, "ERROR: Can't fork! \n");
      exit(EXIT_FAILURE);
      break;
    case 0:
      /* calchild */
      close(stocpipe[1]);
      close(ctospipe[0]);

      receive = fdopen(stocpipe[0], "r");
      send = fdopen(ctospipe[1], "w");

/*Gets the string from the parent process and does the computation.*/
      while(fgets(input2, 17, receive) != NULL)
        {
      strcpy(tmp, input2);
      fprintf(stdout, "After receive: %s", tmp);
      a = strtol(tmp, &endptr, 10);
      fprintf(stdout, "a = %d\n", a);
      b = strtol(endptr, &endptr, 10); 
      fprintf(stdout, "b = %d\n", b);
      c = endptr[0];

/*Loops until it finds a non-space char*/
      for(i = 0; isspace(c = endptr[i]); i++);

      switch(c)
    {
    case '+':
      /*add*/
      result = a + b;
      break;
    case '-':
      /*subtract*/
      result = a - b;
      break;
    case '*':
      /*multiply*/
      result = a * b;
      break;
    case '/':
      /*divide*/
      result = a / b;
      break;
    default:
      fprintf(stderr, "the funk!? %c\n", c);
      break;
    }

      fprintf(stderr, "%d\n", result);
      fprintf(send, "%d", result);

    }
      break;
    default:

  close(stocpipe[0]);
  close(ctospipe[1]);

  send = fdopen(stocpipe[1], "w");
  receive = fdopen(ctospipe[0], "r");

/*Reads string from stdin and sends it to the child process through a pipe. */
  while(fgets(input1, 17, stdin) != NULL)
    {
      fprintf(stdout, "Before send: %s", input1);
      fwrite(input1, 17, 1, send);

if(fflush(send) == EOF)
    {
      fprintf(stderr, "Flush error!");
  }
}

  (void) waitpid(cpid, &status, 0);
  if(status != 0)
    {
      fprintf(stderr, "ERROR: Child calculator exited with %d \n", status);
    }
      break;
   }


  return 0;
}

void usage(void)
{
  fprintf(stderr,"Usage: %s", command);
  exit(EXIT_FAILURE);
}

Программа представляет собой калькулятор. Целью этого является изучение IPC. Родительский процесс принимает строки из stdin (например, 35 +) и отправляет их дочернему элементу. Дочерний анализирует строку и вычисляет результат. Затем он отправляет результат обратно в родительский процесс, который затем печатает его в стандартный вывод.

Я застрял на части отправки строки ребенку. Первая принятая строка отправляется ребенку. И это прекрасно вычисляет результат. Вторая строка и каждая после нее пуста или, по крайней мере, кажется пустой.

1 Ответ

1 голос
/ 18 мая 2012

Обратите внимание на строку fwrite(input1, 17, 1, send);.Процесс parent может отправлять случайный материал после символа '\ n' процессу child .В child while(fgets(input2, 17, receive) != NULL), fgets останавливается при получении '\ n' и может содержать менее 17-1 символов.Его следующий канал чтения получит случайные вещи.

Одно немедленное исправление - fwrite(input1, strlen(input1), 1, send);.Ссылаясь на 'man fwrite', лучше использовать fwrite(input1, sizeof (input1[0]), strlen(input1), send);.

В любом случае использование магического числа 17 опасно.Помните, что PIPE - это непрерывный поток символов.

...