admin/mlib
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add deferred pop release, so that we won't consider the queue as free

Browse Source 
until the user code finished handling with the data?
This commit is contained in:
Patrick Pelissier committed 2017-12-02 17:40:50 +01:00
1 parent cb0f59940f
commit 1cadf702cd
1 file changed
+12 -2
Download Patch File Download Diff File Expand all files Collapse all files
m-buffer.h
+12 -2
View File
@@ -37,7 +37,8 @@ typedef enum {
BUFFER_BLOCKING = 0, BUFFER_UNBLOCKING = 6,
BUFFER_THREAD_SAFE = 0, BUFFER_THREAD_UNSAFE = 8,
BUFFER_PUSH_INIT_POP_MOVE = 16,
BUFFER_PUSH_OVERWRITE = 32
BUFFER_PUSH_OVERWRITE = 32,
BUFFER_DEFERRED_POP = 64
} buffer_policy_e;
/* Define a buffer.
@@ -295,7 +296,8 @@ M_C(name, _init)(buffer_t v, size_t size) \
M_DO_INIT_MOVE (oplist, *data, v->data[v->idx_prod]); \
} \
} \
v->number --; \
if (!BUFFERI_POLICY_P((policy), BUFFER_DEFERRED_POP)) \
v->number --; \
\
/* BUFFER unlock */ \
if (!BUFFERI_POLICY_P((policy), BUFFER_THREAD_UNSAFE)) { \
@@ -319,6 +321,14 @@ M_C(name, _init)(buffer_t v, size_t size) \
(void) v; /* may be unused */ \
return BUFFERI_SIZE(m_size); \
} \
\
static inline void \
M_C(name, _pop_release)(buffer_t v) \
{ \
if (BUFFERI_POLICY_P((policy), BUFFER_DEFERRED_POP)) \
v->number --; \
} \
/* Definition of a a QUEUE for Many Produccer / Many Consummer
for high bandwidth scenario: