| 581 | |
| 582 | private: |
| 583 | void setup_next_write_buffer() |
| 584 | { |
| 585 | std::unique_ptr<Buffer> next_write_buffer(new Buffer()); |
| 586 | m_current_write_buffer.store(next_write_buffer.get(), |
| 587 | std::memory_order_release); |
| 588 | SpinLock spinlock(m_flag); |
| 589 | m_buffers.push(std::move(next_write_buffer)); |
| 590 | m_write_index.store(0, std::memory_order_relaxed); |
| 591 | } |
| 592 | |
| 593 | Buffer* get_next_read_buffer() |
| 594 | { |