Searched refs:queue_buf_size (Results 1 – 4 of 4) sorted by relevance
31 VLenQueue::VLenQueue() : queue_buf(NULL), queue_buf_size(0), queued_size(0), queue_ptr(NULL) in VLenQueue()38 queue_buf_size = initial_capacity; in VLenQueue()45 VLenQueue::VLenQueue(VLenQueue &q) : queue_buf(mem_add(q.queue_buf_size)), in VLenQueue()46 queue_buf_size(q.queue_buf_size) in VLenQueue()61 queue_buf_size = 0; in ~VLenQueue()117 tempInt = queue_buf_size; in swap()118 queue_buf_size = q.queue_buf_size; in swap()119 q.queue_buf_size = tempInt; in swap()146 queue_buf_size = newSize + (QUEUE_SIZE_INC - newSize % QUEUE_SIZE_INC); in expand()147 queue_buf = mem_resize( queue_buf, queue_buf_size); in expand()
195 if( size > rq->queue_buf_size ) in read_queue()196 rq->reserve(size - rq->queue_buf_size); in read_queue()
208 const int queue_buf_size = 1 << 10; variable215 node q[queue_buf_size];246 return writer.local_write_i == writer.local_read_i + queue_buf_size; in writer_empty()254 return static_cast<int>(writer.local_read_i + queue_buf_size - writer.local_write_i); in writer_ready()258 return q[reader.local_read_i++ & (queue_buf_size - 1)].val; in get_unsafe()271 q[writer.local_write_i++ & (queue_buf_size - 1)].val = val; in put_unsafe()
33 int queue_buf_size; // current buffer capacity variable