Форум программистов [Powered by Invision Power Board]

Код

#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <signal.h>
#include <sys/wait.h>
#include <string.h>

int fr=-1, fw=-1;


int read_send(int pid,sigset_t* set)
{
    char symbol;
    int i,err,sgnl;
    for(;(err=read(fr,&symbol,1))==1;)
    {
        for(i=7;i>=0;i--)
        {
            if (((symbol>>i)&1) == '\0')
            {
                kill(pid,SIGUSR1);          //посылает сигнал SIGUSR1 пиду
            }
            else
            {
                kill(pid,SIGUSR2);         //посылает сигнал SIGUSR2 пиду
            }
            
            sigwait(set,&sgnl);
        }
    }
    if (err==-1) return -1;    
    
    close(fr);
    kill(pid,SIGTERM);
    _exit(0);
}

void termination(int signo)
{
    if ( fr != -1 ) close(fr);
    if ( fw != -1 ) close(fw);
    exit(0);
}

int receive_write(int pid,sigset_t* set)
{
    char symbol;
    int err,i,sgnl;

    while(waitpid(-1,NULL,WNOHANG)!=-1)
    {
        for(i=0;i<8;i++)
        {    
            err=0;
            symbol=symbol<<1;
            sigwait(set,&sgnl);
            if (sgnl == SIGUSR2)
                symbol+=1;
            else if (sgnl != SIGUSR1) 
            {
                symbol=symbol>>1;
                i--;
                err=1;        
            }
            kill(pid,SIGUSR1);
        }
        if (err==0)
            if (write(fw,&symbol,1) == -1) return -1;
    }    
    return 0;
}

int copy(char filename1[],char filename2[])                                        //функция copy, работающая от двух аргументов
{
    int n, prtime,pid,ppid;                                                    //описание переменных
    sigset_t set;                                                              //
    
    struct stat stbuf;                                                         //
    if ( stat(filename1,&stbuf) != 0 ) goto err;                               
                
    if (( fr = open(filename1,O_RDONLY) ) == -1 )                              //открываем файл для чтения
    {
        fprintf(stderr,"%s: ",filename1);                                  //возможная ошибка при этом
        goto err;                                                          //переход в блок обработки ошибок
    }
    if (( fw = open(filename2,O_CREAT|O_EXCL|O_WRONLY,stbuf.st_mode)) == -1 )  //создаём и открываем пустой файл для записи
    { 
        fprintf(stderr,"%s: ",filename2);                                  //возможная ошибка при этом
        goto err;                                                          //переход в блок обработки ошибок
    }
    
    sigemptyset(&set);                                                        //инициализирует набор сигналов, указанный в set, и "очищает" его от всех сигналов.
    sigaddset(&set,SIGUSR1);                                                  //добавдяет сигнал SIGUSR1 в набор set
    sigaddset(&set,SIGUSR2);                                                  //добавдяет сигнал SIGUSR2 в набор set
    sigprocmask(SIG_BLOCK,&set,NULL);                                         //Блокируем все сигналы
    
    ppid=getpid();
    
    if ((pid=fork()) == -1) goto err;                                     //создаём чилда и возможная ошибка при этом
    
    if (pid == 0)                                                            //если сын ничего не выполняет
    {
        close(fw);                                                       //закрываем записывающий "канал"
        if (read_send(ppid,&set) == -1)                                  //выполняем функцию чтения
        {
            fprintf(stderr,"%s: ",filename1);
            goto err;
        }
    }
    else
    {
        close(fr);
        if (receive_write(pid,&set) == -1)
        {
            fprintf(stderr,"%s: ",filename2);
            goto err;
        }
    }
    
    if (stat(filename2,&stbuf) != 0 ) goto err;
    
    close(fw);
    return 0;
err:
    fprintf(stderr,"error: %s \n",strerror(errno));
    if ( fr != -1 ) close(fr);
    if ( fw != -1 ) close(fw);
    exit(0);
}

int main(int argc, char **argv)                             //основная функция
{
    struct sigaction act;                               //определение обработчика сигнала
    memset(&act,0,sizeof(act));                         //обнуляет блоки динамической памяти
    act.sa_handler = termination;                       //задаём тип действия процесса:указатель на функцию обработки сигнала
    sigaction(SIGTERM,&act,NULL);

    if (argc!=3)                                       //считает количество операндов, нужно 1 название и 2 операнда
    {
        printf("\nne pravil'no nabrana komanda. Need: ./copy.c name_faila name_his_copy;\n\n");
    goto er0;
    }

    copy(argv[1],argv[2]);                             //копирует файл(запуск функции копирования)
        return 0;
    
er0:
    return -1;                                         //возвращаемый результат при ошибке
}