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