Code Review
/
vpp.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
svm: queue sub: Add conditional timed wait
[vpp.git]
/
src
/
vpp-api
/
vapi
/
vapi.hpp
diff --git
a/src/vpp-api/vapi/vapi.hpp
b/src/vpp-api/vapi/vapi.hpp
index
893851a
..
28357db
100644
(file)
--- a/
src/vpp-api/vapi/vapi.hpp
+++ b/
src/vpp-api/vapi/vapi.hpp
@@
-245,7
+245,7
@@
public:
*
* @return VAPI_OK on success, other error code on error
*/
*
* @return VAPI_OK on success, other error code on error
*/
- vapi_error_e dispatch (const Common_req *limit = nullptr)
+ vapi_error_e dispatch (const Common_req *limit = nullptr
, u32 time = 5
)
{
std::lock_guard<std::mutex> lock (dispatch_mutex);
vapi_error_e rv = VAPI_OK;
{
std::lock_guard<std::mutex> lock (dispatch_mutex);
vapi_error_e rv = VAPI_OK;
@@
-254,7
+254,8
@@
public:
{
void *shm_data;
size_t shm_data_size;
{
void *shm_data;
size_t shm_data_size;
- rv = vapi_recv (vapi_ctx, &shm_data, &shm_data_size);
+ rv = vapi_recv (vapi_ctx, &shm_data, &shm_data_size, SVM_Q_TIMEDWAIT,
+ time);
if (VAPI_OK != rv)
{
return rv;
if (VAPI_OK != rv)
{
return rv;