| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | AbstractQueuedLongSynchronizerTest.java | 96 final Mutex sync; field in AbstractQueuedLongSynchronizerTest.InterruptibleSyncRunnable
97 InterruptibleSyncRunnable(Mutex sync) { this.sync = sync; } in InterruptibleSyncRunnable() argument
99 sync.acquireInterruptibly(); in realRun()
108 final Mutex sync; field in AbstractQueuedLongSynchronizerTest.InterruptedSyncRunnable
109 InterruptedSyncRunnable(Mutex sync) { this.sync = sync; } in InterruptedSyncRunnable() argument
111 sync.acquireInterruptibly(); in realRun()
121 void waitForQueuedThread(AbstractQueuedLongSynchronizer sync, in waitForQueuedThread() argument
124 while (!sync.isQueued(t)) { in waitForQueuedThread()
135 void assertHasQueuedThreads(AbstractQueuedLongSynchronizer sync, in assertHasQueuedThreads() argument
137 Collection<Thread> actual = sync.getQueuedThreads(); in assertHasQueuedThreads()
[all …]
|
| D | AbstractQueuedSynchronizerTest.java | 100 final Mutex sync; field in AbstractQueuedSynchronizerTest.InterruptibleSyncRunnable
101 InterruptibleSyncRunnable(Mutex sync) { this.sync = sync; } in InterruptibleSyncRunnable() argument
103 sync.acquireInterruptibly(); in realRun()
112 final Mutex sync; field in AbstractQueuedSynchronizerTest.InterruptedSyncRunnable
113 InterruptedSyncRunnable(Mutex sync) { this.sync = sync; } in InterruptedSyncRunnable() argument
115 sync.acquireInterruptibly(); in realRun()
125 void waitForQueuedThread(AbstractQueuedSynchronizer sync, Thread t) { in waitForQueuedThread() argument
127 while (!sync.isQueued(t)) { in waitForQueuedThread()
138 void assertHasQueuedThreads(AbstractQueuedSynchronizer sync, in assertHasQueuedThreads() argument
140 Collection<Thread> actual = sync.getQueuedThreads(); in assertHasQueuedThreads()
[all …]
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| D | Semaphore.java | 130 private final Sync sync; field in Semaphore
236 sync = new NonfairSync(permits); in Semaphore()
251 sync = fair ? new FairSync(permits) : new NonfairSync(permits); in Semaphore()
283 sync.acquireSharedInterruptibly(1); in acquire()
306 sync.acquireShared(1); in acquireUninterruptibly()
334 return sync.nonfairTryAcquireShared(1) >= 0; in tryAcquire()
380 return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout)); in tryAcquire()
397 sync.releaseShared(1); in release()
438 sync.acquireSharedInterruptibly(permits); in acquire()
465 sync.acquireShared(permits); in acquireUninterruptibly()
[all …]
|
| D | CountDownLatch.java | 160 private final Sync sync; field in CountDownLatch
171 this.sync = new Sync(count); in CountDownLatch()
202 sync.acquireSharedInterruptibly(1); in await()
248 return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout)); in await()
262 sync.releaseShared(1); in countDown()
273 return sync.getCount(); in getCount()
284 return super.toString() + "[Count = " + sync.getCount() + "]"; in toString()
|
| /libcore/luni/src/main/java/java/util/concurrent/locks/ |
| D | ReentrantLock.java | 80 private final Sync sync; field in ReentrantLock
228 sync = new NonfairSync(); in ReentrantLock()
238 sync = fair ? new FairSync() : new NonfairSync(); in ReentrantLock()
256 sync.lock(); in lock()
306 sync.acquireInterruptibly(1); in lockInterruptibly()
336 return sync.nonfairTryAcquire(1); in tryLock()
413 return sync.tryAcquireNanos(1, unit.toNanos(timeout)); in tryLock()
428 sync.release(1); in unlock()
471 return sync.newCondition(); in newCondition()
504 return sync.getHoldCount(); in getHoldCount()
[all …]
|
| D | ReentrantReadWriteLock.java | 195 final Sync sync; field in ReentrantReadWriteLock
212 sync = fair ? new FairSync() : new NonfairSync(); in ReentrantReadWriteLock()
676 private final Sync sync; field in ReentrantReadWriteLock.ReadLock
685 sync = lock.sync; in ReadLock()
699 sync.acquireShared(1); in lock()
744 sync.acquireSharedInterruptibly(1); in lockInterruptibly()
771 return sync.tryReadLock(); in tryLock()
843 return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout)); in tryLock()
853 sync.releaseShared(1); in unlock()
874 int r = sync.getReadLockCount(); in toString()
[all …]
|
| D | AbstractQueuedSynchronizer.java | 2162 final boolean isOwnedBy(AbstractQueuedSynchronizer sync) { in isOwnedBy() argument
2163 return sync == AbstractQueuedSynchronizer.this; in isOwnedBy()
|
| D | AbstractQueuedLongSynchronizer.java | 1934 final boolean isOwnedBy(AbstractQueuedLongSynchronizer sync) { in isOwnedBy() argument
1935 return sync == AbstractQueuedLongSynchronizer.this; in isOwnedBy()
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/ |
| D | TimerTaskTest.java | 30 private final Object sync = new Object(); field in TimerTaskTest.TimerTestTask
53 synchronized (sync) { in run()
54 sync.notify(); in run()
181 synchronized (testTask.sync) { in test_scheduledExecutionTime()
183 testTask.sync.wait(500); in test_scheduledExecutionTime()
199 synchronized (testTask.sync) { in test_scheduledExecutionTime()
201 testTask.sync.wait(500); in test_scheduledExecutionTime()
|
| D | TimerTest.java | 31 private final Object sync = new Object(); field in TimerTest
76 synchronized (sync) { in run()
77 sync.notify(); in run()
218 synchronized (sync) { in test_cancel()
219 sync.wait(500); in test_cancel()
232 synchronized (sync) { in test_cancel()
233 sync.wait(500); in test_cancel()
245 synchronized (sync) { in test_cancel()
246 sync.wait(200); in test_cancel()
248 sync.wait(200); in test_cancel()
[all …]
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/ |
| D | FileDescriptorTest.java | 44 fd.sync(); in test_sync()
51 fd.sync(); in test_sync()
56 fd.sync(); in test_sync()
|
| D | SyncFailedExceptionTest.java | 38 fd.sync(); in test_ConstructorLjava_lang_String()
|
| /libcore/luni/src/test/java/libcore/java/io/ |
| D | FileDescriptorTest.java | 30 new RandomAccessFile(f, "r").getFD().sync(); in testReadOnlyFileDescriptorSync()
|
| /libcore/luni/src/main/java/java/io/ |
| D | FileDescriptor.java | 69 public void sync() throws SyncFailedException { in sync() method in FileDescriptor
|
| D | RandomAccessFile.java | 122 fd.sync(); in RandomAccessFile()
637 fd.sync(); in setLength()
691 fd.sync(); in write()
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/ |
| D | ThreadTest.java | 457 boolean sync; in test_interrupt() field in ThreadTest.ChildThread1
461 if (sync) { in test_interrupt()
473 public ChildThread1(Thread p, String name, boolean sync) { in test_interrupt() argument
476 this.sync = sync; in test_interrupt()
|
| /libcore/luni/src/test/java/libcore/java/util/prefs/ |
| D | PreferencesTest.java | 82 userPreferences.sync(); in testPreferencesClobbersExistingFiles()
|
| D | OldAbstractPreferencesTest.java | 867 pref.sync(); in testSync()
872 pref.sync(); in testSync()
|
| D | OldPreferencesTest.java | 109 p.sync(); in testAbstractMethods()
1110 public void sync() throws BackingStoreException { in sync() method in OldPreferencesTest.MockPreferences
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/prefs/ |
| D | AbstractPreferencesTest.java | 799 pref.sync(); in testSync()
805 p.sync(); in testSync()
816 p.sync(); in testSync()
823 child.sync(); in testSync()
831 child.sync(); in testSync()
1097 p.sync(); in testBackingStoreException()
1225 p.sync(); in testRuntimeException()
1310 p.sync(); in testSPIReturnNull()
1489 pref.sync(); in testIllegalStateException()
|
| D | PreferencesTest.java | 409 public void sync() throws BackingStoreException { in sync() method in PreferencesTest.MockPreferences
|
| /libcore/luni/src/main/java/java/util/prefs/ |
| D | Preferences.java | 789 public abstract void sync() throws BackingStoreException; in sync() method in Preferences
|
| D | AbstractPreferences.java | 779 public void sync() throws BackingStoreException { in sync() method in AbstractPreferences
785 child.sync(); in sync()
|