| /libcore/luni/src/main/java/java/nio/channels/spi/ |
| D | AbstractInterruptibleChannel.java | 40 volatile boolean interrupted = false; field in AbstractInterruptibleChannel
45 interrupted = true;
111 if (interrupted) { in end()
112 interrupted = false; in end()
|
| /libcore/luni/src/main/java/java/util/concurrent/locks/ |
| D | AbstractQueuedSynchronizer.java | 814 return Thread.interrupted(); in parkAndCheckInterrupt()
837 boolean interrupted = false; in acquireQueued()
844 return interrupted; in acquireQueued()
848 interrupted = true; in acquireQueued()
912 if (Thread.interrupted()) in doAcquireNanos()
929 boolean interrupted = false; in doAcquireShared()
937 if (interrupted) in doAcquireShared()
945 interrupted = true; in doAcquireShared()
1015 if (Thread.interrupted()) in doAcquireSharedNanos()
1196 if (Thread.interrupted()) in acquireInterruptibly()
[all …]
|
| D | AbstractQueuedLongSynchronizer.java | 584 return Thread.interrupted(); in parkAndCheckInterrupt()
607 boolean interrupted = false; in acquireQueued()
614 return interrupted; in acquireQueued()
618 interrupted = true; in acquireQueued()
682 if (Thread.interrupted()) in doAcquireNanos()
699 boolean interrupted = false; in doAcquireShared()
707 if (interrupted) in doAcquireShared()
715 interrupted = true; in doAcquireShared()
785 if (Thread.interrupted()) in doAcquireSharedNanos()
966 if (Thread.interrupted()) in acquireInterruptibly()
[all …]
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | ExchangerTest.java | 118 final CountDownLatch interrupted = new CountDownLatch(1); in testReplacementAfterExchange() local
129 interrupted.await(); in testReplacementAfterExchange()
134 interrupted.await(); in testReplacementAfterExchange()
141 interrupted.countDown(); in testReplacementAfterExchange()
|
| D | CountDownLatchTest.java | 113 assertFalse(Thread.interrupted()); in testAwait_Interruptible()
120 assertFalse(Thread.interrupted()); in testAwait_Interruptible()
144 assertFalse(Thread.interrupted()); in testTimedAwait_Interruptible()
151 assertFalse(Thread.interrupted()); in testTimedAwait_Interruptible()
|
| D | BlockingQueueTest.java | 222 assertFalse(Thread.interrupted()); in testTimedPollWithOffer()
229 assertFalse(Thread.interrupted()); in testTimedPollWithOffer()
256 assertFalse(Thread.interrupted());
278 assertFalse(Thread.interrupted());
297 assertFalse(Thread.interrupted());
319 assertFalse(Thread.interrupted());
|
| D | LinkedBlockingDequeTest.java | 563 assertFalse(Thread.interrupted()); in testBlockingPut()
570 assertFalse(Thread.interrupted()); in testBlockingPut()
601 assertFalse(Thread.interrupted()); in testPutWithTake()
668 assertFalse(Thread.interrupted()); in testBlockingTake()
675 assertFalse(Thread.interrupted()); in testBlockingTake()
795 assertFalse(Thread.interrupted()); in testBlockingPutFirst()
802 assertFalse(Thread.interrupted()); in testBlockingPutFirst()
833 assertFalse(Thread.interrupted()); in testPutFirstWithTake()
896 assertFalse(Thread.interrupted()); in testTakeFirstFromEmptyBlocksInterruptibly()
918 assertFalse(Thread.interrupted()); in testTakeFirstFromEmptyAfterInterrupt()
[all …]
|
| D | PhaserTest.java | 460 assertFalse(Thread.interrupted());
467 assertFalse(Thread.interrupted());
477 assertFalse(Thread.interrupted());
484 assertFalse(Thread.interrupted());
515 assertTrue(Thread.interrupted());
525 assertTrue(Thread.interrupted());
543 assertTrue(Thread.interrupted());
554 assertTrue(Thread.interrupted());
579 assertTrue(Thread.interrupted());
605 assertTrue(Thread.interrupted());
|
| D | TimeUnitTest.java | 367 assertFalse(Thread.interrupted()); in testTimedWait_Interruptible()
376 assertFalse(Thread.interrupted()); in testTimedWait_Interruptible()
402 assertFalse(Thread.interrupted()); in testTimedJoin_Interruptible()
409 assertFalse(Thread.interrupted()); in testTimedJoin_Interruptible()
433 assertFalse(Thread.interrupted()); in testTimedSleep_Interruptible()
440 assertFalse(Thread.interrupted()); in testTimedSleep_Interruptible()
|
| D | RecursiveActionTest.java | 262 Thread.interrupted(); in testJoinIgnoresInterrupts()
275 Thread.interrupted(); in testJoinIgnoresInterrupts()
288 Thread.interrupted(); in testJoinIgnoresInterrupts()
298 Thread.interrupted(); in testJoinIgnoresInterrupts()
308 Thread.interrupted(); in testJoinIgnoresInterrupts()
317 Thread.interrupted(); in testJoinIgnoresInterrupts()
364 assertTrue(Thread.interrupted()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
375 assertTrue(Thread.interrupted()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
386 assertTrue(Thread.interrupted()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
396 assertTrue(Thread.interrupted()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
[all …]
|
| D | SynchronousQueueTest.java | 109 assertFalse(Thread.interrupted()); in testBlockingPut()
116 assertFalse(Thread.interrupted()); in testBlockingPut()
145 assertFalse(Thread.interrupted()); in testPutWithTake()
246 assertFalse(Thread.interrupted()); in testTimedPollWithOffer()
253 assertFalse(Thread.interrupted()); in testTimedPollWithOffer()
|
| D | FutureTaskTest.java | 435 assertFalse(Thread.interrupted()); in testCancelInterrupt_ThrowsSecurityException()
508 assertFalse(Thread.interrupted()); in testCancelNoInterrupt()
716 assertFalse(Thread.interrupted()); in testGet_interruptible()
723 assertFalse(Thread.interrupted()); in testGet_interruptible()
745 assertFalse(Thread.interrupted()); in testTimedGet_interruptible()
752 assertFalse(Thread.interrupted()); in testTimedGet_interruptible()
|
| D | LinkedBlockingQueueTest.java | 253 assertFalse(Thread.interrupted()); in testBlockingPut()
260 assertFalse(Thread.interrupted()); in testBlockingPut()
291 assertFalse(Thread.interrupted()); in testPutWithTake()
358 assertFalse(Thread.interrupted()); in testBlockingTake()
365 assertFalse(Thread.interrupted()); in testBlockingTake()
|
| D | ArrayBlockingQueueTest.java | 263 assertFalse(Thread.interrupted()); in testBlockingPut()
270 assertFalse(Thread.interrupted()); in testBlockingPut()
301 assertFalse(Thread.interrupted()); in testPutWithTake()
368 assertFalse(Thread.interrupted()); in testBlockingTake()
375 assertFalse(Thread.interrupted()); in testBlockingTake()
|
| /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/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/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()
468 wasInterrupted = Thread.interrupted(); in run()
505 wasInterrupted = Thread.interrupted(); in run()
556 wasInterrupted = Thread.interrupted(); in run()
607 wasInterrupted = Thread.interrupted(); in run()
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| D | ForkJoinTask.java | 294 boolean interrupted = false; in externalAwaitDone()
302 interrupted = true; in externalAwaitDone()
310 if (interrupted) in externalAwaitDone()
323 if (Thread.interrupted()) in externalInterruptibleAwaitDone()
986 if (Thread.interrupted()) in get()
1010 boolean interrupted = false; in get()
1028 interrupted = true; in get()
1035 if ((s = status) < 0 || interrupted || in get()
1044 if (interrupted) in get()
|
| D | Phaser.java | 1021 boolean interrupted = Thread.interrupted(); in internalAwaitAdvance()
1022 if (interrupted || --spins < 0) { // need node to record intr in internalAwaitAdvance()
1024 node.wasInterrupted = interrupted; in internalAwaitAdvance()
1089 if (Thread.interrupted()) in isReleasable()
|
| D | Exchanger.java | 388 if (Thread.interrupted()) in arenaExchange()
539 ((Thread.interrupted() || // disambiguates null return in exchange()
595 ((Thread.interrupted() || in exchange()
|
| D | CyclicBarrier.java | 176 if (Thread.interrupted()) { in dowait()
|
| D | LinkedTransferQueue.java | 1078 Thread.interrupted(); // failure possible only due to interrupt in transfer()
1101 if (!Thread.interrupted()) in tryTransfer()
1110 Thread.interrupted(); in take()
1116 if (e != null || !Thread.interrupted()) in poll()
|
| D | SynchronousQueue.java | 847 Thread.interrupted(); in put()
866 if (!Thread.interrupted()) in offer()
896 Thread.interrupted(); in take()
911 if (e != null || !Thread.interrupted()) in poll()
|
| /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()
|