}
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;
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);
}
#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);
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);
wrap_connect (PyObject *self, PyObject *args)
{
char * name, * chroot_prefix = NULL;
+ int rx_qlen=32; /* default rx queue length */
int rv;
PyObject * temp = NULL;
pneum_callback_t cb = NULL;
- if (!PyArg_ParseTuple(args, "s|Os:wrap_connect",
- &name, &temp, &chroot_prefix))
+ if (!PyArg_ParseTuple(args, "s|Ois:wrap_connect",
+ &name, &temp, &rx_qlen, &chroot_prefix))
return (NULL);
if (temp)
cb = wrap_pneum_callback;
}
Py_BEGIN_ALLOW_THREADS
- rv = pneum_connect(name, chroot_prefix, cb);
+ rv = pneum_connect(name, chroot_prefix, cb, rx_qlen);
Py_END_ALLOW_THREADS
return PyLong_FromLong(rv);
}
self.vpp_dictionary[name] = { 'id' : i, 'crc' : crc }
self.vpp_dictionary_maxid = max(self.vpp_dictionary_maxid, i)
- def connect(self, name, chroot_prefix = None, async = False):
+ def connect(self, name, chroot_prefix = None, async = False, rx_qlen = 32):
msg_handler = self.msg_handler if not async else self.msg_handler_async
if not chroot_prefix:
- rv = vpp_api.connect(name, msg_handler)
+ rv = vpp_api.connect(name, msg_handler, rx_qlen)
else:
- rv = vpp_api.connect(name, msg_handler, chroot_prefix)
+ rv = vpp_api.connect(name, msg_handler, rx_qlen, chroot_prefix)
if rv != 0:
raise IOError(2, 'Connect failed')