Changeset 1634

Timestamp:

11/18/08 11:36:32 (2 months ago)

Author:

peet

Message:

link watchdogs

Files:

• branches/0.4.7/lib/cxcore/cxcore/cxnetlink.py (modified) (3 diffs)

branches/0.4.7/lib/cxcore/cxcore/cxnetlink.py

@@ -551 +551 @@
-                        return
-
+                #for i in map(lambda x: x.name, self.mdns.lookupByIP(address)):
+                if self.watch.has_key(address):
+                                self.watch[address].state = "reachable"
+                                del self.watch[address]
+
+                ## watch flags
+                if (header.flags & CX_MSG_ECHO) and (header.flags & CX_FLAGS_FIRST_FRAGMENT):
+                        for i in map(lambda x: x.name, self.mdns.lookupByIP(address)):
+                                (host,prop,record) = self.mdns.lookup(i)
+                                self._send(host,None,record,0,CX_MSG_DROP)
+
+                if header.flags & CX_MSG_DROP:
+                        return
+
-                # drop duplicates
-                origin = self.mdns.lookupByIPPort(address,port)
@@ -568 +582 @@
-                        self.log("debug","nonce for an origin incremented")
-
-                #for i in map(lambda x: x.name, self.mdns.lookupByIP(address)):
-                        #if self.watch.has_key(i):
-                                #self.watch[i].state = "reachable"
-                                #del self.watch[i]
-
-                        ## watch flags
-                        #if (header.flags & CX_MSG_ECHO) and (header.flags & CX_FLAGS_FIRST_FRAGMENT):
-                                #(host,prop,record) = self.mdns.lookup(i)
-                                #self._send(host,None,record,CX_MSG_DROP)
-
-                #if header.flags & CX_MSG_DROP:
-                        #return
-
-                # get plaintext message and load it
-                self.hook(self.bus, self.recv_buffer, header.msg_len + sizeof(header), "cl_socket.recv()")
@@ -679 +680 @@
-                                msg.header.alg_len = a
-
-#
-#self.watch[record.name
-#Timer(2,self.watchdog,(record.name
+
+self.watch[host[0]
+Timer(2,self.watchdog,(host[0]
-
-                        offset = 0
-                        fragment = 1
-                        while (offset < len(c)) and (fragment < CX_MAX_FRAGMENT):
-0
+flags
-                                
-                                if offset == 0: