Szymon Wróblewski committed 0e87669

updated discovery module

Comments (0)

Files changed (1)


         self.address = socket.gethostbyname(host), port
         self.socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
         self.response = None
+        self.callback = None
         self.oid = 0
-        self.u_stop = threading.Event()
-        self.u_thread = threading.Thread(target=self.updater)
-        self.u_thread.daemon = True
-    def __del__(self):
-        self.u_stop.set()
     def _send_msg(self, message, *args):
         oid = self.oid = self.oid + 1
                 _logger.debug('Received data: %r', data)
                 r = self.response = message_factory.unpack(data)
       'Received response from %s', address)
+                if callable(self.callback):
+                    self.callback(r)
       'Unexpected data from %s', address)
-    def updater(self):
-        while not self.u_stop.is_set():
-            self.update(1000)
     def close(self):
Tip: Filter by directory path e.g. /media app.js to search for public/media/app.js.
Tip: Use camelCasing e.g. ProjME to search for
Tip: Filter by extension type e.g. /repo .js to search for all .js files in the /repo directory.
Tip: Separate your search with spaces e.g. /ssh pom.xml to search for src/ssh/pom.xml.
Tip: Use ↑ and ↓ arrow keys to navigate and return to view the file.
Tip: You can also navigate files with Ctrl+j (next) and Ctrl+k (previous) and view the file with Ctrl+o.
Tip: You can also navigate files with Alt+j (next) and Alt+k (previous) and view the file with Alt+o.