Home
last modified time | relevance | path

Searched refs:Sender (Results 1 - 18 of 18) sorted by relevance

/base/msdp/device_status/intention/common/channel/include/
H A Dchannel.h44 class Sender final {
48 Sender() = default;
49 ~Sender() = default;
51 Sender(const Sender &other) in Sender() function in OHOS::Msdp::DeviceStatus::Channel::final
55 Sender(Sender &&other) in Sender() function in OHOS::Msdp::DeviceStatus::Channel::final
61 Sender& operator=(const Sender &other) in operator =()
67 Sender
83 Sender(std::shared_ptr<Channel<Event>> channel) Sender() function in OHOS::Msdp::DeviceStatus::Channel::final
[all...]
/base/msdp/device_status/intention/cooperate/plugin/src/
H A Dcooperate.cpp53 auto ret = context_.Sender().Send(CooperateEvent( in AddObserver()
66 auto ret = context_.Sender().Send(CooperateEvent( in RemoveObserver()
79 auto ret = context_.Sender().Send(CooperateEvent( in RegisterListener()
93 auto ret = context_.Sender().Send(CooperateEvent( in UnregisterListener()
107 auto ret = context_.Sender().Send(CooperateEvent( in RegisterHotAreaListener()
121 auto ret = context_.Sender().Send(CooperateEvent( in UnregisterHotAreaListener()
135 auto ret = context_.Sender().Send(CooperateEvent( in Enable()
151 auto ret = context_.Sender().Send(CooperateEvent( in Disable()
180 auto ret = context_.Sender().Send(CooperateEvent(CooperateEventType::START, event)); in Start()
190 auto ret = context_.Sender() in Stop()
[all...]
H A Dstate_machine.cpp43 StateMachine::AppStateObserver::AppStateObserver(Channel<CooperateEvent>::Sender sender, int32_t clientPid) in AppStateObserver()
501 int32_t StateMachine::RegisterApplicationStateObserver(Channel<CooperateEvent>::Sender sender, in RegisterApplicationStateObserver()
544 RegisterApplicationStateObserver(context.Sender(), event); in AddSessionObserver()
599 auto ret = context.Sender().Send(CooperateEvent( in OnCommonEvent()
608 [sender = context.Sender(), this]() mutable { in OnCommonEvent()
647 auto ret = context.Sender().Send(CooperateEvent( in AddMonitor()
H A Dcooperate_context.cpp40 explicit BoardObserver(Channel<CooperateEvent>::Sender sender) : sender_(sender) {} in BoardObserver()
71 Channel<CooperateEvent>::Sender sender_;
109 void Context::AttachSender(Channel<CooperateEvent>::Sender sender) in AttachSender()
H A Dcooperate_in.cpp422 auto ret = context.Sender().Send(event); in OnRemoteStart()
430 [sender = context.Sender(), event]() mutable { in OnRemoteStart()
446 auto ret = context.Sender().Send(event); in OnRemoteStop()
575 [sender = context.Sender(), remoteNetworkId = context.Peer()]() mutable { in OnProgress()
H A Ddsoftbus_handler.cpp87 void DSoftbusHandler::AttachSender(Channel<CooperateEvent>::Sender sender) in AttachSender()
/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() function in OHOS::Msdp::DeviceStatus::Cooperate::Context
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_;
/base/request/request/services/src/service/run_count/
H A Dmod.rs22 use ylong_runtime::sync::oneshot::Sender;
29 Subscribe(u64, RemoteObj, Sender<ErrorCode>),
30 Unsubscribe(u64, Sender<ErrorCode>),
H A Dmanager.rs17 use ylong_runtime::sync::oneshot::{self, Sender};
115 fn subscribe_run_count(&mut self, pid: u64, obj: RemoteObj, tx: Sender<ErrorCode>) { in subscribe_run_count()
124 fn unsubscribe_run_count(&mut self, subscribe_pid: u64, tx: Sender<ErrorCode>) { in unsubscribe_run_count()
/base/request/request/services/src/manage/events/
H A Dmod.rs16 use ylong_runtime::sync::oneshot::{channel, Sender};
127 Query(u32, Action, Sender<Option<TaskInfo>>),
128 Show(u32, u64, Sender<Option<TaskInfo>>),
129 Touch(u32, u64, String, Sender<Option<TaskInfo>>),
133 Construct(Box<ConstructMessage>, Sender<Result<u32, ErrorCode>>),
134 Pause(u64, u32, Sender<ErrorCode>),
135 Start(u64, u32, Sender<ErrorCode>),
136 Stop(u64, u32, Sender<ErrorCode>),
137 Remove(u64, u32, Sender<ErrorCode>),
138 Resume(u64, u32, Sender<ErrorCod
[all...]
/base/request/request/services/src/service/client/
H A Dmanager.rs17 use ylong_runtime::sync::oneshot::Sender;
131 fn handle_open_channel(&mut self, pid: u64, tx: Sender<Result<i32, ErrorCode>>) { in handle_open_channel()
155 tx: Sender<ErrorCode>, in handle_subscribe()
166 fn handle_unsubscribe(&mut self, tid: u32, tx: Sender<ErrorCode>) { in handle_unsubscribe()
190 fn handle_process_terminated(&mut self, pid: u64, tx: Sender<ErrorCode>) { in handle_process_terminated()
H A Dmod.rs24 use ylong_runtime::sync::oneshot::{channel, Sender};
36 OpenChannel(u64, Sender<Result<i32, ErrorCode>>),
37 Subscribe(u32, u64, u64, u64, Sender<ErrorCode>),
38 Unsubscribe(u32, Sender<ErrorCode>),
40 Terminate(u64, Sender<ErrorCode>),
/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.cpp67 sender_ = context.Sender(); in Enable()
/base/msdp/device_status/test/unittest/intention/cooperate/src/
H A Dcooperate_test.cpp45 Channel<CooperateEvent>::Sender g_sender;
H A Dcooperate_plugin_test.cpp2772 Channel<CooperateEvent>::Sender sender; in HWTEST_F()

Completed in 13 milliseconds