Revision b2d60e49 ncclient/operations/rpc.py
| b/ncclient/operations/rpc.py | ||
|---|---|---|
| 54 | 54 |
def to_dict(self): |
| 55 | 55 |
return dict([ (attr[1:], getattr(self, attr)) for attr in RPCError.tag_to_attr.values() ]) |
| 56 | 56 |
|
| 57 |
"*rpc-error* element as returned." |
|
| 58 | 57 |
@property |
| 59 | 58 |
def xml(self): |
| 59 |
"*rpc-error* element as returned." |
|
| 60 | 60 |
return self._raw |
| 61 | 61 |
|
| 62 | 62 |
@property |
| ... | ... | |
| 123 | 123 |
if error is not None: |
| 124 | 124 |
for err in root.getiterator(error.tag): |
| 125 | 125 |
# Process a particular <rpc-error> |
| 126 |
self._errors.append(ERROR_CLS(err)) |
|
| 126 |
self._errors.append(self.ERROR_CLS(err)) |
|
| 127 |
self._parsing_hook(root) |
|
| 127 | 128 |
self._parsed = True |
| 129 |
|
|
| 130 |
def _parsing_hook(self, root): |
|
| 131 |
pass |
|
| 128 | 132 |
|
| 129 | 133 |
@property |
| 130 | 134 |
def xml(self): |
| ... | ... | |
| 264 | 268 |
logger.debug('Async request, returning %r', self)
|
| 265 | 269 |
return self |
| 266 | 270 |
else: |
| 267 |
logger.debug('Sync request, will wait for timeout=%r' %
|
|
| 268 |
self._timeout) |
|
| 271 |
logger.debug('Sync request, will wait for timeout=%r' % self._timeout)
|
|
| 269 | 272 |
self._event.wait(self._timeout) |
| 270 | 273 |
if self._event.isSet(): |
| 271 | 274 |
if self._error: |
| ... | ... | |
| 283 | 286 |
else: |
| 284 | 287 |
raise TimeoutExpiredError |
| 285 | 288 |
|
| 286 |
def request(self, *args, **kwds):
|
|
| 289 |
def request(self): |
|
| 287 | 290 |
"""Subclasses must implement this method. Typically only the request needs to be built as an |
| 288 | 291 |
`~xml.etree.ElementTree.Element` and everything else can be handed off to |
| 289 | 292 |
:meth:`_request`.""" |
| ... | ... | |
| 294 | 297 |
server, before making a request that requires it. A :exc:`MissingCapabilityError` will be |
| 295 | 298 |
raised if the capability is not available.""" |
| 296 | 299 |
if capability not in self._session.server_capabilities: |
| 297 |
raise MissingCapabilityError('Server does not support [%s]' %
|
|
| 298 |
capability) |
|
| 300 |
raise MissingCapabilityError('Server does not support [%s]' % capability)
|
|
| 299 | 301 |
|
| 300 | 302 |
def deliver_reply(self, raw): |
| 301 | 303 |
# internal use |
Also available in: Unified diff