< prev index next >
src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/PlainHttpConnection.java
Print this page
*** 229,253 ****
public void enableCallback() {
// not used
assert false;
}
! void asyncOutput(ByteBufferReference[] refs, AsyncWriteQueue delayCallback) {
try {
ByteBuffer[] bufs = ByteBufferReference.toBuffers(refs);
while (Utils.remaining(bufs) > 0) {
long n = chan.write(bufs);
if (n == 0) {
delayCallback.setDelayed(refs);
client.registerEvent(new WriteEvent());
! return;
}
}
ByteBufferReference.clear(refs);
} catch (IOException e) {
shutdown();
}
}
@Override
public String toString() {
return "PlainHttpConnection: " + super.toString();
--- 229,254 ----
public void enableCallback() {
// not used
assert false;
}
! boolean asyncOutput(ByteBufferReference[] refs, AsyncWriteQueue delayCallback) {
try {
ByteBuffer[] bufs = ByteBufferReference.toBuffers(refs);
while (Utils.remaining(bufs) > 0) {
long n = chan.write(bufs);
if (n == 0) {
delayCallback.setDelayed(refs);
client.registerEvent(new WriteEvent());
! return false;
}
}
ByteBufferReference.clear(refs);
} catch (IOException e) {
shutdown();
}
+ return true;
}
@Override
public String toString() {
return "PlainHttpConnection: " + super.toString();
< prev index next >