X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ee59b06df4d96bf36d6121f936147509908d85e5..a63b491b014ce7061f61b6fd94876b9abd6ceff2:/src/msg/private.h diff --git a/src/msg/private.h b/src/msg/private.h index b3f64e8986..4e47231fee 100644 --- a/src/msg/private.h +++ b/src/msg/private.h @@ -35,6 +35,7 @@ typedef struct simdata_task { double computation_amount; /* Computation size */ xbt_dynar_t sleeping; /* process to wake-up */ m_process_t sender; + double rate; int using; } s_simdata_task_t; @@ -46,6 +47,10 @@ typedef struct simdata_process { int PID; /* used for debugging purposes */ int PPID; /* The parent PID */ m_task_t waiting_task; + int blocked; + int suspended; + m_host_t put_host; /* used for debugging purposes */ + m_channel_t put_channel; /* used for debugging purposes */ int argc; /* arguments number if any */ char **argv; /* arguments table if any */ MSG_error_t last_errno; /* the last value returned by a MSG_function */ @@ -81,4 +86,8 @@ void __MSG_task_execute(m_process_t process, m_task_t task); MSG_error_t __MSG_wait_for_computation(m_process_t process, m_task_t task); MSG_error_t __MSG_task_wait_event(m_process_t process, m_task_t task); +MSG_error_t __MSG_process_block(void); +MSG_error_t __MSG_process_unblock(m_process_t process); +int __MSG_process_isBlocked(m_process_t process); + #endif