summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorJan Pokorný <jpokorny@redhat.com>2013-09-27 22:12:35 +0200
committerJan Pokorný <jpokorny@redhat.com>2013-09-27 22:12:35 +0200
commit960c2247f29b51d2d91f9b15a7c1dfef6535a05a (patch)
tree2eac8dda00069f74774ef8d9eaabcbea3ac92cb7
parent15bf2046cbe5392c9beb903b07c2f814a64be571 (diff)
downloadcluster-overview-960c2247f29b51d2d91f9b15a7c1dfef6535a05a.zip
cluster-overview-960c2247f29b51d2d91f9b15a7c1dfef6535a05a.tar.gz
cluster-overview-960c2247f29b51d2d91f9b15a7c1dfef6535a05a.tar.xz
lib_cman: new edge for modclusterd peer's XML status interchange
Signed-off-by: Jan Pokorný <jpokorny@redhat.com>
-rwxr-xr-xcluster-cman.py9
-rw-r--r--lib_cman.py15
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'),
))