it will be restarted when the sender process resume */
if(SIMIX_process_is_suspended(comm->src_proc) ||
SIMIX_process_is_suspended(comm->dst_proc)) {
- SIMIX_action_set_priority(comm->act, 0);
+ SIMIX_action_suspend(comm->act);
}
/* Add the communication as user data of the action */
*/
void SIMIX_network_copy_data(smx_comm_t comm)
{
+ size_t buff_size = comm->src_buff_size;
+
+ DEBUG6("Copying comm %p data from %s (%p) -> %s (%p) (%zu bytes)",
+ comm,
+ comm->src_proc->smx_host->name, comm->src_buff,
+ comm->dst_proc->smx_host->name, comm->dst_buff,
+ buff_size);
+
/* If there is no data to be copy then return */
if(!comm->src_buff || !comm->dst_buff)
return;
/* Copy at most dst_buff_size bytes of the message to receiver's buffer */
- size_t buff_size = comm->src_buff_size;
if (comm->dst_buff_size)
buff_size = MIN(buff_size,*(comm->dst_buff_size));
if(buff_size == 0)
return;
- DEBUG6("Copying comm %p data from %s (%p) -> %s (%p) (%zu bytes)",
- comm,
- comm->src_proc->smx_host->name, comm->src_buff,
- comm->dst_proc->smx_host->name, comm->dst_buff,
- buff_size);
(*SIMIX_network_copy_data_callback)(comm, buff_size);
/* pimple to display the message sizes */
{
if (msg_sizes == NULL)
msg_sizes = xbt_dict_new();
- uintptr_t casted_size = buff_size;
+ uintptr_t casted_size = comm->task_size;
uintptr_t amount = xbt_dicti_get(msg_sizes, casted_size);
amount++;
/* pimple to display the message sizes */
void SIMIX_message_sizes_output(const char *filename) {
FILE * out = fopen(filename,"w");
- INFO1("Output message sizes to %s",filename);
xbt_assert1(out,"Cannot open file %s",filename);
uintptr_t key,data;
xbt_dict_cursor_t cursor;
xbt_dict_foreach(msg_sizes,cursor,key,data) {
- fprintf(out,"%ld %ld\n",key,data);
+ fprintf(out,"%zu %zu\n",key,data);
}
fclose(out);
}