Searched refs:ringBuffer (Results 1 - 5 of 5) sorted by relevance
| /base/update/updater/test/unittest/common/ring_buffer/ |
| H A D | ring_buffer_unittest.cpp | 38 void ProducerTask(RingBuffer *ringBuffer) in ProducerTask() argument
45 ringBuffer->Push(buf, sizeof(buf)); in ProducerTask()
49 void ConsumerTask(RingBuffer *ringBuffer) in ConsumerTask() argument
55 ringBuffer->Pop(buf, sizeof(buf), len); in ConsumerTask()
70 RingBuffer ringBuffer; in HWTEST_F() local
71 bool ret = ringBuffer.Init(1024, 8); in HWTEST_F()
73 std::thread consumer(ConsumerTask, &ringBuffer); in HWTEST_F()
74 std::thread producer(ProducerTask, &ringBuffer); in HWTEST_F()
85 RingBuffer ringBuffer; in HWTEST_F() local
86 bool ret = ringBuffer in HWTEST_F()
[all...] |
| /base/update/updater/test/benchmarktest/ |
| H A D | updater_benchmark_test.cpp | 39 void ProducerTask(RingBuffer *ringBuffer) in ProducerTask() argument
45 ringBuffer->Push(buf, sizeof(buf)); in ProducerTask()
49 void ConsumerTask(RingBuffer *ringBuffer) in ConsumerTask() argument
54 ringBuffer->Pop(buf, sizeof(buf), len); in ConsumerTask()
60 RingBuffer ringBuffer; in TestRingBuffer() local
61 bool ret = ringBuffer.Init(1024, 8); in TestRingBuffer()
63 std::thread consumer(ConsumerTask, &ringBuffer); in TestRingBuffer()
64 std::thread producer(ProducerTask, &ringBuffer); in TestRingBuffer()
|
| /base/update/updater/test/unittest/updater_binary/ |
| H A D | update_processor_unittest.cpp | 117 RingBuffer ringBuffer;
in HWTEST_F() local
118 bool ret = ringBuffer.Init(UScriptInstructionUpdateFromBin::STASH_BUFFER_SIZE, 4); // power of 2
in HWTEST_F()
122 BUFFER_SIZE, 0, false, &ringBuffer), 0);
in HWTEST_F()
125 EXPECT_EQ(UScriptInstructionUpdateFromBin::UnCompressDataProducer(emptyBuffer, 0, 0, true, &ringBuffer), 0);
in HWTEST_F()
128 ringBuffer.Pop(recvBuffer, UScriptInstructionUpdateFromBin::STASH_BUFFER_SIZE, len);
in HWTEST_F()
130 ringBuffer.Pop(recvBuffer, UScriptInstructionUpdateFromBin::STASH_BUFFER_SIZE, len);
in HWTEST_F()
|
| /base/update/updater/services/updater_binary/ |
| H A D | update_processor.cpp | 323 RingBuffer ringBuffer; in Execute() local
324 if (!ringBuffer.Init(STASH_BUFFER_SIZE, BUFFER_NUM)) { in Execute()
330 ret = pkgManager->CreatePkgStream(outStream, upgradeFileName, UnCompressDataProducer, &ringBuffer); in Execute()
352 RingBuffer *ringBuffer = static_cast<RingBuffer *>(p); in UnCompressDataProducer() local
353 if (ringBuffer == nullptr) { in UnCompressDataProducer()
363 ringBuffer->Push(stashBuffer.buffer, STASH_BUFFER_SIZE); in UnCompressDataProducer()
373 ringBuffer->Push(stashBuffer.buffer, stashDataSize_ + size); in UnCompressDataProducer()
|
| /base/update/updater/services/flow_update/update_bin/ |
| H A D | bin_process.cpp | 57 RingBuffer ringBuffer; in Execute() local
58 if (!ringBuffer.Init(STASH_BUFFER_SIZE, MAX_BUFFER_NUM)) { in Execute()
72 ret = pkgManager->CreatePkgStream(binFlowStream, upgradeFileName, info->unpackedSize, &ringBuffer); in Execute()
|
Completed in 3 milliseconds