From 960c2247f29b51d2d91f9b15a7c1dfef6535a05a Mon Sep 17 00:00:00 2001
From: Jan Pokorný <jpokorny@redhat.com>
Date: Fri, 27 Sep 2013 22:12:35 +0200
Subject: lib_cman: new edge for modclusterd peer's XML status interchange
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: Jan Pokorný <jpokorny@redhat.com>
---
 cluster-cman.py |  9 +++------
 lib_cman.py     | 15 ++++++++++++++-
 2 files changed, 17 insertions(+), 7 deletions(-)

diff --git a/cluster-cman.py b/cluster-cman.py
index c2608d1..c10fc27 100755
--- a/cluster-cman.py
+++ b/cluster-cman.py
@@ -377,22 +377,19 @@ graph = lambda\
             )]
         ,_edges=\
             ["modclusterd peer-to-peer network"][:0] +\
-            [Exchange\
+            [CmanModclusterdUpdates\
             ('node_a-modclusterd'
             ,'node_b-modclusterd'
-            ,label='port 16851\n(either direction)'
             ,weight='1'
             )
-            ,Exchange\
+            ,CmanModclusterdUpdates\
             ('node_a-modclusterd'
             ,'node_c-modclusterd'
-            ,label='port 16851\n(either direction)'
             ,weight='1'
             )
-            ,Exchange\
+            ,CmanModclusterdUpdates\
             ('node_b-modclusterd'
             ,'node_c-modclusterd'
-            ,label='port 16851\n(either direction)'
             ,weight='1'
             )
             ,EdgeInvisible\
diff --git a/lib_cman.py b/lib_cman.py
index 3ed8d98..8507c84 100644
--- a/lib_cman.py
+++ b/lib_cman.py
@@ -36,6 +36,19 @@ class CmanLuciHTTPS(HTTPS, Delegate):
     ))
 
 
+class CmanModclusterdUpdates(Exchange):
+    """modclusterd <-> modclusterd"""
+    defaults = dict((
+        LABEL('port 16851\n(either direction)'),
+    ))
+    summary = 'XML-formatted status messages'
+
+
+class CmanModclusterdUpdatesPeer(object):
+    common_src_of = CmanModclusterdUpdates
+    common_dst_of = CmanModclusterdUpdates
+
+
 #
 # nodes
 #
@@ -225,7 +238,7 @@ class CmanLuci(Daemon, CmanRicciRPCSrc, HTTPSDst):
     )
 
 
-class CmanModclusterd(Daemon):
+class CmanModclusterd(Daemon, CmanModclusterdUpdatesPeer):
     defaults = dict((
         LABEL('modclusterd'),
     ))
-- 
cgit