Lines Matching defs:ringBuffer
65 auto ringBuffer = std::make_unique<RingBuffer>(0, memAlign);
66 ASSERT_TRUE(ringBuffer != nullptr);
67 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
68 ASSERT_EQ(ringBuffer->bufSize_, RingBuffer::BufferSize::DEFAULT_SIZE);
79 auto ringBuffer = std::make_unique<RingBuffer>(BUFFER_SIZE, memAlign);
80 ASSERT_TRUE(ringBuffer != nullptr);
81 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
82 EXPECT_EQ(ringBuffer->bufSize_, BUFFER_SIZE);
85 ringBuffer = std::make_unique<RingBuffer>(size, memAlign);
86 ASSERT_TRUE(ringBuffer != nullptr);
87 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
88 EXPECT_EQ(ringBuffer->bufSize_, size);
99 auto ringBuffer = std::make_unique<RingBuffer>(BUFFER_SIZE, memAlign);
100 ASSERT_TRUE(ringBuffer != nullptr);
101 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
102 EXPECT_EQ(ringBuffer->bufSize_, BUFFER_SIZE);
107 ringBuffer = std::make_unique<RingBuffer>(size, memAlign);
108 ASSERT_TRUE(ringBuffer != nullptr);
109 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
110 EXPECT_EQ(ringBuffer->bufSize_, expectSize);
121 auto ringBuffer = std::make_unique<RingBuffer>(BUFFER_SIZE, memAlign);
122 ASSERT_TRUE(ringBuffer != nullptr);
123 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
124 EXPECT_EQ(ringBuffer->bufSize_, BUFFER_SIZE);
129 ringBuffer = std::make_unique<RingBuffer>(size, memAlign);
130 ASSERT_TRUE(ringBuffer != nullptr);
131 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
132 EXPECT_EQ(ringBuffer->bufSize_, expectSize);
143 auto ringBuffer = std::make_unique<RingBuffer>(BUFFER_SIZE, memAlign);
144 ASSERT_TRUE(ringBuffer != nullptr);
145 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
146 EXPECT_EQ(ringBuffer->bufSize_, BUFFER_SIZE);
151 ringBuffer = std::make_unique<RingBuffer>(size, memAlign);
152 ASSERT_TRUE(ringBuffer != nullptr);
153 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
154 EXPECT_EQ(ringBuffer->bufSize_, expectSize);
165 auto ringBuffer = std::make_unique<RingBuffer>(BUFFER_SIZE, memAlign);
166 ASSERT_TRUE(ringBuffer != nullptr);
167 EXPECT_EQ(ringBuffer->Capacity(), BUFFER_SIZE);
190 auto ringBuffer = std::make_unique<RingBuffer>(1, memAlign);
191 ASSERT_TRUE(ringBuffer != nullptr);
192 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
193 EXPECT_EQ(ringBuffer->bufSize_, RingBuffer::BufferSize::DEFAULT_SIZE);
195 size_t ret = ringBuffer->Read(-1, 1);
197 ret = ringBuffer->Read(readFd, 0);
200 auto len = ringBuffer->Read(readFd, expectBytes);
207 ret = ringBuffer->Write(-1, 1);
209 ret = ringBuffer->Write(writeFd, len);
216 len = ringBuffer->Read(readFd, bytes);
222 ret = ringBuffer->Write(writeFd, len);
235 auto ringBuffer = std::make_unique<RingBuffer>(1, memAlign);
236 ASSERT_TRUE(ringBuffer != nullptr);
237 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
238 EXPECT_EQ(ringBuffer->bufSize_, RingBuffer::BufferSize::DEFAULT_SIZE);
241 size_t ret = ringBuffer->Put(nullptr, 1);
243 ret = ringBuffer->Put(testStr.c_str(), 0);
245 auto len = ringBuffer->Put(testStr.c_str(), testStr.size());
247 EXPECT_EQ(ringBuffer->tail_, testStr.size());
252 ret = ringBuffer->Write(-1, 1);
254 ret = ringBuffer->Write(writeFd, len);
267 auto ringBuffer = std::make_unique<RingBuffer>(0, memAlign);
268 ASSERT_TRUE(ringBuffer != nullptr);
269 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
270 EXPECT_EQ(ringBuffer->bufSize_, RingBuffer::BufferSize::DEFAULT_SIZE);
272 size_t ret = ringBuffer->Put("");
274 ret = ringBuffer->Put("\0");
277 auto len = ringBuffer->Put(testStr);
283 ret = ringBuffer->Write(-1, 1);
285 ret = ringBuffer->Write(writeFd, len);
298 auto ringBuffer = std::make_unique<RingBuffer>(0, memAlign);
299 ASSERT_TRUE(ringBuffer != nullptr);
300 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
301 EXPECT_EQ(ringBuffer->bufSize_, RingBuffer::BufferSize::DEFAULT_SIZE);
304 auto len = ringBuffer->Put(testStr);
309 len = ringBuffer->Get(nullptr, 1);
311 len = ringBuffer->Get(buff.data(), 0);
313 len = ringBuffer->Get(buff.data(), RingBuffer::BufferSize::DEFAULT_SIZE + 1);
315 len = ringBuffer->Get(buff.data(), testStr.size());
322 len = ringBuffer->Put(testStr);
325 len = ringBuffer->Get(buff.data(), testStr.size());
330 len = ringBuffer->Put(testStr);
333 len = ringBuffer->Get(buff.data(), testStr.size());
344 auto ringBuffer = std::make_unique<RingBuffer>(BUFFER_SIZE, RingBuffer::MemAlignShift::B_ALIGN_SHIFT);
345 ASSERT_TRUE(ringBuffer != nullptr);
346 EXPECT_EQ(ringBuffer->bufSize_, BUFFER_SIZE);
347 auto newBuffer = ringBuffer->Allocate(1);
350 ringBuffer = std::make_unique<RingBuffer>(BUFFER_SIZE, RingBuffer::MemAlignShift::H_ALIGN_SHIFT);
351 ASSERT_TRUE(ringBuffer != nullptr);
352 EXPECT_EQ(ringBuffer->bufSize_, BUFFER_SIZE);
353 newBuffer = ringBuffer->Allocate(1);
356 ringBuffer = std::make_unique<RingBuffer>(BUFFER_SIZE, RingBuffer::MemAlignShift::W_ALIGN_SHIFT);
357 ASSERT_TRUE(ringBuffer != nullptr);
358 EXPECT_EQ(ringBuffer->bufSize_, BUFFER_SIZE);
359 newBuffer = ringBuffer->Allocate(1);
362 ringBuffer = std::make_unique<RingBuffer>(BUFFER_SIZE, RingBuffer::MemAlignShift::D_ALIGN_SHIFT);
363 ASSERT_TRUE(ringBuffer != nullptr);
364 EXPECT_EQ(ringBuffer->bufSize_, BUFFER_SIZE);
365 newBuffer = ringBuffer->Allocate(1);
377 auto ringBuffer = std::make_unique<RingBuffer>(1, memAlign);
378 ASSERT_TRUE(ringBuffer != nullptr);
379 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
382 auto ret = ringBuffer->Peek(&expectNum); // ringBuffer no data
387 auto len = ringBuffer->Put(ptr, sizeof(ptr));
390 ret = ringBuffer->Peek(&expectNum);
396 len = ringBuffer->Put("2", 1);
399 len = ringBuffer->Put("3");
403 ret = ringBuffer->Get(buff, size);
406 len = ringBuffer->Put(ptr, sizeof(ptr));
410 ret = ringBuffer->Peek(&expectNum);
423 auto ringBuffer = std::make_unique<RingBuffer>(1, memAlign);
424 ASSERT_TRUE(ringBuffer != nullptr);
425 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
426 ASSERT_EQ(ringBuffer->bufSize_, RingBuffer::BufferSize::DEFAULT_SIZE);
428 auto oldSize = ringBuffer->bufSize_;
429 auto ret = ringBuffer->Resize();
431 ASSERT_EQ(ringBuffer->bufSize_, oldSize << 1);
438 ret = ringBuffer->Put(destStr);
440 while (putStr.size() < (ringBuffer->bufSize_ - size - 1)) {
443 ret = ringBuffer->Put(putStr.c_str());
447 ret = ringBuffer->Get(buff, size);
450 ret = ringBuffer->Put(testStr);
453 oldSize = ringBuffer->bufSize_;
454 ret = ringBuffer->Resize();
456 ASSERT_EQ(ringBuffer->bufSize_, oldSize << 1);