Home
last modified time | relevance | path

Searched refs:compareAndSet (Results 1 – 25 of 29) sorted by relevance

12

/external/jetty/src/java/org/eclipse/jetty/util/
DAtomics.java35 if (currentMin.compareAndSet(oldValue, newValue)) in updateMin()
46 if (currentMax.compareAndSet(oldValue, newValue)) in updateMax()
57 if (currentMin.compareAndSet(oldValue, newValue)) in updateMin()
68 if (currentMax.compareAndSet(oldValue, newValue)) in updateMax()
/external/jetty/src/java/org/eclipse/jetty/client/
DHttpExchange.java222 set = _status.compareAndSet(oldStatus,newStatus); in setStatus()
235 set = _status.compareAndSet(oldStatus,newStatus); in setStatus()
248 set = _status.compareAndSet(oldStatus,newStatus); in setStatus()
259 if (set = _status.compareAndSet(oldStatus,newStatus)) in setStatus()
264 set = _status.compareAndSet(oldStatus,newStatus); in setStatus()
277 set = _status.compareAndSet(oldStatus,newStatus); in setStatus()
288 if (set = _status.compareAndSet(oldStatus,newStatus)) in setStatus()
293 set = _status.compareAndSet(oldStatus,newStatus); in setStatus()
304 if (set = _status.compareAndSet(oldStatus,newStatus)) in setStatus()
309 set = _status.compareAndSet(oldStatus,newStatus); in setStatus()
[all …]
DAbstractHttpConnection.java411 if (_idle.compareAndSet(false, true)) in setIdleTimeout()
422 if (_idle.compareAndSet(true, false)) in cancelIdleTimeout()
482 if (_idle.compareAndSet(true, false)) in expired()
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAtomicDoubleTest.java105 assertFalse(at.compareAndSet(unused, x)); in testCompareAndSet()
107 assertTrue(at.compareAndSet(prev, x)); in testCompareAndSet()
122 while (!at.compareAndSet(2.0, 3.0)) { in testCompareAndSetInMultipleThreads()
127 assertTrue(at.compareAndSet(1.0, 2.0)); in testCompareAndSetInMultipleThreads()
276 assertFalse(at.compareAndSet(-0.0, 7.0)); in testDistinctZeros()
279 assertTrue(at.compareAndSet(+0.0, -0.0)); in testDistinctZeros()
281 assertFalse(at.compareAndSet(+0.0, 7.0)); in testDistinctZeros()
DAtomicDoubleArrayTest.java131 aa.compareAndSet(index, 1.0, 2.0); in testIndexing()
187 assertFalse(aa.compareAndSet(i, unused, x)); in testCompareAndSet()
189 assertTrue(aa.compareAndSet(i, prev, x)); in testCompareAndSet()
206 while (!a.compareAndSet(0, 2.0, 3.0)) { in testCompareAndSetInMultipleThreads()
211 assertTrue(a.compareAndSet(0, 1.0, 2.0)); in testCompareAndSetInMultipleThreads()
300 if (aa.compareAndSet(i, v, v - 1.0)) { in realRun()
372 assertFalse(aa.compareAndSet(i, -0.0, 7.0)); in testDistinctZeros()
375 assertTrue(aa.compareAndSet(i, +0.0, -0.0)); in testDistinctZeros()
377 assertFalse(aa.compareAndSet(i, +0.0, 7.0)); in testDistinctZeros()
DExecutionListTest.java116 integer.compareAndSet(expectedCount, expectedCount + 1); in testOrdering()
DJSR166TestCase.java311 threadFailure.compareAndSet(null, t); in threadRecordFailure()
/external/guava/guava/src/com/google/common/util/concurrent/
DAtomicDouble.java131 public final boolean compareAndSet(double expect, double update) { in compareAndSet() method in AtomicDouble
132 return updater.compareAndSet(this, in compareAndSet()
170 if (updater.compareAndSet(this, current, next)) { in getAndAdd()
188 if (updater.compareAndSet(this, current, next)) { in addAndGet()
DAtomicLongMap.java127 if (atomic.compareAndSet(oldValue, newValue)) { in addAndGet()
176 if (atomic.compareAndSet(oldValue, newValue)) { in getAndAdd()
210 if (atomic.compareAndSet(oldValue, newValue)) { in put()
242 if (oldValue == 0L || atomic.compareAndSet(oldValue, 0L)) { in remove()
402 return (atomic == null) ? false : atomic.compareAndSet(expectedOldValue, newValue);
421 if (oldValue == 0L || atomic.compareAndSet(oldValue, 0L)) {
DAtomicDoubleArray.java143 public final boolean compareAndSet(int i, double expect, double update) { in compareAndSet() method in AtomicDoubleArray
144 return longs.compareAndSet(i, in compareAndSet()
185 if (longs.compareAndSet(i, current, next)) { in getAndAdd()
204 if (longs.compareAndSet(i, current, next)) { in addAndGet()
DJdkFutureAdapters.java152 if (hasListeners.compareAndSet(false, true)) { in addListener()
DStriped.java366 while (!locks.compareAndSet(index, existingRef, newRef)) {
388 locks.compareAndSet(arrayRef.index, arrayRef, null);
/external/guava/guava/src/com/google/common/cache/
DStriped64.java104 return valueUpdater.compareAndSet(this, cmp, val); in cas()
168 return baseUpdater.compareAndSet(this, cmp, val); in casBase()
175 return busyUpdater.compareAndSet(this, 0, 1); in casBusy()
/external/guava/guava/src/com/google/common/collect/
DConcurrentHashMultiset.java233 if (existingCounter.compareAndSet(oldValue, newValue)) { in add()
290 if (existingCounter.compareAndSet(oldValue, newValue)) { in remove()
331 if (existingCounter.compareAndSet(oldValue, newValue)) { in removeExactly()
380 if (existingCounter.compareAndSet(oldValue, count)) { in setCount()
433 if (existingCounter.compareAndSet(oldValue, newCount)) { in setCount()
/external/droiddriver/src/io/appium/droiddriver/helpers/
DSingleRun.java35 if (hasRun.compareAndSet(false, true)) { in singleRun()
/external/jetty/src/java/org/eclipse/jetty/util/thread/
DQueuedThreadPool.java429 if (!_threadsStarted.compareAndSet(threads,next)) in startThread()
566 shrink=_lastShrink.compareAndSet(last,now) &&
567 _threadsStarted.compareAndSet(size,size-1);
/external/guava/guava-gwt/src-super/java/util/super/java/util/concurrent/atomic/
DAtomicInteger.java54 public final boolean compareAndSet(int expect, int update) { in compareAndSet() method in AtomicInteger
DAtomicLong.java54 public final boolean compareAndSet(long expect, long update) { in compareAndSet() method in AtomicLong
/external/jetty/src/java/org/eclipse/jetty/server/
DResourceCache.java467 else if (_indirectBuffer.compareAndSet(null,buffer2))
488 else if (_directBuffer.compareAndSet(null,buffer2))
DAbstractConnector.java1217 if (valueHolder.compareAndSet(oldValue,value)) in updateNotEqual()
/external/jetty/src/java/org/eclipse/jetty/servlets/
DBalancerServlet.java137 if (_index.compareAndSet(currentIndex,nextIndex)) in next()
/external/nist-sip/java/gov/nist/javax/sip/stack/
DSIPClientTransaction.java1306 if (this.transactionTimerStarted.compareAndSet(false, true)) { in startTransactionTimer()
DSIPServerTransaction.java1463 if (this.transactionTimerStarted.compareAndSet(false, true)) { in startTransactionTimer()
/external/littlemock/src/com/google/testing/littlemock/
DLittleMock.java675 mCurrentThread.compareAndSet(null, currentThread);
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
DCacheTest.java1972 ifNoneMatch.compareAndSet(null, chain.request().header("If-None-Match")); in networkInterceptorInvokedForConditionalGet()

12