Code Review
/
vpp.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
papi: add a per-call _timeout option
[vpp.git]
/
src
/
vpp-api
/
python
/
vpp_papi
/
vpp_transport_shmem.py
diff --git
a/src/vpp-api/python/vpp_papi/vpp_transport_shmem.py
b/src/vpp-api/python/vpp_papi/vpp_transport_shmem.py
index
4e40f23
..
2563a6e
100644
(file)
--- a/
src/vpp-api/python/vpp_papi/vpp_transport_shmem.py
+++ b/
src/vpp-api/python/vpp_papi/vpp_transport_shmem.py
@@
-116,12
+116,14
@@
class VppTransport(object):
raise VppTransportShmemIOError(1, 'Not connected')
return vpp_api.vac_write(bytes(buf), len(buf))
raise VppTransportShmemIOError(1, 'Not connected')
return vpp_api.vac_write(bytes(buf), len(buf))
- def read(self):
+ def read(self
, timeout=None
):
if not self.connected:
raise VppTransportShmemIOError(1, 'Not connected')
if not self.connected:
raise VppTransportShmemIOError(1, 'Not connected')
+ if timeout is None:
+ timeout = self.read_timeout
mem = ffi.new("char **")
size = ffi.new("int *")
mem = ffi.new("char **")
size = ffi.new("int *")
- rv = vpp_api.vac_read(mem, size,
self.read_
timeout)
+ rv = vpp_api.vac_read(mem, size, timeout)
if rv:
strerror = 'vac_read failed. It is likely that VPP died.'
raise VppTransportShmemIOError(rv, strerror)
if rv:
strerror = 'vac_read failed. It is likely that VPP died.'
raise VppTransportShmemIOError(rv, strerror)