#define _DEFAULT_SOURCE
#include <errno.h>
#include <unistd.h>
#include <stdbool.h>

#include "io.h"
#include "ipc.h"
#include "child.h"

int
send(void *self, local_id dst, const Message *msg) {
    proc_t *p   = (proc_t*)self;
    local_id src  = p->self_id;

    if (src == dst)
        return -1;

    int    fd   = p->io->fds[src][dst][WRITE_FD];
    fprintf(p->io->pipes_log_stream, "ID %hhd send to %hhd.\n", src, dst);
    return write(fd, msg, sizeof(Message));
}

int
send_multicast(void *self, const Message *msg) {
    proc_t   *p   = (proc_t*)self;
    size_t   pnum = p->io->procnum;

    for (local_id i = 0; i <= pnum; i++) {
        send((void*)p, i, msg);
    }
    return 0;
}

int
receive(void *self, local_id from, Message *msg) {
    proc_t *p   = (proc_t*)self;
    local_id to = p->self_id;
    if (to == from)
        return -1;
    int    fd   = p->io->fds[from][to][READ_FD];
    ssize_t r = read(fd, msg, sizeof(Message));
    if (r < 0 && errno != EAGAIN) {
        perror("read");
        return -1;
    }
    return r > 0 ? 0 : -1;
}

int
receive_any(void *self, Message *msg) {
    return -1;   
}