X-Git-Url: https://git.llucax.com/software/pymin.git/blobdiff_plain/b1c83f0151bd8a0de3d56778c64e2de368e64e58..55efba31a241826ed31597b14f2b5eb9efe808f1:/pymin/services/vrrp/__init__.py?ds=sidebyside diff --git a/pymin/services/vrrp/__init__.py b/pymin/services/vrrp/__init__.py index 8f5a003..f13db3e 100644 --- a/pymin/services/vrrp/__init__.py +++ b/pymin/services/vrrp/__init__.py @@ -1,59 +1,81 @@ # vim: set encoding=utf-8 et sw=4 sts=4 : +import os from os import path +from signal import SIGTERM from subprocess import Popen, PIPE +import logging ; log = logging.getLogger('pymin.services.vrrp') +from pymin import procman from pymin.seqtools import Sequence from pymin.dispatcher import Handler, handler, HandlerError -from pymin.services.util import Restorable, TransactionalHandler, ParametersHandler, call +from pymin.services.util import Restorable, TransactionalHandler, \ + ReloadHandler, RestartHandler, \ + ServiceHandler, ParametersHandler, call -__ALL__ = ('VrrpHandler') +__ALL__ = ('VrrpHandler',) -pid_filename = 'vrrp.pid' +# FIXME the the command should not use new parameters unless commit where called +# i.e. integrate commit with procman to update internal procman parameters. +class VrrpHandler(Restorable, ParametersHandler, ReloadHandler, RestartHandler, + ServiceHandler, TransactionalHandler): -class VrrpHandler(Restorable, ParametersHandler, TransactionalHandler): handler_help = u"Manage VRRP service" - _persistent_attrs = 'params' + _persistent_attrs = ['params'] _restorable_defaults = dict( - params = dict( ipaddress='192.168.0.1', - id = '1', - prio = '', - dev = 'eth0', - ), - ) + params = dict( + ipaddress = '192.168.0.1', + id = '1', + prio = '', + dev = 'eth0', + persist = True, + ), + ) + + @property + def _command(self): + command = ['vrrpd', '-i', self.params['dev'], '-v', self.params['id']] + if self.params['prio']: + command.extend(('-p', self.params['prio'])) + command.append(self.params['ipaddress']) + return command + + def _service_start(self): + log.debug(u'VrrpHandler._service_start()') + procinfo = procman.get('vrrp') + procinfo.command = self._command + procinfo.persist = self.params['persist'] + procman.start('vrrp') + + def _service_stop(self): + log.debug(u'VrrpHandler._service_stop()') + procman.stop('vrrp') + + def _service_restart(self): + procinfo = procman.get('vrrp') + procinfo.command = self._command + procinfo.persist = self.params['persist'] + procman.restart('vrrp') def __init__(self, pickle_dir='.', config_dir='.', pid_dir='.'): + log.debug(u'VrrpHandler(%r, %r, $r)', pickle_dir, config_dir, pid_dir) self._persistent_dir = pickle_dir self._pid_dir = pid_dir - self._restore() - - @handler('Starts the service') - def start(self): - if self.params['prio'] != '': - #call(('vrrp','-i',self.params[dev],'-v',self.params[id],'-p',self.params[prio],self.params[ipaddress])) - print ('vrrp','-i',self.params['dev'],'-v',self.params['id'],'-p',self.params['prio'],self.params['ipaddress']) - else: - #call(('vrrp','-i',self.params[dev],'-v',self.params[id],self.params[ipaddress])) - print ('vrrp','-i',self.params['dev'],'-v',self.params['id'],self.params['ipaddress']) - - @handler('Stop the service') - def stop(self): - try : - f = file(path.join(self._pid_dir, pid_filename ), 'r') - #call(('kill','<',f.read())) - print(('kill','<',f.read())) - except IOError: - pass - - @handler('Reloads the service') - def reload(self): - self.stop() - self.start() + procman.register('vrrp', None) + ServiceHandler.__init__(self) if __name__ == '__main__': + + logging.basicConfig( + level = logging.DEBUG, + format = '%(asctime)s %(levelname)-8s %(message)s', + datefmt = '%H:%M:%S', + ) + v = VrrpHandler() - v.set('prio','10') - v.commit() \ No newline at end of file + v.set('prio', '10') + v.commit() +