simdata->computation_amount);
SIMIX_action_set_priority(simdata->compute, simdata->priority);
simdata->computation_amount);
SIMIX_action_set_priority(simdata->compute, simdata->priority);
SIMIX_register_action_to_condition(simdata->compute, simdata->cond);
do {
SIMIX_cond_wait(simdata->cond, simdata->mutex);
state = SIMIX_action_get_state(simdata->compute);
} while (state == SURF_ACTION_READY || state == SURF_ACTION_RUNNING);
SIMIX_unregister_action_to_condition(simdata->compute, simdata->cond);
SIMIX_register_action_to_condition(simdata->compute, simdata->cond);
do {
SIMIX_cond_wait(simdata->cond, simdata->mutex);
state = SIMIX_action_get_state(simdata->compute);
} while (state == SURF_ACTION_READY || state == SURF_ACTION_RUNNING);
SIMIX_unregister_action_to_condition(simdata->compute, simdata->cond);
simdata->host_list, simdata->comp_amount,
simdata->comm_amount, 1.0, -1.0);
simdata->host_list, simdata->comp_amount,
simdata->comm_amount, 1.0, -1.0);
SIMIX_register_action_to_condition(simdata->compute, simdata->cond);
do {
SIMIX_cond_wait(simdata->cond, simdata->mutex);
SIMIX_register_action_to_condition(simdata->compute, simdata->cond);
do {
SIMIX_cond_wait(simdata->cond, simdata->mutex);
} while (state == SURF_ACTION_READY || state == SURF_ACTION_RUNNING);
SIMIX_unregister_action_to_condition(simdata->compute, simdata->cond);
} while (state == SURF_ACTION_READY || state == SURF_ACTION_RUNNING);
SIMIX_unregister_action_to_condition(simdata->compute, simdata->cond);
SIMIX_register_action_to_condition(act_sleep, cond);
do {
SIMIX_cond_wait(cond, mutex);
state = SIMIX_action_get_state(act_sleep);
} while (state == SURF_ACTION_READY || state == SURF_ACTION_RUNNING);
SIMIX_register_action_to_condition(act_sleep, cond);
do {
SIMIX_cond_wait(cond, mutex);
state = SIMIX_action_get_state(act_sleep);
} while (state == SURF_ACTION_READY || state == SURF_ACTION_RUNNING);
SIMIX_unregister_action_to_condition(act_sleep, cond);
SIMIX_mutex_unlock(mutex);
SIMIX_unregister_action_to_condition(act_sleep, cond);
SIMIX_mutex_unlock(mutex);
-/** \ingroup msg_gos_functions
- * \brief Return the number of MSG tasks currently running on
- * the host of the current running process.
- */
-static int MSG_get_msgload(void)
-{
- xbt_die("not implemented yet");
- return 0;
-}
-
-
-
/** \ingroup msg_gos_functions
* \brief Listen on \a channel and waits for receiving a task from \a host.
*
/** \ingroup msg_gos_functions
* \brief Listen on \a channel and waits for receiving a task from \a host.
*