Searched refs:isBlocking (Results 1 – 23 of 23) sorted by relevance
47 assertTrue(sink.isBlocking()); in test_sink()56 assertTrue(source.isBlocking()); in test_source()
710 assertTrue(this.channel1.isBlocking()); in testCFII_Norml_NoServer_Block()765 assertTrue(this.channel1.isBlocking()); in testCFII_ServerClosed_Block()832 assertTrue(this.channel1.isBlocking()); in testCFII_ServerStartLater_Block()924 assertTrue(this.channel1.isBlocking()); in testCFII_ConnectAfterFinish_NoServer_Block()1150 assertTrue(this.channel1.isBlocking()); in testCFII_ConnectTwice_Server_Block()1244 assertTrue(this.channel1.isBlocking()); in testCFII_FinishFirst_NoServer_Block()1308 assertTrue(this.channel1.isBlocking()); in testCFII_FinishFirst_Server_Block()1442 assertTrue(this.channel1.isBlocking()); in testCFII_StatusAfterFinish()1452 assertTrue(this.channel1.isBlocking()); in testCFII_StatusAfterFinish()1472 assertTrue(this.channel1.isBlocking()); in testCFII_StatusAfterFinish()[all …]
81 boolean isBlocking = sinkBlockingMode[i] && sourceBlockingMode[i]; in test_write_LByteBuffer()93 } while (totalCount != BUFFER_SIZE && !isBlocking); in test_write_LByteBuffer()193 boolean isBlocking = sinkBlockingMode[i] && sourceBlockingMode[i]; in test_write_$LByteBuffer()203 } while (totalCount != BUFFER_SIZE && !isBlocking); in test_write_$LByteBuffer()291 boolean isBlocking = sinkBlockingMode[i] && sourceBlockingMode[i]; in test_write_$LByteBufferII()300 } while (totalCount != BUFFER_SIZE && !isBlocking); in test_write_$LByteBufferII()
253 assertTrue(this.serverChannel.isBlocking()); in testSocket_Block_BeforeClose()286 assertTrue(this.serverChannel.isBlocking()); in testSocket_Block_Closed()298 assertFalse(this.serverChannel.isBlocking()); in testSocket_NonBlock_Closed()323 assertTrue(this.serverChannel.isBlocking()); in testChannelBasicStatus()339 assertTrue(this.serverChannel.isBlocking()); in testAccept_Block_NotYetBound()371 assertTrue(this.serverChannel.isBlocking()); in testAccept_Block_NoConnect()462 assertTrue(serverChannel.isBlocking()); in test_write_Blocking_RealData()
57 public boolean isBlocking() { in isBlocking() method in SelectableChannelTest.MockSelectableChannel
348 assertTrue(channel1.isBlocking()); in testSocket_ActionsBeforeConnect()427 assertTrue(this.channel1.isBlocking()); in testConnect_BlockWithServer()616 assertTrue(this.channel1.isBlocking()); in testDisconnect_BlockWithServerChannelClosed()639 assertTrue(this.channel1.isBlocking()); in testDisconnect_BlockWithServerServerClosed()654 assertFalse(this.channel1.isBlocking()); in testDisconnect_NonBlockWithServerServerClosed()808 assertTrue(this.channel1.isBlocking()); in testReceive_BlockNoServerNull()824 assertTrue(this.channel1.isBlocking()); in testReceive_BlockNoServerReadonly()869 assertTrue(this.channel1.isBlocking()); in testReceive_BlockNoServerChannelClose()885 assertTrue(this.channel1.isBlocking()); in testReceive_BlockNoServerCloseNull()909 assertTrue(this.channel1.isBlocking()); in testReceive_BlockNoServerCloseReadonly()[all …]
601 assertFalse(sc.isBlocking()); in test_newReader_LReadableByteChannel_LString()605 assertFalse(sc.isBlocking()); in test_newReader_LReadableByteChannel_LString()
239 assertTrue(sc.isBlocking()); in test_connect_blocking()247 assertTrue(sc.isBlocking()); in test_connect_blocking()258 assertTrue(sc.isBlocking()); in test_connect_nonBlocking()260 assertFalse(sc.isBlocking()); in test_connect_nonBlocking()274 assertFalse(sc.isBlocking()); in test_connect_nonBlocking()
79 assertTrue(this.serverChannel.isBlocking()); in test_accept_Block_NoConnect_interrupt()
173 assertTrue(this.channel1.isBlocking()); in testChannelBasicStatus()
307 public abstract boolean isBlocking(); in isBlocking() method in SelectableChannel
93 if (!sc.isBlocking()) in writeFully()
88 assertTrue(testChannel.isBlocking()); in test_isBlocking()90 assertFalse(testChannel.isBlocking()); in test_isBlocking()92 assertTrue(testChannel.isBlocking()); in test_isBlocking()
208 if (isBlocking()) in register()282 public final boolean isBlocking() { in isBlocking() method in AbstractSelectableChannel
55 boolean bm = sc.isBlocking(); in read()
141 if (!dc.isBlocking()) in send()209 if (!dc.isBlocking()) in receive()
92 if (!sc.isBlocking()) in connect()206 if (!sc.isBlocking()) in read()
101 if (sc == null && !ssc.isBlocking()) in accept()
723 if (!isBlocking()) { in connect()760 if (!isBlocking()) { in finishConnect()1005 assert Thread.holdsLock(blockingLock()) && !isBlocking(); in poll()
352 assert Thread.holdsLock(blockingLock()) && !isBlocking(); in poll()
792 blocking = isBlocking(); in connect()1150 assert Thread.holdsLock(blockingLock()) && !isBlocking(); in poll()
454 assertFalse(sc.isBlocking()); in test_Constructor_LReadableByteChannel()458 assertFalse(sc.isBlocking()); in test_Constructor_LReadableByteChannel()
6916 method public abstract boolean isBlocking();7034 method public final boolean isBlocking();