Home
last modified time | relevance | path

Searched refs:MessageHandler (Results 1 – 25 of 41) sorted by relevance

12

/third_party/mindspore/mindspore/ccsrc/ps/core/communicator/
Dmessage_handler.h25 class MessageHandler {
27 MessageHandler() = default;
28 virtual ~MessageHandler() = default;
Dcommunicator_base.h66 using MessageCallback = std::function<void(std::shared_ptr<MessageHandler>)>;
83 …bool SendResponse(const void *rsp_data, size_t rsp_len, const std::shared_ptr<MessageHandler> &msg…
Dcommunicator_base.cc29 const std::shared_ptr<MessageHandler> &msg_handler) { in SendResponse()
Dhttp_msg_handler.h28 class HttpMsgHandler : public MessageHandler {
Dtcp_msg_handler.h29 class TcpMsgHandler : public MessageHandler {
/third_party/flutter/flutter/packages/flutter/lib/src/services/
Dbinary_messenger.dart12 typedef MessageHandler = Future<ByteData> Function(ByteData message);
69 static final Map<String, MessageHandler> _handlers =
70 <String, MessageHandler>{};
74 static final Map<String, MessageHandler> _mockHandlers =
75 <String, MessageHandler>{};
108 final MessageHandler handler = _handlers[channel];
126 final MessageHandler handler = _mockHandlers[channel];
133 void setMessageHandler(String channel, MessageHandler handler) {
141 void setMockMessageHandler(String channel, MessageHandler handler) {
/third_party/mindspore/mindspore/ccsrc/fl/server/
Diteration.h158 void HandleSyncIterationRequest(const std::shared_ptr<ps::core::MessageHandler> &message);
166 …void HandleNotifyLeaderMoveToNextIterRequest(const std::shared_ptr<ps::core::MessageHandler> &mess…
170 void HandlePrepareForNextIterRequest(const std::shared_ptr<ps::core::MessageHandler> &message);
176 void HandleMoveToNextIterRequest(const std::shared_ptr<ps::core::MessageHandler> &message);
182 void HandleEndLastIterRequest(const std::shared_ptr<ps::core::MessageHandler> &message);
Dserver.h142 void HandleEnableServerRequest(const std::shared_ptr<ps::core::MessageHandler> &message);
143 void HandleDisableServerRequest(const std::shared_ptr<ps::core::MessageHandler> &message);
146 void HandleNewInstanceRequest(const std::shared_ptr<ps::core::MessageHandler> &message);
149 void HandleQueryInstanceRequest(const std::shared_ptr<ps::core::MessageHandler> &message);
Dround.h54 void LaunchRoundKernel(const std::shared_ptr<ps::core::MessageHandler> &message);
66 void OnFirstCountEvent(const std::shared_ptr<ps::core::MessageHandler> &message);
67 void OnLastCountEvent(const std::shared_ptr<ps::core::MessageHandler> &message);
Ddistributed_count_service.h94 void HandleCountRequest(const std::shared_ptr<ps::core::MessageHandler> &message);
98 void HandleCountReachThresholdRequest(const std::shared_ptr<ps::core::MessageHandler> &message);
102 void HandleCounterEvent(const std::shared_ptr<ps::core::MessageHandler> &message);
Dround.cc43 communicator_->RegisterMsgCallBack(name_, [&](std::shared_ptr<ps::core::MessageHandler> message) { in Initialize()
128 void Round::LaunchRoundKernel(const std::shared_ptr<ps::core::MessageHandler> &message) { in LaunchRoundKernel()
187 void Round::OnFirstCountEvent(const std::shared_ptr<ps::core::MessageHandler> &message) { in OnFirstCountEvent()
201 void Round::OnLastCountEvent(const std::shared_ptr<ps::core::MessageHandler> &message) { in OnLastCountEvent()
Ddistributed_metadata_store.h83 void HandleUpdateMetadataRequest(const std::shared_ptr<ps::core::MessageHandler> &message);
86 void HandleGetMetadataRequest(const std::shared_ptr<ps::core::MessageHandler> &message);
Ddistributed_count_service.cc191 void DistributedCountService::HandleCountRequest(const std::shared_ptr<ps::core::MessageHandler> &m… in HandleCountRequest()
249 const std::shared_ptr<ps::core::MessageHandler> &message) { in HandleCountReachThresholdRequest()
271 void DistributedCountService::HandleCounterEvent(const std::shared_ptr<ps::core::MessageHandler> &m… in HandleCounterEvent()
/third_party/flutter/engine/flutter/shell/platform/android/io/flutter/plugin/common/
DBasicMessageChannel.java100 public void setMessageHandler(@Nullable final MessageHandler<T> handler) { in setMessageHandler()
108 public interface MessageHandler<T> { interface in BasicMessageChannel
162 private final MessageHandler<T> handler;
164 private IncomingMessageHandler(@NonNull MessageHandler<T> handler) { in IncomingMessageHandler()
/third_party/mindspore/mindspore/ccsrc/fl/server/kernel/round/
Dround_kernel.h71 virtual void OnFirstCountEvent(const std::shared_ptr<ps::core::MessageHandler> &message);
72 virtual void OnLastCountEvent(const std::shared_ptr<ps::core::MessageHandler> &message);
Dreconstruct_secrets_kernel.cc31 auto last_cnt_handler = [&](std::shared_ptr<ps::core::MessageHandler>) { in InitKernel() argument
39 auto first_cnt_handler = [&](std::shared_ptr<ps::core::MessageHandler>) { return; }; in InitKernel() argument
118 void ReconstructSecretsKernel::OnLastCountEvent(const std::shared_ptr<ps::core::MessageHandler> &) { in OnLastCountEvent() argument
Dround_kernel.cc64 void RoundKernel::OnFirstCountEvent(const std::shared_ptr<ps::core::MessageHandler> &) { return; } in OnFirstCountEvent() argument
66 void RoundKernel::OnLastCountEvent(const std::shared_ptr<ps::core::MessageHandler> &) { return; } in OnLastCountEvent() argument
Dreconstruct_secrets_kernel.h42 void OnLastCountEvent(const std::shared_ptr<ps::core::MessageHandler> &message) override;
Dpush_metrics_kernel.h42 void OnLastCountEvent(const std::shared_ptr<ps::core::MessageHandler> &message) override;
/third_party/flutter/engine/flutter/shell/platform/common/cpp/client_wrapper/include/flutter/
Dbasic_message_channel.h27 using MessageHandler = variable
64 void SetMessageHandler(MessageHandler<T> handler) const { in SetMessageHandler()
/third_party/flutter/flutter/examples/flutter_view/android/app/src/main/java/com/example/view/
DMainActivity.java11 import io.flutter.plugin.common.BasicMessageChannel.MessageHandler;
71 setMessageHandler(new MessageHandler<String>() { in onCreate()
/third_party/flutter/engine/flutter/shell/platform/android/io/flutter/embedding/engine/systemchannels/
DAccessibilityChannel.java31 …private final BasicMessageChannel.MessageHandler<Object> parsingMessageHandler = new BasicMessageC…
/third_party/mindspore/mindspore/core/mindrt/include/async/
Dasync.h32 using MessageHandler = std::function<void(ActorBase *)>; variable
36 explicit MessageAsync(MessageHandler &&h) : MessageBase("Async", Type::KASYNC), handler(h) {} in MessageAsync()
41 MessageHandler handler;
69 MessageHandler handler = [=](ActorBase *) { promise->Associate(f()); };
/third_party/flutter/engine/flutter/shell/platform/windows/
Dwin32_window.cc99 return that->MessageHandler(window, message, wparam, lparam); in WndProc()
106 Win32Window::MessageHandler(HWND hwnd, in MessageHandler() function in flutter::Win32Window
/third_party/mindspore/mindspore/ccsrc/fl/server/kernel/
Dfed_avg_kernel.h78 first_cnt_handler_ = [&](std::shared_ptr<ps::core::MessageHandler>) { in InitKernel()
84 last_cnt_handler_ = [&](std::shared_ptr<ps::core::MessageHandler>) { in InitKernel()

12