X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=plugins%2Fvsys.py;h=96582a76fb04bd3a8e09940699630a38729c22c1;hb=a41a6c333955a30682573be315561be0030abcaf;hp=b836dc5ddc41b23547488f762e15c0b9db4298fb;hpb=04832c4525d0b35dc3f1d48e64a632b26f120639;p=nodemanager.git diff --git a/plugins/vsys.py b/plugins/vsys.py index b836dc5..96582a7 100644 --- a/plugins/vsys.py +++ b/plugins/vsys.py @@ -1,10 +1,8 @@ -# $Id$ -# $URL$ - """vsys configurator. Maintains ACLs and script pipes inside vservers based on slice attributes.""" import logger import os +import tools VSYSCONF="/etc/vsys.conf" VSYSBKEND="/vsys" @@ -43,9 +41,16 @@ def GetSlivers(data, config=None, plc=None): _restart = writeConf(slices, parseConf()) or _restart # Write out the ACLs if writeAcls(scripts, parseAcls()) or _restart: - logger.log("vsys: restarting vsys service") - logger.log_call(["/etc/init.d/vsys", "restart", ]) + restartService() +# check for systemctl, use it if present +def restartService (): + if tools.has_systemctl(): + logger.log("vsys: restarting vsys service through systemctl") + logger.log_call(["systemctl", "restart", "vsys"]) + else: + logger.log("vsys: restarting vsys service through /etc/init.d/vsys") + logger.log_call(["/etc/init.d/vsys", "restart", ]) def createVsysDir(sliver): '''Create /vsys directory in slice. Update vsys conf file.''' @@ -149,3 +154,25 @@ def parseConf(): f.close() except: logger.log_exc("vsys: failed parseConf") return slicesinconf + + +# before shutting down slivers, it is safe to first remove them from vsys's scope +# so that we are sure that no dangling open file remains +# this will also restart vsys if needed +def removeSliverFromVsys (sliver): + current_slivers=parseConf() + new_slivers= [ s for s in current_slivers if s != sliver ] + if writeConf (current_slivers, new_slivers): + restartService() + trashVsysHandleInSliver (sliver) + else: + logger.log("vsys.removeSliverFromConf: no need to remove %s"%sliver) + + +def trashVsysHandleInSliver (sliver): + slice_vsys_area = "/vservers/%s/vsys"%sliver + if not os.path.exists(slice_vsys_area): + logger.log("vsys.trashVsysHandleInSliver: no action needed, %s not found"%slice_vsys_area) + return + ret=subprocess.call([ 'rm', '-rf' , slice_vsys_area]) + logger.log ("vsys.trashVsysHandleInSliver: Removed %s (retcod=%s)"%(slice_vsys_area,retcod))