Add more documentation.

[loba.git] / process.cpp

diff --git a/process.cpp b/process.cpp
index 339938a703df6b4215fb45e04c9b02049fcc5016..b0d702644de509e4cc2e12c53212847e924a07ac 100644 (file)
--- a/process.cpp
+++ b/process.cpp
@@ -16,7 +16,7 @@ XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(proc);
 process::process(int argc, char* argv[])
 {
     if (argc < 2 || !(std::istringstream(argv[1]) >> load))
 process::process(int argc, char* argv[])
 {
     if (argc < 2 || !(std::istringstream(argv[1]) >> load))

-        throw std::invalid_argument("bad or missing initial load");
+        throw std::invalid_argument("bad or missing initial load parameter");

 
     neigh.assign(argv + 2, argv + argc);
 
 
     neigh.assign(argv + 2, argv + argc);
 


@@ -129,6 +129,8 @@ double process::sum_of_to_send() const
 
 double process::load_balance(double /*my_load*/)
 {
 
 double process::load_balance(double /*my_load*/)
 {

+    if (iter == 1)
+        WARN0("process::load_balance is a no-op!");

     return 0.0;
 }
 
     return 0.0;
 }
 


@@ -186,7 +188,6 @@ void process::send()
     using namespace std::tr1;
     using namespace std::tr1::placeholders;
 
     using namespace std::tr1;
     using namespace std::tr1::placeholders;
 

-    // fixme: shall we send data at all iterations?

     if (opt::bookkeeping) {
         std::for_each(neigh.begin(), neigh.end(),
                       bind(&process::send1_bookkeeping, this, _1));
     if (opt::bookkeeping) {
         std::for_each(neigh.begin(), neigh.end(),
                       bind(&process::send1_bookkeeping, this, _1));


@@ -198,7 +199,6 @@ void process::send()
     }
 }
 
     }
 }
 

-// Returns false if a CLOSE message was received. 

 bool process::receive(recv_wait_mode wait)
 {
     bool result = true;
 bool process::receive(recv_wait_mode wait)
 {
     bool result = true;