| 116 | } |
| 117 | |
| 118 | void* ring_queue_writer(void* arg) |
| 119 | { |
| 120 | rq_test_exited = false; |
| 121 | DEFER(rq_test_exited = true); |
| 122 | auto* b = (RingBuffer*)arg; |
| 123 | for (int i = 0; i< 10; ++i) |
| 124 | { |
| 125 | LOG_DEBUG("write"); |
| 126 | auto ret = b->write(str, LEN(str)); |
| 127 | EXPECT_EQ(ret, LEN(str)); |
| 128 | LOG_DEBUG("written ", VALUE(ret)); |
| 129 | } |
| 130 | LOG_DEBUG("exit"); |
| 131 | return nullptr; |
| 132 | } |
| 133 | |
| 134 | TEST(ring, buffer) |
| 135 | { |