#include #include #include #include #include #include #include #include #include #include #include #include "CuTest.h" #include "linked_list_queue.h" #include "raft.h" typedef struct { void* inbox; } sender_t; int sender_send(void* caller, void* udata, int peer, const unsigned char* data, int len) { sender_t* me = caller; unsigned char * n; n = malloc(len); memcpy(n,data,len); llqueue_offer(me->inbox,n); return 0; } void* sender_new() { sender_t* me; me = malloc(sizeof(sender_t)); me->inbox = llqueue_new(); return me; } void* sender_poll_msg(void* s) { sender_t* me = s; return llqueue_poll(me->inbox); }