Home
last modified time | relevance | path

Searched refs:STASH_BUFFER_SIZE (Results 1 – 4 of 4) sorted by relevance

/ohos5.0/base/update/updater/test/unittest/updater_binary/
H A Dupdate_processor_unittest.cpp118 bool ret = ringBuffer.Init(UScriptInstructionUpdateFromBin::STASH_BUFFER_SIZE, 4); // power of 2
126 uint8_t recvBuffer[UScriptInstructionUpdateFromBin::STASH_BUFFER_SIZE] {};
128 ringBuffer.Pop(recvBuffer, UScriptInstructionUpdateFromBin::STASH_BUFFER_SIZE, len);
129 EXPECT_EQ(len, UScriptInstructionUpdateFromBin::STASH_BUFFER_SIZE);
130 ringBuffer.Pop(recvBuffer, UScriptInstructionUpdateFromBin::STASH_BUFFER_SIZE, len);
/ohos5.0/base/update/updater/services/flow_update/update_bin/
H A Dbin_process.cpp35 constexpr uint32_t STASH_BUFFER_SIZE = 4 * 1024 * 1024; variable
58 if (!ringBuffer.Init(STASH_BUFFER_SIZE, MAX_BUFFER_NUM)) { in Execute()
64 stashBuffer_.data.resize(STASH_BUFFER_SIZE); in Execute()
173 while (size - writeSize > STASH_BUFFER_SIZE - stashDataSize_) { in UnCompressDataProducer()
174 copyLen = STASH_BUFFER_SIZE - stashDataSize_; in UnCompressDataProducer()
179 …if (flowStream->Write(stashBuffer_, STASH_BUFFER_SIZE, start - stashDataSize_) != USCRIPT_SUCCESS)… in UnCompressDataProducer()
192 if (stashDataSize_ == STASH_BUFFER_SIZE) { in UnCompressDataProducer()
/ohos5.0/base/update/updater/services/updater_binary/
H A Dupdate_processor.cpp324 if (!ringBuffer.Init(STASH_BUFFER_SIZE, BUFFER_NUM)) { in Execute()
349 static PkgBuffer stashBuffer(STASH_BUFFER_SIZE); in UnCompressDataProducer()
358 while (stashDataSize_ + size >= STASH_BUFFER_SIZE) { in UnCompressDataProducer()
359 size_t readLen = STASH_BUFFER_SIZE - stashDataSize_; in UnCompressDataProducer()
363 ringBuffer->Push(stashBuffer.buffer, STASH_BUFFER_SIZE); in UnCompressDataProducer()
370 …} else if (size == 0 || memcpy_s(stashBuffer.buffer + stashDataSize_, STASH_BUFFER_SIZE - stashDat… in UnCompressDataProducer()
H A Dupdate_processor.h100 constexpr static uint32_t STASH_BUFFER_SIZE = 1024 * 1024 * 4; variable