/foundation/multimedia/media_foundation/engine/plugin/plugins/source/stream_source/ |
H A D | stream_source_plugin.cpp | 116 std::shared_ptr<Buffer> StreamSourcePlugin::WrapDataBuffer(const std::shared_ptr<DataBuffer>& dataBuffer) in WrapDataBuffer() argument 118 FALSE_RETURN_V(dataBuffer != nullptr, nullptr); in WrapDataBuffer() 121 std::shared_ptr<uint8_t> address = std::shared_ptr<uint8_t>(dataBuffer->GetAddress(), deleter); in WrapDataBuffer() 122 buffer->WrapMemoryPtr(address, dataBuffer->GetCapacity(), dataBuffer->GetSize()); in WrapDataBuffer() 123 if (dataBuffer->IsEos()) { in WrapDataBuffer() 135 std::shared_ptr<DataBuffer> dataBuffer; in Read() local 136 FALSE_RETURN_V(stream_->GetDataBuffer(dataBuffer), Status::ERROR_TIMED_OUT); in Read() 137 buffer = WrapDataBuffer(dataBuffer); in Read()
|
/foundation/CastEngine/castengine_wifi_display/services/protocol/frame/ |
H A D | frame.h | 46 explicit Frame(DataBuffer &&dataBuffer) : DataBuffer(std::move(dataBuffer)) {} in Frame() argument 90 explicit FrameImpl(DataBuffer &&dataBuffer) : Frame(std::move(dataBuffer)) {} in FrameImpl() argument 92 static std::shared_ptr<FrameImpl> CreateFrom(DataBuffer &&dataBuffer) in CreateFrom() argument 94 return std::make_shared<FrameImpl>(std::move(dataBuffer)); in CreateFrom()
|
H A D | h264_frame.h | 50 explicit H264Frame(DataBuffer &&dataBuffer) : FrameImpl(std::move(dataBuffer)) in H264Frame() argument
|
/foundation/distributedhardware/distributed_camera/services/cameraservice/cameraoperator/client/src/listener/ |
H A D | dcamera_photo_surface_listener.cpp | 64 std::shared_ptr<DataBuffer> dataBuffer = std::make_shared<DataBuffer>(size); in OnBufferAvailable() local 65 int32_t ret = memcpy_s(dataBuffer->Data(), dataBuffer->Capacity(), address, size); in OnBufferAvailable() 73 DumpBufferToFile(fileName, dataBuffer->Data(), dataBuffer->Size()); in OnBufferAvailable() 76 callback_->OnPhotoResult(dataBuffer); in OnBufferAvailable()
|
/foundation/distributedhardware/distributed_screen/services/common/test/unittest/imageJpeg/ |
H A D | jpeg_image_processor_test.cpp | 76 std::shared_ptr<DataBuffer> dataBuffer = std::make_shared<DataBuffer>(10); in HWTEST_F() local 78 dataBuffer->AddDirtyRect(rect); in HWTEST_F() 79 int32_t ret = jpeg_->FillDirtyImages2Surface(dataBuffer, nullptr); in HWTEST_F() 94 std::shared_ptr<DataBuffer> dataBuffer = std::make_shared<DataBuffer>(20); in HWTEST_F() local 96 dataBuffer->AddDirtyRect(rect); in HWTEST_F() 98 int32_t ret = jpeg_->FillDirtyImages2Surface(dataBuffer, lastFrame); in HWTEST_F()
|
/foundation/ai/neural_network_runtime/frameworks/native/neural_network_runtime/ |
H A D | neural_network_runtime_compat.cpp | 46 uint32_t inputIndex, const OH_NN_Tensor *tensor, const void *dataBuffer, size_t length) in OH_NNExecutor_SetInput() 56 if (dataBuffer == nullptr) { in OH_NNExecutor_SetInput() 57 LOGE("OH_NNExecutor_SetInput failed, dataBuffer is nullptr."); in OH_NNExecutor_SetInput() 61 LOGE("OH_NNExecutor_SetInput failed, dataBuffer length is 0."); in OH_NNExecutor_SetInput() 66 return executorImpl->SetInput(inputIndex, *tensor, dataBuffer, length); in OH_NNExecutor_SetInput() 70 uint32_t outputIndex, void *dataBuffer, size_t length) in OH_NNExecutor_SetOutput() 76 if (dataBuffer == nullptr) { in OH_NNExecutor_SetOutput() 77 LOGE("OH_NNExecutor_SetOutput failed, passed nullptr to dataBuffer."); in OH_NNExecutor_SetOutput() 81 LOGE("OH_NNExecutor_SetOutput failed, dataBuffer length is 0."); in OH_NNExecutor_SetOutput() 86 return executorImpl->SetOutput(outputIndex, dataBuffer, lengt in OH_NNExecutor_SetOutput() 45 OH_NNExecutor_SetInput(OH_NNExecutor *executor, uint32_t inputIndex, const OH_NN_Tensor *tensor, const void *dataBuffer, size_t length) OH_NNExecutor_SetInput() argument 69 OH_NNExecutor_SetOutput(OH_NNExecutor *executor, uint32_t outputIndex, void *dataBuffer, size_t length) OH_NNExecutor_SetOutput() argument [all...] |
/foundation/distributedhardware/distributed_screen/services/screentransport/screendatachannel/src/ |
H A D | screen_data_channel_impl.cpp | 298 auto dataBuffer = std::make_shared<DataBuffer>(data->bufLen); in OnStreamReceived() local 301 ProcessDullData(data, dataBuffer); in OnStreamReceived() 305 ProcessDirtyData(data, dataBuffer, ext); in OnStreamReceived() 309 void ScreenDataChannelImpl::ProcessDullData(const StreamData *data, std::shared_ptr<DataBuffer> dataBuffer) in ProcessDullData() argument 317 int32_t ret = memcpy_s(dataBuffer->Data(), dataBuffer->Capacity(), in ProcessDullData() 323 dataBuffer->SetDataType(VIDEO_FULL_SCREEN_DATA); in ProcessDullData() 324 listener->OnDataReceived(dataBuffer); in ProcessDullData() 328 std::shared_ptr<DataBuffer> dataBuffer, const StreamData *ext) in ProcessDirtyData() 336 int32_t ret = memcpy_s(dataBuffer in ProcessDirtyData() 327 ProcessDirtyData(const StreamData *data, std::shared_ptr<DataBuffer> dataBuffer, const StreamData *ext) ProcessDirtyData() argument [all...] |
/foundation/communication/ipc/ipc/native/src/mock/include/ |
H A D | dbinder_base_invoker_object.h | 112 bool DBinderBaseInvoker<T>::IRemoteObjectTranslateWhenSend(char *dataBuffer, binder_size_t bufferSize,
in IRemoteObjectTranslateWhenSend() argument 115 if (data.GetOffsetsSize() <= 0 || dataBuffer == nullptr) {
in IRemoteObjectTranslateWhenSend() 122 char *flatOffset = dataBuffer + offsetOfSession;
in IRemoteObjectTranslateWhenSend() 125 auto binderObject = reinterpret_cast<flat_binder_object *>(dataBuffer + *(binderObjectsOffsets + i));
in IRemoteObjectTranslateWhenSend() 162 bool DBinderBaseInvoker<T>::IRemoteObjectTranslateWhenRcv(char *dataBuffer, binder_size_t bufferSize,
in IRemoteObjectTranslateWhenRcv() argument 165 if (data.GetOffsetsSize() <= 0 || dataBuffer == nullptr) {
in IRemoteObjectTranslateWhenRcv() 170 char *flatOffset = dataBuffer + offsetOfSession;
in IRemoteObjectTranslateWhenRcv() 173 auto binderObject = reinterpret_cast<flat_binder_object *>(dataBuffer + *(binderObjectsOffsets + i));
in IRemoteObjectTranslateWhenRcv() 199 if (!TranslateRawData(dataBuffer, data, socketId)) {
in IRemoteObjectTranslateWhenRcv() 262 bool DBinderBaseInvoker<T>::TranslateRawData(char *dataBuffer, MessageParce argument [all...] |
/foundation/ability/dmsfwk/services/dtbschedmgr/include/continue/ |
H A D | dsched_continue_manager.h | 55 void OnDataRecv(int32_t sessionId, std::shared_ptr<DSchedDataBuffer> dataBuffer); 78 void HandleDataRecv(int32_t sessionId, std::shared_ptr<DSchedDataBuffer> dataBuffer); 80 std::shared_ptr<DSchedDataBuffer> dataBuffer); 89 void OnDataRecv(int32_t socket, std::shared_ptr<DSchedDataBuffer> dataBuffer);
|
/foundation/multimedia/ringtone_library/test/unittest/ringtone_scanner/src/ |
H A D | ringtone_read_test.cpp | 88 string dataBuffer = "hello world"; in RingtoneRead() local 90 ssize_t written = write(fd, dataBuffer.c_str(), dataBuffer.size()); in RingtoneRead() 114 if (strcmp(readBuffer, dataBuffer.c_str())) { in RingtoneRead() 115 cout << "Read failure readBuffer != dataBuffer, readBuffer = " << static_cast<int>(readRet) << in RingtoneRead()
|
/foundation/ability/dmsfwk/test/fuzztest/dschedtransportsoftbusadapter_fuzzer/ |
H A D | dschedtransportsoftbusadapter_fuzzer.cpp | 74 std::shared_ptr<DSchedDataBuffer> dataBuffer = std::make_shared<DSchedDataBuffer>(size); in FuzzConnectDevice() local 75 dschedTransportSoftbusAdapter.SendData(sessionId, dataType, dataBuffer); in FuzzConnectDevice() 76 dschedTransportSoftbusAdapter.SendBytesBySoftbus(sessionId, dataBuffer); in FuzzConnectDevice() 106 std::shared_ptr<DSchedDataBuffer> dataBuffer = std::make_shared<DSchedDataBuffer>(size); in FuzzOnDataReady() local 109 dschedTransportSoftbusAdapter.OnDataReady(sessionId, dataBuffer, dataType); in FuzzOnDataReady()
|
/foundation/distributedhardware/distributed_camera/services/cameraservice/sinkservice/src/distributedcameramgr/ |
H A D | dcamera_sink_data_process.cpp | 123 int32_t DCameraSinkDataProcess::FeedStream(std::shared_ptr<DataBuffer>& dataBuffer) in FeedStream() argument 129 int32_t ret = FeedStreamInner(dataBuffer); in FeedStream() 138 SendDataAsync(dataBuffer); in FeedStream() 180 int32_t DCameraSinkDataProcess::FeedStreamInner(std::shared_ptr<DataBuffer>& dataBuffer) in FeedStreamInner() argument 183 buffers.push_back(dataBuffer); in FeedStreamInner()
|
/foundation/multimodalinput/input/test/fuzztest/appendextradata_fuzzer/ |
H A D | appendextradata_fuzzer.cpp | 52 std::vector<uint8_t> dataBuffer(512, 1); in AppendExtraDataFuzzTest() 53 extraData.buffer = dataBuffer; in AppendExtraDataFuzzTest()
|
/foundation/ability/dmsfwk/services/dtbschedmgr/include/softbus_adapter/transport/ |
H A D | dsched_transport_softbus_adapter.h | 53 int32_t SendData(int32_t sessionId, int32_t dataType, std::shared_ptr<DSchedDataBuffer> dataBuffer); 54 int32_t SendBytesBySoftbus(int32_t sessionId, std::shared_ptr<DSchedDataBuffer> dataBuffer); 58 void OnDataReady(int32_t sessionId, std::shared_ptr<DSchedDataBuffer> dataBuffer, uint32_t dataType);
|
H A D | idata_listener.h | 30 virtual void OnDataRecv(int32_t socket, std::shared_ptr<DSchedDataBuffer> dataBuffer) = 0;
|
/foundation/ai/neural_network_runtime/interfaces/kits/c/neural_network_runtime/ |
H A D | neural_network_runtime.h | 193 * @param dataBuffer Pointer to real data. 201 OH_NN_ReturnCode OH_NNModel_SetTensorData(OH_NNModel *model, uint32_t index, const void *dataBuffer, size_t length); 390 * This method copies the data whose length is specified by <b>length</b> (in bytes) in <b>dataBuffer</b> to the shared 413 * @param dataBuffer Pointer to the input data. 426 const void *dataBuffer, 432 * This method binds the buffer to which <b>dataBuffer</b> points to the output specified by <b>outputIndex</b>. 436 * the length of the buffer to which <b>dataBuffer</b> points with the length of the output data and returns different 440 * {@link OH_NN_SUCCESS} is returned. You can read the inference result from <b>dataBuffer</b>. 450 * @param dataBuffer Pointer to the output data. 462 void *dataBuffer, [all...] |
/foundation/distributedhardware/distributed_camera/services/channel/test/unittest/common/channel/ |
H A D | dcamera_channel_sink_impl_test.cpp | 174 std::shared_ptr<DataBuffer> dataBuffer = std::make_shared<DataBuffer>(capacity); in HWTEST_F() local 175 ret = channel_->SendData(dataBuffer); in HWTEST_F() 218 std::shared_ptr<DataBuffer> dataBuffer = std::make_shared<DataBuffer>(capacity); in HWTEST_F() local 219 int32_t ret = channel_->SendData(dataBuffer); in HWTEST_F() 265 std::shared_ptr<DataBuffer> dataBuffer = std::make_shared<DataBuffer>(capacity); in HWTEST_F() local 267 buffers.push_back(dataBuffer); in HWTEST_F()
|
H A D | dcamera_channel_source_impl_test.cpp | 156 std::shared_ptr<DataBuffer> dataBuffer = std::make_shared<DataBuffer>(capacity); in HWTEST_F() local 157 ret = channel_->SendData(dataBuffer); in HWTEST_F() 199 std::shared_ptr<DataBuffer> dataBuffer = std::make_shared<DataBuffer>(capacity); in HWTEST_F() local 200 int32_t ret = channel_->SendData(dataBuffer); in HWTEST_F()
|
/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/transport/ |
H A D | dsched_transport_softbus_adapter.cpp | 363 std::shared_ptr<DSchedDataBuffer> dataBuffer) in SendData() 370 return sessions_[sessionId]->SendData(dataBuffer, dataType); in SendData() 374 std::shared_ptr<DSchedDataBuffer> dataBuffer) in SendBytesBySoftbus() 376 if (dataBuffer != nullptr) { in SendBytesBySoftbus() 377 return SendBytes(sessionId, dataBuffer->Data(), dataBuffer->Size()); in SendBytesBySoftbus() 379 HILOGE("dataBuffer is nullptr"); in SendBytesBySoftbus() 409 void DSchedTransportSoftbusAdapter::OnDataReady(int32_t sessionId, std::shared_ptr<DSchedDataBuffer> dataBuffer, in OnDataReady() argument 424 iter->OnDataRecv(sessionId, dataBuffer); in OnDataReady() 362 SendData(int32_t sessionId, int32_t dataType, std::shared_ptr<DSchedDataBuffer> dataBuffer) SendData() argument 373 SendBytesBySoftbus(int32_t sessionId, std::shared_ptr<DSchedDataBuffer> dataBuffer) SendBytesBySoftbus() argument
|
/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/ |
H A D | snapshot.cpp | 163 auto dataBuffer = data.data(); in Create() local 169 uint32_t msgSize = *reinterpret_cast<const uint32_t *>(dataBuffer); in Create() 174 dataBuffer += sizeof(uint32_t); in Create() 176 bool ret = dataParcel.WriteBuffer(dataBuffer, msgSize); in Create() 186 dataBuffer += msgSize; in Create() 192 uint32_t pixelmapLen = *reinterpret_cast<const uint32_t *>(dataBuffer); in Create() 197 dataBuffer += sizeof(uint32_t); in Create() 198 unique_ptr<PixelMap> pixelMap = CreatePixelMap(dataBuffer, pixelmapLen); in Create()
|
/foundation/distributedhardware/distributed_camera/services/cameraservice/sinkservice/include/distributedcameramgr/ |
H A D | dcamera_sink_data_process.h | 40 int32_t FeedStream(std::shared_ptr<DataBuffer>& dataBuffer) override; 49 int32_t FeedStreamInner(std::shared_ptr<DataBuffer>& dataBuffer);
|
/foundation/distributedhardware/distributed_screen/services/screentransport/screendatachannel/include/ |
H A D | screen_data_channel_impl.h | 43 void ProcessDirtyData(const StreamData *data, std::shared_ptr<DataBuffer> dataBuffer, const StreamData *ext); 44 void ProcessDullData(const StreamData *data, std::shared_ptr<DataBuffer> dataBuffer);
|
/foundation/ability/dmsfwk/services/dtbschedmgr/src/continue/ |
H A D | dsched_continue_manager.cpp | 592 void DSchedContinueManager::OnDataRecv(int32_t sessionId, std::shared_ptr<DSchedDataBuffer> dataBuffer) in OnDataRecv() argument 594 auto func = [this, sessionId, dataBuffer]() { in OnDataRecv() 595 HandleDataRecv(sessionId, dataBuffer); in OnDataRecv() 604 void DSchedContinueManager::HandleDataRecv(int32_t sessionId, std::shared_ptr<DSchedDataBuffer> dataBuffer) in HandleDataRecv() argument 607 if (dataBuffer == nullptr) { in HandleDataRecv() 608 HILOGE("dataBuffer is null."); in HandleDataRecv() 611 uint8_t *data = dataBuffer->Data(); in HandleDataRecv() 612 std::string jsonStr(reinterpret_cast<const char *>(data), dataBuffer->Capacity()); in HandleDataRecv() 640 NotifyContinueDataRecv(sessionId, command, jsonStr, dataBuffer); in HandleDataRecv() 645 std::shared_ptr<DSchedDataBuffer> dataBuffer) in NotifyContinueDataRecv() 644 NotifyContinueDataRecv(int32_t sessionId, int32_t command, const std::string& jsonStr, std::shared_ptr<DSchedDataBuffer> dataBuffer) NotifyContinueDataRecv() argument 776 OnDataRecv(int32_t socket, std::shared_ptr<DSchedDataBuffer> dataBuffer) OnDataRecv() argument [all...] |
/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/continue/ |
H A D | dsched_continue_test.cpp | 1016 std::shared_ptr<DSchedDataBuffer> dataBuffer = nullptr; in HWTEST_F() local 1017 conti->OnDataRecv(command, dataBuffer); in HWTEST_F() 1018 EXPECT_EQ(nullptr, dataBuffer); in HWTEST_F() 1020 dataBuffer = std::make_shared<DSchedDataBuffer>(DSCHED_BUFFER_SIZE); in HWTEST_F() 1021 conti->OnDataRecv(command, dataBuffer); in HWTEST_F() 1022 EXPECT_NE(nullptr, dataBuffer); in HWTEST_F() 1024 conti->OnDataRecv(command, dataBuffer); in HWTEST_F() 1025 EXPECT_NE(nullptr, dataBuffer); in HWTEST_F() 1027 conti->OnDataRecv(command, dataBuffer); in HWTEST_F() 1028 EXPECT_NE(nullptr, dataBuffer); in HWTEST_F() [all...] |
/foundation/graphic/graphic_3d/lume/LumeDotfield/src/render/ |
H A D | render_data_store_default_dotfield.cpp | 66 buffer.dataBuffer[0] = gpuResourceMgr_.Create(desc); in AddDotfieldPrimitive() 67 buffer.dataBuffer[1] = gpuResourceMgr_.Create(desc); in AddDotfieldPrimitive()
|