Read in Pipe

//ipc.h
typedef int8_t local_id;
typedef int16_t timestamp_t;
 
enum {
    MESSAGE_MAGIC = 0xAFAF,
    MAX_MESSAGE_LEN = 4096,
    PARENT_ID = 0,
    MAX_PROCESS_ID = 15
};
 
typedef enum {
    STARTED = 0,     ///< message with string (doesn't include trailing '\0')
    DONE,            ///< message with string (doesn't include trailing '\0')
    ACK,             ///< empty message
    STOP,            ///< empty message
    TRANSFER,        ///< message with TransferOrder
    BALANCE_HISTORY, ///< message with BalanceHistory
    CS_REQUEST,      ///< empty message
    CS_REPLY,        ///< empty message
    CS_RELEASE       ///< empty message
} MessageType;
 
typedef struct {
    uint16_t     s_magic;        ///< magic signature, must be MESSAGE_MAGIC
    uint16_t     s_payload_len;  ///< length of payload
    int16_t      s_type;         ///< type of the message
    timestamp_t  s_local_time;   ///< set by sender, depends on particular PA:
                                 ///< physical time in PA2 or Lamport's scalar
                                 ///< time in PA3
} __attribute__((packed)) MessageHeader;
 
enum {
    MAX_PAYLOAD_LEN = MAX_MESSAGE_LEN - sizeof(MessageHeader)
};
 
typedef struct {
    MessageHeader s_header;
    char s_payload[MAX_PAYLOAD_LEN]; ///< Must be used as a buffer, unused "tail"
                                     ///< shouldn't be transfered
} __attribute__((packed)) Message;

//pa1.h
static const char * const log_done_fmt =
    "Process %1d has DONE its work\n";
 
static const char * const log_received_all_done_fmt =
    "Process %1d received all DONE messages\n";

int receive(void *self, local_id from, Message *msg)//read 1 message
{   
 
Message msg = {.s_header={.s_magic=MESSAGE_MAGIC}};
msg.s_header.s_payload_len = MAX_PAYLOAD_LEN;/*len*/
//msg.s_header.s_type = /*type*/
time_t ttime;
time(&ttime);
msg.s_header.s_local_time = 0;//ctime(&ttime);/*time*/
 
///////////////
//pipe
///////////////
int fpipe[2];
if(pipe(fpipe)<0)
{
    printf("Cant create pipe!\n");
    exit(1);
    }   
    char sdata[4]={msg->s_header.s_magic,msg->s_header.s_payload_len,msg->s_header.s_local_time,(char)log_done_fmt};
    int dataproc;
    char buffer[4];
printf("%d\n",15);
    dataproc=read(fpipe[0],buffer,14);
printf("%d\n",16);
close(fpipe[0]);
 
        /////////////////////////////////
        //открыть файл events.log
        /////////////////////////////////
        FILE * f2; 
      
        f2 = fopen(events_log, "a");
        if (f2==NULL)
            perror("Ошибка открытия файла");
        else
            {
       printf("файл %s открыт для записи\n",events_log);
    MessageType mt=DONE;
    fprintf(f2,"%hu %hu %hu %u \n",(unsigned short int)msg->s_header.s_magic,(unsigned short int)msg->s_header.s_payload_len,
    (unsigned short int)msg->s_header.s_local_time,(short int)mt);
    }
        fclose(f2);
        
        /////////////////////////////////
        //открыть файл pipes.log
        /////////////////////////////////
        FILE *f1;
        f1 = fopen(pipes_log, "a");
        if (f1==NULL)
            perror("Ошибка открытия файла");
        else
            {
       printf("файл %s открыт\n",pipes_log);  
       fputs("R-open desc f2 file events\n",f1);
       fputs("R-close desc f2 file events\n",f1);                    
       fputs("R-open desc f1 file pipes\n",f1);
       fputs("R-close desc f1 file pipes\n",f1);  
    }
        fclose(f1);
    return from;
}

int send(void *self, local_id dst, const Message *msg)//write 1 message in pipe
{           
///////////////
//pipe
///////////////
int all;
all=5;
int fpipe[2];
if(pipe(fpipe)<0)
{
    printf("Cant create pipe!\n");
    exit(1);
    }
    char sdata[4]={msg->s_header.s_magic,msg->s_header.s_payload_len,msg->s_header.s_local_time,(char)log_started_fmt};
    int dataproc;
    dataproc=write(fpipe[1],sdata,strlen(sdata));
        close(fpipe[1]);
}