examples/msg/chainsend/peer.h

   1 #ifndef KADEPLOY_PEER_H
   2 #define KADEPLOY_PEER_H
   3
   4 #include "msg/msg.h"
   5 #include "xbt/sysdep.h"
   6
   7 #include "messages.h"
   8 #include "common.h"
   9
  10 #define PEER_SHUTDOWN_DEADLINE 60000
  11
  12 /* Peer struct */
  13 typedef struct s_peer {
  14   int init;
  15   const char *prev;
  16   const char *next;
  17   char *me;
  18   int pieces;
  19   xbt_dynar_t pending_sends;
  20   int close_asap; /* TODO: unused */
  21 } s_peer_t, *peer_t;
  22
  23 /* Peer: helper functions */
  24 msg_error_t peer_wait_for_message(peer_t peer);
  25 int peer_execute_task(peer_t peer, msg_task_t task);
  26 void peer_init_chain(peer_t peer, message_t msg);
  27 void peer_shutdown(peer_t p);
  28 void peer_init(peer_t p, int argc, char *argv[]);
  29
  30 int peer(int argc, char *argv[]);
  31
  32 #endif /* KADEPLOY_PEER_H */