Searched refs:demand (Results 1 - 8 of 8) sorted by relevance

/openjdk9/jdk/test/java/net/httpclient/http2/server/
H A DBodyOutputStream.java61 void waitForWindow(int demand) throws InterruptedException { argument
63 conn.obtainConnectionWindow(demand);
66 while (demand > 0) {
67 int n = Math.min(demand, window);
68 demand -= n;
70 if (demand > 0) {
/openjdk9/jdk/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/
H A DPushPublisher.java39 long demand; field in class:PushPublisher
59 if (demand == 0) {
60 throw new IllegalStateException("demand == 0");
62 demand--;
85 demand += n;
H A DPullPublisher.java53 private long demand = 0; field in class:PullPublisher.Subscription
66 demand += n;
71 while (demand > 0) {
79 demand --;
H A DBlockingPushPublisher.java35 * acceptData() may therefore block while waiting for subscriber demand
41 long demand; field in class:BlockingPushPublisher
52 * when no demand available.
88 while (demand == 0) {
94 demand --;
98 long old = demand;
99 demand += n;
H A DDefaultPublisher.java70 private final AtomicLong demand = new AtomicLong(); field in class:DefaultPublisher.Subscription
83 while (!done.get() && demand.get() == 0) {
90 long nbItemsDemanded = demand.getAndSet(0);
120 demand.updateAndGet(d -> (d + n > 0) ? d + n : Long.MAX_VALUE);
/openjdk9/hotspot/src/share/vm/gc/cms/
H A DallocationStats.hpp39 // We measure the demand between the end of the previous sweep and
44 // previous sweep gives us a time rate of demand for blocks
46 // our current estimate for the time rate of demand for blocks
48 // between sweeps. Our current estimate for demand for blocks of
106 ssize_t demand = prev_sweep() - (ssize_t)count + split_births() + coal_births() local
108 assert(demand >= 0,
111 demand, p2i(this), count);
113 if (demand < 0) {
114 demand = 0;
117 float rate = ((float)demand)/inter_sweep_curren
[all...]
/openjdk9/jdk/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/internal/websocket/
H A DReceiver.java34 * Receives incoming data from the channel on demand and converts it into a
59 private final AtomicLong demand = new AtomicLong(); field in class:Receiver
100 demand.accumulateAndGet(n, (p, i) -> p + i < 0 ? Long.MAX_VALUE : p + i);
105 long x = demand.decrementAndGet();
113 * regardless of the current demand and data availability.
122 if (demand.get() > 0) {
/openjdk9/jdk/src/java.base/share/classes/java/util/concurrent/
H A DSubmissionPublisher.java811 if ((d = b.demand - n) < min)
948 * there is demand (unfilled requests). This is complicated on
988 volatile long demand; // # unfilled requests field in class:SubmissionPublisher.BufferedSubscription
1202 else if (demand == 0L || tail == head)
1335 * Adds to demand and possibly starts task.
1340 long prev = demand, d;
1361 if (demand == 0L)
1422 long d = demand;
1513 * Responds to apparent zero demand in consume().
1517 if (demand
[all...]

Completed in 104 milliseconds