Revision 66cd54c8 ncclient/operations/rpc.py
b/ncclient/operations/rpc.py | ||
---|---|---|
291 | 291 |
""" |
292 | 292 |
logger.debug('request %r with opsepc=%r' % (self, op)) |
293 | 293 |
req = self._build(op) |
294 |
self.session.send(req) |
|
295 |
if self.async: |
|
294 |
self._session.send(req)
|
|
295 |
if self._async:
|
|
296 | 296 |
logger.debug('async, returning event') |
297 |
return self.event |
|
297 |
return self._event
|
|
298 | 298 |
else: |
299 |
logger.debug('sync, will wait for timeout=%r' % self.timeout) |
|
300 |
self.event.wait(self.timeout)
|
|
301 |
if self.event.isSet(): |
|
302 |
if self.error: |
|
299 |
logger.debug('sync, will wait for timeout=%r' % self._timeout)
|
|
300 |
self._event.wait(self._timeout)
|
|
301 |
if self._event.isSet():
|
|
302 |
if self._error:
|
|
303 | 303 |
raise self._error |
304 |
self.reply.parse() |
|
305 |
return self.reply |
|
304 |
self._reply.parse()
|
|
305 |
return self._reply
|
|
306 | 306 |
else: |
307 | 307 |
raise TimeoutExpiredError |
308 | 308 |
|
Also available in: Unified diff