| /external/tensorflow/tensorflow/python/distribute/coordinator/ |
| D | cluster_coordinator_test.py | 34 from tensorflow.python.distribute.coordinator import cluster_coordinator as coordinator_lib
49 from tensorflow.python.training import coordinator
72 coord = coordinator.Coordinator(clean_stop_exception_types=[])
120 coord = coordinator.Coordinator(clean_stop_exception_types=[])
141 coord = coordinator.Coordinator(clean_stop_exception_types=[])
169 coord = coordinator.Coordinator(clean_stop_exception_types=[])
450 cls.coordinator = make_coordinator(num_workers=3, num_ps=2)
451 cls.strategy = cls.coordinator.strategy
460 got = self.coordinator.schedule(f)
463 self.assertEqual(self.coordinator.fetch(got), want)
[all …]
|
| /external/glide/library/src/main/java/com/bumptech/glide/request/ |
| D | ThumbnailRequestCoordinator.java | 10 private RequestCoordinator coordinator; field in ThumbnailRequestCoordinator
16 public ThumbnailRequestCoordinator(RequestCoordinator coordinator) { in ThumbnailRequestCoordinator() argument
17 this.coordinator = coordinator; in ThumbnailRequestCoordinator()
38 return coordinator == null || coordinator.canSetImage(this); in parentCanSetImage()
53 return coordinator == null || coordinator.canNotifyStatusChanged(this); in parentCanNotifyStatusChanged()
62 return coordinator != null && coordinator.isAnyResourceSet(); in parentIsAnyResourceSet()
|
| /external/tensorflow/tensorflow/python/training/ |
| D | coordinator_test.py | 27 from tensorflow.python.training import coordinator
75 coord = coordinator.Coordinator()
83 coord = coordinator.Coordinator()
99 coord = coordinator.Coordinator()
112 coord = coordinator.Coordinator()
126 coord = coordinator.Coordinator()
143 coord = coordinator.Coordinator()
165 coord = coordinator.Coordinator()
181 coord = coordinator.Coordinator()
201 coord = coordinator.Coordinator()
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-window_toggle.hpp | 96 , coordinator(std::move(c)) in window_toggle_subscriber_values()
97 , worker(coordinator.get_worker()) in window_toggle_subscriber_values()
102 coordinator_type coordinator; member
126 [&](){return localState->coordinator.in(localState->openings);}, in window_toggle_observer()
155 auto source = localState->coordinator.in(closer); in window_toggle_observer()
185 auto selectedSink = localState->coordinator.out(sink); in window_toggle_observer()
197 [&](){return localState->coordinator.out(sink);}, in window_toggle_observer()
213 [&](){return localState->coordinator.act(work);}, in on_next()
230 [&](){return localState->coordinator.act(work);}, in on_error()
247 [&](){return localState->coordinator.act(work);}, in on_completed()
[all …]
|
| D | rx-timeout.hpp | 91 , coordinator(std::move(c)) in timeout_subscriber_values()
92 , worker(coordinator.get_worker()) in timeout_subscriber_values()
99 coordinator_type coordinator; member
117 [&](){ return localState->coordinator.act(disposer); }, in timeout_observer()
137 [&](){return localState->coordinator.act(work);}, in timeout_observer()
154 [&](){ return state->coordinator.act(produce); }, in produce_timeout()
173 [&](){return localState->coordinator.act(work);}, in on_next()
187 [&](){ return localState->coordinator.act(work); }, in on_error()
201 [&](){ return localState->coordinator.act(work); }, in on_completed()
211 auto coordinator = v.coordination.create_coordinator(); in make() local
[all …]
|
| D | rx-switch_on_next.hpp | 92 , coordinator(std::move(coor)) in on_subscribe()
100 coordinator_type coordinator; in on_subscribe() member
105 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe() local
108 …auto state = std::make_shared<switch_state_type>(initial, std::move(coordinator), std::move(scbr)); in on_subscribe()
117 [&](){return state->coordinator.in(state->source);}, in on_subscribe()
146 auto selectedSource = state->coordinator.in(st); in on_subscribe()
169 auto selectedSinkInner = state->coordinator.out(sinkInner); in on_subscribe()
186 [&](){return state->coordinator.out(sink);}, in on_subscribe()
|
| D | rx-sample_time.hpp | 82 , coordinator(std::move(c)) in sample_with_time_subscriber_value()
83 , worker(coordinator.get_worker()) in sample_with_time_subscriber_value()
88 coordinator_type coordinator; member
105 [&](){ return localState->coordinator.act(disposer); }, in sample_with_time_observer()
125 [&](){ return localState->coordinator.act(produce_sample); }, in sample_with_time_observer()
145 [&](){ return localState->coordinator.act(work); }, in on_next()
159 [&](){ return localState->coordinator.act(work); }, in on_error()
173 [&](){ return localState->coordinator.act(work); }, in on_completed()
183 auto coordinator = v.coordination.create_coordinator(); in make() local
185 … return make_subscriber<T>(cs, this_type(cs, std::move(d), std::move(v), std::move(coordinator))); in make()
|
| D | rx-buffer_time_count.hpp | 90 , coordinator(std::move(c)) in buffer_with_time_or_count_subscriber_values()
91 , worker(coordinator.get_worker()) in buffer_with_time_or_count_subscriber_values()
97 coordinator_type coordinator; member
118 [&](){return localState->coordinator.act(disposer);}, in buffer_with_time_or_count_observer()
157 [&](){return state->coordinator.act(produce);}, in produce_buffer()
175 [&](){return localState->coordinator.act(work);}, in on_next()
188 [&](){return localState->coordinator.act(work);}, in on_error()
202 [&](){return localState->coordinator.act(work);}, in on_completed()
212 auto coordinator = v.coordination.create_coordinator(); in make() local
214 … return make_subscriber<T>(cs, this_type(cs, std::move(d), std::move(v), std::move(coordinator))); in make()
|
| D | rx-window_time_count.hpp | 90 , coordinator(std::move(c)) in window_with_time_or_count_subscriber_values()
91 , worker(coordinator.get_worker()) in window_with_time_or_count_subscriber_values()
98 coordinator_type coordinator; member
120 [&](){return localState->coordinator.act(disposer);}, in window_with_time_or_count_observer()
160 [&](){return state->coordinator.act(release);}, in release_window()
178 [&](){return localState->coordinator.act(work);}, in on_next()
193 [&](){return localState->coordinator.act(work);}, in on_error()
208 [&](){return localState->coordinator.act(work);}, in on_completed()
218 auto coordinator = v.coordination.create_coordinator(); in make() local
220 …ubscriber<T>(cs, observer_type(this_type(cs, std::move(d), std::move(v), std::move(coordinator)))); in make()
|
| D | rx-debounce.hpp | 83 , coordinator(std::move(c)) in debounce_subscriber_values()
84 , worker(coordinator.get_worker()) in debounce_subscriber_values()
91 coordinator_type coordinator; member
110 [&](){ return localState->coordinator.act(disposer); }, in debounce_observer()
134 [&](){ return state->coordinator.act(produce); }, in produce_item()
153 [&](){return localState->coordinator.act(work);}, in on_next()
168 [&](){ return localState->coordinator.act(work); }, in on_error()
185 [&](){ return localState->coordinator.act(work); }, in on_completed()
195 auto coordinator = v.coordination.create_coordinator(); in make() local
197 …ubscriber<T>(cs, observer_type(this_type(cs, std::move(d), std::move(v), std::move(coordinator)))); in make()
|
| D | rx-delay.hpp | 82 , coordinator(std::move(c)) in delay_subscriber_values()
83 , worker(coordinator.get_worker()) in delay_subscriber_values()
89 coordinator_type coordinator; member
106 [&](){return localState->coordinator.act(disposer);}, in delay_observer()
126 [&](){return localState->coordinator.act(work);}, in on_next()
140 [&](){return localState->coordinator.act(work);}, in on_error()
154 [&](){return localState->coordinator.act(work);}, in on_completed()
164 auto coordinator = v.coordination.create_coordinator(); in make() local
166 …ubscriber<T>(cs, observer_type(this_type(cs, std::move(d), std::move(v), std::move(coordinator)))); in make()
|
| D | rx-buffer_time.hpp | 108 , coordinator(std::move(c)) in buffer_with_time_subscriber_values()
109 , worker(coordinator.get_worker()) in buffer_with_time_subscriber_values()
115 coordinator_type coordinator; member
133 [&](){return localState->coordinator.act(disposer);}, in buffer_with_time_observer()
157 [&](){return localState->coordinator.act(produce_buffer);}, in buffer_with_time_observer()
172 [&](){return localState->coordinator.act(create_buffer);}, in buffer_with_time_observer()
193 [&](){return localState->coordinator.act(work);}, in on_next()
206 [&](){return localState->coordinator.act(work);}, in on_error()
228 [&](){return localState->coordinator.act(work);}, in on_completed()
238 auto coordinator = v.coordination.create_coordinator(); in make() local
[all …]
|
| D | rx-window_time.hpp | 100 , coordinator(std::move(c)) in window_with_time_subscriber_values()
101 , worker(coordinator.get_worker()) in window_with_time_subscriber_values()
107 coordinator_type coordinator; member
125 [&](){return localState->coordinator.act(disposer);}, in window_with_time_observer()
151 [&](){return localState->coordinator.act(release_window);}, in window_with_time_observer()
168 [&](){return localState->coordinator.act(create_window);}, in window_with_time_observer()
190 [&](){return localState->coordinator.act(work);}, in on_next()
207 [&](){return localState->coordinator.act(work);}, in on_error()
224 [&](){return localState->coordinator.act(work);}, in on_completed()
234 auto coordinator = v.coordination.create_coordinator(); in make() local
[all …]
|
| D | rx-merge.hpp | 113 , coordinator(std::move(coor)) in on_subscribe()
121 coordinator_type coordinator; in on_subscribe() member
125 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe() local
128 … auto state = std::make_shared<merge_state_type>(initial, std::move(coordinator), std::move(scbr)); in on_subscribe()
137 [&](){return state->coordinator.in(state->source);}, in on_subscribe()
163 auto selectedSource = state->coordinator.in(st); in on_subscribe()
187 auto selectedSinkInner = state->coordinator.out(sinkInner); in on_subscribe()
202 [&](){return state->coordinator.out(sink);}, in on_subscribe()
|
| D | rx-take_until.hpp | 106 , coordinator(std::move(coor)) in on_subscribe()
115 coordinator_type coordinator; in on_subscribe() member
119 auto coordinator = initial.coordination.create_coordinator(s.get_subscription()); in on_subscribe() local
122 …auto state = std::make_shared<take_until_state_type>(initial, std::move(coordinator), std::move(s)… in on_subscribe()
125 [&](){return state->coordinator.in(state->trigger);}, in on_subscribe()
132 [&](){return state->coordinator.in(state->source);}, in on_subscribe()
162 [&](){return state->coordinator.out(sinkTrigger);}, in on_subscribe()
195 [&](){return state->coordinator.out(sinkSource);}, in on_subscribe()
|
| D | rx-merge_delay_error.hpp | 106 , coordinator(std::move(coor)) in on_subscribe()
115 coordinator_type coordinator; in on_subscribe() member
119 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe() local
122 … auto state = std::make_shared<merge_state_type>(initial, std::move(coordinator), std::move(scbr)); in on_subscribe()
131 [&](){return state->coordinator.in(state->source);}, in on_subscribe()
157 auto selectedSource = state->coordinator.in(st); in on_subscribe()
191 auto selectedSinkInner = state->coordinator.out(sinkInner); in on_subscribe()
216 [&](){return state->coordinator.out(sink);}, in on_subscribe()
|
| D | rx-amb.hpp | 108 , coordinator(std::move(coor)) in on_subscribe()
115 coordinator_type coordinator; in on_subscribe() member
122 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe() local
125 … auto state = std::make_shared<amb_state_type>(initial, std::move(coordinator), std::move(scbr)); in on_subscribe()
134 [&](){return state->coordinator.in(state->source);}, in on_subscribe()
164 auto selectedSource = state->coordinator.in(st); in on_subscribe()
195 auto selectedSinkInner = state->coordinator.out(sinkInner); in on_subscribe()
210 [&](){return state->coordinator.out(sink);}, in on_subscribe()
|
| D | rx-concat.hpp | 110 , coordinator(std::move(coor)) in on_subscribe()
130 [&](){return state->coordinator.in(std::move(st));}, in on_subscribe()
162 [&](){return state->coordinator.out(sinkInner);}, in on_subscribe()
173 coordinator_type coordinator; in on_subscribe() member
177 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe() local
180 …auto state = std::make_shared<concat_state_type>(initial, std::move(coordinator), std::move(scbr)); in on_subscribe()
189 [&](){return state->coordinator.in(state->source);}, in on_subscribe()
221 [&](){return state->coordinator.out(sink);}, in on_subscribe()
|
| D | rx-skip_until.hpp | 96 , coordinator(std::move(coor)) in on_subscribe()
105 coordinator_type coordinator; in on_subscribe() member
109 auto coordinator = initial.coordination.create_coordinator(); in on_subscribe() local
112 auto state = std::make_shared<state_type>(initial, std::move(coordinator), std::move(s)); in on_subscribe()
115 [&](){return state->coordinator.in(state->trigger);}, in on_subscribe()
122 [&](){return state->coordinator.in(state->source);}, in on_subscribe()
159 [&](){return state->coordinator.out(sinkTrigger);}, in on_subscribe()
|
| D | rx-sequence_equal.hpp | 89 , coordinator(std::move(coor)) in on_subscribe()
100 coordinator_type coordinator; in on_subscribe() member
109 auto coordinator = initial.coordination.create_coordinator(); in on_subscribe() local
110 auto state = std::make_shared<state_type>(initial, std::move(coordinator), std::move(s)); in on_subscribe()
113 [&](){ return state->coordinator.in(state->other); }, in on_subscribe()
120 [&](){ return state->coordinator.in(state->source); }, in on_subscribe()
176 [&](){ return state->coordinator.out(sinkOther); }, in on_subscribe()
|
| D | rx-flat_map.hpp | 137 , coordinator(std::move(coor)) in on_subscribe()
144 coordinator_type coordinator; in on_subscribe() member
148 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe() local
151 auto state = std::make_shared<state_type>(initial, std::move(coordinator), std::move(scbr)); in on_subscribe()
160 [&](){return state->coordinator.in(state->source);}, in on_subscribe()
187 auto selectedSource = state->coordinator.in(selectedCollection); in on_subscribe()
212 auto selectedSinkInner = state->coordinator.out(sinkInner); in on_subscribe()
228 [&](){return state->coordinator.out(sink);}, in on_subscribe()
|
| /external/libchrome/base/memory/ |
| D | memory_coordinator_proxy.cc | 26 MemoryCoordinator* coordinator) { in SetMemoryCoordinator() argument
27 DCHECK(!g_memory_coordinator || !coordinator); in SetMemoryCoordinator()
28 g_memory_coordinator = coordinator; in SetMemoryCoordinator()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-synchronize.hpp | 47 coordinator_type coordinator; member
85 [&](){return coordinator.act(drain_queue);}, in ensure_processing()
91 auto processor = coordinator.get_worker(); in ensure_processing()
99 , coordinator(std::move(coor)) in synchronize_observer_state()
140 auto coordinator = cn.create_coordinator(dl); in synchronize_observer() local
142 …state = std::make_shared<synchronize_observer_state>(std::move(coordinator), std::move(il), std::m… in synchronize_observer()
238 typedef coordinator<input_type> coordinator_type;
|
| D | rx-replaysubject.hpp | 49 mutable coordinator_type coordinator; member in rxcpp::subjects::detail::replay_observer::replay_observer_state
68 , coordinator(std::move(_coordinator)) in replay_observer_state()
102 auto coordinator = coordination.create_coordinator(replayLifetime); in replay_observer() local
103 …td::move(count), std::move(period), std::move(coordination), std::move(coordinator), std::move(rep… in replay_observer()
115 return state->coordinator; in get_coordinator()
|
| /external/glide/library/src/main/java/com/bumptech/glide/ |
| D | GenericRequestBuilder.java | 737 … ThumbnailRequestCoordinator coordinator = new ThumbnailRequestCoordinator(parentCoordinator); in buildRequestRecursive() local
738 Request fullRequest = obtainRequest(target, sizeMultiplier, priority, coordinator); in buildRequestRecursive()
740 … Request thumbRequest = thumbnailRequestBuilder.buildRequestRecursive(target, coordinator); in buildRequestRecursive()
741 coordinator.setRequests(fullRequest, thumbRequest); in buildRequestRecursive()
742 return coordinator; in buildRequestRecursive()
745 … ThumbnailRequestCoordinator coordinator = new ThumbnailRequestCoordinator(parentCoordinator); in buildRequestRecursive() local
746 Request fullRequest = obtainRequest(target, sizeMultiplier, priority, coordinator); in buildRequestRecursive()
747 …thumbnailRequest = obtainRequest(target, thumbSizeMultiplier, getThumbnailPriority(), coordinator); in buildRequestRecursive()
748 coordinator.setRequests(fullRequest, thumbnailRequest); in buildRequestRecursive()
749 return coordinator; in buildRequestRecursive()
|