diff options
| -rw-r--r-- | lib/buffer_queue_pool.cpp | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/lib/buffer_queue_pool.cpp b/lib/buffer_queue_pool.cpp index db9b68a..003dec3 100644 --- a/lib/buffer_queue_pool.cpp +++ b/lib/buffer_queue_pool.cpp @@ -37,6 +37,12 @@ struct BufferQueuePool : BufferQueue void push(const SBuffer &buff) { + //is it my buffer? otherwise dont keep it + if (buff->config.token.lock() != _token) return; + + //should never get a buffer from a circ queue + ASSERT(buff.get_user_index() == size_t(~0)); + _queue.push_back(buff); } |