Show More
@@ -41,7 +41,8 b' class Heartbeat(Thread):' | |||||
41 | self.port = s.getsockname()[1] |
|
41 | self.port = s.getsockname()[1] | |
42 | s.close() |
|
42 | s.close() | |
43 | elif addr[0] == 'ipc': |
|
43 | elif addr[0] == 'ipc': | |
44 | while os.path.exists(self.ip + '-' + self.port): |
|
44 | self.port = 1 | |
|
45 | while os.path.exists("%s-%s" % (self.ip, self.port)): | |||
45 | self.port = self.port + 1 |
|
46 | self.port = self.port + 1 | |
46 | else: |
|
47 | else: | |
47 | raise ValueError("Unrecognized zmq transport: %s" % addr[0]) |
|
48 | raise ValueError("Unrecognized zmq transport: %s" % addr[0]) |
General Comments 0
You need to be logged in to leave comments.
Login now