Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
We now use http://simgrid.gforge.inria.fr/simgrid.dtd to generate maintainer sources.
[simgrid.git] / src / amok / Bandwidth / saturate.c
index 0e11a8e..c2b74ec 100644 (file)
@@ -1,6 +1,7 @@
 /* amok_saturate - Link saturating facilities (for ALNeM's BW testing)      */
 
-/* Copyright (c) 2003, 2004 Martin Quinson. All rights reserved.            */
+/* Copyright (c) 2004, 2005, 2006, 2007, 2009, 2010. The SimGrid Team.
+ * All rights reserved.                                                     */
 
 /* This program is free software; you can redistribute it and/or modify it
  * under the terms of the license (GNU LGPL) which comes with this package. */
@@ -174,7 +175,8 @@ void amok_bw_saturate_begin(const char *to_name, unsigned int to_port,
 
   /* Launch the saturation */
 
-  ctx = gras_msg_rpc_async_call(peer_cmd, 60, "amok_bw_sat begin", &request);
+  ctx =
+      gras_msg_rpc_async_call(peer_cmd, 60, "amok_bw_sat begin", &request);
   free(request);
   gras_msg_rpc_async_wait(ctx, &request);
   meas = gras_socket_client_ext(to_name, request->peer.port,
@@ -246,9 +248,9 @@ void amok_bw_saturate_begin(const char *to_name, unsigned int to_port,
     free(answer);
   } else {
     INFO6
-      ("Saturation from %s:%d to %s:%d elapsed after %f sec (achieving %f kb/s)",
-       gras_os_myname(), gras_os_myport(), to_name, to_port, elapsed,
-       bw / 1024.0);
+        ("Saturation from %s:%d to %s:%d elapsed after %f sec (achieving %f kb/s)",
+         gras_os_myname(), gras_os_myport(), to_name, to_port, elapsed,
+         bw / 1024.0);
   }
 
   gras_socket_close(meas);
@@ -276,7 +278,7 @@ static int amok_bw_cb_sat_begin(gras_msg_cb_ctx_t ctx, void *payload)
         xbt_ex_free(e);
       else
         RETHROW0
-          ("Error encountered while opening a measurement server socket: %s");
+            ("Error encountered while opening a measurement server socket: %s");
     }
     if (measMaster == NULL)
       port++;                   /* prepare for a new loop */
@@ -336,7 +338,8 @@ void amok_bw_saturate_stop(const char *from_name, unsigned int from_port,
   TRY {
     gras_msg_rpccall(sock, 60, "amok_bw_sat stop", NULL, &answer);
   } CATCH(e) {
-    RETHROW2("Cannot ask %s:%d to stop saturation: %s", from_name, from_port);
+    RETHROW2("Cannot ask %s:%d to stop saturation: %s", from_name,
+             from_port);
   }
   gras_socket_close(sock);
   if (time)