Home
last modified time | relevance | path

Searched refs:buffer (Results 551 - 575 of 2926) sorted by relevance

1...<<21222324252627282930>>...118

/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/src/render_context/
H A Dcache_data.cpp71 void *buffer = mmap(nullptr, fileSize, PROT_READ, MAP_PRIVATE, fd, 0); in CacheReadFromFile() local
72 if (buffer == MAP_FAILED) { in CacheReadFromFile()
77 uint8_t *shaderBuffer = reinterpret_cast<uint8_t*>(buffer); in CacheReadFromFile()
81 munmap(buffer, fileSize); in CacheReadFromFile()
121 uint8_t *buffer = new uint8_t[cacheSize]; in WriteToFile() local
122 if (!buffer) { in WriteToFile()
123 LOGD("abandon, because fail to allocate buffer for cache content"); in WriteToFile()
128 if (Serialize(buffer, cacheSize) < 0) { in WriteToFile()
130 delete[] buffer; in WriteToFile()
135 if (write(fd, buffer, cacheSiz in WriteToFile()
237 Serialize(uint8_t *buffer, const size_t size) const Serialize() argument
286 DeSerialize(uint8_t const *buffer, const size_t size) DeSerialize() argument
[all...]
/foundation/multimedia/av_codec/test/nativedemo/video_demo/
H A Davcodec_video_decoder_inner_demo.cpp61 sptr<SurfaceBuffer> buffer; in OnBufferAvailable() local
64 cs_->AcquireBuffer(buffer, flushFence, timestamp_, damage_); in OnBufferAvailable()
66 (void)outFile_->write(reinterpret_cast<char *>(buffer->GetVirAddr()), buffer->GetSize()); in OnBufferAvailable()
67 cs_->ReleaseBuffer(buffer, -1); in OnBufferAvailable()
265 std::cout << "end buffer" << std::endl; in HandleInputEOS()
330 std::shared_ptr<AVSharedMemory> buffer = signal_->inBufferQueue_.front(); in InputFunc() local
333 if (buffer == nullptr) { in InputFunc()
335 std::cout << "buffer is null:" << index << std::endl; in InputFunc()
349 if (memcpy_s(buffer in InputFunc()
379 auto buffer = signal_->outBufferQueue_.front(); OutputFunc() local
421 OnInputBufferAvailable(uint32_t index, std::shared_ptr<AVSharedMemory> buffer) OnInputBufferAvailable() argument
430 OnOutputBufferAvailable(uint32_t index, AVCodecBufferInfo info, AVCodecBufferFlag flag, std::shared_ptr<AVSharedMemory> buffer) OnOutputBufferAvailable() argument
[all...]
/base/usb/usb_manager/test/native/service_unittest/src/
H A Dusb_device_pipe_test.cpp297 uint8_t buffer[BUFFER_SIZE] = {0}; in HWTEST_F() local
299 std::vector<uint8_t> ctrlbuffer = {buffer, buffer + len}; in HWTEST_F()
334 uint8_t buffer[BUFFER_SIZE] = {0}; in HWTEST_F() local
337 std::vector<uint8_t> ctrlbuffer = {buffer, buffer + len}; in HWTEST_F()
373 uint8_t buffer[BUFFER_SIZE] = {0}; in HWTEST_F() local
376 std::vector<uint8_t> ctrlbuffer = {buffer, buffer + len}; in HWTEST_F()
412 uint8_t buffer[BUFFER_SIZ in HWTEST_F() local
449 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
488 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
528 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
567 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
608 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
648 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
686 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
726 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
767 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
806 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
847 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
887 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
925 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
965 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1005 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1042 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1081 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1120 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1157 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1196 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1235 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1272 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1311 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1351 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1390 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1431 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1471 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1509 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1549 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1590 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1629 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1670 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1710 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1748 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1788 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1828 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1865 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
1904 uint8_t buffer[BUFFER_SIZE] = {0}; HWTEST_F() local
2467 uint8_t buffer[BUFFER_SIZE] = "bulk read"; HWTEST_F() local
2511 uint8_t buffer[BUFFER_SIZE] = "bulk read"; HWTEST_F() local
2557 uint8_t buffer[BUFFER_SIZE] = "bulk read"; HWTEST_F() local
2605 uint8_t buffer[BUFFER_SIZE] = "bulk read"; HWTEST_F() local
2654 uint8_t buffer[BUFFER_SIZE] = "bulk read"; HWTEST_F() local
2701 uint8_t buffer[BUFFER_SIZE] = "bulk read"; HWTEST_F() local
2748 uint8_t buffer[BUFFER_SIZE] = "hello world Bulk transfer007"; HWTEST_F() local
2794 uint8_t buffer[BUFFER_SIZE] = "hello world Bulk transfer008"; HWTEST_F() local
2842 uint8_t buffer[BUFFER_SIZE] = "hello world Bulk transfer009"; HWTEST_F() local
2890 uint8_t buffer[BUFFER_SIZE] = "hello world Bulk transfer010"; HWTEST_F() local
[all...]
/foundation/multimedia/av_codec/test/unittest/video_test/vcodec_framework_test/
H A Dvideoenc_func_unit_test.cpp78 cb.onNeedInputBuffer = [](OH_AVCodec *codec, uint32_t index, OH_AVBuffer *buffer, void *userData) { in GetVoidCallback()
81 (void)buffer; in GetVoidCallback()
84 cb.onNewOutputBuffer = [](OH_AVCodec *codec, uint32_t index, OH_AVBuffer *buffer, void *userData) { in GetVoidCallback()
87 (void)buffer; in GetVoidCallback()
135 bool ReadCustomDataToAVBuffer(const std::string &fileName, std::shared_ptr<AVBuffer> buffer);
261 bool TEST_SUIT::ReadCustomDataToAVBuffer(const std::string &fileName, std::shared_ptr<AVBuffer> buffer) in ReadCustomDataToAVBuffer() argument
267 sptr<SurfaceBuffer> surfaceBuffer = buffer->memory_->GetSurfaceBuffer(); in ReadCustomDataToAVBuffer()
558 * @tc.desc: video push input buffer
573 * @tc.desc: video push input buffer
587 * @tc.desc: video push input buffer
988 std::shared_ptr<AVBufferMock> buffer = AVBufferMockFactory::CreateAVBuffer(avbuffer); HWTEST_P() local
1016 std::shared_ptr<AVBufferMock> buffer = AVBufferMockFactory::CreateAVBuffer(avbuffer); HWTEST_P() local
1044 std::shared_ptr<AVBufferMock> buffer = AVBufferMockFactory::CreateAVBuffer(avbuffer); HWTEST_P() local
1071 std::shared_ptr<AVBufferMock> buffer = AVBufferMockFactory::CreateAVBuffer(avbuffer); HWTEST_P() local
1107 std::shared_ptr<AVBufferMock> buffer = AVBufferMockFactory::CreateAVBuffer(avbuffer); HWTEST_P() local
1133 std::shared_ptr<AVBufferMock> buffer = AVBufferMockFactory::CreateAVBuffer(10000); HWTEST_P() local
1159 std::shared_ptr<AVBufferMock> buffer = AVBufferMockFactory::CreateAVBuffer(10000); HWTEST_P() local
1184 std::shared_ptr<AVBufferMock> buffer = AVBufferMockFactory::CreateAVBuffer(10000); HWTEST_P() local
1223 std::shared_ptr<AVBufferMock> buffer = AVBufferMockFactory::CreateAVBuffer(avbuffer); HWTEST_P() local
1262 std::shared_ptr<AVBufferMock> buffer = AVBufferMockFactory::CreateAVBuffer(avbuffer); HWTEST_P() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dvalue_slice_sync.cpp100 int ValueSliceSync::Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in Serialization() argument
102 if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in Serialization()
108 return RequestPacketSerialization(buffer, length, inMsg); in Serialization()
110 return AckPacketSerialization(buffer, length, inMsg); in Serialization()
116 int ValueSliceSync::DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) in DeSerialization() argument
118 if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in DeSerialization()
124 return RequestPacketDeSerialization(buffer, length, inMsg); in DeSerialization()
126 return AckPacketDeSerialization(buffer, length, inMsg); in DeSerialization()
160 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterTransformFunc()
161 return Serialization(buffer, lengt in RegisterTransformFunc()
352 RequestPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) RequestPacketSerialization() argument
378 RequestPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) RequestPacketDeSerialization() argument
422 AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) AckPacketSerialization() argument
453 AckPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) AckPacketDeSerialization() argument
[all...]
/base/global/resource_management_lite/frameworks/resmgr_lite/include/
H A Dhap_parser.h32 * Read specified file in zip to buffer
35 * @param buffer bytes will write to buffer
40 static int32_t ReadFileFromZip(const char *zipFile, const char *fileName, void **buffer,
44 * Read resource.index in hap to buffer
46 * @param buffer bytes will write to buffer
51 static int32_t ReadIndexFromFile(const char *zipFile, void **buffer,
56 * @param buffer the resource bytes
62 static int32_t ParseResHex(const char *buffer, cons
[all...]
/base/msdp/device_status/rust/data/binding/src/
H A Dfusion_data_binding.cpp37 cdrag->buffer = drag->buffer.data(); in CDragDataFrom()
38 cdrag->bufSize = drag->buffer.size(); in CDragDataFrom()
/base/telephony/sms_mms/services/sms/include/gsm/
H A Dgsm_sms_param_codec.h34 bool DecodeAddressPdu(SmsReadBuffer &buffer, struct AddressNumber *resultNum);
36 bool DecodeDcsPdu(SmsReadBuffer &buffer, struct SmsDcs *smsDcs);
40 bool CheckVoicemail(SmsReadBuffer &buffer, int32_t *setType, int32_t *indType);
/base/time/time_service/test/fuzztest/timeservice_fuzzer/timereceivedmessage_fuzzer/
H A Dtimereceivedmessage_fuzzer.cpp52 char buffer[NTP_PACKAGE_SIZE] = { 0 }; in FuzzTimeReceivedMessage() local
53 if (memcpy_s(buffer, NTP_PACKAGE_SIZE, data, size) != EOK) { in FuzzTimeReceivedMessage()
57 client->ReceivedMessage(buffer); in FuzzTimeReceivedMessage()
/base/useriam/user_auth_framework/frameworks/native/client/src/
H A Dexecutor_messenger_client.cpp40 std::vector<uint8_t> buffer; in SendData() local
45 buffer = AuthMessageImpl::GetMsgBuffer(msg); in SendData()
47 return messenger_->SendData(scheduleId, dstRole, buffer); in SendData()
/base/web/webview/ohos_interface/ohos_glue/ohos_adapter/bridge/webview/
H A Dark_decoder_callback_adapter_wrapper.cpp39 void ArkDecoderCallbackAdapterWrapper::OnNeedInputData(uint32_t index, std::shared_ptr<NWeb::OhosBufferAdapter> buffer) in OnNeedInputData() argument
41 if (CHECK_SHARED_PTR_IS_NULL(buffer)) { in OnNeedInputData()
45 ctocpp_->OnNeedInputData(index, new ArkOhosBufferAdapterImpl(buffer)); in OnNeedInputData()
/foundation/arkui/ace_engine_lite/frameworks/src/core/modules/presets/
H A Dsyscap_module.cpp64 jerry_char_t buffer[SYSCAP_BUFFER_SIZE] = {0}; in CheckSyscap() local
65 jerry_size_t syscapStrSize = jerry_string_to_utf8_char_buffer(strVal, buffer, length); in CheckSyscap()
70 const char *syscapString = (char *)buffer; in CheckSyscap()
/foundation/graphic/graphic_surface/surface/include/
H A Dconsumer_surface_delegator.h29 GSError QueueBuffer(sptr<SurfaceBuffer>& buffer, int32_t fenceFd);
31 GSError CancelBuffer(sptr<SurfaceBuffer>& buffer);
32 GSError DetachBuffer(sptr<SurfaceBuffer>& buffer);
/foundation/graphic/graphic_surface/surface/src/
H A Dconsumer_surface_delegator.cpp34 GSError ConsumerSurfaceDelegator::QueueBuffer(sptr<SurfaceBuffer>& buffer, int32_t fenceFd) in QueueBuffer() argument
44 GSError ConsumerSurfaceDelegator::CancelBuffer(sptr<SurfaceBuffer>& buffer) in CancelBuffer() argument
49 GSError ConsumerSurfaceDelegator::DetachBuffer(sptr<SurfaceBuffer>& buffer) in DetachBuffer() argument
/foundation/multimedia/image_framework/frameworks/innerkitsimpl/stream/src/
H A Dbuffer_packer_stream.cpp34 bool BufferPackerStream::Write(const uint8_t *buffer, uint32_t size) in Write() argument
36 if ((buffer == nullptr) || (size == 0)) { in Write()
50 if (memcpy_s(outputData_ + offset_, leftSize, buffer, size) != EOK) { in Write()
/foundation/distributeddatamgr/pasteboard/framework/tlv/
H A Dparcel_util.cpp32 rawMem.buffer = rawMem.parcel->GetData(); in Parcelable2Raw()
38 if (rawMem.buffer == 0 || rawMem.bufferLen == 0) { in Raw2Parcel()
45 auto err = memcpy_s(temp, rawMem.bufferLen, reinterpret_cast<const void *>(rawMem.buffer), rawMem.bufferLen); in Raw2Parcel()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dprotocol_proto.cpp120 SerialBuffer *buffer = new (std::nothrow) SerialBuffer(); in ToSerialBuffer() local
121 if (buffer == nullptr) { in ToSerialBuffer()
126 buffer->SetExtendHeadLength(headSize); in ToSerialBuffer()
130 errCode = buffer->AllocBufferByPayloadLength(payLoadLength, GetAppLayerFrameHeaderLength()); in ToSerialBuffer()
135 errCode = FillExtendHeadDataIfNeed(extendHandle, buffer, headSize); in ToSerialBuffer()
141 errCode = SerializeMessage(buffer, inMsg); in ToSerialBuffer()
147 return buffer; in ToSerialBuffer()
150 delete buffer; in ToSerialBuffer()
151 buffer = nullptr; in ToSerialBuffer()
181 SerialBuffer *buffer in BuildEmptyFrameForVersionNegotiate() local
204 SerialBuffer *buffer = ToSerialBuffer(inMsg, extendHandle, true, outErrorNo); BuildFeedbackMessageFrame() local
232 SerialBuffer *buffer = new (std::nothrow) SerialBuffer(); BuildLabelExchange() local
271 SerialBuffer *buffer = new (std::nothrow) SerialBuffer(); BuildLabelExchangeAck() local
1095 FillExtendHeadDataIfNeed(std::shared_ptr<ExtendHeaderHandle> &extendHandle, SerialBuffer *buffer, uint32_t headSize) FillExtendHeadDataIfNeed() argument
[all...]
/base/startup/init/services/param/adapter/
H A Dparam_persistadp.c117 char *buffer, uint32_t buffSize, bool isFullLoad) in LoadPersistParam_()
123 while (fgets(buffer, buffSize, fp) != NULL) { in LoadPersistParam_()
124 buffer[buffSize - 1] = '\0'; in LoadPersistParam_()
126 ret = SplitParamString(buffer, NULL, 0, LoadOnePersistParam_, (uint32_t*)&clearFactoryPersistParams); in LoadPersistParam_()
128 ret = SplitParamString(buffer, NULL, 0, LoadOnePublicPersistParam_, (uint32_t*)&clearFactoryPersistParams); in LoadPersistParam_()
130 PARAM_CHECK(ret == 0, continue, "Failed to set param %d %s", ret, buffer); in LoadPersistParam_()
183 char *buffer = calloc(1, buffSize); in LoadPersistParam() local
184 PARAM_CHECK(buffer != NULL, return -1, "Failed to alloc"); in LoadPersistParam()
189 LoadPersistParam_(clearFactoryPersistParams, path, buffer, buffSize, isFullLoad); in LoadPersistParam()
190 LoadPersistParam_(clearFactoryPersistParams, tmpPath, buffer, buffSiz in LoadPersistParam()
116 LoadPersistParam_(const bool clearFactoryPersistParams, const char *fileName, char *buffer, uint32_t buffSize, bool isFullLoad) LoadPersistParam_() argument
[all...]
/foundation/ai/intelligent_voice_framework/services/intell_voice_engine/proxy/
H A Dintell_voice_service_proxy.cpp174 int32_t IntellVoiceServiceProxy::GetWakeupSourceFile(const std::string &filePath, std::vector<uint8_t> &buffer) in GetWakeupSourceFile() argument
205 buffer.resize(size); in GetWakeupSourceFile()
206 std::copy(buff, buff + size, buffer.data()); in GetWakeupSourceFile()
211 int32_t IntellVoiceServiceProxy::SendWakeupFile(const std::string &filePath, const std::vector<uint8_t> &buffer) in SendWakeupFile() argument
217 if (buffer.data() == nullptr) { in SendWakeupFile()
222 if (buffer.size() == 0 || buffer.size() > CROSS_PROCESS_BUF_SIZE_LIMIT) { in SendWakeupFile()
223 INTELL_VOICE_LOG_ERROR("buffer size is invalid %{public}u", static_cast<uint32_t>(buffer.size())); in SendWakeupFile()
229 data.WriteUint32(buffer in SendWakeupFile()
[all...]
/foundation/multimedia/camera_framework/interfaces/inner_api/native/test/
H A Dtest_common.cpp52 int32_t TestUtils::SaveYUV(const char* buffer, int32_t size, SurfaceType type) in SaveYUV() argument
57 if ((buffer == nullptr) || (size == 0)) { in SaveYUV()
58 MEDIA_ERR_LOG("buffer is null or size is 0"); in SaveYUV()
98 int ret = write(imgFd, buffer, size); in SaveYUV()
118 int32_t TestUtils::SaveVideoFile(const char* buffer, int32_t size, VideoSaveMode operationMode, int32_t &fd) in SaveVideoFile() argument
139 int32_t ret = write(fd, buffer, size); in SaveVideoFile()
350 OHOS::sptr<OHOS::SurfaceBuffer> buffer = nullptr; in OnBufferAvailable() local
355 surface_->AcquireBuffer(buffer, flushFence, timestamp, damage); in OnBufferAvailable()
356 if (buffer != nullptr) { in OnBufferAvailable()
357 char* addr = static_cast<char *>(buffer in OnBufferAvailable()
[all...]
/foundation/multimedia/media_foundation/engine/pipeline/filters/codec/
H A Dasync_mode.cpp107 ErrorCode AsyncMode::PushData(const std::string &inPort, const AVBufferPtr& buffer, int64_t offset) in PushData() argument
109 DUMP_BUFFER2LOG("AsyncMode in", buffer, offset); in PushData()
112 if (buffer != nullptr && !stopped_) { in PushData()
113 inBufQue_->Push(buffer); in PushData()
115 MEDIA_LOG_DD("PushData buffer = nullptr."); in PushData()
231 MEDIA_LOG_DD("Send data to plugin error: " PUBLIC_LOG_D32 ", currently, input buffer cannot be inputted, " in HandleFrame()
257 MEDIA_LOG_DD("Invalid buffer."); in DecodeFrame()
293 void AsyncMode::OnOutputBufferDone(const std::shared_ptr<Plugin::Buffer>& buffer) in OnOutputBufferDone() argument
295 if (buffer == nullptr) { in OnOutputBufferDone()
296 MEDIA_LOG_E("Out put buffer i in OnOutputBufferDone()
368 CheckBufferValidity(std::shared_ptr<AVBuffer>& buffer) CheckBufferValidity() argument
[all...]
/foundation/multimedia/av_codec/services/services/codec/server/
H A Dcodec_server.h84 int32_t SetCustomBuffer(std::shared_ptr<AVBuffer> buffer) override;
90 void OnInputBufferAvailable(uint32_t index, std::shared_ptr<AVSharedMemory> buffer);
92 std::shared_ptr<AVSharedMemory> buffer);
94 void OnInputBufferAvailable(uint32_t index, std::shared_ptr<AVBuffer> buffer);
95 void OnOutputBufferAvailable(uint32_t index, std::shared_ptr<AVBuffer> buffer);
174 int32_t PushDecodedBufferInfo(uint32_t index, std::shared_ptr<AVBuffer> buffer);
186 std::shared_ptr<AVBuffer> buffer; member
206 void OnInputBufferAvailable(uint32_t index, std::shared_ptr<AVSharedMemory> buffer) override;
208 std::shared_ptr<AVSharedMemory> buffer) override;
221 void OnInputBufferAvailable(uint32_t index, std::shared_ptr<AVBuffer> buffer) overrid
[all...]
/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/test/unittest/common/distributedcameramgr/
H A Ddcamera_stream_data_process_test.cpp81 std::shared_ptr<DataBuffer> buffer = std::make_shared<DataBuffer>(capacity); in HWTEST_F() local
86 streamProcess1->FeedStream(buffer); in HWTEST_F()
91 streamProcess2->FeedStream(buffer); in HWTEST_F()
130 std::shared_ptr<DataBuffer> buffer = std::make_shared<DataBuffer>(capacity); in HWTEST_F() local
132 streamProcess->FeedStreamToSnapShot(buffer); in HWTEST_F()
149 std::shared_ptr<DataBuffer> buffer = std::make_shared<DataBuffer>(capacity); in HWTEST_F() local
158 streamProcess->FeedStreamToContinue(buffer); in HWTEST_F()
161 streamProcess->FeedStreamToContinue(buffer); in HWTEST_F()
228 std::shared_ptr<DataBuffer> buffer = std::make_shared<DataBuffer>(capacity); in HWTEST_F() local
229 listener1->OnProcessedVideoBuffer(buffer); in HWTEST_F()
[all...]
/foundation/filemanagement/app_file_service/utils/src/b_json/
H A Db_report_entity.cpp201 char buffer[HASH_BUFFER_SIZE]; in GetReportInfos() local
207 while ((bytesRead = read(srcFile_, buffer, sizeof(buffer))) > 0) { in GetReportInfos()
209 if (buffer[i] == LINE_SEP) { in GetReportInfos()
213 currentLine += buffer[i]; in GetReportInfos()
228 char buffer[BUFFER_LENGTH]; in GetStorageReportInfos() local
234 if ((bytesRead = read(srcFile_, buffer, 1)) <= 0) { in GetStorageReportInfos()
240 if (buffer[0] != LINE_SEP && buffer[0] != '\0') { in GetStorageReportInfos()
241 currentLine += buffer[ in GetStorageReportInfos()
[all...]
/foundation/filemanagement/file_api/interfaces/kits/js/src/mod_fs/properties/
H A Dread_text.cpp105 string buffer(len, '\0'); in ReadTextAsync()
106 uv_buf_t readbuf = uv_buf_init(const_cast<char *>(buffer.c_str()), static_cast<unsigned int>(len)); in ReadTextAsync()
118 arg->buffer = buffer; in ReadTextAsync()
136 static int ReadFromFile(int fd, int64_t offset, string& buffer) in ReadFromFile() argument
138 uv_buf_t readbuf = uv_buf_init(const_cast<char *>(buffer.c_str()), static_cast<unsigned int>(buffer.size())); in ReadFromFile()
193 string buffer(len, '\0'); in Sync()
194 int readRet = ReadFromFile(sfd.GetFD(), offset, buffer); in Sync()
201 return NVal::CreateUTF8String(env, buffer in Sync()
[all...]

Completed in 20 milliseconds

1...<<21222324252627282930>>...118