| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/callback/ |
| D | callback_manager.cc | 26 callbacks_.insert(callbacks_.end(), callbacks.begin(), callbacks.end()); in AddCallbacks()
33 enabled_ = !callbacks_.empty(); in Init()
36 for (auto &cb : callbacks_) { in Init()
48 for (size_t ind = 0; ind < callbacks_.size(); ind++) { in Begin()
49 if (callbacks_[ind]->IsBeginNeeded()) callback_inds.push_back(ind); in Begin()
58 RETURN_IF_NOT_OK(callbacks_[ind]->DSBegin(cb_param)); in Begin()
68 for (size_t ind = 0; ind < callbacks_.size(); ind++) { in EpochBegin()
69 if (callbacks_[ind]->IsEpochBeginNeeded()) callback_inds.push_back(ind); in EpochBegin()
78 RETURN_IF_NOT_OK(callbacks_[ind]->DSEpochBegin(cb_param)); in EpochBegin()
88 for (size_t ind = 0; ind < callbacks_.size(); ind++) { in StepBegin()
[all …]
|
| D | callback_manager.h | 45 void ClearCallbacks() { callbacks_.clear(); } in ClearCallbacks()
79 …std::vector<std::shared_ptr<DSCallback>> callbacks_; // list of callbacks the DatasetOp needs to… variable
|
| /third_party/cef/include/base/ |
| D | cef_callback_list.h | 198 callbacks_.insert(callbacks_.end(), std::move(cb))));
209 callbacks_.push_back(std::move(cb));
221 return std::all_of(callbacks_.cbegin(), callbacks_.cend(),
253 return std::find_if_not(it, callbacks_.end(), [](const auto& callback) {
257 for (auto it = next_valid(callbacks_.begin()); it != callbacks_.end();
274 EraseIf(callbacks_, [](const auto& cb) { return cb.is_null(); });
291 Callbacks callbacks_;
306 callbacks_.erase(it);
336 null_callbacks_.splice(null_callbacks_.end(), this->callbacks_, it);
|
| /third_party/flutter/engine/flutter/shell/platform/common/cpp/ |
| D | incoming_message_dispatcher.cc | 22 if (callbacks_.find(channel) == callbacks_.end()) { in HandleMessage()
27 auto& callback_info = callbacks_[channel]; in HandleMessage()
46 callbacks_.erase(channel); in SetMessageCallback()
49 callbacks_[channel] = std::make_pair(callback, user_data); in SetMessageCallback()
|
| D | incoming_message_dispatcher.h | 69 callbacks_; variable
|
| /third_party/gstreamer/gstplugins_bad/sys/wasapi/ |
| D | gstmmdeviceenumerator.cpp | 52 self->callbacks_ = *callbacks; in CreateInstance()
112 if (!callbacks_.device_state_changed) in OnDeviceStateChanged()
119 hr = callbacks_.device_state_changed (listener, device_id, new_state, in OnDeviceStateChanged()
132 if (!callbacks_.device_added) in OnDeviceAdded()
139 hr = callbacks_.device_added (listener, device_id, user_data_); in OnDeviceAdded()
151 if (!callbacks_.device_removed) in OnDeviceRemoved()
158 hr = callbacks_.device_removed (listener, device_id, user_data_); in OnDeviceRemoved()
170 if (!callbacks_.default_device_changed) in OnDefaultDeviceChanged()
177 hr = callbacks_.default_device_changed (listener, in OnDefaultDeviceChanged()
190 if (!callbacks_.property_value_changed) in OnPropertyValueChanged()
[all …]
|
| /third_party/boost/libs/dll/example/tutorial6/ |
| D | on_unload_lib.cpp | 23 for (std::size_t i = 0; i < callbacks_.size(); ++i) { in ~on_unload()
24 callback_t& function = callbacks_[i]; in ~on_unload()
32 instance.callbacks_.push_back(function); in add()
36 std::vector<callback_t> callbacks_; member
|
| /third_party/flutter/engine/flutter/runtime/ |
| D | dart_service_isolate.cc | 52 DartServiceIsolate::callbacks_;
71 for (auto& callback : callbacks_) { in NotifyServerState()
95 callbacks_.insert(std::move(callback_pointer)); in AddServerStatusCallback()
109 callbacks_.begin(), callbacks_.end(), in RemoveServerStatusCallback()
114 if (found == callbacks_.end()) { in RemoveServerStatusCallback()
118 callbacks_.erase(found); in RemoveServerStatusCallback()
|
| D | dart_service_isolate.h | 49 static std::set<std::unique_ptr<ObservatoryServerStateCallback>> callbacks_
|
| /third_party/grpc/src/cpp/server/ |
| D | dynamic_thread_pool.cc | 57 if (!shutdown_ && callbacks_.empty()) { in ThreadFunc()
68 if (!callbacks_.empty()) { in ThreadFunc()
69 auto cb = callbacks_.front(); in ThreadFunc()
70 callbacks_.pop(); in ThreadFunc()
110 callbacks_.push(callback); in Add()
|
| D | dynamic_thread_pool.h | 56 std::queue<std::function<void()>> callbacks_; variable
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/ir/datasetops/ |
| D | map_node.cc | 44 callbacks_(callbacks) { in MapNode()
51 callbacks_); in Copy()
86 if (!callbacks_.empty()) { in Build()
87 map_op->AddCallbacks(callbacks_); in Build()
182 (void)std::transform(callbacks_.begin(), callbacks_.end(), std::back_inserter(cbs), in to_json()
|
| D | map_node.h | 74 void ClearCallbacks() { callbacks_.clear(); } in ClearCallbacks()
89 const std::vector<std::shared_ptr<DSCallback>> &Callbacks() const { return callbacks_; } in Callbacks()
120 std::vector<std::shared_ptr<DSCallback>> callbacks_; variable
|
| /third_party/cef/libcef/browser/osr/ |
| D | video_consumer_osr.cc | 22 : callbacks_(std::move(callbacks)) {} in ScopedVideoFrameDone()
23 ~ScopedVideoFrameDone() { callbacks_->Done(); } in ~ScopedVideoFrameDone()
26 mojo::Remote<viz::mojom::FrameSinkVideoConsumerFrameCallbacks> callbacks_; member in __anon736617740111::ScopedVideoFrameDone
|
| /third_party/mindspore/mindspore/ccsrc/ps/core/ |
| D | scheduler_node.cc | 1023 callbacks_["/scaleout"] = scale_out; in StartRestfulServer()
1024 http_server_->RegisterRoute("/scaleout", &callbacks_["/scaleout"]); in StartRestfulServer()
1027 callbacks_["/scalein"] = scale_in; in StartRestfulServer()
1028 http_server_->RegisterRoute("/scalein", &callbacks_["/scalein"]); in StartRestfulServer()
1031 callbacks_["/nodes"] = nodes; in StartRestfulServer()
1032 http_server_->RegisterRoute("/nodes", &callbacks_["/nodes"]); in StartRestfulServer()
1035 callbacks_["/state"] = cluster_state; in StartRestfulServer()
1036 http_server_->RegisterRoute("/state", &callbacks_["/state"]); in StartRestfulServer()
1039 callbacks_["/newInstance"] = new_instance; in StartRestfulServer()
1040 http_server_->RegisterRoute("/newInstance", &callbacks_["/newInstance"]); in StartRestfulServer()
[all …]
|
| D | scheduler_node.h | 165 std::unordered_map<std::string, OnRequestReceive> callbacks_; variable
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/wpa_supplicant/binder/ |
| D | supplicant.h | 50 callbacks_; variable
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/wpa_supplicant/binder/ |
| D | supplicant.h | 50 callbacks_; variable
|
| /third_party/node/src/ |
| D | node_http2.cc | 412 nghttp2_session_callbacks* callbacks_; in Callbacks() local
413 CHECK_EQ(nghttp2_session_callbacks_new(&callbacks_), 0); in Callbacks()
414 callbacks.reset(callbacks_); in Callbacks()
417 callbacks_, OnBeginHeadersCallback); in Callbacks()
419 callbacks_, OnHeaderCallback); in Callbacks()
421 callbacks_, OnFrameReceive); in Callbacks()
423 callbacks_, OnStreamClose); in Callbacks()
425 callbacks_, OnDataChunkReceived); in Callbacks()
427 callbacks_, OnFrameNotSent); in Callbacks()
429 callbacks_, OnInvalidHeader); in Callbacks()
[all …]
|
| /third_party/nghttp2/src/ |
| D | HttpServer.cc | 234 callbacks_(nullptr), in Sessions()
239 nghttp2_session_callbacks_new(&callbacks_); in Sessions()
241 fill_callback(callbacks_, config_); in Sessions()
259 nghttp2_session_callbacks_del(callbacks_); in ~Sessions()
295 const nghttp2_session_callbacks *get_callbacks() const { return callbacks_; } in get_callbacks()
421 nghttp2_session_callbacks *callbacks_; member in nghttp2::Sessions
|
| /third_party/flutter/flutter/packages/flutter/lib/src/scheduler/ |
| D | binding.dart | 176 /// * _Transient callbacks_, triggered by the system's [Window.onBeginFrame]
181 /// * _Persistent callbacks_, triggered by the system's [Window.onDrawFrame]
186 /// * _Post-frame callbacks_, which are run after persistent callbacks, just
|
| /third_party/chromium/patch/ |
| D | 0003-3.2-Beta3-1115.patch | 38933 callbacks_.insert(std::make_pair(id, std::move(callback)));
|