53     def open(self, **params):  argument
57     def reboot(self, **params):  argument
61     def close(self):  argument
69     def open(self, **params):  argument
72     def reboot(self, **params):  argument
75     def close(self):  argument
81     def __init__(self):  argument
82         self.tn = None
84     def __del__(self):  argument
85         self.close()
87     def _init(self):  argument
90         self.tn = telnetlib.Telnet(self.ip, self.port)
91         self.tn.read_until('User Name')
92         self.tn.write('apc\r\n')
93         self.tn.read_until('Password')
94         self.tn.write('apc\r\n')
95         self.until_done()
97     def open(self, **params):  argument
107         self.port = params['port']
108         self.ip = params['ip']
109         self.tn = None
110         self._init()
112     def close(self):  argument
115         if self.tn:
116             self.tn.close()
118     def until_done(self):  argument
121         self.until(r'^>')
123     def until(self, regex):  argument
128         self.tn.expect([r])
130     def reboot(self, **params):  argument
142         self.tn.write('\x1b\r\n')
143         self.until_done()
145         self.tn.write('1\r\n')
146         self.until_done()
148         self.tn.write('2\r\n')
149         self.until_done()
151         self.tn.write('1\r\n')
152         self.until_done()
154         self.tn.write('%d\r\n' % outlet)
155         self.until_done()
157         self.tn.write('1\r\n')
158         self.until_done()
160         self.tn.write('2\r\n')
161         self.until('to cancel')
162         self.tn.write('YES\r\n')
163         self.until('to continue')
164         self.tn.write('\r\n')
165         self.until_done()
169         self.tn.write('1\r\n')
170         self.until('to cancel')
171         self.tn.write('YES\r\n')
172         self.until('to continue')
173         self.tn.write('\r\n')
174         self.until_done()
179     def open(self, **params):  argument
182     def _pin_reset(self, serial_number):  argument
185     def reboot(self, **params):  argument
190             self._pin_reset(serial_number)
192     def close(self):  argument
206     def open(self, **params):  argument
211         self.params = params
212         self.type = 'pdu'
213         self.ip = self.params['ip']
214         self.snmp_agent_port = int(self.params['port'])
215         self._community = 'public'
216         self._snmp_engine = SnmpEngine()
217         self._community_data = CommunityData(self._community, mpModel=0)
218         self._udp_transport_target = UdpTransportTarget((self.ip, self.snmp_agent_port))
219         self._context = ContextData()
221     def _outlet_oid_get(self, param, socket):  argument
233             'get_state': self.outlet_oid_cmd_get_state_base,
234             'set_on': self.outlet_oid_cmd_set_on_base,
235             'set_off': self.outlet_oid_cmd_set_off_base,
236             'set_reboot_delay': self.outlet_oid_cmd_set_reboot_delay_seconds_base,
237             'reboot': self.outlet_oid_cmd_reboot_base
243     def _oid_set(self, oid, value):  argument
252 …         setCmd(self._snmp_engine, self._community_data, self._udp_transport_target, self._context,
264     def _oid_get(self, oid):  argument
275 …         getCmd(self._snmp_engine, self._community_data, self._udp_transport_target, self._context,
289     def _outlet_value_set(self, cmd, socket, value=1):  argument
298         oid = self._outlet_oid_get(cmd, socket)
304         self._oid_set(oid, value)
306     def _outlet_value_get(self, cmd, socket):  argument
317         oid = self._outlet_oid_get(cmd, socket)
319         return self._oid_get(oid)
321     def validate_state(self, socket, state):  argument
322         return (self._outlet_value_get('get_state', socket) == state)
324     def turn_off(self, sockets):  argument
334             self._outlet_value_set('set_off', socket)
337             timeout = time.time() + self.PDU_COMMAND_TIMEOUT
338             while ((time.time() < timeout) and not self.validate_state(socket, 0)):
341             if self.validate_state(socket, 0):
342                 logger.debug('Turned OFF socket {} at {}'.format(socket, self.ip))
344                 logger.error('Failed to turn OFF socket {} at {}'.format(socket, self.ip))
346     def turn_on(self, sockets):  argument
357             self._outlet_value_set('set_on', socket)
360             timeout = time.time() + self.PDU_COMMAND_TIMEOUT
361             while ((time.time() < timeout) and not self.validate_state(socket, 1)):
364             if self.validate_state(socket, 1):
365                 logger.debug('Turned ON socket {} at {}'.format(socket, self.ip))
367                 logger.error('Failed to turn ON socket {} at {}'.format(socket, self.ip))
369     def close(self):  argument
370         self._community = None
371         self._snmp_engine = None
372         self._community_data = None
373         self._udp_transport_target = None
374         self._context = None
376     def reboot(self, **params):  argument
385         self.turn_off(params['sockets'])
387         self.turn_on(params['sockets'])
393     def open(self, **params):  argument
394         self._base_url = 'http://{}/outs.cgi?out'.format(params['ip'])
396         password_manager.add_password(None, self._base_url, params['user'], params['pass'])
398         self._opener = build_opener(authentication_handler)
400     def reboot(self, **params):  argument
403             self._turn_off(socket)
405             self._turn_on(socket)
408     def _change_state(self, socket, state):  argument
409         self._opener.open('{}{}={}'.format(self._base_url, socket, state))
411     def _turn_off(self, socket):  argument
412         self._change_state(socket, 1)
414     def _turn_on(self, socket):  argument
415         self._change_state(socket, 0)
417     def close(self):  argument
418         self._base_url = None
419         self._opener = None
424     def open(self, **kwargs):  argument
427     def reboot(self, **kwargs):  argument
430     def close(self):  argument