| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
| D | rx-newthread.hpp | 80 auto keepAlive = state; in new_worker() local
82 state->lifetime.add([keepAlive](){ in new_worker()
83 std::unique_lock<std::mutex> guard(keepAlive->lock); in new_worker()
84 auto expired = std::move(keepAlive->q); in new_worker()
85 keepAlive->q = new_worker_state::queue_item_time{}; in new_worker()
86 if (!keepAlive->q.empty()) std::terminate(); in new_worker()
87 keepAlive->wake.notify_one(); in new_worker()
92 state->worker = tf([keepAlive](){ in new_worker()
95 queue_type::ensure(std::make_shared<new_worker>(keepAlive)); in new_worker()
102 std::unique_lock<std::mutex> guard(keepAlive->lock); in new_worker()
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-ref_count.hpp | 150 auto keepAlive = state; in on_subscribe() local
153 [keepAlive](){ in on_subscribe()
154 std::unique_lock<std::mutex> guard_unsubscribe(keepAlive->lock); in on_subscribe()
155 if (--keepAlive->subscribers == 0) { in on_subscribe()
156 keepAlive->connection.unsubscribe(); in on_subscribe()
157 keepAlive->connection = composite_subscription(); in on_subscribe()
160 keepAlive->subscribe(std::forward<Subscriber>(o)); in on_subscribe()
162 keepAlive->connectable.connect(keepAlive->connection); in on_subscribe()
|
| D | rx-observe_on.hpp | 126 auto keepAlive = this->shared_from_this(); in ensure_processing() local
128 auto drain = [keepAlive, this](const rxsc::schedulable& self){ in ensure_processing()
210 auto keepAlive = o.state; in make() local
212 std::unique_lock<std::mutex> guard(keepAlive->lock); in make()
213 keepAlive->ensure_processing(guard); in make()
|
| /external/androidplot/AndroidPlot-Core/src/main/java/com/androidplot/util/ |
| D | Redrawer.java | 21 private boolean keepAlive; field in Redrawer
67 keepAlive = false; in finish()
73 keepAlive = true; in run()
75 while(keepAlive) { in run()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-behavior.hpp | 93 auto keepAlive = s; in get_observable() local
95 if (keepAlive.get_subscription().is_subscribed()) { in get_observable()
98 keepAlive.add(s.get_subscriber(), std::move(o)); in get_observable()
|
| D | rx-synchronize.hpp | 56 auto keepAlive = this->shared_from_this(); in ensure_processing() local
58 auto drain_queue = [keepAlive, this](const rxsc::schedulable& self){ in ensure_processing()
183 auto keepAlive = s; in get_observable() local
185 keepAlive.add(keepAlive.get_subscriber(), std::move(o)); in get_observable()
|
| D | rx-replaysubject.hpp | 171 auto keepAlive = s; in get_observable() local
176 keepAlive.add(keepAlive.get_subscriber(), std::move(o)); in get_observable()
|
| D | rx-subject.hpp | 266 auto keepAlive = s; in get_observable() local
268 keepAlive.add(keepAlive.get_subscriber(), std::move(o)); in get_observable()
|
| /external/webrtc/modules/audio_device/android/java/src/org/webrtc/voiceengine/ |
| D | WebRtcAudioRecord.java | 140 private volatile boolean keepAlive = true; field in WebRtcAudioRecord.AudioRecordThread
155 while (keepAlive) { in run()
165 if (keepAlive) { in run()
179 keepAlive = false; in run()
204 keepAlive = false; in stopThread()
|
| D | WebRtcAudioTrack.java | 127 private volatile boolean keepAlive = true; field in WebRtcAudioTrack.AudioTrackThread
143 while (keepAlive) { in run()
163 keepAlive = false; in run()
203 keepAlive = false; in stopThread()
|
| /external/glide/library/src/main/java/com/bumptech/glide/load/engine/executor/ |
| D | FifoPriorityThreadPoolExecutor.java | 30 …public FifoPriorityThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAlive, TimeU… in FifoPriorityThreadPoolExecutor() argument
32 …super(corePoolSize, maximumPoolSize, keepAlive, timeUnit, new PriorityBlockingQueue<Runnable>(), t… in FifoPriorityThreadPoolExecutor()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| D | ConnectionPool.java | 64 String keepAlive = System.getProperty("http.keepAlive");
70 if (keepAlive != null && !Boolean.parseBoolean(keepAlive)) {
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/ |
| D | ConnectionPool.java | 67 String keepAlive = System.getProperty("http.keepAlive");
73 if (keepAlive != null && !Boolean.parseBoolean(keepAlive)) {
|
| /external/webrtc/sdk/android/src/java/org/webrtc/audio/ |
| D | WebRtcAudioTrack.java | 93 private volatile boolean keepAlive = true; field in WebRtcAudioTrack.AudioTrackThread
112 while (keepAlive) { in run()
132 keepAlive = false; in run()
159 keepAlive = false; in stopThread()
|
| D | WebRtcAudioRecord.java | 114 private volatile boolean keepAlive = true; field in WebRtcAudioRecord.AudioRecordThread
130 while (keepAlive) { in run()
140 if (keepAlive) { in run()
156 keepAlive = false; in run()
176 keepAlive = false; in stopThread()
|
| /external/apache-http/src/org/apache/http/ |
| D | ConnectionReuseStrategy.java | 78 boolean keepAlive(HttpResponse response, HttpContext context); in keepAlive() method
|
| /external/apache-http/src/org/apache/http/impl/ |
| D | NoConnectionReuseStrategy.java | 59 public boolean keepAlive(final HttpResponse response, final HttpContext context) { in keepAlive() method in NoConnectionReuseStrategy
|
| D | DefaultConnectionReuseStrategy.java | 83 public boolean keepAlive(final HttpResponse response, in keepAlive() method in DefaultConnectionReuseStrategy
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | DelegatingSSLSocket.java | 180 @Override public void setKeepAlive(boolean keepAlive) throws SocketException { in setKeepAlive() argument
181 delegate.setKeepAlive(keepAlive); in setKeepAlive()
|
| /external/nanohttpd/core/src/main/java/fi/iki/elonen/ |
| D | NanoHTTPD.java | 833 …boolean keepAlive = protocolVersion.equals("HTTP/1.1") && (connection == null || !connection.match… in execute()
851 r.setKeepAlive(keepAlive); in execute()
854 if (!keepAlive || "close".equalsIgnoreCase(r.getHeader("connection"))) { in execute()
1305 private boolean keepAlive; field in NanoHTTPD.Response
1321 keepAlive = true; in Response()
1368 this.keepAlive = useKeepAlive;
1410 pw.print("Connection: " + (this.keepAlive ? "keep-alive" : "close") + "\r\n");
|
| /external/apache-http/android/src/android/net/http/ |
| D | Connection.java | 514 private boolean keepAlive(HttpEntity entity, in keepAlive() method in Connection
543 mCanPersist = keepAlive(entity, ver, connType, mHttpContext); in setCanPersist()
|
| /external/fonttools/Lib/fontTools/colorLib/ |
| D | builder.py | 414 keepAlive: List[ot.Paint] # we need id to remain valid
421 self.keepAlive = []
453 self.keepAlive.append(paint)
|
| /external/skia/tests/ |
| D | ReadWritePixelsGpuTest.cpp | 1151 GrPixmap keepAlive; in DEF_GPUTEST_FOR_RENDERING_CONTEXTS() local
1157 keepAlive = GrPixmap::Allocate(levels[1].info().makeWH(w, h)); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
1161 SkAssertResult(GrConvertPixels(keepAlive, src)); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
1163 keepAlive.addr(), in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
1164 keepAlive.rowBytes()); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
1174 keepAlive = {}; in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-scheduler.hpp | 848 auto keepAlive = *this; in schedule_periodically_rebind() local
850 auto activity = make_schedulable(scbl, keepAlive, std::forward<ArgN>(an)...); in schedule_periodically_rebind()
853 [keepAlive, target, period, activity](schedulable self) { in schedule_periodically_rebind()
|
| /external/apache-http/src/org/apache/http/protocol/ |
| D | HttpService.java | 217 if (!this.connStrategy.keepAlive(response, context)) { in handleRequest()
|