X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0c13871d73e933c1847faf8debea7b7745a3ff44..2eef51f85212214302326508352271ca96de05eb:/examples/msg/chainsend/messages.h diff --git a/examples/msg/chainsend/messages.h b/examples/msg/chainsend/messages.h index 52ba874d33..7118d29f93 100644 --- a/examples/msg/chainsend/messages.h +++ b/examples/msg/chainsend/messages.h @@ -11,8 +11,7 @@ /* Messages enum */ typedef enum { MESSAGE_BUILD_CHAIN = 0, - MESSAGE_SEND_DATA, - MESSAGE_END_DATA + MESSAGE_SEND_DATA } e_message_type; /* Message struct */ @@ -24,13 +23,13 @@ typedef struct s_message { const char *next_hostname; const char *data_block; unsigned int data_length; + unsigned int num_pieces; } s_message_t, *message_t; /* Message methods */ msg_task_t task_message_new(e_message_type type, unsigned int len, const char *issuer_hostname, const char *mailbox); -msg_task_t task_message_chain_new(const char *issuer_hostname, const char *mailbox, const char* prev, const char *next); +msg_task_t task_message_chain_new(const char *issuer_hostname, const char *mailbox, const char* prev, const char *next, const unsigned int num_pieces); msg_task_t task_message_data_new(const char *issuer_hostname, const char *mailbox, const char *block, unsigned int len); -msg_task_t task_message_end_data_new(const char *issuer_hostname, const char *mailbox); void task_message_delete(void *); #endif /* KADEPLOY_MESSAGES_H */