Skip to content

Commit

Permalink
Directional Messages
Browse files Browse the repository at this point in the history
  • Loading branch information
MegaKG committed Feb 10, 2023
1 parent 3637fca commit 538a61b
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 3 deletions.
7 changes: 5 additions & 2 deletions ClusterTalk.py
Original file line number Diff line number Diff line change
Expand Up @@ -57,8 +57,11 @@ def _decodeRequest(self,D):
}

def getResponses(self,ID):
Out = self.Responses[ID].getall()
del self.Responses[ID]
if ID in self.Responses:
Out = self.Responses[ID].getall()
del self.Responses[ID]
else:
Out = []
return Out

def findNodes(self):
Expand Down
2 changes: 1 addition & 1 deletion LXC_failover_cluster_server.py
Original file line number Diff line number Diff line change
Expand Up @@ -213,7 +213,7 @@ def run(self):
if i not in Running:
print("Warning,",i,"Is not Active, starting")

#Determine which host is least utilised
#Determine which host is least utilised #Fix Me (Multicast)
BestScore = self.MainServer.getResourceLevel(platform.node())
BestNode = platform.node().encode()
for a in self.MainServer.findNodes():
Expand Down

0 comments on commit 538a61b

Please sign in to comment.