diff options
Diffstat (limited to 'pysnmp/hlapi/v3arch/asyncio/cmdgen.py')
| -rw-r--r-- | pysnmp/hlapi/v3arch/asyncio/cmdgen.py | 41 |
1 files changed, 21 insertions, 20 deletions
diff --git a/pysnmp/hlapi/v3arch/asyncio/cmdgen.py b/pysnmp/hlapi/v3arch/asyncio/cmdgen.py index 278be5be..8d978573 100644 --- a/pysnmp/hlapi/v3arch/asyncio/cmdgen.py +++ b/pysnmp/hlapi/v3arch/asyncio/cmdgen.py @@ -42,13 +42,14 @@ from pysnmp.proto.api import v2c try: import asyncio + except ImportError: import trollius as asyncio __all__ = ['getCmd', 'nextCmd', 'setCmd', 'bulkCmd', 'isEndOfMib'] -vbProcessor = CommandGeneratorVarBinds() -lcd = CommandGeneratorLcdConfigurator() +VB_PROCESSOR = CommandGeneratorVarBinds() +LCD = CommandGeneratorLcdConfigurator() isEndOfMib = lambda varBinds: not v2c.apiPDU.getNextVarBinds(varBinds) @@ -136,8 +137,8 @@ def getCmd(snmpEngine, authData, transportTarget, contextData, if future.cancelled(): return try: - varBindsUnmade = vbProcessor.unmakeVarBinds(snmpEngine.cache, varBinds, - lookupMib) + varBindsUnmade = VB_PROCESSOR.unmakeVarBinds(snmpEngine.cache, varBinds, + lookupMib) except Exception as e: future.set_exception(e) else: @@ -145,7 +146,7 @@ def getCmd(snmpEngine, authData, transportTarget, contextData, (errorIndication, errorStatus, errorIndex, varBindsUnmade) ) - addrName, paramsName = lcd.configure( + addrName, paramsName = LCD.configure( snmpEngine, authData, transportTarget, contextData.contextName) future = asyncio.Future() @@ -153,7 +154,7 @@ def getCmd(snmpEngine, authData, transportTarget, contextData, cmdgen.GetCommandGenerator().sendVarBinds( snmpEngine, addrName, contextData.contextEngineId, contextData.contextName, - vbProcessor.makeVarBinds(snmpEngine.cache, varBinds), __cbFun, + VB_PROCESSOR.makeVarBinds(snmpEngine.cache, varBinds), __cbFun, (options.get('lookupMib', True), future) ) return future @@ -242,8 +243,8 @@ def setCmd(snmpEngine, authData, transportTarget, contextData, if future.cancelled(): return try: - varBindsUnmade = vbProcessor.unmakeVarBinds(snmpEngine.cache, varBinds, - lookupMib) + varBindsUnmade = VB_PROCESSOR.unmakeVarBinds(snmpEngine.cache, varBinds, + lookupMib) except Exception as e: future.set_exception(e) else: @@ -251,7 +252,7 @@ def setCmd(snmpEngine, authData, transportTarget, contextData, (errorIndication, errorStatus, errorIndex, varBindsUnmade) ) - addrName, paramsName = lcd.configure( + addrName, paramsName = LCD.configure( snmpEngine, authData, transportTarget, contextData.contextName) future = asyncio.Future() @@ -259,7 +260,7 @@ def setCmd(snmpEngine, authData, transportTarget, contextData, cmdgen.SetCommandGenerator().sendVarBinds( snmpEngine, addrName, contextData.contextEngineId, contextData.contextName, - vbProcessor.makeVarBinds(snmpEngine.cache, varBinds), __cbFun, + VB_PROCESSOR.makeVarBinds(snmpEngine.cache, varBinds), __cbFun, (options.get('lookupMib', True), future) ) return future @@ -352,9 +353,9 @@ def nextCmd(snmpEngine, authData, transportTarget, contextData, if future.cancelled(): return try: - varBindsUnmade = [vbProcessor.unmakeVarBinds(snmpEngine.cache, - varBindTableRow, - lookupMib) + varBindsUnmade = [VB_PROCESSOR.unmakeVarBinds(snmpEngine.cache, + varBindTableRow, + lookupMib) for varBindTableRow in varBindTable] except Exception as e: future.set_exception(e) @@ -363,7 +364,7 @@ def nextCmd(snmpEngine, authData, transportTarget, contextData, (errorIndication, errorStatus, errorIndex, varBindsUnmade) ) - addrName, paramsName = lcd.configure( + addrName, paramsName = LCD.configure( snmpEngine, authData, transportTarget, contextData.contextName) future = asyncio.Future() @@ -371,7 +372,7 @@ def nextCmd(snmpEngine, authData, transportTarget, contextData, cmdgen.NextCommandGenerator().sendVarBinds( snmpEngine, addrName, contextData.contextEngineId, contextData.contextName, - vbProcessor.makeVarBinds(snmpEngine.cache, varBinds), __cbFun, + VB_PROCESSOR.makeVarBinds(snmpEngine.cache, varBinds), __cbFun, (options.get('lookupMib', True), future) ) return future @@ -493,9 +494,9 @@ def bulkCmd(snmpEngine, authData, transportTarget, contextData, if future.cancelled(): return try: - varBindsUnmade = [vbProcessor.unmakeVarBinds(snmpEngine.cache, - varBindTableRow, - lookupMib) + varBindsUnmade = [VB_PROCESSOR.unmakeVarBinds(snmpEngine.cache, + varBindTableRow, + lookupMib) for varBindTableRow in varBindTable] except Exception as e: future.set_exception(e) @@ -504,7 +505,7 @@ def bulkCmd(snmpEngine, authData, transportTarget, contextData, (errorIndication, errorStatus, errorIndex, varBindsUnmade) ) - addrName, paramsName = lcd.configure( + addrName, paramsName = LCD.configure( snmpEngine, authData, transportTarget, contextData.contextName) future = asyncio.Future() @@ -512,7 +513,7 @@ def bulkCmd(snmpEngine, authData, transportTarget, contextData, cmdgen.BulkCommandGenerator().sendVarBinds( snmpEngine, addrName, contextData.contextEngineId, contextData.contextName, nonRepeaters, maxRepetitions, - vbProcessor.makeVarBinds(snmpEngine.cache, varBinds), __cbFun, + VB_PROCESSOR.makeVarBinds(snmpEngine.cache, varBinds), __cbFun, (options.get('lookupMib', True), future) ) return future |