Fixed updating peers

rtrevinnoc · Mar 9, 2021 · 1a09ac3 · 1a09ac3
1 parent 5674857
commit 1a09ac3
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/future.py b/future.py
@@ -87,6 +87,7 @@
 
 
 def sendRegisterRequestToPeer(url):
+    global listOfPeers
     peer = url.decode("utf-8")
     print("#######################")
     print("host:, ", hostIP)
@@ -134,6 +135,7 @@ def sendRegisterRequestToPeer(url):
 
 def sendAnswerRequestToPeer(url, query, queryVector, queryLanguage,
                             numberOfURLs, numberOfPage, minimumScore):
+    global listOfPeers
     peer = url
     queryVector = json.dumps(queryVector.tolist())
     print("#######################")
@@ -190,6 +192,7 @@ def sendAnswerRequestToPeer(url, query, queryVector, queryLanguage,
 
 def sendImagesAnswerRequestToPeer(url, query, queryVector, queryLanguage,
                                   numberOfURLs, numberOfPage, minimumScore):
+    global listOfPeers
     peer = url
     queryVector = json.dumps(queryVector.tolist())
     print("#######################")
@@ -602,6 +605,7 @@ def answerPeerImages(query: str, q_vec: list, queryLanguage: str,
 
 @app.route('/_registerPeer')
 def _registerPeer():
+    global listOfPeers
     peerIP = request.args.get("ip", 0, type=str)
     peerRegistryTransaction = peerRegistry.begin(write=True)
     peerRegistryTransaction.put(str(peerIP).encode('utf-8'),