1 #ifndef KADEPLOY_PEER_H
2 #define KADEPLOY_PEER_H
5 #include "xbt/sysdep.h"
10 #define PEER_SHUTDOWN_DEADLINE 60000
13 typedef struct s_peer {
19 unsigned long long bytes;
20 xbt_dynar_t pending_recvs;
21 xbt_dynar_t pending_sends;
22 unsigned int total_pieces;
25 /* Peer: helper functions */
26 msg_error_t peer_wait_for_message(peer_t peer);
27 int peer_execute_task(peer_t peer, msg_task_t task);
28 void peer_init_chain(peer_t peer, message_t msg);
29 void peer_delete(peer_t p);
30 void peer_shutdown(peer_t p);
31 void peer_init(peer_t p, int argc, char *argv[]);
32 void peer_print_stats(peer_t p, float elapsed_time);
34 int peer(int argc, char *argv[]);
36 #endif /* KADEPLOY_PEER_H */