Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
72a65ccb746908c1285a258a1b4a0cf06dc6d494
[simgrid.git] / src / msg / private.h
1 /*     $Id$      */
2
3 /* Copyright (c) 2002-2007 Arnaud Legrand.                                  */
4 /* Copyright (c) 2007 Bruno Donassolo.                                      */
5 /* All rights reserved.                                                     */
6
7 /* This program is free software; you can redistribute it and/or modify it
8  * under the terms of the license (GNU LGPL) which comes with this package. */
9
10 #ifndef METASIMGRID_PRIVATE_H
11 #define METASIMGRID_PRIVATE_H
12
13 #include "msg/msg.h"
14 #include "simix/simix.h"
15 #include "surf/surf.h"
16 #include "xbt/fifo.h"
17 #include "xbt/dynar.h"
18 #include "xbt/swag.h"
19 #include "xbt/dict.h"
20 #include "xbt/config.h"
21
22 SG_BEGIN_DECL()
23
24 /**************** datatypes **********************************/
25 /* this structure represents a mailbox */
26      typedef struct s_msg_mailbox {
27        char *alias;             /* the key of the mailbox in the global dictionary */
28        smx_cond_t cond;         /* the condition on the mailbox */
29        smx_rdv_t rdv;           /* SIMIX rendez-vous point */
30      } s_msg_mailbox_t;
31
32      typedef struct simdata_host {
33        smx_host_t smx_host;     /* SURF modeling                                                                */
34        struct s_msg_mailbox **mailboxes;        /* mailboxes to store msg tasks of of the host  */
35        smx_mutex_t mutex;       /* mutex to access the host                                     */
36      } s_simdata_host_t;
37
38 /********************************* Task **************************************/
39
40      typedef struct simdata_task {
41        smx_action_t compute;    /* SURF modeling of computation  */
42        smx_comm_t comm;         /* SIMIX communication  */
43        double message_size;     /* Data size  */
44        double computation_amount;       /* Computation size  */
45        smx_cond_t cond;
46        smx_mutex_t mutex;       /* Task mutex */
47        m_process_t sender;
48        m_process_t receiver;
49        m_host_t source;
50        double priority;
51        double rate;
52        int refcount;
53   /*******  Parallel Tasks Only !!!! *******/
54        int host_nb;
55        smx_host_t *host_list;
56        double *comp_amount;
57        double *comm_amount;
58      } s_simdata_task_t;
59
60 /******************************* Process *************************************/
61
62      typedef struct simdata_process {
63        m_host_t m_host;         /* the host on which the process is running */
64        smx_process_t s_process;
65        int PID;                 /* used for debugging purposes */
66        int PPID;                /* The parent PID */
67        m_host_t put_host;       /* used for debugging purposes */
68        m_channel_t put_channel; /* used for debugging purposes */
69        smx_action_t waiting_action;
70        m_task_t waiting_task;
71        int argc;                /* arguments number if any */
72        char **argv;             /* arguments table if any */
73        MSG_error_t last_errno;  /* the last value returned by a MSG_function */
74      } s_simdata_process_t;
75
76      typedef struct process_arg {
77        const char *name;
78        xbt_main_func_t code;
79        void *data;
80        m_host_t m_host;
81        int argc;
82        char **argv;
83        double kill_time;
84      } s_process_arg_t, *process_arg_t;
85
86 /************************** Global variables ********************************/
87      typedef struct MSG_Global {
88        xbt_fifo_t host;
89        xbt_fifo_t process_list;
90        int max_channel;
91        int PID;
92        int session;
93        unsigned long int sent_msg;      /* Total amount of messages sent during the simulation */
94      } s_MSG_Global_t, *MSG_Global_t;
95
96 /*extern MSG_Global_t msg_global;*/
97 XBT_PUBLIC_DATA(MSG_Global_t) msg_global;
98
99
100 /*************************************************************/
101
102 #define PROCESS_SET_ERRNO(val) (MSG_process_self()->simdata->last_errno=val)
103 #define PROCESS_GET_ERRNO() (MSG_process_self()->simdata->last_errno)
104 #define MSG_RETURN(val) do {PROCESS_SET_ERRNO(val);return(val);} while(0)
105 /* #define CHECK_ERRNO()  ASSERT((PROCESS_GET_ERRNO()!=MSG_HOST_FAILURE),"Host failed, you cannot call this function.") */
106
107 #define CHECK_HOST()  xbt_assert1(SIMIX_host_get_state(SIMIX_host_self())==1,\
108                                   "Host failed, you cannot call this function. (state=%d)",SIMIX_host_get_state(SIMIX_host_self()))
109
110      m_host_t __MSG_host_create(smx_host_t workstation, void *data);
111
112      void __MSG_host_destroy(m_host_t host);
113
114      void __MSG_display_process_status(void);
115
116      void __MSG_process_cleanup(void *arg);
117      void *_MSG_process_create_from_SIMIX(const char *name,
118                                           xbt_main_func_t code, void *data,
119                                           char *hostname, int argc,
120                                           char **argv, xbt_dict_t properties);
121      void _MSG_process_kill_from_SIMIX(void *p);
122
123      void _MSG_action_init(void);
124
125 SG_END_DECL()
126 #endif