Home
last modified time | relevance | path

Searched refs:consumer_ (Results 1 - 25 of 53) sorted by relevance

123

/foundation/CastEngine/castengine_wifi_display/tests/unittest/impl/screen_capture/
H A Dwfd_screen_capture_test.cpp30 consumer_ = std::make_shared<MockScreenCaptureConsumer>(); in SetUpTestCase()
31 consumer_->Initialize(); in SetUpTestCase()
36 consumer_->DeInitialize(); in TearDownTestCase()
37 consumer_ = nullptr; in TearDownTestCase()
50 ASSERT_TRUE(consumer_ != nullptr); in HWTEST_F()
51 ASSERT_TRUE(consumer_->dispatcher_ != nullptr); in HWTEST_F()
54 consumer_->HandleSpsFrame(consumer_->dispatcher_, frame); in HWTEST_F()
59 ASSERT_TRUE(consumer_ != nullptr); in HWTEST_F()
60 ASSERT_TRUE(consumer_ in HWTEST_F()
[all...]
H A Dwfd_screen_capture_test.h38 static inline std::shared_ptr<MockScreenCaptureConsumer> consumer_; member in OHOS::Sharing::WfdScreenCaptureTest
/foundation/CastEngine/castengine_wifi_display/tests/unittest/impl/rtp/
H A Dwfd_rtp_consumer_test.cpp30 consumer_ = std::make_shared<MockWfdRtpConsumer>(); in SetUpTestCase()
44 consumer_ = nullptr; in TearDownTestCase()
50 consumer_->SetConsumerListener(listener_); in SetUp()
57 consumer_->rtpUnpacker_ = mockRtpUnpack_; in SetUp()
58 consumer_->rtpServer_ = std::make_pair(consumer_->rtpServer_.first, mockRtpServer_); in SetUp()
67 ASSERT_TRUE(consumer_ != nullptr); in HWTEST_F()
74 int32_t ret = consumer_->HandleEvent(event); in HWTEST_F()
80 ASSERT_TRUE(consumer_ != nullptr); in HWTEST_F()
91 int32_t ret = consumer_ in HWTEST_F()
[all...]
H A Dwfd_rtp_consumer_test.h42 static inline std::shared_ptr<MockWfdRtpConsumer> consumer_; member in OHOS::Sharing::WfdRtpConsumerTest
/foundation/graphic/graphic_surface/surface/src/
H A Dconsumer_surface.cpp48 consumer_ = nullptr; in ConsumerSurface()
54 if (consumer_ != nullptr) { in ~ConsumerSurface()
55 consumer_->OnConsumerDied(); in ~ConsumerSurface()
56 consumer_->SetStatus(false); in ~ConsumerSurface()
62 consumer_ = nullptr; in ~ConsumerSurface()
70 consumer_ = new BufferQueueConsumer(queue_); in Init()
110 if (consumer_ == nullptr) { in AcquireBuffer()
113 return consumer_->AcquireBuffer(buffer, fence, timestamp, damages); in AcquireBuffer()
119 if (consumer_ == nullptr) { in AcquireBuffer()
122 return consumer_ in AcquireBuffer()
[all...]
/foundation/multimodalinput/input/common/anco/comm/src/
H A Danco_channel.cpp29 : consumer_(consumer) in AncoChannel()
34 CHKPR(consumer_, RET_ERR); in SyncInputEvent()
35 return consumer_->SyncInputEvent(pointerEvent); in SyncInputEvent()
40 CHKPR(consumer_, RET_ERR); in SyncInputEvent()
41 return consumer_->SyncInputEvent(keyEvent); in SyncInputEvent()
46 CHKPR(consumer_, RET_ERR); in UpdateWindowInfo()
47 return consumer_->UpdateWindowInfo(windows); in UpdateWindowInfo()
/foundation/CastEngine/castengine_wifi_display/services/mediachannel/
H A Dmedia_channel.cpp55 if (consumer_) { in ~MediaChannel()
56 consumer_.reset(); in ~MediaChannel()
77 statusMsg->prosumerId = consumer_ ? consumer_->GetId() : INVALID_ID; in OnWriteTimeout()
85 if (consumer_) in GetSinkAgentId()
86 return consumer_->GetSinkAgentId(); in GetSinkAgentId()
226 if (consumer_) { in CreateConsumer()
227 consumer_.reset(); in CreateConsumer()
230 consumer_ = ClassReflector<BaseConsumer>::Class2Instance(className); in CreateConsumer()
231 if (consumer_) { in CreateConsumer()
[all...]
H A Dbase_channel.h46 BaseConsumer::Ptr consumer_ = nullptr; member in OHOS::Sharing::BaseChannel
/foundation/graphic/surface_lite/frameworks/
H A Dsurface_impl.cpp26 : consumer_(nullptr), producer_(nullptr), IsConsumer_(true) in SurfaceImpl()
35 : sid_(sid), consumer_(nullptr), producer_(nullptr), IsConsumer_(false) in SurfaceImpl()
41 if (consumer_ != nullptr) { in ~SurfaceImpl()
42 delete consumer_; in ~SurfaceImpl()
43 consumer_ = nullptr; in ~SurfaceImpl()
79 consumer_ = new BufferQueueConsumer(*bufferQueue); in Init()
80 if (consumer_ == nullptr) { in Init()
221 RETURN_VAL_IF_FAIL(consumer_, nullptr); in AcquireBuffer()
222 return consumer_->AcquireBuffer(); in AcquireBuffer()
227 RETURN_VAL_IF_FAIL(consumer_, fals in ReleaseBuffer()
[all...]
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/include/pipeline/
H A Drs_surface_handler.h93 if (consumer_ != nullptr) { in SetDefaultWidthAndHeight()
94 consumer_->SetDefaultWidthAndHeight(width, height); in SetDefaultWidthAndHeight()
104 return consumer_; in GetConsumer()
190 if (consumer_ == nullptr || buffer_.buffer == nullptr) { in CheckScalingModeChanged()
195 consumer_->GetScalingMode(buffer_.buffer->GetSeqNum(), scalingMode); in CheckScalingModeChanged()
270 return consumer_ != nullptr; in HasConsumer()
302 sptr<IConsumerSurface> consumer_ = nullptr; member in OHOS::Rosen::RSSurfaceHandler
/foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/round_corner_display/
H A Drs_rcd_surface_render_node.cpp71 if (consumer_ != nullptr && surface_ != nullptr) { in CreateSurface()
84 consumer_ = IConsumerSurface::Create(surfaceName.c_str()); in CreateSurface()
86 if (consumer_ == nullptr) { in CreateSurface()
90 SurfaceError ret = consumer_->RegisterConsumerListener(listener); in CreateSurface()
96 auto producer = consumer_->GetProducer(); in CreateSurface()
292 if (consumer_ != nullptr) { in ClearBufferCache()
293 consumer_->GoBackground(); in ClearBufferCache()
/foundation/multimedia/media_foundation/video_processing_engine/framework/capi/video_processing/
H A Dvideo_processing_native.cpp153 if (consumer_ != nullptr) {
158 consumer_ = CreateConsumerSurface(*window);
159 if (consumer_ == nullptr) {
188 if (consumer_ == nullptr || producer_ == nullptr || callback_ == nullptr) {
327 GSError errorCode = consumer_->AcquireBuffer(bufferInfo.buffer, releaseFence, bufferInfo.timestamp, damage);
447 if (consumer_ == nullptr) {
450 consumer = consumer_;
/foundation/arkui/ace_engine/adapter/ohos/capability/interaction/
H A Dinteraction_impl.cpp151 if (consumer_) { in RegisterCoordinationListener()
154 consumer_ = std::make_shared<CoordinationListenerImpl>(callback); in RegisterCoordinationListener()
155 return InteractionManager::GetInstance()->RegisterCoordinationListener(consumer_); in RegisterCoordinationListener()
160 CHECK_NULL_RETURN(consumer_, 0); in UnRegisterCoordinationListener()
161 auto ret = InteractionManager::GetInstance()->UnregisterCoordinationListener(consumer_); in UnRegisterCoordinationListener()
162 consumer_ = nullptr; in UnRegisterCoordinationListener()
H A Dinteraction_impl.h65 std::shared_ptr<CoordinationListenerImpl> consumer_; member in OHOS::Ace::InteractionImpl
/foundation/multimodalinput/input/frameworks/proxy/event_handler/src/
H A Dinput_handler_manager.cpp269 .consumer_ = consumer, in AddGestureToLocal()
292 .consumer_ = monitor, in AddLocal()
324 .consumer_ = monitor, in AddLocal()
435 return iter->second.consumer_; in FindHandler()
441 return item.consumer_; in FindHandler()
461 std::shared_ptr<IInputEventConsumer> consumer = item.second.consumer_; in OnInputEvent()
474 std::shared_ptr<IInputEventConsumer> consumer = item.consumer_; in OnInputEvent()
522 std::shared_ptr<IInputEventConsumer> consumer = item.consumer_; in GetConsumerInfos()
566 std::shared_ptr<IInputEventConsumer> consumer = item.second.consumer_; in GetMonitorConsumerInfos()
581 std::shared_ptr<IInputEventConsumer> consumer = item.second.consumer_; in GetMonitorConsumerInfos()
[all...]
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/fuzztest/rssurfaceohos_fuzzer/
H A Drssurfaceohos_fuzzer.cpp87 auto consumer_ = IConsumerSurface::Create("DisplayNode"); in RSSurfaceOhosFuzzTest() local
88 auto producer = consumer_->GetProducer(); in RSSurfaceOhosFuzzTest()
/foundation/multimedia/media_foundation/src/capi/common/
H A Dnative_avbuffer_queue_define.h67 consumer_(consumer) { } in OH_AVBufferQueueConsumer()
72 OHOS::sptr<OHOS::Media::AVBufferQueueConsumer> consumer_; member
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/pipeline/
H A Drs_surface_handler.cpp27 consumer_ = consumer; in SetConsumer()
/foundation/multimodalinput/input/common/anco/comm/include/
H A Danco_channel.h37 std::shared_ptr<IAncoConsumer> consumer_; member in OHOS::MMI::final
/foundation/multimedia/av_codec/test/unittest/filter_test/
H A Dvideo_capture_filter_unit_test.cpp360 surf->consumer_ = new BufferQueueConsumer(queue_); in CreateSurfaceAsConsumer()
382 EXPECT_NE(mockConsumerSurface->consumer_, nullptr); in HWTEST_F()
414 EXPECT_NE(mockConsumerSurface->consumer_, nullptr); in HWTEST_F()
435 EXPECT_NE(mockConsumerSurface->consumer_, nullptr); in HWTEST_F()
459 EXPECT_NE(mockConsumerSurface->consumer_, nullptr); in HWTEST_F()
480 EXPECT_NE(mockConsumerSurface->consumer_, nullptr); in HWTEST_F()
506 EXPECT_NE(mockConsumerSurface->consumer_, nullptr); in HWTEST_F()
538 EXPECT_NE(mockConsumerSurface->consumer_, nullptr); in HWTEST_F()
569 EXPECT_NE(mockConsumerSurface->consumer_, nullptr); in HWTEST_F()
/foundation/multimedia/player_framework/test/unittest/screen_capture_test/screen_capture_unittest/include/
H A Dscreen_capture_unit_test.h111 : consumer_(consumer) {} in ScreenCapBufferDemoConsumerListener()
115 sptr<OHOS::Surface> consumer_ = nullptr; member in OHOS::Media::ScreenCapBufferDemoConsumerListener
/foundation/graphic/graphic_surface/surface/test/unittest/
H A Dconsumer_surface_test.cpp66 static inline sptr<BufferQueueConsumer> consumer_ = nullptr; member in OHOS::Rosen::ConsumerSurfaceTest
92 ASSERT_EQ(surface_->consumer_, nullptr); in SetUp()
129 * CaseDescription: 1. new ConsumerSurface, only one nullptr for consumer_ and producer_
137 ASSERT_EQ(surface_->consumer_, nullptr); in HWTEST_F()
145 * CaseDescription: 1. new ConsumerSurface, only one nullptr for consumer_ and producer_
151 surface_->consumer_ = new BufferQueueConsumer(queue); in HWTEST_F()
152 ASSERT_NE(surface_->consumer_, nullptr); in HWTEST_F()
222 * CaseDescription: 1. call SetDefaultWidthAndHeight with consumer_ is nullptr
267 * CaseDescription: 1. call SetDefaultUsage with consumer_ is nullptr
306 * CaseDescription: 1. call AcquireBuffer with consumer_ i
[all...]
/foundation/multimedia/av_codec/services/media_engine/modules/muxer/
H A Dmedia_muxer.cpp202 track->consumer_ = track->bufferQ_->GetConsumer(); in AddTrack()
268 track->consumer_->SetBufferAvailableListener(listener);
299 track->consumer_->SetBufferAvailableListener(listener);
392 Status ret = consumer_->AcquireBuffer(curBuffer_);
406 consumer_->ReleaseBuffer(curBuffer_);
/foundation/multimedia/player_framework/services/services/screen_capture/server/
H A Dscreen_capture_server.cpp1066 consumer_ = nullptr; in StartScreenCaptureFile()
1070 ret = CreateVirtualScreen(virtualScreenName, consumer_); in StartScreenCaptureFile()
1341 consumer_ = recorder_->GetSurface(videoSourceId_); in InitRecorder()
1342 CHECK_AND_RETURN_RET_LOG(consumer_ != nullptr, MSERR_UNKNOWN, "recorder GetSurface failed"); in InitRecorder()
1814 if (consumer_ != nullptr && surfaceCb_ != nullptr) { in StartHomeVideoCapture()
1815 consumer_->UnregisterConsumerListener(); in StartHomeVideoCapture()
1817 consumer_ = nullptr; in StartHomeVideoCapture()
1820 consumer_ = OHOS::Surface::CreateSurfaceAsConsumer(); in StartHomeVideoCapture()
1821 CHECK_AND_RETURN_RET_LOG(consumer_ != nullptr, MSERR_UNKNOWN, "CreateSurfaceAsConsumer failed"); in StartHomeVideoCapture()
1822 MEDIA_LOGI("ScreenCaptureServer consumer_ BUFFER_USAGE_CPU_REA in StartHomeVideoCapture()
[all...]
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/unittest/pipeline/
H A Drs_surface_handler_test.cpp109 EXPECT_EQ(rSSurfaceHandlerPtr_->consumer_->GetDefaultWidth(), width); in HWTEST_F()
110 EXPECT_EQ(rSSurfaceHandlerPtr_->consumer_->GetDefaultHeight(), height); in HWTEST_F()

Completed in 16 milliseconds

123