Searched refs:Channel (Results 1 - 15 of 15) sorted by relevance
| /base/msdp/device_status/intention/common/channel/include/ |
| H A D | channel.h | 30 class Channel { class
45 friend class Channel<Event>;
83 Sender(std::shared_ptr<Channel<Event>> channel) in Sender()
87 std::shared_ptr<Channel<Event>> channel_ { nullptr };
91 friend class Channel<Event>;
152 Receiver(std::shared_ptr<Channel<Event>> channel) in Receiver()
156 std::shared_ptr<Channel<Event>> channel_ { nullptr };
159 Channel() = default;
160 ~Channel() = default;
181 std::pair<typename Channel<Even
[all...] |
| /base/msdp/device_status/test/unittest/intention/common/src/ |
| H A D | channel_test.cpp | 51 auto [sender, receiver] = Channel<size_t>::OpenChannel(); in HWTEST_F()
52 constexpr size_t count = Channel<size_t>::QUEUE_CAPACITY; in HWTEST_F()
57 EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR); in HWTEST_F()
80 auto [sender, receiver] = Channel<size_t>::OpenChannel(); in HWTEST_F()
81 constexpr size_t count = Channel<size_t>::QUEUE_CAPACITY; in HWTEST_F()
86 EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR); in HWTEST_F()
109 auto [sender, receiver] = Channel<size_t>::OpenChannel(); in HWTEST_F()
111 EXPECT_EQ(sender.Send(data), Channel<size_t>::INACTIVE_CHANNEL); in HWTEST_F()
122 auto [sender, receiver] = Channel<size_t>::OpenChannel(); in HWTEST_F()
126 for (size_t index = 0; index < Channel<size_ in HWTEST_F()
[all...] |
| /base/msdp/device_status/intention/cooperate/plugin/src/ |
| H A D | cooperate.cpp | 36 auto [sender, receiver] = Channel<CooperateEvent>::OpenChannel(); in Cooperate()
58 if (ret != Channel<CooperateEvent>::NO_ERROR) { in AddObserver()
71 if (ret != Channel<CooperateEvent>::NO_ERROR) { in RemoveObserver()
84 if (ret != Channel<CooperateEvent>::NO_ERROR) { in RegisterListener()
98 if (ret != Channel<CooperateEvent>::NO_ERROR) { in UnregisterListener()
112 if (ret != Channel<CooperateEvent>::NO_ERROR) { in RegisterHotAreaListener()
126 if (ret != Channel<CooperateEvent>::NO_ERROR) { in UnregisterHotAreaListener()
142 if (ret != Channel<CooperateEvent>::NO_ERROR) { in Enable()
157 if (ret != Channel<CooperateEvent>::NO_ERROR) { in Disable()
181 if (ret != Channel<CooperateEven in Start()
[all...] |
| H A D | cooperate_context.cpp | 40 explicit BoardObserver(Channel<CooperateEvent>::Sender sender) : sender_(sender) {} in BoardObserver()
52 if (ret != Channel<CooperateEvent>::NO_ERROR) {
65 if (ret != Channel<CooperateEvent>::NO_ERROR) {
71 Channel<CooperateEvent>::Sender sender_;
84 if (ret != Channel<CooperateEvent>::NO_ERROR) { in OnDeviceAdded()
99 if (ret != Channel<CooperateEvent>::NO_ERROR) { in OnDeviceRemoved()
109 void Context::AttachSender(Channel<CooperateEvent>::Sender sender) in AttachSender()
|
| H A D | state_machine.cpp | 43 StateMachine::AppStateObserver::AppStateObserver(Channel<CooperateEvent>::Sender sender, int32_t clientPid) in AppStateObserver()
55 if (ret != Channel<CooperateEvent>::NO_ERROR) { in OnProcessDied()
501 int32_t StateMachine::RegisterApplicationStateObserver(Channel<CooperateEvent>::Sender sender, in RegisterApplicationStateObserver()
604 if (ret != Channel<CooperateEvent>::NO_ERROR) { in OnCommonEvent()
614 if (res != Channel<CooperateEvent>::NO_ERROR) { in OnCommonEvent()
658 if (ret != Channel<CooperateEvent>::NO_ERROR) { in AddMonitor()
|
| H A D | cooperate_in.cpp | 423 if (ret != Channel<CooperateEvent>::NO_ERROR) { in OnRemoteStart()
432 if (ret != Channel<CooperateEvent>::NO_ERROR) { in OnRemoteStart()
447 if (ret != Channel<CooperateEvent>::NO_ERROR) { in OnRemoteStop()
582 if (ret != Channel<CooperateEvent>::NO_ERROR) { in OnProgress()
|
| H A D | dsoftbus_handler.cpp | 87 void DSoftbusHandler::AttachSender(Channel<CooperateEvent>::Sender sender) in AttachSender()
246 if (ret != Channel<CooperateEvent>::NO_ERROR) { in SendEvent()
|
| /base/msdp/device_status/intention/cooperate/plugin/include/ |
| H A D | cooperate_context.h | 50 void AttachSender(Channel<CooperateEvent>::Sender sender);
56 Channel<CooperateEvent>::Sender Sender() const;
116 Channel<CooperateEvent>::Sender sender_;
134 explicit HotplugObserver(Channel<CooperateEvent>::Sender sender) : sender_(sender) {} in HotplugObserver()
141 Channel<CooperateEvent>::Sender sender_;
144 inline Channel<CooperateEvent>::Sender Context::Sender() const in Sender()
|
| H A D | state_machine.h | 45 AppStateObserver(Channel<CooperateEvent>::Sender sender, int32_t clientPid);
51 Channel<CooperateEvent>::Sender sender_;
90 int32_t RegisterApplicationStateObserver(Channel<CooperateEvent>::Sender sender, const EnableCooperateEvent &event);
|
| H A D | dsoftbus_handler.h | 69 void AttachSender(Channel<CooperateEvent>::Sender sender);
104 Channel<CooperateEvent>::Sender sender_;
|
| H A D | cooperate.h | 70 Channel<CooperateEvent>::Receiver receiver_;
|
| /base/msdp/device_status/intention/cooperate/plugin/include/input_event_transmission/ |
| H A D | input_event_interceptor.h | 55 Channel<CooperateEvent>::Sender sender_;
|
| /base/msdp/device_status/intention/cooperate/plugin/src/input_event_transmission/ |
| H A D | input_event_interceptor.cpp | 222 if (ret != Channel<CooperateEvent>::NO_ERROR) {
in ReportPointerEvent()
|
| /base/msdp/device_status/test/unittest/intention/cooperate/src/ |
| H A D | cooperate_test.cpp | 45 Channel<CooperateEvent>::Sender g_sender;
|
| H A D | cooperate_plugin_test.cpp | 388 auto [sender, receiver] = Channel<CooperateEvent>::OpenChannel(); in HWTEST_F()
559 auto [sender, receiver] = Channel<CooperateEvent>::OpenChannel(); in HWTEST_F()
2772 Channel<CooperateEvent>::Sender sender; in HWTEST_F()
|
Completed in 12 milliseconds