diff options
| author |   Dave Barach <dave@barachs.net> | 2017-01-06 16:33:06 -0500 |
|---|---|---|
| committer |   Ole Trøan <otroan@employees.org> | 2017-01-06 22:55:02 +0000 |
| commit | f952692c871b78590fcd6f2d1340a77ce59030a6 (patch) | |
| tree | 7f9871b0dded8c8c8c471d3c16c9f6db21ec73cd /src/vpp-api/python/pneum | |
| parent | a1b99dada3190d793555a075aa4eb3560c68fec7 (diff) | |
python clients can set the API rx message queue length
Change-Id: I7af1493a823747e0f7389ad6c2093e4cec6c2ce9
Signed-off-by: Dave Barach <dave@barachs.net>
Diffstat (limited to 'src/vpp-api/python/pneum')
| -rw-r--r-- | src/vpp-api/python/pneum/pneum.c | 5 | ||||
| -rw-r--r-- | src/vpp-api/python/pneum/pneum.h | 3 | ||||
| -rw-r--r-- | src/vpp-api/python/pneum/test_pneum.c | 2 |
3 files changed, 6 insertions, 4 deletions
diff --git a/src/vpp-api/python/pneum/pneum.c b/src/vpp-api/python/pneum/pneum.c index b805f04b..37c8d8fe 100644 --- a/src/vpp-api/python/pneum/pneum.c +++ b/src/vpp-api/python/pneum/pneum.c @@ -126,7 +126,8 @@ pneum_msg_table_size(void) } int -pneum_connect (char * name, char * chroot_prefix, pneum_callback_t cb) +pneum_connect (char * name, char * chroot_prefix, pneum_callback_t cb, + int rx_qlen) { int rv = 0; pneum_main_t *pm = &pneum_main; @@ -139,7 +140,7 @@ pneum_connect (char * name, char * chroot_prefix, pneum_callback_t cb) return rv; } - if (vl_client_connect(name, 0, 32) < 0) { + if (vl_client_connect(name, 0, rx_qlen) < 0) { vl_client_api_unmap(); return (-1); } diff --git a/src/vpp-api/python/pneum/pneum.h b/src/vpp-api/python/pneum/pneum.h index a347bd25..9312eb47 100644 --- a/src/vpp-api/python/pneum/pneum.h +++ b/src/vpp-api/python/pneum/pneum.h @@ -19,7 +19,8 @@ #include <vppinfra/types.h> typedef void (*pneum_callback_t)(unsigned char * data, int len); -int pneum_connect(char * name, char * chroot_prefix, pneum_callback_t cb); +int pneum_connect(char * name, char * chroot_prefix, pneum_callback_t cb, + int rx_qlen); int pneum_disconnect(void); int pneum_read(char **data, int *l); int pneum_write(char *data, int len); diff --git a/src/vpp-api/python/pneum/test_pneum.c b/src/vpp-api/python/pneum/test_pneum.c index 0d55b8a9..334e58e9 100644 --- a/src/vpp-api/python/pneum/test_pneum.c +++ b/src/vpp-api/python/pneum/test_pneum.c @@ -80,7 +80,7 @@ int main (int argc, char ** argv) vl_api_show_version_t message; vl_api_show_version_t *mp; int async = 1; - int rv = pneum_connect("pneum_client", NULL, NULL); + int rv = pneum_connect("pneum_client", NULL, NULL, 32 /* rx queue-length*/); if (rv != 0) { printf("Connect failed: %d\n", rv); |