[C] клиент-сервер

#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#define oops(m,x) {perror(m); exit(x);}
int run_unpack(int *, int *);
int run_ui(int *, int *);
int main(void)
{
 
    int pid;
    int to_unpack[2], from_unpack[2];
 
    /*образовать два канала*/
    if(pipe(to_unpack) == -1 || pipe(from_unpack) == -1)
    {
        oops("pipe failed", 1);
    }
 
    /*создать два процесса*/
    switch(fork())  
        {
            case -1: 
                oops("ошибка fork",1);     
                break;
            case 0: 
                printf("Порожденный процесс pid=%d\n",getpid());
                run_unpack(to_unpack,from_unpack);
            default:
                printf("Родительский процесс pid=%d\n",getpid());
                run_ui(to_unpack, from_unpack);
                wait(NULL);
        }
}
 
int run_unpack(int in [2], int out [2])
{
    if(dup2(in[0],0) == -1) /*дублирование дескриптора конца для чтения в дескриптор 0*/
    {
        oops("dc: cannot redirect stdin",3);
    }
 
    close(in[0]);   /*уже продублировали in[0] в 0, будем читать данные через дескриптор 0*/
    close(in[1]); /*закрываем записываемый конец канала*/
 
    if(dup2(out[1],1) == -1)    /*дублирование дескриптора конца для записи в дескриптор 1*/
    {
        oops("run_unpack: cannot redirect stdout",4);
    }
    close(out[1]);  /*уже продублировали out[1] в 1, будем записывать данные через дескриптор 1*/
    close(out[0]); /*закрываем читаемый конец канала*/
    execlp("./unpack","./unpack", NULL);
    oops("cannot run unpack",5);
}
 
 
int run_ui(int to_unpack[2], int from_unpack[2])
{
    unsigned int r; /* код состояния */
    unsigned int e; /* признак ошибки */
    unsigned int w; /* признак занятости */
    unsigned int u; /* количество байт */
    unsigned int UnitStateWord; /*слово состояния */
    FILE *fin, *fout;
    int i;
 
    close(to_unpack[0]); /*не производить чтение из канала к unpack*/
    close(from_unpack[1]); /*не записывать в канал из unpack*/
 
    fout = fdopen(to_unpack[1],"w"); /*преобразовать файловые дескрипторы*/
    fin = fdopen(from_unpack[0],"r"); /*в потоки*/
 
    if (fout == NULL || fin == NULL)
 
    {
        fprintf(stderr, "Ошибка: не удалось преобразовать каналы в потоки");
        exit(1);
    }
        for (i =0; i<2; i++)
        {
            printf("Введите упакованое слово состояния устройства (0 - 65535) >");
            scanf("%u",&UnitStateWord);
            if (fprintf(fout, "%u\n", UnitStateWord) == EOF)
            {
                fprintf(stderr, "Ошибка: не удалось записать в канал");
                exit(1);
            }
 
            fflush(fout);
 
            if (fscanf(fin, "%u %u %u %u",&r,&e,&w,&u) <= 0)
            {
                break;
            }
            
            printf("Код состояния: %u\n",r);
            printf("Признак ошибки: %u\n",e);
            printf("Признак занятости: %u\n",w);
            printf("Кол-во переданных байт: %u\n",u);
        
            }
    fclose(fout);
    fclose(fin);    
}
2.2 Листинг программы сервера.
 
#include <stdio.h>
int main(void)
 
{
  unsigned int r; /* код состояния */
  unsigned int e; /* признак ошибки */
  unsigned int w; /* признак занятости */
  unsigned int u; /* количество байт */
  unsigned int UnitStateWord; /*слово состояния */
  /* формирование упакованного кода */
        while (scanf("%u",&UnitStateWord) != EOF)
    {
        /*fprintf(stderr,"unpack schital %u\n",UnitStateWord);*/
        r=(UnitStateWord>>7)&1;
        e=(UnitStateWord>>5)&1;
        w=(UnitStateWord>>6)&1;
        u=(UnitStateWord>>8)&0xFF;
  /* вывод результата */
        printf("%u %u %u %u\n", r,e,w,u);
        fflush(stdout);
  /*fprintf(stderr,"unpack vivel %u %u %u %u\n", r,e,w,u);*/
        }
}