X-Git-Url: http://xvm.mit.edu/gitweb/invirt/third/libt4.git/blobdiff_plain/603bac8fcb3697f283e6537d81b4a92e457ebbad..d54215aea2a7321ab0f2dc7b0042fea2b7ff5df5:/rsm_client.cc?ds=sidebyside

diff --git a/rsm_client.cc b/rsm_client.cc
index 01098d6..9e86915 100644
--- a/rsm_client.cc
+++ b/rsm_client.cc
@@ -1,4 +1,3 @@
-#include "types.h"
 #include "rsm_client.h"
 #include <arpa/inet.h>
 #include <handle.h>
@@ -8,7 +7,7 @@ rsm_client::rsm_client(string dst) : primary(dst) {
     LOG("create rsm_client");
     lock ml(rsm_client_mutex);
     VERIFY (init_members(ml));
-    LOG("rsm_client: done");
+    LOG("done");
 }
 
 void rsm_client::primary_failure(lock &) {
@@ -26,7 +25,7 @@ rsm_protocol::status rsm_client::invoke(unsigned int proc, string &rep, const st
         rpcc *cl = h.safebind();
         auto ret = rsm_client_protocol::OK;
         if (cl)
-            ret = (rsm_client_protocol::status)cl->call_timeout(rsm_client_protocol::invoke, rpcc::to(500), rep, proc, req);
+            ret = (rsm_client_protocol::status)cl->call_timeout(rsm_client_protocol::invoke, milliseconds(500), rep, proc, req);
         ml.lock();
 
         if (!cl)
@@ -61,7 +60,7 @@ bool rsm_client::init_members(lock & rsm_client_mutex_lock) {
         rsm_client_mutex_lock.unlock();
         cl = h.safebind();
         if (cl)
-            ret = cl->call_timeout(rsm_client_protocol::members, rpcc::to(100), known_mems, 0);
+            ret = cl->call_timeout(rsm_client_protocol::members, milliseconds(100), known_mems, 0);
         rsm_client_mutex_lock.lock();
     }
     if (cl == 0 || ret != rsm_protocol::OK)