| /ohos5.0/foundation/graphic/graphic_2d/frameworks/surfaceimage/src/ |
| H A D | native_image.cpp | 25 OHOS::sptr<OHOS::SurfaceImage> consumer; member
36 nativeImage->consumer = surfaceImage; in OH_NativeImage_Create()
48 nativeImage->consumer = surfaceImage; in OH_ConsumerSurface_Create()
79 return image->consumer->AttachContext(textureId); in OH_NativeImage_AttachContext()
88 return image->consumer->DetachContext(); in OH_NativeImage_DetachContext()
97 return image->consumer->UpdateSurfaceImage(); in OH_NativeImage_UpdateSurfaceImage()
106 return image->consumer->GetTimeStamp(); in OH_NativeImage_GetTimestamp()
115 return image->consumer->GetTransformMatrix(matrix); in OH_NativeImage_GetTransformMatrix()
133 *surfaceId = image->consumer->GetUniqueId(); in OH_NativeImage_GetSurfaceId()
166 if ((*image)->consumer != nullptr) { in OH_NativeImage_Destroy()
[all …]
|
| /ohos5.0/foundation/systemabilitymgr/samgr_lite/communication/broadcast/source/ |
| H A D | pub_sub_implement.c | 68 newRelation->callbacks.consumer = NULL; in AddTopic()
96 if (item->consumer->Equal(item->consumer, consumer)) { in Subscribe()
108 consumerNode->consumer = consumer; in Subscribe()
135 if (item->consumer->Equal(item->consumer, oldConsumer)) { in ModifyConsumer()
136 Consumer *older = item->consumer; in ModifyConsumer()
137 item->consumer = newConsumer; in ModifyConsumer()
164 if (item->consumer->Equal(item->consumer, consumer)) { in Unsubscribe()
173 Consumer *oldConsumer = item->consumer; in Unsubscribe()
226 if (item->consumer->identity == NULL) { in ImmediatelyPublish()
248 if (consumer == NULL || consumer->Notify == NULL || g_pubSubImplement.feature == NULL) { in DefaultHandle()
[all …]
|
| H A D | pub_sub_feature.c | 40 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()
|
| /ohos5.0/foundation/graphic/graphic_surface/surface/test/unittest/ |
| H A D | buffer_queue_consumer_test.cpp | 206 sptr<BufferQueueConsumer> consumer = new BufferQueueConsumer(bufferQueue); variable
229 ASSERT_EQ(consumer->AttachBufferToQueue(buffer), OHOS::SURFACE_ERROR_UNKOWN);
231 ASSERT_EQ(consumer->AttachBuffer(buffer), OHOS::GSERROR_INVALID_ARGUMENTS);
232 ASSERT_EQ(consumer->DetachBuffer(buffer), OHOS::GSERROR_INVALID_ARGUMENTS);
234 ASSERT_EQ(consumer->QueryIfBufferAvailable(), false);
241 ASSERT_EQ(consumer->SetDefaultUsage(0), OHOS::GSERROR_INVALID_ARGUMENTS);
242 consumer->Dump(result);
248 ASSERT_EQ(consumer->GetTunnelHandle(), nullptr);
250 consumer->SetBufferHold(0);
251 ASSERT_EQ(consumer->OnConsumerDied(), OHOS::GSERROR_INVALID_ARGUMENTS);
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/ |
| H A D | core.rs | 49 &consumer, in core()
62 &consumer, in core()
76 consumer: &C, in recur()
85 return Ok(consumer.consume(par_iter)); in recur()
91 return Ok(consumer.consume(left)); in recur()
100 consumer, in recur()
108 consumer, in recur()
128 consumer: &C, in spawn_task()
142 consumer, in spawn_task()
153 consumer: &C, in recur_ffrt()
[all …]
|
| /ohos5.0/drivers/peripheral/camera/test/mpi/src/ |
| H A D | hdi_stream_test.cpp | 92 consumer->StopConsumer();
144 consumer->StopConsumer();
231 consumer->StopConsumer();
277 consumer->StopConsumer();
319 consumer->StopConsumer();
363 consumer->StopConsumer();
404 consumer->StopConsumer();
449 consumer->StopConsumer();
491 consumer->StopConsumer();
536 consumer->StopConsumer();
[all …]
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/core/ |
| H A D | version_ctx.h | 52 void AddConsumer(SCPUEUTask* consumer, NestType nestType);
63 void onConsumed(SCPUEUTask* consumer);
77 for (auto consumer : std::as_const(consumers)) { in NotifyConsumers() local
78 consumer->DecDepRef(); in NotifyConsumers()
92 for (const auto& consumer : std::as_const(v->consumers)) { in MergeConsumerInDep() local
93 consumer->ins.insert(this); in MergeConsumerInDep()
94 consumer->ins.erase(consumer->ins.find(v)); in MergeConsumerInDep()
|
| H A D | version_ctx.cpp | 22 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()
|
| /ohos5.0/foundation/multimodalinput/input/intention/cooperate/test/src/ |
| H A D | cooperate_client_test.cpp | 135 std::shared_ptr<CoordinationListenerTest> consumer = variable
140 int32_t ret = cooperateClient.RegisterListener(tunnel, consumer, isCompatible);
142 ret = cooperateClient.RegisterListener(tunnel, consumer, isCompatible);
155 std::shared_ptr<CoordinationListenerTest> consumer = variable
160 int32_t ret = cooperateClient.RegisterListener(tunnel, consumer, isCompatible);
173 std::shared_ptr<CoordinationListenerTest> consumer = variable
178 int32_t ret = cooperateClient.RegisterListener(tunnel, consumer, isCompatible);
200 std::shared_ptr<CoordinationListenerTest> consumer = variable
205 int32_t ret = cooperateClient.RegisterListener(tunnel, consumer, isCompatible);
225 std::shared_ptr<CoordinationListenerTest> consumer = variable
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/core/common/include/ |
| H A D | softbus_queue.h | 60 } consumer; member
84 consumerTail = queue->consumer.tail; in QueueIsEmpty()
109 consumerTail = queue->consumer.tail; in QueueSingleProducerEnqueue()
165 consumerTail = queue->consumer.tail; in QueueMultiProducerEnqueue()
220 consumerHead = queue->consumer.head; in QueueSingleConsumerDequeue()
241 queue->consumer.head = consumerNext; in QueueSingleConsumerDequeue()
255 queue->consumer.tail = consumerNext; in QueueSingleConsumerDequeue()
275 consumerHead = queue->consumer.head; in QueueMultiConsumerDequeue()
301 success = SoftBusAtomicCmpAndSwap32(&queue->consumer.head, consumerHead, consumerNext); in QueueMultiConsumerDequeue()
317 while (queue->consumer.tail != consumerHead) { in QueueMultiConsumerDequeue()
[all …]
|
| /ohos5.0/base/msdp/device_status/test/unittest/intention/cooperate/src/ |
| H A D | cooperate_client_test.cpp | 118 std::shared_ptr<CoordinationListenerTest> consumer = variable
131 ret = cooperateClient.RegisterListener(tunnel, consumer, isCompatible);
133 ret = cooperateClient.RegisterListener(tunnel, consumer, isCompatible);
139 ret = cooperateClient.RegisterListener(tunnel, consumer, isCompatible);
157 std::shared_ptr<CoordinationListenerTest> consumer = nullptr; variable
166 consumer = std::make_shared<CoordinationListenerTest>();
170 ret = cooperateClient.RegisterListener(tunnel, consumer, isCompatible);
221 std::shared_ptr<CoordinationListenerTest> consumer = variable
250 std::shared_ptr<CoordinationListenerTest> consumer = variable
277 std::shared_ptr<CoordinationListenerTest> consumer = variable
[all …]
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service/core/drawable/ |
| H A D | rs_dma_buffer_surface_render_node_drawable.cpp | 49 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()
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 != nullptr) { in ClearBufferQueue()
203 consumer->GoBackground(); in ClearBufferQueue()
|
| /ohos5.0/docs/zh-cn/release-notes/changelogs/OpenHarmony_5.0.0.25/ |
| H A D | changelogs-network.md | 38 开发者在进行元服务应用开发时，涉及http请求，先到[AppGallery Connect](https://developer.huawei.com/consumer/cn/service/jos…
39 完成服务器域名相关配置，可参考此[指导文档](https://developer.huawei.com/consumer/cn/doc/atomic-guides-V5/agc-help-harmo…
42 …ps://developer.huawei.com/consumer/cn/service/josp/agc/index.html)完成服务器域名相关配置，可参考此[指导文档](https://d…
79 开发者在进行元服务应用开发时，涉及http流式请求，先到[AppGallery Connect](https://developer.huawei.com/consumer/cn/service/j…
80 完成服务器域名相关配置，可参考此[指导文档](https://developer.huawei.com/consumer/cn/doc/atomic-guides-V5/agc-help-harmo…
83 …ps://developer.huawei.com/consumer/cn/service/josp/agc/index.html)完成服务器域名相关配置，可参考此[指导文档](https://d…
|
| /ohos5.0/base/inputmethod/imf/test/common/src/ |
| H A D | keyboard_listener_test_impl.cpp | 29 …enerTestImpl::OnKeyEvent(int32_t keyCode, int32_t keyStatus, sptr<KeyEventConsumerProxy> &consumer) in OnKeyEvent() argument
32 if (consumer != nullptr) { in OnKeyEvent()
33 consumer->OnKeyCodeConsumeResult(true); in OnKeyEvent()
39 const std::shared_ptr<MMI::KeyEvent> &keyEvent, sptr<KeyEventConsumerProxy> &consumer) in OnDealKeyEvent() argument
41 bool isKeyCodeConsume = OnKeyEvent(keyEvent->GetKeyCode(), keyEvent->GetKeyAction(), consumer); in OnDealKeyEvent()
42 bool isKeyEventConsume = OnKeyEvent(keyEvent, consumer); in OnDealKeyEvent()
43 if (consumer != nullptr) { in OnDealKeyEvent()
44 consumer->OnKeyEventResult(isKeyEventConsume || isKeyCodeConsume); in OnDealKeyEvent()
|
| /ohos5.0/foundation/communication/dsoftbus/core/common/queue/ |
| H A D | softbus_queue.c | 47 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()
|
| /ohos5.0/foundation/multimodalinput/input/frameworks/proxy/event_handler/src/ |
| H A D | input_handler_manager.cpp | 54 CHKPR(consumer, INVALID_HANDLER_ID); in AddHandler()
250 CHKPV(consumer); in OnInputEvent()
251 consumer->OnInputEvent(keyEvent); in OnInputEvent()
263 CHKPV(consumer); in OnInputEvent()
264 consumer->OnInputEvent(keyEvent); in OnInputEvent()
311 CHKPV(consumer); in GetConsumerInfos()
312 auto ret = consumerInfos.emplace(handlerId, consumer); in GetConsumerInfos()
469 CHKPR(consumer, INVALID_HANDLER_ID); in GetMonitorConsumerInfos()
470 auto ret = consumerInfos.emplace(handlerId, consumer); in GetMonitorConsumerInfos()
495 auto consumer = iter->second; in OnInputEvent() local
[all …]
|
| /ohos5.0/docs/zh-cn/application-dev/key-features/multi-device-app-dev/ |
| H A D | ide-using.md | 15 参考[创建系统工程](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides-V14/ide-create-new-project…
58 …com/consumer/cn/doc/harmonyos-guides-V14/ide-har-V14)，新建三个ohpm模块，分别命名为common、feature1、feature2。参考[…
116 …eature1和feature2模块中的代码。更多详情参考[配置系统ohpm包依赖](https://developer.huawei.com/consumer/cn/doc/harmonyos-…
127 在[开发ohpm包](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides-V14/ide-har-V14)中，仅介绍了如何使用…
148 > 如果需要将ohpm包发布供其他开发者使用，具体可参考[发布ohpm包](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides…
155 …如何进行编译构建、如何签名、如何使用预览器等，[DevEco Studio使用指南](https://developer.huawei.com/consumer/cn/doc/harmonyos-…
|
| /ohos5.0/docs/zh-cn/release-notes/changelogs/OpenHarmony_5.0.0.36/ |
| H A D | changelogs-network.md | 38 …cket.connect接口建立连接是，先到[AppGallery Connect](https://developer.huawei.com/consumer/cn/service/josp/a…
39 完成服务器域名相关配置，可参考此[指导文档](https://developer.huawei.com/consumer/cn/doc/atomic-guides-V5/agc-help-harmo…
42 …ps://developer.huawei.com/consumer/cn/service/josp/agc/index.html)完成服务器域名相关配置，可参考此[指导文档](https://d…
|
| /ohos5.0/base/inputmethod/imf/frameworks/js/napi/inputmethodability/ |
| H A D | js_keyboard_delegate_setting.cpp | 317 …auto task = [keyEventEntry, keyCodeEntry, consumer]() { DealKeyEvent(keyEventEntry, keyCodeEntry, … in OnDealKeyEvent()
364 if (consumer != nullptr) { in DealKeyEvent()
365 consumer->OnKeyEventResult(consumeResult); in DealKeyEvent()
378 entry.keyEvenetConsumer = consumer; in OnKeyEvent()
409 auto consumer = entry->keyEvenetConsumer; in OnKeyEvent() local
410 if (consumer != nullptr) { in OnKeyEvent()
412 consumer->OnKeyEventConsumeResult(isConsumed); in OnKeyEvent()
426 entry.keyEvenetConsumer = consumer; in OnKeyEvent()
458 auto consumer = entry->keyEvenetConsumer; in OnKeyEvent() local
459 if (consumer != nullptr) { in OnKeyEvent()
[all …]
|
| /ohos5.0/docs/en/release-notes/changelogs/OpenHarmony_5.0.0.25/ |
| H A D | changelogs-network.md | 37 …ce, you need to go to [AppGallery Connect](https://developer.huawei.com/consumer/en-us/service/jos…
38 …name. For details, see [Development Guide](https://developer.huawei.com/consumer/en-us/doc/atomic-…
40 …loper.huawei.com/consumer/en-us/service/josp/agc/index.html). For details, see [Development Guide]…
76 …ce, you need to go to [AppGallery Connect](https://developer.huawei.com/consumer/en-us/service/jos…
77 …name. For details, see [Development Guide](https://developer.huawei.com/consumer/en-us/doc/atomic-…
79 …loper.huawei.com/consumer/en-us/service/josp/agc/index.html). For details, see [Development Guide]…
|
| /ohos5.0/base/inputmethod/imf/interfaces/inner_api/inputmethod_ability/include/ |
| H A D | keyboard_listener.h | 28 const std::shared_ptr<MMI::KeyEvent> &keyEvent, sptr<KeyEventConsumerProxy> &consumer) = 0;
29 …ual bool OnKeyEvent(int32_t keyCode, int32_t keyStatus, sptr<KeyEventConsumerProxy> &consumer) = 0;
30 …eyEvent(const std::shared_ptr<MMI::KeyEvent> &keyEvent, sptr<KeyEventConsumerProxy> &consumer) = 0;
|
| /ohos5.0/base/inputmethod/imf/test/fuzztest/inputmethodability_fuzzer/ |
| H A D | inputmethodability_fuzzer.cpp | 26 bool OnKeyEvent(int32_t keyCode, int32_t keyStatus, sptr<KeyEventConsumerProxy> &consumer) in OnKeyEvent() argument
30 …l OnKeyEvent(const std::shared_ptr<MMI::KeyEvent> &keyEvent, sptr<KeyEventConsumerProxy> &consumer) in OnKeyEvent() argument
34 …DealKeyEvent(const std::shared_ptr<MMI::KeyEvent> &keyEvent, sptr<KeyEventConsumerProxy> &consumer) in OnDealKeyEvent() argument
127 sptr<KeyEventConsumerProxy> consumer = new (std::nothrow) KeyEventConsumerProxy(nullptr); in TestDispatchKeyEvent() local
128 ability->DispatchKeyEvent(keyEvent, consumer); in TestDispatchKeyEvent()
|
| /ohos5.0/foundation/systemabilitymgr/samgr_lite/interfaces/kits/communication/broadcast/ |
| H A D | broadcast_interface.h | 109 void (*Notify)(Consumer *consumer, const Topic *topic, const Request *origin);
185 int (*Subscribe)(IUnknown *iUnknown, const Topic *topic, Consumer *consumer);
218 Consumer *(*Unsubscribe)(IUnknown *iUnknown, const Topic *topic, const Consumer *consumer);
|
| /ohos5.0/docs/zh-cn/application-dev/device/driver/ |
| H A D | externaldevice-guidelines.md | 15 …consumer/cn/download/)该工具，并参考[DevEco Studio使用指南](https://developer.huawei.com/consumer/cn/doc/harm…
23 …ows/Linux/Mac系统上与真实设备或者模拟器进行交互，详细参考[HDC配置](https://developer.huawei.com/consumer/cn/doc/harmonyos-…
66 1. 创建新工程，请参考[创建一个新的工程](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides-V13/ide-create…
179 7. 渲染UI界面，更多UI界面开发请参考[UI开发](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides-V5/arkts-…
247 自动签名方法： 请参考[自动签名](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides-V13/ide-signing-V13…
249 权限配置方法： 请参考[使用ACL的签名配置指导](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides-V13/ide-sig…
|
| /ohos5.0/base/inputmethod/imf/test/common/include/ |
| H A D | keyboard_listener_test_impl.h | 30 …bool OnKeyEvent(int32_t keyCode, int32_t keyStatus, sptr<KeyEventConsumerProxy> &consumer) overrid…
31 …ent(const std::shared_ptr<MMI::KeyEvent> &keyEvent, sptr<KeyEventConsumerProxy> &consumer) override in OnKeyEvent() argument
36 … const std::shared_ptr<MMI::KeyEvent> &keyEvent, sptr<KeyEventConsumerProxy> &consumer) override;
|