@@ -699,10 +699,10 @@ class NBuffer : public BaseBuffer<T> {
699
699
if (buffer_size==size && buffer_count == count)
700
700
return ;
701
701
freeMemory ();
702
- // filled_buffers.resize(count);
703
- // available_buffers.resize(count);
704
- filled_buffers.clear ();
705
- available_buffers.clear ();
702
+ filled_buffers.resize (count);
703
+ available_buffers.resize (count);
704
+ // filled_buffers.clear();
705
+ // available_buffers.clear();
706
706
707
707
buffer_count = count;
708
708
buffer_size = size;
@@ -720,10 +720,10 @@ class NBuffer : public BaseBuffer<T> {
720
720
uint16_t buffer_count = 0 ;
721
721
BaseBuffer<T> *actual_read_buffer = nullptr ;
722
722
BaseBuffer<T> *actual_write_buffer = nullptr ;
723
- // QueueFromVector<BaseBuffer<T> *> available_buffers{0, nullptr};
724
- // QueueFromVector<BaseBuffer<T> *> filled_buffers{0, nullptr};
725
- Queue<BaseBuffer<T> *> available_buffers;
726
- Queue<BaseBuffer<T> *> filled_buffers;
723
+ QueueFromVector<BaseBuffer<T> *> available_buffers{0 , nullptr };
724
+ QueueFromVector<BaseBuffer<T> *> filled_buffers{0 , nullptr };
725
+ // Queue<BaseBuffer<T> *> available_buffers;
726
+ // Queue<BaseBuffer<T> *> filled_buffers;
727
727
unsigned long start_time = 0 ;
728
728
unsigned long sample_count = 0 ;
729
729
0 commit comments