X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/af0b5e9494ca8988c8dd7d3874c3c7a400a63172..fc727903530d55d5d3f903a8213c7cb8a3273c7a:/include/msg/msg.h diff --git a/include/msg/msg.h b/include/msg/msg.h index 2452e27312..d28939b70e 100644 --- a/include/msg/msg.h +++ b/include/msg/msg.h @@ -12,8 +12,27 @@ #include "msg/datatypes.h" #include "xbt/automaton.h" +#include "simgrid/simix.h" + SG_BEGIN_DECL() +/** @brief Return code of most MSG functions + @ingroup msg_simulation + @{ */ +/* Keep these code as binary values: java bindings manipulate | of these values */ +typedef enum { + MSG_OK = 0, /**< @brief Everything is right. Keep on going this way ! */ + MSG_TIMEOUT = 1, /**< @brief nothing good happened before the timer you provided elapsed */ + MSG_TRANSFER_FAILURE = 2, /**< @brief There has been a problem during you task + transfer. Either the network is down or the remote host has been + shutdown. */ + MSG_HOST_FAILURE = 4, /**< @brief System shutdown. The host on which you are + running has just been rebooted. Free your datastructures and + return now !*/ + MSG_TASK_CANCELED = 8 /**< @brief Canceled task. This task has been canceled by somebody!*/ +} MSG_error_t; +/** @} */ + /************************** Global ******************************************/ XBT_PUBLIC(void) MSG_config(const char *name, ...); @@ -42,7 +61,7 @@ XBT_PUBLIC(size_t) MSG_file_read(const char* storage, void* ptr, size_t size, si XBT_PUBLIC(size_t) MSG_file_write(const char* storage, const void* ptr, size_t size, size_t nmemb, msg_file_t stream); XBT_PUBLIC(msg_file_t) MSG_file_open(const char* storage, const char* path, const char* mode); XBT_PUBLIC(int) MSG_file_close(const char* storage, msg_file_t fp); -XBT_PUBLIC(int) MSG_file_stat(const char* storage, int fd, void* buf); +XBT_PUBLIC(int) MSG_file_stat(const char* storage, msg_file_t fd, s_msg_stat_t *buf); /************************** Host handling ***********************************/ @@ -83,6 +102,7 @@ XBT_PUBLIC(m_process_t) MSG_process_create_with_environment(const char code, void *data, m_host_t host, + double kill_time, int argc, char **argv, xbt_dict_t @@ -174,7 +194,7 @@ XBT_PUBLIC(MSG_error_t) XBT_PUBLIC(msg_comm_t) MSG_task_isend(m_task_t task, const char *alias); XBT_PUBLIC(msg_comm_t) MSG_task_isend_with_matching(m_task_t task, const char *alias, - int (*match_fun)(void*,void*), + int (*match_fun)(void*,void*, smx_action_t), void *match_data); XBT_PUBLIC(void) MSG_task_dsend(m_task_t task, const char *alias, void_f_pvoid_t cleanup); @@ -268,7 +288,6 @@ XBT_PUBLIC(int) MSG_get_channel_number(void); #include "instr/instr.h" /* Used only by the bindings */ -#include "simix/simix.h" XBT_PUBLIC(smx_context_t) MSG_process_get_smx_ctx(m_process_t process); SG_END_DECL()