Home
last modified time | relevance | path

Searched refs:consumer (Results 1 - 25 of 90) sorted by relevance

1234

/foundation/graphic/graphic_2d/frameworks/surfaceimage/src/
H A Dnative_image.cpp25 OHOS::sptr<OHOS::SurfaceImage> consumer = nullptr; member
36 nativeImage->consumer = surfaceImage; in OH_NativeImage_Create()
39 nativeImage->consumer->RegisterConsumerListener(listener); in OH_NativeImage_Create()
48 nativeImage->consumer = surfaceImage; in OH_ConsumerSurface_Create()
51 nativeImage->consumer->RegisterConsumerListener(listener); in OH_ConsumerSurface_Create()
75 if (image == nullptr || image->consumer == nullptr) { in OH_NativeImage_AttachContext()
79 return image->consumer->AttachContext(textureId); in OH_NativeImage_AttachContext()
84 if (image == nullptr || image->consumer == nullptr) { in OH_NativeImage_DetachContext()
88 return image->consumer->DetachContext(); in OH_NativeImage_DetachContext()
93 if (image == nullptr || image->consumer in OH_NativeImage_UpdateSurfaceImage()
[all...]
/foundation/graphic/graphic_surface/surface/test/unittest/
H A Dbuffer_queue_consumer_test.cpp206 sptr<BufferQueueConsumer> consumer = new BufferQueueConsumer(bufferQueue); in HWTEST_F() local
228 ASSERT_EQ(consumer->AcquireBuffer(buffer, fence, timestamp, damages), OHOS::SURFACE_ERROR_UNKOWN); in HWTEST_F()
229 ASSERT_EQ(consumer->ReleaseBuffer(buffer, fence), OHOS::SURFACE_ERROR_UNKOWN); in HWTEST_F()
230 ASSERT_EQ(consumer->AttachBufferToQueue(buffer), OHOS::SURFACE_ERROR_UNKOWN); in HWTEST_F()
231 ASSERT_EQ(consumer->DetachBufferFromQueue(buffer), OHOS::SURFACE_ERROR_UNKOWN); in HWTEST_F()
232 ASSERT_EQ(consumer->AttachBuffer(buffer), OHOS::GSERROR_INVALID_ARGUMENTS); in HWTEST_F()
233 ASSERT_EQ(consumer->DetachBuffer(buffer), OHOS::GSERROR_INVALID_ARGUMENTS); in HWTEST_F()
234 ASSERT_EQ(consumer->RegisterSurfaceDelegator(client, cSurface), OHOS::GSERROR_INVALID_ARGUMENTS); in HWTEST_F()
235 ASSERT_EQ(consumer->QueryIfBufferAvailable(), false); in HWTEST_F()
236 ASSERT_EQ(consumer in HWTEST_F()
[all...]
/foundation/systemabilitymgr/samgr_lite/communication/broadcast/source/
H A Dpub_sub_implement.c23 static int Subscribe(IUnknown *iUnknown, const Topic *topic, Consumer *consumer);
25 static Consumer *Unsubscribe(IUnknown *iUnknown, const Topic *topic, const Consumer *consumer);
68 newRelation->callbacks.consumer = NULL; in AddTopic()
77 static int Subscribe(IUnknown *iUnknown, const Topic *topic, Consumer *consumer) in Subscribe() argument
79 if (iUnknown == NULL || topic == NULL || consumer == NULL) { in Subscribe()
96 if (item->consumer->Equal(item->consumer, consumer)) { in Subscribe()
108 consumerNode->consumer = consumer; in Subscribe()
146 Unsubscribe(IUnknown *iUnknown, const Topic *topic, const Consumer *consumer) Unsubscribe() argument
247 Consumer *consumer = (Consumer *)response->data; DefaultHandle() local
[all...]
H A Dpub_sub_feature.c40 feature->relations.callbacks.consumer = NULL; in Init()
82 if (item->consumer->identity == NULL) { in OnMessage()
83 item->consumer->Notify(item->consumer, &topic, request); in OnMessage()
/foundation/resourceschedule/ffrt/src/core/
H A Dversion_ctx.h52 void AddConsumer(SCPUEUTask* consumer, NestType nestType);
63 void onConsumed(SCPUEUTask* consumer);
77 for (auto consumer : std::as_const(consumers)) { in NotifyConsumers()
78 consumer->DecDepRef(); in NotifyConsumers()
92 for (const auto& consumer : std::as_const(v->consumers)) { in MergeConsumerInDep()
93 consumer->ins.insert(this); in MergeConsumerInDep()
94 consumer->ins.erase(consumer->ins.find(v)); in MergeConsumerInDep()
H A Dversion_ctx.cpp22 static inline void BuildConsumeRelationship(VersionCtx* version, SCPUEUTask* consumer) in BuildConsumeRelationship() argument
25 consumer->IncDepRef(); in BuildConsumeRelationship()
27 version->consumers.insert(consumer); in BuildConsumeRelationship()
41 void VersionCtx::AddConsumer(SCPUEUTask* consumer, NestType nestType) in AddConsumer() argument
49 CreateChildVersion(consumer, DataStatus::READY); in AddConsumer()
53 BuildConsumeRelationship(beConsumeVersion, consumer); in AddConsumer()
54 consumer->ins.insert(beConsumeVersion); in AddConsumer()
92 void VersionCtx::onConsumed(SCPUEUTask* consumer) in onConsumed() argument
94 auto it = std::as_const(consumers).find(consumer); in onConsumed()
/foundation/multimodalinput/input/intention/cooperate/test/src/
H A Dcooperate_client_test.cpp131 std::shared_ptr<CoordinationListenerTest> consumer = in HWTEST_F() local
136 int32_t ret = cooperateClient.RegisterListener(tunnel, consumer, isCompatible); in HWTEST_F()
138 ret = cooperateClient.RegisterListener(tunnel, consumer, isCompatible); in HWTEST_F()
151 std::shared_ptr<CoordinationListenerTest> consumer = in HWTEST_F() local
156 int32_t ret = cooperateClient.RegisterListener(tunnel, consumer, isCompatible); in HWTEST_F()
169 std::shared_ptr<CoordinationListenerTest> consumer = in HWTEST_F() local
174 int32_t ret = cooperateClient.RegisterListener(tunnel, consumer, isCompatible); in HWTEST_F()
196 std::shared_ptr<CoordinationListenerTest> consumer = in HWTEST_F() local
201 int32_t ret = cooperateClient.RegisterListener(tunnel, consumer, isCompatible); in HWTEST_F()
221 std::shared_ptr<CoordinationListenerTest> consumer in HWTEST_F() local
247 std::shared_ptr<CoordinationListenerTest> consumer = HWTEST_F() local
[all...]
/foundation/graphic/graphic_2d/rosen/modules/render_service/core/drawable/
H A Drs_dma_buffer_surface_render_node_drawable.cpp49 auto consumer = surfaceHandlerUiFirst_->GetConsumer(); in CreateSurface() local
50 if (consumer != nullptr && surface_ != nullptr) { in CreateSurface()
65 consumer = IConsumerSurface::Create(name_); in CreateSurface()
66 if (consumer == nullptr) { in CreateSurface()
67 RS_LOGE("RSSurfaceRenderNodeDrawable::CreateSurface get consumer surface fail"); in CreateSurface()
70 SurfaceError ret = consumer->RegisterConsumerListener(consumerListener_); in CreateSurface()
75 auto producer = consumer->GetProducer(); in CreateSurface()
85 surfaceHandlerUiFirst_->SetConsumer(consumer); in CreateSurface()
201 auto consumer = surfaceHandlerUiFirst_->GetConsumer(); in ClearBufferQueue() local
202 if (consumer ! in ClearBufferQueue()
[all...]
/foundation/communication/dsoftbus/core/common/include/
H A Dsoftbus_queue.h53 /* consumer status */
57 volatile uint32_t head; /* consumer head */
58 volatile uint32_t tail; /* consumer tail */
60 } consumer; member
84 consumerTail = queue->consumer.tail; in QueueIsEmpty()
109 consumerTail = queue->consumer.tail; in QueueSingleProducerEnqueue()
132 * 1. The consumer thinks that the elements in this area have been queued and can be consumed, in QueueSingleProducerEnqueue()
133 * but the consumer actually reads dirty elements. in QueueSingleProducerEnqueue()
160 * Make sure the producer's head is read before the consumer's tail. in QueueMultiProducerEnqueue()
161 * If the consumer tai in QueueMultiProducerEnqueue()
[all...]
/foundation/multimodalinput/input/frameworks/proxy/event_handler/src/
H A Dinput_handler_manager.cpp48 int32_t InputHandlerManager::AddHandler(InputHandlerType handlerType, std::shared_ptr<IInputEventConsumer> consumer, in AddHandler() argument
52 CHKPR(consumer, INVALID_HANDLER_ID); in AddHandler()
73 if (RET_OK == AddLocal(handlerId, handlerType, eventType, priority, deviceTags, consumer)) { in AddHandler()
101 InputHandlerType handlerType, std::shared_ptr<IInputEventConsumer> consumer, in AddGestureMonitor()
104 CHKPR(consumer, INVALID_HANDLER_ID); in AddGestureMonitor()
112 int32_t ret = AddGestureToLocal(handlerId, eventType, gestureType, fingers, consumer); in AddGestureMonitor()
130 int32_t InputHandlerManager::AddHandler(InputHandlerType handlerType, std::shared_ptr<IInputEventConsumer> consumer, in AddHandler() argument
134 CHKPR(consumer, INVALID_HANDLER_ID); in AddHandler()
141 if (RET_OK == AddLocal(handlerId, handlerType, actionsType, consumer)) { in AddHandler()
247 TouchGestureType gestureType, int32_t fingers, std::shared_ptr<IInputEventConsumer> consumer) in AddGestureToLocal()
100 AddGestureMonitor( InputHandlerType handlerType, std::shared_ptr<IInputEventConsumer> consumer, HandleEventType eventType, TouchGestureType gestureType, int32_t fingers) AddGestureMonitor() argument
246 AddGestureToLocal(int32_t handlerId, HandleEventType eventType, TouchGestureType gestureType, int32_t fingers, std::shared_ptr<IInputEventConsumer> consumer) AddGestureToLocal() argument
461 std::shared_ptr<IInputEventConsumer> consumer = item.second.consumer_; OnInputEvent() local
474 std::shared_ptr<IInputEventConsumer> consumer = item.consumer_; OnInputEvent() local
522 std::shared_ptr<IInputEventConsumer> consumer = item.consumer_; GetConsumerInfos() local
566 std::shared_ptr<IInputEventConsumer> consumer = item.second.consumer_; GetMonitorConsumerInfos() local
581 std::shared_ptr<IInputEventConsumer> consumer = item.second.consumer_; GetMonitorConsumerInfos() local
615 auto consumer = iter->second; OnInputEvent() local
[all...]
H A Dinput_monitor_manager.cpp36 std::shared_ptr<IInputEventConsumer> consumer, TouchGestureType type, int32_t fingers) in AddGestureMonitor()
38 CHKPR(consumer, INVALID_HANDLER_ID); in AddGestureMonitor()
40 consumer, HANDLE_EVENT_TYPE_TOUCH_GESTURE, type, fingers); in AddGestureMonitor()
35 AddGestureMonitor( std::shared_ptr<IInputEventConsumer> consumer, TouchGestureType type, int32_t fingers) AddGestureMonitor() argument
/foundation/communication/dsoftbus/core/common/queue/
H A Dsoftbus_queue.c47 queue->consumer.size = unitNum; in QueueInit()
49 queue->consumer.mask = unitNum - 1; in QueueInit()
51 queue->consumer.head = 0; in QueueInit()
53 queue->consumer.tail = 0; in QueueInit()
88 consumerTail = queue->consumer.tail; in QueueCountGet()
/foundation/systemabilitymgr/samgr_lite/interfaces/kits/communication/broadcast/
H A Dbroadcast_interface.h89 * @brief Defines the topic consumer used to receive events and push data. You need to implement
97 * @brief Defines how the consumer will process the events or data of a released topic.
100 * Note that the passed topic must have been subscribed by the consumer. Otherwise, the
103 * @param consumer Indicates <b>this</b> pointer of the consumer.
109 void (*Notify)(Consumer *consumer, const Topic *topic, const Request *origin);
116 * @param current Indicates the pointer to the current consumer.
117 * @param other Indicates the pointer to the target consumer to compare.
179 * @param consumer Indicates the consumer wh
[all...]
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/pipeline/
H A Drs_surface_handler.cpp25 void RSSurfaceHandler::SetConsumer(sptr<IConsumerSurface> consumer) in SetConsumer() argument
27 consumer_ = consumer; in SetConsumer()
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/unittest/platform/ohos/
H A Drs_surface_ohos_converter_test.cpp51 sptr<IConsumerSurface> consumer = IConsumerSurface::Create("DisplayNode"); in HWTEST_F() local
52 sptr<IBufferProducer> producer = consumer->GetProducer(); in HWTEST_F()
/foundation/multimodalinput/input/common/anco/comm/src/
H A Danco_channel.cpp28 AncoChannel::AncoChannel(std::shared_ptr<IAncoConsumer> consumer) in AncoChannel() argument
29 : consumer_(consumer) in AncoChannel()
/foundation/multimodalinput/input/test/fuzztest/setwindowinputeventconsumer_fuzzer/
H A Dsetwindowinputeventconsumer_fuzzer.cpp38 std::shared_ptr<InputEventConsumerTest> consumer = std::make_shared<InputEventConsumerTest>(); in SetWindowInputEventConsumerFuzzTest() local
39 InputManager::GetInstance()->SetWindowInputEventConsumer(consumer); in SetWindowInputEventConsumerFuzzTest()
/foundation/multimodalinput/input/test/fuzztest/addinterceptor_fuzzer/
H A Daddinterceptor_fuzzer.cpp38 auto consumer = std::make_shared<InputEventConsumerTest>(); in AddInterceptorFuzzTest() local
39 int32_t inceptorId = InputManager::GetInstance()->AddInterceptor(consumer); in AddInterceptorFuzzTest()
/foundation/graphic/graphic_2d/rosen/test/render/render/unittest/pipeline/
H A Drs_composer_adapter_unit_test.cpp155 auto consumer = surfaceNode1->GetRSSurfaceHandler()->GetConsumer(); in HWTEST_F() local
156 ASSERT_NE(consumer, nullptr); in HWTEST_F()
160 consumer->SetTunnelHandle(&handle); in HWTEST_F()
434 sptr<IConsumerSurface> consumer = IConsumerSurface::Create("test"); in HWTEST_F() local
436 node->GetRenderDrawable())->GetRSSurfaceHandlerOnDraw()->SetConsumer(consumer); in HWTEST_F()
463 sptr<IConsumerSurface> consumer = IConsumerSurface::Create("test"); in HWTEST_F() local
465 composerAdapter_->LayerPresentTimestamp(layer, consumer); in HWTEST_F()
485 sptr<IConsumerSurface> consumer = IConsumerSurface::Create("test"); in HWTEST_F() local
487 composerAdapter_->LayerPresentTimestamp(layer, consumer); in HWTEST_F()
504 sptr<IConsumerSurface> consumer in HWTEST_F() local
[all...]
H A Drs_unittest_composer_adapter_test.cpp130 auto consumer = surfaceNode1->GetRSSurfaceHandler()->GetConsumer(); in HWTEST_F() local
134 consumer->SetTunnelHandle(&handle); in HWTEST_F()
183 sptr<IConsumerSurface> consumer = IConsumerSurface::Create("test"); in HWTEST_F() local
185 composerAdapter_->LayerPresentTimestamp(layer, consumer); in HWTEST_F()
205 sptr<IConsumerSurface> consumer = IConsumerSurface::Create("test"); in HWTEST_F() local
207 composerAdapter_->LayerPresentTimestamp(layer, consumer); in HWTEST_F()
223 sptr<IConsumerSurface> consumer = IConsumerSurface::Create("test"); in HWTEST_F() local
225 composerAdapter_->LayerPresentTimestamp(layer, consumer); in HWTEST_F()
525 sptr<IConsumerSurface> consumer = IConsumerSurface::Create("test"); in HWTEST_F() local
527 node->GetRenderDrawable())->GetRSSurfaceHandlerOnDraw()->SetConsumer(consumer); in HWTEST_F()
[all...]
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service/unittest/pipeline/
H A Drs_composer_adapter_test.cpp131 auto consumer = surfaceNode1->GetRSSurfaceHandler()->GetConsumer(); in HWTEST_F() local
132 ASSERT_NE(consumer, nullptr); in HWTEST_F()
136 consumer->SetTunnelHandle(&handle); in HWTEST_F()
434 sptr<IConsumerSurface> consumer = IConsumerSurface::Create("test"); in HWTEST_F() local
436 node->GetRenderDrawable())->GetRSSurfaceHandlerOnDraw()->SetConsumer(consumer); in HWTEST_F()
463 sptr<IConsumerSurface> consumer = IConsumerSurface::Create("test"); in HWTEST_F() local
465 composerAdapter_->LayerPresentTimestamp(layer, consumer); in HWTEST_F()
485 sptr<IConsumerSurface> consumer = IConsumerSurface::Create("test"); in HWTEST_F() local
487 composerAdapter_->LayerPresentTimestamp(layer, consumer); in HWTEST_F()
504 sptr<IConsumerSurface> consumer in HWTEST_F() local
[all...]
/foundation/multimodalinput/input/test/fuzztest/addmonitor_fuzzer/
H A Daddmonitor_fuzzer.cpp50 auto consumer = std::make_shared<InputEventConsumerTest>(); in AddMonitorFuzzTeset() local
51 monitorId = InputManager::GetInstance()->AddMonitor(consumer); in AddMonitorFuzzTeset()
/foundation/multimodalinput/input/test/fuzztest/markconsumed_fuzzer/
H A Dmarkconsumed_fuzzer.cpp57 auto consumer = std::make_shared<InputEventConsumerTest>(); in MarkConsumedFuzzTest() local
58 int32_t monitorId = InputManager::GetInstance()->AddMonitor(consumer); in MarkConsumedFuzzTest()
/foundation/multimedia/media_foundation/video_processing_engine/framework/capi/video_processing/
H A Dvideo_processing_native.cpp154 VPE_LOGE("consumer surface is already created!");
160 VPE_LOGE("Failed to create consumer surface!");
189 VPE_LOGE("The consumer, producer surfaces and callback are not ready!");
391 sptr<Surface> consumer = Surface::CreateSurfaceAsConsumer("VideoProcessingSurface");
392 if (consumer == nullptr) {
393 VPE_LOGE("Failed to create consumer surface!");
398 VPE_LOGE("Failed to create consumer surface listener!");
401 if (consumer->RegisterConsumerListener(listener) != GSERROR_OK) {
402 VPE_LOGE("Failed to register consumer surface listener!");
406 sptr<IBufferProducer> producer = consumer
[all...]
/foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/round_corner_display/
H A Drs_rcd_render_visitor.cpp37 auto consumer = node.GetConsumer(); in ConsumeAndUpdateBuffer() local
38 if (consumer == nullptr) { in ConsumeAndUpdateBuffer()
46 auto ret = consumer->AcquireBuffer(buffer, acquireFence, timestamp, damage); in ConsumeAndUpdateBuffer()

Completed in 11 milliseconds

1234