examples/msg/kadeploy/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
   9 #define PEER_SHUTDOWN_DEADLINE 6000
  10
  11 /* Peer struct */
  12 typedef struct s_peer {
  13   int init;
  14   const char *prev;
  15   const char *next;
  16   const char *me;
  17   int pieces;
  18   xbt_dynar_t pending_sends;
  19   int close_asap; /* TODO: unused */
  20 } s_peer_t, *peer_t;
  21
  22 /* Peer: helper functions */
  23 msg_error_t peer_wait_for_message(peer_t peer);
  24 int peer_execute_task(peer_t peer, msg_task_t task);
  25 void peer_init_chain(peer_t peer, message_t msg);
  26 void peer_shutdown(peer_t p);
  27 void peer_init(peer_t p);
  28
  29 int peer(int argc, char *argv[]);
  30
  31 #endif /* KADEPLOY_PEER_H */