| /ohos5.0/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; variable
71 bool ret = ringBuffer.Init(1024, 8);
73 std::thread consumer(ConsumerTask, &ringBuffer);
74 std::thread producer(ProducerTask, &ringBuffer);
85 RingBuffer ringBuffer; variable
86 bool ret = ringBuffer.Init(1024, 3);
|
| /ohos5.0/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()
|
| /ohos5.0/base/update/updater/test/unittest/updater_binary/ |
| H A D | update_processor_unittest.cpp | 117 RingBuffer ringBuffer; variable
118 bool ret = ringBuffer.Init(UScriptInstructionUpdateFromBin::STASH_BUFFER_SIZE, 4); // power of 2
122 BUFFER_SIZE, 0, false, &ringBuffer), 0);
125 …(UScriptInstructionUpdateFromBin::UnCompressDataProducer(emptyBuffer, 0, 0, true, &ringBuffer), 0);
128 ringBuffer.Pop(recvBuffer, UScriptInstructionUpdateFromBin::STASH_BUFFER_SIZE, len);
130 ringBuffer.Pop(recvBuffer, UScriptInstructionUpdateFromBin::STASH_BUFFER_SIZE, len);
|
| /ohos5.0/drivers/hdf_core/framework/test/unittest/platform/virtual/ |
| H A D | spi_virtual.c | 39 uint16_t *ringBuffer; member
61 *word = virtual->ringBuffer[pos]; in RingBufferReadWord()
75 virtual->ringBuffer[virtual->wp] = word; in RingBufferWriteWord()
101 if ((virtual->cfg.mode & SPI_MODE_LOOP) != 0 && virtual->ringBuffer == NULL) { in RingBufferConfig()
102 virtual->ringBuffer = OsalMemAlloc(virtual->fifoSize * BYTES_PER_WORD); in RingBufferConfig()
103 if (virtual->ringBuffer == NULL) { in RingBufferConfig()
108 OsalMemFree(virtual->ringBuffer); in RingBufferConfig()
109 virtual->ringBuffer = NULL; in RingBufferConfig()
132 if ((virtual->cfg.mode & SPI_MODE_LOOP) == 0 || virtual->ringBuffer == NULL) { in VirtualSpiWriteFifo()
154 if ((virtual->cfg.mode & SPI_MODE_LOOP) == 0 || virtual->ringBuffer == NULL) { in VirtualSpiReadFifo()
[all …]
|
| /ohos5.0/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()
|
| /ohos5.0/foundation/multimedia/av_codec/test/unittest/plugins_source_test/ |
| H A D | file_fd_source_plugin_unit_test.cpp | 48 std::shared_ptr<RingBuffer> ringBuffer = std::make_shared<RingBuffer>(bufferSize); in SetUp() local
49 fileFdSourcePlugin_->ringBuffer_ = ringBuffer; in SetUp()
|
| /ohos5.0/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()
|