diff --git a/pydfs/minion.py b/pydfs/minion.py index 8cf0513..c250038 100644 --- a/pydfs/minion.py +++ b/pydfs/minion.py @@ -1,9 +1,13 @@ import rpyc import uuid import os +import logging from rpyc.utils.server import ThreadedServer +logging.basicConfig(level=logging.DEBUG) +LOG = logging.getLogger(__name__) + DATA_DIR="/tmp/minion/" class MinionService(rpyc.Service): @@ -13,6 +17,7 @@ class exposed_Minion(): def exposed_put(self,block_uuid,data,minions): with open(DATA_DIR+str(block_uuid),'w') as f: f.write(data) + LOG.error("data written to: "+DATA_DIR+str(block_uuid)) if len(minions)>0: self.forward(block_uuid,data,minions) @@ -20,13 +25,13 @@ def exposed_put(self,block_uuid,data,minions): def exposed_get(self,block_uuid): block_addr=DATA_DIR+str(block_uuid) if not os.path.isfile(block_addr): + LOG.error(block_addr+" not found") return None with open(block_addr) as f: return f.read() def forward(self,block_uuid,data,minions): - print "8888: forwaring to:" - print block_uuid, minions + LOG.info("8888: forwaring to:"+str(block_uuid)+str(minions)) minion=minions[0] minions=minions[1:] host,port=minion