##// END OF EJS Templates
fix default heartbeat location when transport is ipc
MinRK -
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