X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=plugins%2Fprivatebridge.py;h=263cf79767b9704a748ce1009ba5d888d6b6b850;hb=2addae8b573ec6d712c3cd508eda48d8e8b54446;hp=52c3932b386ea437e25f199cb8b8a2a3a5049cec;hpb=5f75e88482dd462924a9687f8af9d2d3e1145489;p=nodemanager.git diff --git a/plugins/privatebridge.py b/plugins/privatebridge.py index 52c3932..263cf79 100644 --- a/plugins/privatebridge.py +++ b/plugins/privatebridge.py @@ -16,6 +16,11 @@ import tools priority = 9 +class OvsException (Exception) : + def __init__ (self, message="no message"): + self.message=message + def __repr__ (self): return message + def start(): logger.log('private bridge plugin starting up...') @@ -65,25 +70,21 @@ def ovs_vsctl(args): def ovs_listbridge(): (returncode, stdout) = ovs_vsctl(["list-br"]) - if (returncode != 0): - raise OvsException() + if (returncode != 0): raise OvsException("list-br") return stdout.split() def ovs_addbridge(name): (returncode, stdout) = ovs_vsctl(["add-br",name]) - if (returncode != 0): - raise OvsException() + if (returncode != 0): raise OvsException("add-br") def ovs_listports(name): (returncode, stdout) = ovs_vsctl(["list-ports", name]) - if (returncode != 0): - raise OvsException() + if (returncode != 0): raise OvsException("list-ports") return stdout.split() def ovs_delbridge(name): (returncode, stdout) = ovs_vsctl(["del-br",name]) - if (returncode != 0): - raise OvsException() + if (returncode != 0): raise OvsException("del-br") def ovs_addport(name, portname, type, remoteip, key): args = ["add-port", name, portname, "--", "set", "interface", portname, "type="+type] @@ -93,13 +94,11 @@ def ovs_addport(name, portname, type, remoteip, key): args = args + ["options:key=" + str(key)] (returncode, stdout) = ovs_vsctl(args) - if (returncode != 0): - raise OvsException() + if (returncode != 0): raise OvsException("add-port") def ovs_delport(name, portname): (returncode, stdout) = ovs_vsctl(["del-port",name,portname]) - if (returncode != 0): - raise OvsException() + if (returncode != 0): raise OvsException("del-port") def ensure_slicebridge_created(name, addr): bridges = ovs_listbridge()