src/java.net.http/share/classes/jdk/internal/net/http/common/SubscriberWrapper.java
equal
deleted
inserted
replaced
318 } |
318 } |
319 |
319 |
320 void upstreamWindowUpdate() { |
320 void upstreamWindowUpdate() { |
321 long downstreamQueueSize = outputQ.size(); |
321 long downstreamQueueSize = outputQ.size(); |
322 long n = upstreamWindowUpdate(upstreamWindow.get(), downstreamQueueSize); |
322 long n = upstreamWindowUpdate(upstreamWindow.get(), downstreamQueueSize); |
|
323 logger.log(Level.DEBUG, "upstreamWindowUpdate, downstreamQueueSize:%d, upstreamWindow:%d", |
|
324 downstreamQueueSize, upstreamWindow.get()); |
323 if (n > 0) |
325 if (n > 0) |
324 upstreamRequest(n); |
326 upstreamRequest(n); |
325 } |
327 } |
326 |
328 |
327 @Override |
329 @Override |