| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
| D | rx-newthread.hpp | 70 auto keepAlive = state; in new_worker() local
72 state->lifetime.add([keepAlive](){ in new_worker()
73 std::unique_lock<std::mutex> guard(keepAlive->lock); in new_worker()
74 auto expired = std::move(keepAlive->q); in new_worker()
75 keepAlive->q = new_worker_state::queue_item_time{}; in new_worker()
76 if (!keepAlive->q.empty()) std::terminate(); in new_worker()
77 keepAlive->wake.notify_one(); in new_worker()
79 … if (keepAlive->worker.joinable() && keepAlive->worker.get_id() != std::this_thread::get_id()) { in new_worker()
81 keepAlive->worker.join(); in new_worker()
84 keepAlive->worker.detach(); 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/webrtc/modules/audio_device/android/java/src/org/webrtc/voiceengine/ |
| D | WebRtcAudioTrack.java | 56 private volatile boolean keepAlive = true; field in WebRtcAudioTrack.AudioTrackThread
83 while (keepAlive) { in run()
101 keepAlive = false; in run()
133 keepAlive = false; in joinThread()
|
| D | WebRtcAudioRecord.java | 64 private volatile boolean keepAlive = true; field in WebRtcAudioRecord.AudioRecordThread
78 while (keepAlive) { in run()
85 keepAlive = false; in run()
105 keepAlive = false; in joinThread()
|
| /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/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/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/syzkaller/pkg/rpctype/ |
| D | rpc.go | 106 func setupKeepAlive(conn net.Conn, keepAlive time.Duration) {
108 conn.(*net.TCPConn).SetKeepAlivePeriod(keepAlive)
|
| /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/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()
|
| D | rx-subscription.hpp | 182 auto keepAlive = state; in unsubscribe() local
|
| /external/apache-http/src/org/apache/http/protocol/ |
| D | HttpService.java | 217 if (!this.connStrategy.keepAlive(response, context)) { in handleRequest()
|
| /external/robolectric-shadows/shadows/httpclient/src/main/java/org/robolectric/shadows/httpclient/ |
| D | DefaultRequestDirector.java | 533 reuse = reuseStrategy.keepAlive(response, context); in execute()
815 if (this.reuseStrategy.keepAlive(response, context)) { in createTunnelToTarget()
|
| /external/apache-http/src/org/apache/http/impl/client/ |
| D | DefaultRequestDirector.java | 482 reuse = reuseStrategy.keepAlive(response, context); in execute()
783 if (this.reuseStrategy.keepAlive(response, context)) { in createTunnelToTarget()
|