xbt_assert2(!(h_simdata->sleeping[channel]),
"A process (%s(%d)) is already blocked on this channel",
h_simdata->sleeping[channel]->name,
xbt_assert2(!(h_simdata->sleeping[channel]),
"A process (%s(%d)) is already blocked on this channel",
h_simdata->sleeping[channel]->name,
- item = xbt_fifo_getFirstItem(((simdata_host_t)h->simdata)->mbox[channel]);
- if (!item || !(t = xbt_fifo_get_item_content(item)) || (simdata_task_t)t->simdata)
+ item = xbt_fifo_getFirstItem(h->simdata->mbox[channel]);
+ if (!item || !(t = xbt_fifo_get_item_content(item)))
*/
MSG_error_t MSG_task_put_bounded(m_task_t task,
m_host_t dest, m_channel_t channel,
*/
MSG_error_t MSG_task_put_bounded(m_task_t task,
m_host_t dest, m_channel_t channel,
{
task->simdata->rate=max_rate;
return(MSG_task_put(task, dest, channel));
{
task->simdata->rate=max_rate;
return(MSG_task_put(task, dest, channel));
__MSG_task_execute(process, task);
PAJE_PROCESS_PUSH_STATE(process,"E");
__MSG_task_execute(process, task);
PAJE_PROCESS_PUSH_STATE(process,"E");
{
e_surf_action_state_t state = SURF_ACTION_NOT_IN_THE_SYSTEM;
m_process_t process = MSG_process_self();
{
e_surf_action_state_t state = SURF_ACTION_NOT_IN_THE_SYSTEM;
m_process_t process = MSG_process_self();