Lines Matching refs:blocking

301     private void beginRead(boolean blocking) throws ClosedChannelException {  in beginRead()  argument
302 if (blocking) { in beginRead()
322 private void endRead(boolean blocking, boolean completed) in endRead() argument
325 if (blocking) { in endRead()
344 boolean blocking = isBlocking(); in read()
347 beginRead(blocking); in read()
353 if (blocking) { in read()
361 endRead(blocking, n > 0); in read()
379 boolean blocking = isBlocking(); in read()
382 beginRead(blocking); in read()
388 if (blocking) { in read()
396 endRead(blocking, n > 0); in read()
412 private void beginWrite(boolean blocking) throws ClosedChannelException { in beginWrite() argument
413 if (blocking) { in beginWrite()
435 private void endWrite(boolean blocking, boolean completed) in endWrite() argument
438 if (blocking) { in endWrite()
457 boolean blocking = isBlocking(); in write()
460 beginWrite(blocking); in write()
461 if (blocking) { in write()
469 endWrite(blocking, n > 0); in write()
487 boolean blocking = isBlocking(); in write()
490 beginWrite(blocking); in write()
491 if (blocking) { in write()
499 endWrite(blocking, n > 0); in write()
515 boolean blocking = isBlocking(); in sendOutOfBandData()
518 beginWrite(blocking); in sendOutOfBandData()
519 if (blocking) { in sendOutOfBandData()
527 endWrite(blocking, n > 0); in sendOutOfBandData()
623 private void beginConnect(boolean blocking, InetSocketAddress isa) in beginConnect() argument
626 if (blocking) { in beginConnect()
644 if (blocking) { in beginConnect()
658 private void endConnect(boolean blocking, boolean completed) in endConnect() argument
661 endRead(blocking, completed); in endConnect()
690 boolean blocking = isBlocking(); in connect()
692 beginConnect(blocking, isa); in connect()
697 endConnect(blocking, (n > 0)); in connect()
720 private void beginFinishConnect(boolean blocking) throws ClosedChannelException { in beginFinishConnect() argument
721 if (blocking) { in beginFinishConnect()
729 if (blocking) { in beginFinishConnect()
743 private void endFinishConnect(boolean blocking, boolean completed) in endFinishConnect() argument
746 endRead(blocking, completed); in endFinishConnect()
769 boolean blocking = isBlocking(); in finishConnect()
772 beginFinishConnect(blocking); in finishConnect()
774 if (blocking) { in finishConnect()
783 endFinishConnect(blocking, connected); in finishConnect()
785 assert (blocking && connected) ^ !blocking; in finishConnect()
821 boolean blocking; in implCloseSelectableChannel()
828 blocking = isBlocking(); in implCloseSelectableChannel()
834 if (blocking) { in implCloseSelectableChannel()
959 boolean blocking = isBlocking();
960 assert Thread.holdsLock(blockingLock()) && blocking;
966 beginRead(blocking);
970 endRead(blocking, polled);
983 boolean blocking = isBlocking();
984 assert Thread.holdsLock(blockingLock()) && blocking;
992 beginFinishConnect(blocking);
999 endFinishConnect(blocking, /*completed*/false);