- DEBUG3("recv chunk on %s from %s on channel %d",
- MSG_host_get_name(MSG_host_self()),
- MSG_host_get_name(sock_data->to_host), sock_data->to_chan);
- if (MSG_task_get(&task, (sock->raw ? pd->rawChan : pd->chan)) != MSG_OK)
- RAISE0(unknown_error,"Error in MSG_task_get()");
+ xbt_assert0(sock->meas, "SG chunk exchange shouldn't be used on non-measurement sockets");
+ XBT_IN;
+ DEBUG4("recv chunk on %s -> %s:%d (size=%ld)",
+ MSG_host_get_name(sock_data->to_host),
+ MSG_host_get_name(MSG_host_self()), sock_data->to_chan, size);
+ if (MSG_task_get_with_time_out(&task,
+ (sock->meas ? pd->measChan : pd->chan),
+ 60) != MSG_OK)
+ THROW0(system_error,0,"Error in MSG_task_get()");
+ DEBUG1("Got chuck %s",MSG_task_get_name(task));