< 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 >