X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/2aaa919aa7451546f9576b3a71fc41f896c24b31..42e69c5d43675587aae0bb367b8bf0746f6be13a:/examples/msg/chainsend/peer.h

diff --git a/examples/msg/chainsend/peer.h b/examples/msg/chainsend/peer.h
index 58278625ec..8727e15f36 100644
--- a/examples/msg/chainsend/peer.h
+++ b/examples/msg/chainsend/peer.h
@@ -7,7 +7,7 @@
 #include "messages.h"
 #include "common.h"
 
-#define PEER_SHUTDOWN_DEADLINE 6000
+#define PEER_SHUTDOWN_DEADLINE 60000
 
 /* Peer struct */
 typedef struct s_peer {
@@ -16,6 +16,8 @@ typedef struct s_peer {
   const char *next;
   char *me;
   int pieces;
+  unsigned long long bytes;
+  xbt_dynar_t pending_recvs;
   xbt_dynar_t pending_sends;
   int close_asap; /* TODO: unused */
 } s_peer_t, *peer_t;
@@ -24,8 +26,10 @@ typedef struct s_peer {
 msg_error_t peer_wait_for_message(peer_t peer);
 int peer_execute_task(peer_t peer, msg_task_t task);
 void peer_init_chain(peer_t peer, message_t msg);
+void peer_delete(peer_t p);
 void peer_shutdown(peer_t p);
 void peer_init(peer_t p, int argc, char *argv[]);
+void peer_print_stats(peer_t p, float elapsed_time);
 
 int peer(int argc, char *argv[]);