- xbt_dynar_foreach(hosts,i,h1) {
-
- TRY {
- amok_bw_saturate_start(h1->name,h1->port,
- host_test,h1->port,//"Ginette"
- msg_size,120); // sturation of the link with msg_size to compute a concurent bandwidth MA //MB
- } CATCH(e) {
- RETHROW0("Cannot ask hosts to saturate the link: %s");
- }
- // gras_os_sleep(1.0);
-
- xbt_dynar_foreach(hosts,j,h2) {
- if (i==j) continue;
-
- peer = gras_socket_client(h2->name,h2->port);
- amok_bw_test(peer,buf_size,exp_size,msg_size,min_duration,&sec,&bw);
- INFO6("Bandwidth between me and %s // measurement between me and %s (%d bytes in msgs of %d bytes) took %f sec, achieving %.3f kb/s",
- h2->name,h1->name,
- exp_size,msg_size,
- sec,((double)bw)/1024.0);
-
+ xbt_dynar_foreach(hosts, i, h1) {
+
+ TRY {
+ amok_bw_saturate_start(h1->name, h1->port, host_test, h1->port, //"Ginette"
+ msg_size, 120); // sturation of the link with msg_size to compute a concurent bandwidth MA //MB
+ }
+ CATCH(e) {
+ RETHROW0("Cannot ask hosts to saturate the link: %s");
+ }
+ // gras_os_sleep(1.0);
+
+ xbt_dynar_foreach(hosts, j, h2) {
+ if (i == j)
+ continue;
+
+ peer = gras_socket_client(h2->name, h2->port);
+ amok_bw_test(peer, buf_size, exp_size, msg_size, min_duration, &sec,
+ &bw);
+ INFO6
+ ("Bandwidth between me and %s // measurement between me and %s (%d bytes in msgs of %d bytes) took %f sec, achieving %.3f kb/s",
+ h2->name, h1->name, exp_size, msg_size, sec,
+ ((double) bw) / 1024.0);
+
+ }
+ amok_bw_saturate_stop(h1->name, h1->port, NULL, NULL);