svn commit: r1131758 - /incubator/mesos/trunk/src/third_party/libprocess/process.cpp

[be...@apache.org]

Author: benh
Date: Sun Jun  5 05:26:19 2011
New Revision: 1131758

URL: http://svn.apache.org/viewvc?rev=1131758&view=rev
Log:
Trying to figure out timing wierdness.

Modified:
    incubator/mesos/trunk/src/third_party/libprocess/process.cpp

Modified: incubator/mesos/trunk/src/third_party/libprocess/process.cpp
URL: http://svn.apache.org/viewvc/incubator/mesos/trunk/src/third_party/libprocess/process.cpp?rev=1131758&r1=1131757&r2=1131758&view=diff
==============================================================================
--- incubator/mesos/trunk/src/third_party/libprocess/process.cpp (original)
+++ incubator/mesos/trunk/src/third_party/libprocess/process.cpp Sun Jun  5 05:26:19 2011
@@ -1749,7 +1749,10 @@ public:
   timeout_t create_timeout(Process *process, double secs)
   {
     assert(process != NULL);
-    ev_tstamp tstamp = ev_now(loop) + secs;
+    ev_tstamp now = ev_now(loop);
+    ev_tstamp tstamp = now + secs;
+    cout << std::setprecision(30);
+    cout << "create_timeout: now is " << now << " and timeout is " << tstamp << endl;
     return make_tuple(tstamp, process, process->generation);
   }
 
@@ -2263,12 +2266,18 @@ void handle_timeout(struct ev_loop *loop
   {
     ev_tstamp now = ev_now(loop);
 
+    cout << std::setprecision(30);
+    cout << "handle_timeout: now is " << now << endl;
+
     map<ev_tstamp, list<timeout_t> >::iterator it = timers->begin();
     map<ev_tstamp, list<timeout_t> >::iterator last = timers->begin();
 
     for (; it != timers->end(); ++it) {
       // Check if timer has expired.
       ev_tstamp tstamp = it->first;
+      cout << std::setprecision(30);
+      cout << "checking if tstamp > now (tstamp - now = " << tstamp - now << ")" << endl;
+      
       if (tstamp > now) {
 	last = it;
 	break;