Home
last modified time | relevance | path

Searched refs:Channel (Results 1 - 15 of 15) sorted by relevance

/base/msdp/device_status/intention/common/channel/include/
H A Dchannel.h30 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 Dchannel_test.cpp51 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 Dcooperate.cpp36 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 Dcooperate_context.cpp40 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 Dstate_machine.cpp43 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 Dcooperate_in.cpp423 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 Ddsoftbus_handler.cpp87 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 Dcooperate_context.h50 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 Dstate_machine.h45 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 Ddsoftbus_handler.h69 void AttachSender(Channel<CooperateEvent>::Sender sender);
104 Channel<CooperateEvent>::Sender sender_;
H A Dcooperate.h70 Channel<CooperateEvent>::Receiver receiver_;
/base/msdp/device_status/intention/cooperate/plugin/include/input_event_transmission/
H A Dinput_event_interceptor.h55 Channel<CooperateEvent>::Sender sender_;
/base/msdp/device_status/intention/cooperate/plugin/src/input_event_transmission/
H A Dinput_event_interceptor.cpp222 if (ret != Channel<CooperateEvent>::NO_ERROR) { in ReportPointerEvent()
/base/msdp/device_status/test/unittest/intention/cooperate/src/
H A Dcooperate_test.cpp45 Channel<CooperateEvent>::Sender g_sender;
H A Dcooperate_plugin_test.cpp388 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