-#include "rpc/rpc.h"
+#include "lock_server.h"
#include <arpa/inet.h>
-#include <stdlib.h>
-#include "tprintf.h"
#include <unistd.h>
-#include "lock_server.h"
-#include "rsm.h"
// Main loop of lock_server
-char tprintf_thread_prefix = 's';
+char log_thread_prefix = 's';
-int
-main(int argc, char *argv[])
-{
+int main(int argc, char *argv[]) {
setvbuf(stdout, NULL, _IONBF, 0);
setvbuf(stderr, NULL, _IONBF, 0);
srandom((uint32_t)getpid());
if(argc != 3){
- fprintf(stderr, "Usage: %s [master:]port [me:]port\n", argv[0]);
+ LOG_NONMEMBER("Usage: " << argv[0] << " [master:]port [me:]port");
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)
sleep(1000);