equal
deleted
inserted
replaced
43 self.retrytimer = None |
43 self.retrytimer = None |
44 |
44 |
45 def RegisterService(self, name, ip, port): |
45 def RegisterService(self, name, ip, port): |
46 try: |
46 try: |
47 self._RegisterService(name, ip, port) |
47 self._RegisterService(name, ip, port) |
48 except Exception, e: |
48 except Exception: |
49 self.retrytimer = threading.Timer(2, self.RegisterService, [name, ip, port]) |
49 self.retrytimer = threading.Timer(2, self.RegisterService, [name, ip, port]) |
50 self.retrytimer.start() |
50 self.retrytimer.start() |
51 |
51 |
52 def _RegisterService(self, name, ip, port): |
52 def _RegisterService(self, name, ip, port): |
53 # name: fully qualified service name |
53 # name: fully qualified service name |
91 s.connect((dst, 7)) |
91 s.connect((dst, 7)) |
92 (host, port) = s.getsockname() |
92 (host, port) = s.getsockname() |
93 s.close() |
93 s.close() |
94 if host != '0.0.0.0': |
94 if host != '0.0.0.0': |
95 return host |
95 return host |
96 except Exception, e: |
96 except Exception: |
97 pass |
97 pass |
98 return socket.gethostbyname(socket.gethostname()) |
98 return socket.gethostbyname(socket.gethostname()) |