| /libcore/ojluni/src/main/java/java/nio/channels/spi/ |
| D | AbstractInterruptibleChannel.java | 146 private volatile Thread interrupted; field in AbstractInterruptibleChannel
164 interrupted = target; in begin()
200 Thread interrupted = this.interrupted; in end() local
201 if (interrupted != null && interrupted == Thread.currentThread()) { in end()
202 interrupted = null; in end()
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| D | NativeThreadSet.java | 99 boolean interrupted = false; in signalAndWait()
104 interrupted = true; in signalAndWait()
107 if (interrupted) in signalAndWait()
|
| D | EPollArrayWrapper.java | 261 interrupted = true; in poll()
302 private boolean interrupted = false; field in EPollArrayWrapper
312 boolean interrupted() { in interrupted() method in EPollArrayWrapper
313 return interrupted; in interrupted()
317 interrupted = false; in clearInterrupted()
|
| D | DevPollArrayWrapper.java | 224 interrupted = true; in poll()
294 boolean interrupted = false; field in DevPollArrayWrapper
304 boolean interrupted() { in interrupted() method in DevPollArrayWrapper
305 return interrupted; in interrupted()
309 interrupted = false; in clearInterrupted()
|
| /libcore/luni/src/main/java/java/util/concurrent/locks/ |
| D | AbstractQueuedLongSynchronizer.java | 374 return Thread.interrupted(); in parkAndCheckInterrupt()
396 boolean interrupted = false; in acquireQueued()
402 return interrupted; in acquireQueued()
406 interrupted = true; in acquireQueued()
468 if (Thread.interrupted()) in doAcquireNanos()
484 boolean interrupted = false; in doAcquireShared()
492 if (interrupted) in doAcquireShared()
499 interrupted = true; in doAcquireShared()
567 if (Thread.interrupted()) in doAcquireSharedNanos()
748 if (Thread.interrupted()) in acquireInterruptibly()
[all …]
|
| D | AbstractQueuedSynchronizer.java | 841 return Thread.interrupted(); in parkAndCheckInterrupt()
864 boolean interrupted = false; in acquireQueued()
870 return interrupted; in acquireQueued()
874 interrupted = true; in acquireQueued()
936 if (Thread.interrupted()) in doAcquireNanos()
952 boolean interrupted = false; in doAcquireShared()
960 if (interrupted) in doAcquireShared()
967 interrupted = true; in doAcquireShared()
1035 if (Thread.interrupted()) in doAcquireSharedNanos()
1217 if (Thread.interrupted()) in acquireInterruptibly()
[all …]
|
| D | StampedLock.java | 353 if (!Thread.interrupted()) { in tryWriteLock()
379 if (!Thread.interrupted() && in writeLockInterruptibly()
435 if (!Thread.interrupted()) { in tryReadLock()
466 if (!Thread.interrupted() && in readLockInterruptibly()
1093 if (Thread.interrupted()) { in acquireWrite()
1202 if (Thread.interrupted()) { in acquireRead()
1278 if (Thread.interrupted()) { in acquireRead()
1304 private long cancelWaiter(WNode node, WNode group, boolean interrupted) { in cancelWaiter() argument
1368 return (interrupted || Thread.interrupted()) ? INTERRUPTED : 0L; in cancelWaiter()
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | ExchangerTest.java | 130 final CountDownLatch interrupted = new CountDownLatch(1); in testReplacementAfterExchange() local
141 interrupted.await(); in testReplacementAfterExchange()
146 interrupted.await(); in testReplacementAfterExchange()
153 interrupted.countDown(); in testReplacementAfterExchange()
|
| D | CountDownLatchTest.java | 124 assertFalse(Thread.interrupted()); in testAwait_Interruptible()
131 assertFalse(Thread.interrupted()); in testAwait_Interruptible()
155 assertFalse(Thread.interrupted()); in testTimedAwait_Interruptible()
162 assertFalse(Thread.interrupted()); in testTimedAwait_Interruptible()
|
| D | BlockingQueueTest.java | 234 assertFalse(Thread.interrupted()); in testTimedPollWithOffer()
241 assertFalse(Thread.interrupted()); in testTimedPollWithOffer()
270 assertFalse(Thread.interrupted());
292 assertFalse(Thread.interrupted());
311 assertFalse(Thread.interrupted());
333 assertFalse(Thread.interrupted());
|
| D | LinkedBlockingDequeTest.java | 590 assertFalse(Thread.interrupted()); in testBlockingPut()
597 assertFalse(Thread.interrupted()); in testBlockingPut()
628 assertFalse(Thread.interrupted()); in testPutWithTake()
695 assertFalse(Thread.interrupted()); in testBlockingTake()
702 assertFalse(Thread.interrupted()); in testBlockingTake()
820 assertFalse(Thread.interrupted()); in testBlockingPutFirst()
827 assertFalse(Thread.interrupted()); in testBlockingPutFirst()
858 assertFalse(Thread.interrupted()); in testPutFirstWithTake()
921 assertFalse(Thread.interrupted()); in testTakeFirstFromEmptyBlocksInterruptibly()
943 assertFalse(Thread.interrupted()); in testTakeFirstFromEmptyAfterInterrupt()
[all …]
|
| D | TimeUnitTest.java | 350 assertFalse(Thread.interrupted()); in testTimedWait_Interruptible()
359 assertFalse(Thread.interrupted()); in testTimedWait_Interruptible()
385 assertFalse(Thread.interrupted()); in testTimedJoin_Interruptible()
392 assertFalse(Thread.interrupted()); in testTimedJoin_Interruptible()
416 assertFalse(Thread.interrupted()); in testTimedSleep_Interruptible()
423 assertFalse(Thread.interrupted()); in testTimedSleep_Interruptible()
|
| D | PhaserTest.java | 471 assertFalse(Thread.interrupted());
478 assertFalse(Thread.interrupted());
488 assertFalse(Thread.interrupted());
495 assertFalse(Thread.interrupted());
526 assertTrue(Thread.interrupted());
536 assertTrue(Thread.interrupted());
554 assertTrue(Thread.interrupted());
565 assertTrue(Thread.interrupted());
590 assertTrue(Thread.interrupted());
616 assertTrue(Thread.interrupted());
|
| D | RecursiveActionTest.java | 272 Thread.interrupted(); in testJoinIgnoresInterrupts()
285 Thread.interrupted(); in testJoinIgnoresInterrupts()
298 Thread.interrupted(); in testJoinIgnoresInterrupts()
308 Thread.interrupted(); in testJoinIgnoresInterrupts()
318 Thread.interrupted(); in testJoinIgnoresInterrupts()
327 Thread.interrupted(); in testJoinIgnoresInterrupts()
374 assertTrue(Thread.interrupted()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
385 assertTrue(Thread.interrupted()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
396 assertTrue(Thread.interrupted()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
406 assertTrue(Thread.interrupted()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
[all …]
|
| D | SynchronousQueueTest.java | 137 assertFalse(Thread.interrupted()); in testBlockingPut()
144 assertFalse(Thread.interrupted()); in testBlockingPut()
173 assertFalse(Thread.interrupted()); in testPutWithTake()
273 assertFalse(Thread.interrupted()); in testTimedPollWithOffer()
280 assertFalse(Thread.interrupted()); in testTimedPollWithOffer()
|
| D | FutureTaskTest.java | 453 assertFalse(Thread.interrupted()); in testCancelInterrupt_ThrowsSecurityException()
526 assertFalse(Thread.interrupted()); in testCancelNoInterrupt()
734 assertFalse(Thread.interrupted()); in testGet_interruptible()
741 assertFalse(Thread.interrupted()); in testGet_interruptible()
763 assertFalse(Thread.interrupted()); in testTimedGet_interruptible()
770 assertFalse(Thread.interrupted()); in testTimedGet_interruptible()
|
| /libcore/ojluni/src/main/java/sun/misc/ |
| D | Resource.java | 96 boolean isInterrupted = Thread.interrupted(); in getBytes()
103 Thread.interrupted(); in getBytes()
126 Thread.interrupted(); in getBytes()
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/ |
| D | ThreadTest.java | 479 boolean interrupted = false; in test_interrupt()
488 interrupted = true; in test_interrupt()
490 assertTrue("Failed to Interrupt thread1", interrupted); in test_interrupt()
492 interrupted = false; in test_interrupt()
503 interrupted = true; in test_interrupt()
505 assertTrue("Failed to Interrupt thread2", interrupted); in test_interrupt()
514 .interrupted()); in test_interrupted()
516 assertTrue("Interrupted returned true for non-interrupted thread", Thread.interrupted()); in test_interrupted()
517 assertFalse("Failed to clear interrupted flag", Thread.interrupted()); in test_interrupted()
|
| /libcore/luni/src/test/java/libcore/java/io/ |
| D | InterruptedStreamTest.java | 52 Thread.interrupted(); in setUp()
61 Thread.interrupted(); // clear interrupted bit in tearDown()
211 assertTrue(Thread.interrupted()); in confirmInterrupted()
|
| /libcore/luni/src/test/java/libcore/java/lang/ |
| D | OldThreadGroupTest.java | 245 private static boolean interrupted = false; field in OldThreadGroupTest
259 assertFalse("Incorrect state of thread", interrupted); in test_interrupt()
261 assertFalse("Incorrect state of thread", interrupted); in test_interrupt()
267 assertTrue("Incorrect state of thread", interrupted); in test_interrupt()
321 interrupted = true; in uncaughtException()
|
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| D | FileIOInterruptTest.java | 94 Thread.interrupted(); in tearDown()
245 assertTrue(Thread.interrupted()); in testChannelRead_exceptionWhenAlreadyInterrupted()
377 assertTrue(Thread.interrupted()); in testChannelWrite_exceptionWhenAlreadyInterrupted()
476 wasInterrupted = Thread.interrupted(); in run()
513 wasInterrupted = Thread.interrupted(); in run()
564 wasInterrupted = Thread.interrupted(); in run()
615 wasInterrupted = Thread.interrupted(); in run()
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| D | Phaser.java | 1016 boolean interrupted = Thread.interrupted(); in internalAwaitAdvance()
1017 if (interrupted || --spins < 0) { // need node to record intr in internalAwaitAdvance()
1019 node.wasInterrupted = interrupted; in internalAwaitAdvance()
1084 if (Thread.interrupted()) in isReleasable()
|
| D | Exchanger.java | 383 if (Thread.interrupted()) in arenaExchange()
534 ((Thread.interrupted() || // disambiguates null return in exchange()
590 ((Thread.interrupted() || in exchange()
|
| D | CyclicBarrier.java | 181 if (Thread.interrupted()) { in dowait()
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/net/ |
| D | ServerSocketTest.java | 43 boolean interrupted; field in ServerSocketTest
186 interrupted = false; in test_accept()
194 interrupted = true; in test_accept()
214 if (interrupted) { in test_accept()
222 interrupted = false; in test_accept()
229 interrupted = true; in test_accept()
231 assertTrue("accept not interrupted", interrupted); in test_accept()
|