X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0c13871d73e933c1847faf8debea7b7745a3ff44..49e85177c669d793e84242983a1b1f430e47184e:/examples/msg/chainsend/messages.h diff --git a/examples/msg/chainsend/messages.h b/examples/msg/chainsend/messages.h index 52ba874d33..b717d5c0dc 100644 --- a/examples/msg/chainsend/messages.h +++ b/examples/msg/chainsend/messages.h @@ -1,3 +1,9 @@ +/* Copyright (c) 2012-2014. The SimGrid Team. + * All rights reserved. */ + +/* This program is free software; you can redistribute it and/or modify it + * under the terms of the license (GNU LGPL) which comes with this package. */ + #ifndef KADEPLOY_MESSAGES_H #define KADEPLOY_MESSAGES_H @@ -11,26 +17,23 @@ /* Messages enum */ typedef enum { MESSAGE_BUILD_CHAIN = 0, - MESSAGE_SEND_DATA, - MESSAGE_END_DATA + MESSAGE_SEND_DATA } e_message_type; /* Message struct */ typedef struct s_message { e_message_type type; - const char *issuer_hostname; - const char *mailbox; - const char *prev_hostname; - const char *next_hostname; + char *prev_hostname; + 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_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); +msg_task_t task_message_new(e_message_type type, unsigned int len); +msg_task_t task_message_chain_new(const char* prev, const char *next, const unsigned int num_pieces); +msg_task_t task_message_data_new(const char *block, unsigned int len); void task_message_delete(void *); #endif /* KADEPLOY_MESSAGES_H */