Fix bug
This commit is contained in:
1 parent
a12e2d5f0b
commit
40b3b04d55
1 file changed
+2
@@ -127,6 +127,8 @@ static inline void \
|
|||||||
m_mutex_lock(v->mutex); \
|
m_mutex_lock(v->mutex); \
|
||||||
if (((policy)&BUFFER_PUSH_INIT_POP_MOVE) != 0) \
|
if (((policy)&BUFFER_PUSH_INIT_POP_MOVE) != 0) \
|
||||||
M_C3(bufferi_, name, _clear_obj)(v); \
|
M_C3(bufferi_, name, _clear_obj)(v); \
|
||||||
|
else \
|
||||||
|
v->idx_prod = v->idx_cons = v->number = 0; \
|
||||||
if (((policy) & BUFFER_THREAD_UNSAFE) != BUFFER_THREAD_UNSAFE) { \
|
if (((policy) & BUFFER_THREAD_UNSAFE) != BUFFER_THREAD_UNSAFE) { \
|
||||||
m_cond_signal(v->there_is_room_for_data); \
|
m_cond_signal(v->there_is_room_for_data); \
|
||||||
m_mutex_unlock(v->mutex); \
|
m_mutex_unlock(v->mutex); \
|
||||||
|
|||||||
Reference in new issue
Block a user