git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@6094
48e7efb5-ca39-0410-a469-
dd3cf9ba447f
} channel_t;
//keep a pointer to all surf running tasks.
} channel_t;
//keep a pointer to all surf running tasks.
int bool_printed=0;
double start_time, end_time, elapsed_time;
double gl_data_size[NTASKS];
int bool_printed=0;
double start_time, end_time, elapsed_time;
double gl_data_size[NTASKS];
/* time measurement */
start_time = MSG_get_clock();
//MSG_task_put(todo, slave, PORT_22);
/* time measurement */
start_time = MSG_get_clock();
//MSG_task_put(todo, slave, PORT_22);
+ INFO1("Sending to %s", id_alias);
MSG_task_send(todo, id_alias);
end_time = MSG_get_clock();
MSG_task_send(todo, id_alias);
end_time = MSG_get_clock();
//a = MSG_task_get(&(task), PORT_22);
//a = MSG_task_get(&(task), PORT_22);
+ INFO1("Receiving on %s", id_alias);
a = MSG_task_receive(&(task), id_alias );
a = MSG_task_receive(&(task), id_alias );
bool_printed=1;
for(id=0; id<NTASKS; id++){
if(gl_task_array[id] == NULL){
bool_printed=1;
for(id=0; id<NTASKS; id++){
if(gl_task_array[id] == NULL){
}else if(gl_task_array[id] == task){
INFO5("===> Estimated Bw of FLOW[%d] : %f ; message from %s to %s with remaining : %f", id, gl_data_size[id]/elapsed_time, masternames[id], slavenames[id], 0.0);
}else{
}else if(gl_task_array[id] == task){
INFO5("===> Estimated Bw of FLOW[%d] : %f ; message from %s to %s with remaining : %f", id, gl_data_size[id]/elapsed_time, masternames[id], slavenames[id], 0.0);
}else{
- MSG_task_destroy(task);
-
+ for(id=0; id<NTASKS; id++){
+ if(gl_task_array[id] == task){
+ MSG_task_destroy(task);
+ gl_task_array[id] = NULL;
+ return 0;
+ }
+ }
return 0;
} /* end_of_slave */
return 0;
} /* end_of_slave */