1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
from twisted.internet import defer
from pysnmp.entity.rfc3413 import cmdgen
def _cbFun(snmpEngine, sendRequestHandle, errorIndication,
errorStatus, errorIndex, varBinds, cbCtx):
df = cbCtx['df']
df.callback(
(snmpEngine, errorIndication, errorStatus, errorIndex, varBinds)
)
# Callback function may return another deferred to indicate
# it wishes to continue MIB walk.
if isinstance(df.result, defer.Deferred):
cbCtx['df'] = df.result
return 1 # continue walking
class AbstractCommandGenerator:
commandGenerator = None
def sendVarBinds(self, snmpEngine, targetName,
contextEngineId, contextName, varBinds):
df = defer.Deferred()
self.commandGenerator.sendVarBinds(
snmpEngine,
targetName,
contextEngineId,
contextName,
varBinds,
_cbFun,
{ 'df': df } # anonymous dictionary used for cbCtx
)
return df
class GetCommandGenerator(AbstractCommandGenerator):
commandGenerator = cmdgen.GetCommandGenerator()
class SetCommandGenerator(AbstractCommandGenerator):
commandGenerator = cmdgen.SetCommandGenerator()
class NextCommandGeneratorSingleRun(AbstractCommandGenerator):
commandGenerator = cmdgen.NextCommandGeneratorSingleRun()
class NextCommandGenerator(AbstractCommandGenerator):
commandGenerator = cmdgen.NextCommandGenerator()
class AbstractBulkCommandGenerator:
commandGenerator = None
def sendVarBinds(
self,
snmpEngine,
targetName,
contextEngineId,
contextName,
nonRepeaters,
maxRepetitions,
varBinds
):
df = defer.Deferred()
self.commandGenerator.sendVarBinds(
snmpEngine,
targetName,
contextEngineId,
contextName,
nonRepeaters,
maxRepetitions,
varBinds,
_cbFun,
{ 'df': df } # anonymous dictionary used for cbCtx
)
return df
class BulkCommandGeneratorSingleRun(AbstractBulkCommandGenerator):
commandGenerator = cmdgen.BulkCommandGeneratorSingleRun()
class BulkCommandGenerator(AbstractBulkCommandGenerator):
commandGenerator = cmdgen.BulkCommandGenerator()
#
# Obsolete, compatibility interfaces.
#
def __sendReqCbFun(response, outerDf):
( snmpEngine,
errorIndication,
errorStatus,
errorIndex,
varBinds) = response
outerDf.callback((errorIndication, errorStatus, errorIndex, varBinds))
# Callback function may return another deferred to indicate
# it wishes to continue MIB walk.
if isinstance(outerDf.result, defer.Deferred):
innerDf = defer.Deferred()
innerDf.addCallback(__sendReqCbFun, outerDf.result)
return innerDf
def _sendReq(self,
snmpEngine,
targetName,
varBinds,
contextEngineId=None,
contextName=''):
innerDf = self.sendVarBinds(snmpEngine,
targetName,
contextEngineId,
contextName,
varBinds)
outerDf = defer.Deferred()
innerDf.addCallback(__sendReqCbFun, outerDf)
return outerDf
def _sendBulkReq(self,
snmpEngine,
targetName,
nonRepeaters,
maxRepetitions,
varBinds,
contextEngineId=None,
contextName=''):
innerDf = self.sendVarBinds(snmpEngine,
targetName,
contextEngineId,
contextName,
nonRepeaters,
maxRepetitions,
varBinds)
outerDf = defer.Deferred()
innerDf.addCallback(__sendReqCbFun, outerDf)
return outerDf
# install compatibility wrappers
GetCommandGenerator.sendReq = _sendReq
SetCommandGenerator.sendReq = _sendReq
NextCommandGenerator.sendReq = _sendReq
NextCommandGeneratorSingleRun.sendReq = _sendReq
BulkCommandGenerator.sendReq = _sendBulkReq
BulkCommandGeneratorSingleRun.sendReq = _sendBulkReq
|
