So many changes. Broken.

[invirt/third/libt4.git] / lock_smain.cc

diff --git a/lock_smain.cc b/lock_smain.cc
index 3bd7376..52e6c4f 100644 (file)
--- a/lock_smain.cc
+++ b/lock_smain.cc
@@ -1,30 +1,22 @@
-#include "lock_server.h"
-#include <arpa/inet.h>
-#include <unistd.h>
+#include "include/lock_server.h"

 
 

-// Main loop of lock_server
-
-char log_thread_prefix = 's';
+using namespace std::chrono;

 
 int main(int argc, char *argv[]) {
 
 int main(int argc, char *argv[]) {

+    global = new t4_state('s');

     setvbuf(stdout, NULL, _IONBF, 0);
     setvbuf(stderr, NULL, _IONBF, 0);
 
     setvbuf(stdout, NULL, _IONBF, 0);
     setvbuf(stderr, NULL, _IONBF, 0);
 

-    srandom((uint32_t)getpid());
-

     if(argc != 3){
     if(argc != 3){

-        cerr << "Usage: " << argv[0] << " [master:]port [me:]port" << endl;
+        LOG_NONMEMBER << "Usage: " << argv[0] << " [master:]port [me:]port";

         exit(1);
     }
 
     rsm rsm(argv[1], argv[2]);
         exit(1);
     }
 
     rsm rsm(argv[1], argv[2]);

-    lock_server ls(&rsm);
-    rsm.set_state_transfer(&ls);
+    lock_server ls(rsm);

 
 

-    rsm.reg(lock_protocol::acquire, &lock_server::acquire, &ls);
-    rsm.reg(lock_protocol::release, &lock_server::release, &ls);
-    rsm.reg(lock_protocol::stat, &lock_server::stat, &ls);
+    rsm.start();

 
     while(1)
 
     while(1)

-        sleep(1000);
+        std::this_thread::sleep_for(1000ms);

 }
 }