Changeset 1624

Timestamp:

11/12/08 15:21:19 (2 months ago)

Author:

peet

Message:

more sane timeout algorithm

Files:

• branches/0.4.7/shell/state/ddb.py (modified) (7 diffs)

branches/0.4.7/shell/state/ddb.py

@@ -642 +642 @@
-                else:
-                        ring = self.mdns.lookupPTR(domain)
+                        print ring
-                        return filter(lambda x: x[0] != exclude, ring)
-
@@ -679 +680 @@
-                        self.log("debug","node: %s" % (node))
-                except:
-
+a
-                        return
-
-                if node.async.has_key(hostname):
-                        node.async[hostname] -= 1
-
+a
-                        self.log("debug","Sent %s" % (primer.dump()))
-
-
-
-
-
+
+
+
-                        else:
-sync (add) watchdog: low watermark touch; mark node as stale
+async watchdog: low watermark touch; kick ourself in the ass
-                                del node.async[hostname]
-x
-x
-       return
+y
+y
+x = ACoreService(self.bus,"%s@%s" %(self.prefix, hostname),flags=CX_MSG_TRACK)
-                        x._add(primer)
-                else:
-
+a
-
-        def _t_update(self,host,primer):
@@ -708 +708 @@
-                        self.log("debug","node: %s" % (node))
-                except:
-
+u
-                        return
-
-                if node.usync.has_key(hostname):
-                        node.usync[hostname] -= 1
-
+u
-                        self.log("debug","Sent %s" % (primer.dump()))
-
-
-
-
-
+
+
+
-                        else:
-sync (update) watchdog: low watermark touch; mark node as stale
+usync watchdog: low watermark touch; kick ourself in the ass
-                                del node.usync[hostname]
-x
-x
-       return
+y
+y
+x = ACoreService(self.bus,"%s@%s" %(self.prefix, hostname),flags=CX_MSG_TRACK)
-                        x._update(primer)
-                else:
-
+u
-
-        def _t_del(self,host,index):
@@ -737 +736 @@
-                        self.log("debug","node: %s" % (node))
-                except:
-
+d
-                        return
-
-                if node.dsync.has_key(hostname):
-                        node.dsync[hostname] -= 1
-
-
-
-
-
-
+
+
+
+
+
-                        else:
-sync (del) watchdog: low watermark touch; mark node as stale
+dsync watchdog: low watermark touch; kick ourself in the ass
-                                del node.dsync[hostname]
-x
-x
-       return
+y
+y
+x = ACoreService(self.bus,"%s@%s" %(self.prefix, hostname),flags=CX_MSG_TRACK)
-                        x._del(index)
-                else:
-
+d
-
-
@@ -772 +770 @@
-                self.log("debug","hosts list: `%s`" % (x))
-                for i in x:
-
+
+
-                        self._t_del(i,index)
-                        
@@ -817 +816 @@
-                self.log("debug","hosts list: `%s`" % (x))
-                for i in x:
-
+
+
-                        self._t_update(i,p)
-                        
@@ -894 +894 @@
-                p.private_data = {}
-                for i in x:
-
+
+
-                        self._t_add(i,p)
-                #