X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/9e68ca10e951fb61e944c99c7774b1e415ae9f6d..b3b356352e87ae00a20f737c48e19b0c8413455a:/examples/msg/chainsend/messages.h diff --git a/examples/msg/chainsend/messages.h b/examples/msg/chainsend/messages.h index 52ba874d33..9e976d402c 100644 --- a/examples/msg/chainsend/messages.h +++ b/examples/msg/chainsend/messages.h @@ -1,7 +1,13 @@ +/* Copyright (c) 2012-2015. 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 -#include "msg/msg.h" +#include "simgrid/msg.h" #include "xbt/sysdep.h" #define MESSAGE_BUILD_CHAIN_SIZE 40 @@ -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 */