Home
last modified time | relevance | path

Searched refs:RingBuffer (Results 1 - 12 of 12) sorted by relevance

/base/update/updater/services/common/ring_buffer/
H A Dring_buffer.cpp25 RingBuffer::~RingBuffer() in ~RingBuffer()
30 bool RingBuffer::Init(uint32_t singleSize, uint32_t num) in Init()
57 void RingBuffer::Reset() in Reset()
67 bool RingBuffer::IsFull() in IsFull()
74 bool RingBuffer::IsEmpty() in IsEmpty()
81 bool RingBuffer::Push(uint8_t *buf, uint32_t len) in Push()
84 LOG(ERROR) << "RingBuffer push error, len:" << len << " singleSize:" << singleSize_; in Push()
91 LOG(WARNING) << "RingBuffer push stopped"; in Push()
94 LOG(DEBUG) << "RingBuffer ful in Push()
[all...]
H A Dring_buffer.h28 class RingBuffer { class
29 DISALLOW_COPY_MOVE(RingBuffer);
31 RingBuffer() = default;
32 virtual ~RingBuffer();
/base/update/updater/test/unittest/common/ring_buffer/
H A Dring_buffer_unittest.cpp38 void ProducerTask(RingBuffer *ringBuffer) in ProducerTask()
49 void ConsumerTask(RingBuffer *ringBuffer) in ConsumerTask()
70 RingBuffer ringBuffer; in HWTEST_F()
85 RingBuffer ringBuffer; in HWTEST_F()
/base/update/updater/test/benchmarktest/
H A Dupdater_benchmark_test.cpp39 void ProducerTask(RingBuffer *ringBuffer) in ProducerTask()
49 void ConsumerTask(RingBuffer *ringBuffer) in ConsumerTask()
60 RingBuffer ringBuffer; in TestRingBuffer()
/base/update/updater/test/unittest/updater_binary/
H A Dupdate_processor_unittest.cpp117 RingBuffer ringBuffer; in HWTEST_F()
/base/update/updater/services/updater_binary/
H A Dupdate_processor.cpp323 RingBuffer ringBuffer; in Execute()
352 RingBuffer *ringBuffer = static_cast<RingBuffer *>(p); in UnCompressDataProducer()
/base/update/updater/services/package/pkg_manager/
H A Dpkg_stream.h232 const size_t fileSize, Updater::RingBuffer *buffer, int32_t streamType = in FlowDataStream()
275 Updater::RingBuffer *ringBuf_ {};
H A Dpkg_manager_impl.h77 uint64_t fileLen, Updater::RingBuffer *buffer) override;
H A Dpkg_managerImpl.cpp519 uint64_t fileLen, RingBuffer *buffer) in CreatePkgStream()
/base/update/updater/test/unittest/script/
H A Dscript_unittest.h115 uint64_t fileLen, Updater::RingBuffer *buffer) override
/base/update/updater/services/flow_update/update_bin/
H A Dbin_process.cpp57 RingBuffer ringBuffer; in Execute()
/base/update/updater/services/include/package/
H A Dpkg_manager.h338 uint64_t fileLen, Updater::RingBuffer *buffer) = 0;

Completed in 8 milliseconds