in leda_python/leda.py [0:0]
def _registerModule(self):
'''register driver
'''
inMsg = {}
inMsg['params'] = {}
inMsg['params']['driverLocalId'] = self.driver_name
inMsg['params']['driverStartupTime'] = str(int(round(time.time() * 1000)))
if (None == self.driverMbusHandle):
raise exception.LedaBusHandleException("mbus Handle is None")
reply_cb = self._registerModule_cb
error_cb = self._registerModule_errCb
self.registerModuleSync.clear()
self.driverMbusHandle.registerDriver(json.dumps(inMsg, ensure_ascii = False), reply_cb, error_cb)
syncMsg = self.registerModuleSync.wait(mbusConfig.MERHOD_SYNC_TIMEOUT)
if (None == syncMsg):
raise exception.LedaRPCMethodException("registerDriver time out", exception.LEDA_ERROR_TIMEOUT)
elif (False == syncMsg["state"]):
raise exception.LedaRPCMethodException("registerDriver failed", exception.LEDA_ERROR_FAILED)