Commit 09da7005 authored by Pramod S's avatar Pramod S

Merge branch 'rdma_metadata_server' of https://git.cse.iitb.ac.in/synerg/hpdos...

Merge branch 'rdma_metadata_server' of https://git.cse.iitb.ac.in/synerg/hpdos into rdma_metadata_server
parents 25ceaae4 90c74082
...@@ -10,6 +10,7 @@ import com.ibm.darpc.DaRPCServerEndpoint; ...@@ -10,6 +10,7 @@ import com.ibm.darpc.DaRPCServerEndpoint;
import com.ibm.darpc.DaRPCServerGroup; import com.ibm.darpc.DaRPCServerGroup;
import com.ibm.disni.RdmaServerEndpoint; import com.ibm.disni.RdmaServerEndpoint;
import org.apache.log4j.BasicConfigurator;
import org.apache.log4j.Logger; import org.apache.log4j.Logger;
import org.rocksdb.RocksDB; import org.rocksdb.RocksDB;
...@@ -90,6 +91,7 @@ public class MetadataServer{ ...@@ -90,6 +91,7 @@ public class MetadataServer{
{ {
Property property = new Property(args[0]); Property property = new Property(args[0]);
RocksDB.loadLibrary(); RocksDB.loadLibrary();
BasicConfigurator.configure();
var server = new MetadataServer(); var server = new MetadataServer();
server.storageHandler = new StorageHandler(property.dbPath); server.storageHandler = new StorageHandler(property.dbPath);
server.run(property); server.run(property);
......
...@@ -32,7 +32,7 @@ public class StorageHandler implements AutoCloseable{ ...@@ -32,7 +32,7 @@ public class StorageHandler implements AutoCloseable{
rocksDB.put(key,value); rocksDB.put(key,value);
} }
public void create(Request request) throws RocksDBException { public void create(Request request) throws RocksDBException {
logger.info("Writing to local"); logger.debug("Writing to local");
rocksDB.put(request.getKey(),request.getValue()); rocksDB.put(request.getKey(),request.getValue());
} }
public byte[] read(byte[] key)throws RocksDBException public byte[] read(byte[] key)throws RocksDBException
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment