Show More
@@ -41,7 +41,8 b' class Heartbeat(Thread):' | |||
|
41 | 41 | self.port = s.getsockname()[1] |
|
42 | 42 | s.close() |
|
43 | 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 | 46 | self.port = self.port + 1 |
|
46 | 47 | else: |
|
47 | 48 | raise ValueError("Unrecognized zmq transport: %s" % addr[0]) |
General Comments 0
You need to be logged in to leave comments.
Login now