| /third_party/flutter/engine/flutter/runtime/ |
| D | service_protocol.cc | 61 handlers_.emplace(handler, description); in AddHandler()
66 handlers_.erase(handler); in RemoveHandler()
72 auto it = handlers_.find(handler); in SetHandlerDescription()
73 if (it != handlers_.end()) in SetHandlerDescription()
184 if (handlers_.size() == 0) { in HandleMessage()
195 auto handler_found = handlers_.find(handler); in HandleMessage()
196 if (handler_found != handlers_.end()) { in HandleMessage()
207 return HandleMessageOnHandler(handlers_.begin()->first, method, params, in HandleMessage()
255 for (const auto& handler : handlers_) { in HandleListViewsMethod()
|
| D | service_protocol.h | 78 std::map<Handler*, fml::AtomicObject<Handler::Description>> handlers_; variable
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/invocation/ |
| D | prioritised_handlers.cpp | 23 handlers_.push(queued_handler(priority, function)); in add()
28 while (!handlers_.empty()) in execute_all()
30 queued_handler handler = handlers_.top(); in execute_all()
32 handlers_.pop(); in execute_all()
117 std::priority_queue<queued_handler> handlers_; member in handler_priority_queue
|
| /third_party/boost/libs/asio/example/cpp03/invocation/ |
| D | prioritised_handlers.cpp | 23 handlers_.push(queued_handler(priority, function)); in add()
28 while (!handlers_.empty()) in execute_all()
30 queued_handler handler = handlers_.top(); in execute_all()
32 handlers_.pop(); in execute_all()
117 std::priority_queue<queued_handler> handlers_; member in handler_priority_queue
|
| /third_party/boost/libs/asio/example/cpp11/invocation/ |
| D | prioritised_handlers.cpp | 28 handlers_.push(std::move(handler)); in add()
33 while (!handlers_.empty()) in execute_all()
35 handlers_.top()->execute(); in execute_all()
36 handlers_.pop(); in execute_all()
140 std::priority_queue<std::unique_ptr<queued_handler_base>> handlers_; member in handler_priority_queue
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/invocation/ |
| D | prioritised_handlers.cpp | 28 handlers_.push(std::move(handler)); in add()
33 while (!handlers_.empty()) in execute_all()
35 handlers_.top()->execute(); in execute_all()
36 handlers_.pop(); in execute_all()
140 std::priority_queue<std::unique_ptr<queued_handler_base>> handlers_; member in handler_priority_queue
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/executors/ |
| D | actor.cpp | 118 handlers_.push_back( in register_handler()
128 for (auto iter = handlers_.begin(); iter != handlers_.end(); ++iter) in deregister_handler()
135 handlers_.erase(iter); in deregister_handler()
161 for (auto& h: handlers_) in call_handler()
176 std::vector<std::shared_ptr<message_handler_base>> handlers_; member in actor
|
| /third_party/boost/libs/asio/example/cpp14/executors/ |
| D | actor.cpp | 118 handlers_.push_back( in register_handler()
128 for (auto iter = handlers_.begin(); iter != handlers_.end(); ++iter) in deregister_handler()
135 handlers_.erase(iter); in deregister_handler()
160 for (auto& h: handlers_) in call_handler()
175 std::vector<std::shared_ptr<message_handler_base>> handlers_; member in actor
|
| /third_party/boost/libs/asio/example/cpp11/executors/ |
| D | actor.cpp | 118 handlers_.push_back( in register_handler()
128 for (auto iter = handlers_.begin(); iter != handlers_.end(); ++iter) in deregister_handler()
135 handlers_.erase(iter); in deregister_handler()
161 for (auto& h: handlers_) in call_handler()
176 std::vector<std::shared_ptr<message_handler_base>> handlers_; member in actor
|
| /third_party/flutter/engine/flutter/shell/platform/common/cpp/client_wrapper/ |
| D | plugin_registrar.cc | 86 std::map<std::string, BinaryMessageHandler> handlers_; member in flutter::BinaryMessengerImpl
128 handlers_.erase(channel); in SetMessageHandler()
134 handlers_[channel] = std::move(handler); in SetMessageHandler()
135 BinaryMessageHandler* message_handler = &handlers_[channel]; in SetMessageHandler()
|
| /third_party/mindspore/mindspore/ccsrc/ps/ |
| D | parameter_server.cc | 576 handlers_[kInitWeightsCmd] = &ServerHandler::HandleInitWeights; in Init()
577 handlers_[kInitWeightToOptimIdCmd] = &ServerHandler::HandleInitWeightToOptimId; in Init()
578 handlers_[kInitOptimInputsShapeCmd] = &ServerHandler::HandleInitInputsShape; in Init()
579 handlers_[kInitEmbeddingsCmd] = &ServerHandler::HandleInitEmbeddings; in Init()
580 handlers_[kCheckReadyForPushCmd] = &ServerHandler::HandleCheckReadyForPush; in Init()
581 handlers_[kCheckReadyForPullCmd] = &ServerHandler::HandleCheckReadyForPull; in Init()
582 handlers_[kEmbeddingLookupCmd] = &ServerHandler::HandleEmbeddingLookup; in Init()
583 handlers_[kUpdateEmbeddingsCmd] = &ServerHandler::HandleUpdateEmbeddings; in Init()
584 handlers_[kFinalizeCmd] = &ServerHandler::HandleFinalize; in Init()
585 handlers_[kPushCmd] = &ServerHandler::HandlePushReq; in Init()
[all …]
|
| D | parameter_server.h | 114 std::unordered_map<int, RequestHandler> handlers_; variable
|
| /third_party/mindspore/mindspore/ccsrc/ps/core/ |
| D | scheduler_node.cc | 105 handlers_[NodeCommand::HEARTBEAT] = &SchedulerNode::ProcessHeartbeat; in InitCommandHandler()
106 handlers_[NodeCommand::REGISTER] = &SchedulerNode::ProcessRegister; in InitCommandHandler()
107 handlers_[NodeCommand::FINISH] = &SchedulerNode::ProcessFinish; in InitCommandHandler()
108 handlers_[NodeCommand::FETCH_METADATA] = &SchedulerNode::ProcessFetchMetadata; in InitCommandHandler()
109 handlers_[NodeCommand::SCALE_OUT_DONE] = &SchedulerNode::ProcessScaleOutDone; in InitCommandHandler()
110 handlers_[NodeCommand::SCALE_IN_DONE] = &SchedulerNode::ProcessScaleInDone; in InitCommandHandler()
111 handlers_[NodeCommand::SEND_EVENT] = &SchedulerNode::ProcessSendEvent; in InitCommandHandler()
123 if (handlers_.count(meta->cmd()) == 0) { in CreateTcpServer()
126 const auto &handler_ptr = handlers_[meta->cmd()]; in CreateTcpServer()
|
| D | abstract_node.cc | 825 if (handlers_.count(meta->cmd()) == 0) { in InitClientToScheduler()
828 if (handlers_[meta->cmd()] != nullptr) { in InitClientToScheduler()
829 const auto &handler_ptr = handlers_[meta->cmd()]; in InitClientToScheduler()
1034 handlers_[NodeCommand::HEARTBEAT] = &AbstractNode::ProcessHeartbeatResp; in InitCommandHandler()
1035 handlers_[NodeCommand::REGISTER] = &AbstractNode::ProcessRegisterResp; in InitCommandHandler()
1036 handlers_[NodeCommand::FETCH_METADATA] = &AbstractNode::ProcessFetchServersResp; in InitCommandHandler()
1037 handlers_[NodeCommand::FINISH] = nullptr; in InitCommandHandler()
1038 handlers_[NodeCommand::SCALE_OUT_DONE] = nullptr; in InitCommandHandler()
1039 handlers_[NodeCommand::SCALE_IN_DONE] = nullptr; in InitCommandHandler()
1040 handlers_[NodeCommand::SEND_EVENT] = nullptr; in InitCommandHandler()
|
| D | scheduler_node.h | 150 std::unordered_map<NodeCommand, ResponseHandler> handlers_; variable
|
| D | abstract_node.h | 236 std::unordered_map<NodeCommand, ResponseHandler> handlers_; variable
|
| /third_party/nghttp2/src/ |
| D | HttpServer.cc | 255 for (auto handler : handlers_) { in ~Sessions()
261 void add_handler(Http2Handler *handler) { handlers_.insert(handler); } in add_handler()
263 handlers_.erase(handler); in remove_handler()
264 if (handlers_.empty() && !fd_cache_.empty()) { in remove_handler()
410 bool handlers_empty() const { return handlers_.empty(); } in handlers_empty()
413 std::set<Http2Handler *> handlers_; member in nghttp2::Sessions
|