diff --git a/src/server.py b/src/server.py --- a/src/server.py +++ b/src/server.py @@ -41,7 +41,7 @@ class Server: self._ss.bind(("", conf.port)) self._ss.listen(1) - self._lastWrite=-1 + self._lastIndex=-1 self._dataFile=None def serve(self): @@ -62,7 +62,10 @@ class Server: outcoming.writeMsg({"command": "ack"}) elif jsonData["command"]=="req": - outcoming.writeMsg(*self._requestHash(jsonData)) + if jsonData["dataType"]=="data": + outcoming.writeMsg(*self._requestData(jsonData["index"])) + else: + outcoming.writeMsg(*self._requestHash(jsonData["index"])) elif jsonData["command"]=="send" and jsonData["dataType"]=="data": outcoming.writeMsg(*self._receiveData(jsonData,binData)) @@ -76,13 +79,23 @@ class Server: return True - def _requestHash(self,jsonData): - log.info("received request for node #{0}".format(jsonData["index"])) - assert jsonData["index"]