aboutsummaryrefslogtreecommitdiff
path: root/rumba/model.py
diff options
context:
space:
mode:
authorMarco Capitani <m.capitani@nextworks.it>2017-09-26 17:20:48 +0200
committerMarco Capitani <m.capitani@nextworks.it>2017-09-26 17:20:48 +0200
commitbc8f4bd7e45affd6e3d74562a0511a634d0d92cd (patch)
treea7f18bcc9a2a39507dd89f1ec5b55e807ef11c96 /rumba/model.py
parent257ac48837755f2d48e2b99e9462da9fa17c05d7 (diff)
downloadrumba-bc8f4bd7e45affd6e3d74562a0511a634d0d92cd.tar.gz
rumba-bc8f4bd7e45affd6e3d74562a0511a634d0d92cd.zip
Model: add check for disconnected dif
Diffstat (limited to 'rumba/model.py')
-rw-r--r--rumba/model.py2
1 files changed, 2 insertions, 0 deletions
diff --git a/rumba/model.py b/rumba/model.py
index bb7d213..a223fb4 100644
--- a/rumba/model.py
+++ b/rumba/model.py
@@ -694,6 +694,8 @@ class Experiment:
self.dt_flows[-1].append({'src': enrollee,
'dst': enroller})
frontier.add(edge[0])
+ if len(dif.members) != len(enrolled):
+ raise Exception("Disconnected DIF found: %s" % (dif,))
# In case of a full mesh enrollment or dt flows
for cur in dif_graphs[dif]: