X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=nm.py;h=85c9004fedf6f606f42a09f894509974ed38dbeb;hb=f2fa7fab52733182f331eef2fab63e5088f5adde;hp=c26290644c0a9a57ad7eeb3edfb45f3d06b4233b;hpb=72136191e3387c336b998e2b81442dbcca9275cf;p=nodemanager.git diff --git a/nm.py b/nm.py index c262906..85c9004 100755 --- a/nm.py +++ b/nm.py @@ -54,7 +54,7 @@ if os.path.exists(options.path): modules = [] -def GetSlivers(plc, config): +def GetSlivers(config, plc): '''Run call backs defined in modules''' try: logger.log("Syncing w/ PLC") @@ -70,7 +70,7 @@ def GetSlivers(plc, config): for module in modules: try: callback = getattr(module, 'GetSlivers') - callback(plc, data, config) + callback(data, config, plc) except: logger.log_exc() @@ -133,10 +133,22 @@ def run(): irandom=int(options.random) plc = PLCAPI(config.plc_api_uri, config.cacert, session, timeout=iperiod/2) + #check auth + logger.log("Checking Auth.") + while plc.check_authentication() != True: + try: + plc.update_session() + logger.log("Authentication Failure. Retrying") + except: + logger.log("Retry Failed. Waiting") + time.sleep(iperiod) + logger.log("Authentication Succeeded!") + + while True: # Main NM Loop logger.verbose('mainloop - nm:getSlivers - period=%d random=%d'%(iperiod,irandom)) - GetSlivers(plc, config) + GetSlivers(config, plc) delay=iperiod + random.randrange(0,irandom) logger.verbose('mainloop - sleeping for %d s'%delay) time.sleep(delay)