Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for holdsLock (0.05 sec)

  1. guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java

        @Override
        public boolean offer(E o) {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.offer(o);
        }
    
        @Override
        public @Nullable E poll() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.poll();
        }
    
        @Override
        public E remove() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.remove();
        }
    
        @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java

        @Override
        public boolean offer(E o) {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.offer(o);
        }
    
        @Override
        public @Nullable E poll() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.poll();
        }
    
        @Override
        public E remove() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.remove();
        }
    
        @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/collect/SynchronizedTableTest.java

        @Override
        public String toString() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.toString();
        }
    
        @Override
        public boolean equals(@Nullable Object o) {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.equals(o);
        }
    
        @Override
        public int hashCode() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.hashCode();
        }
    
        @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/collect/LockHeldAssertingSet.java

        assertTrue(Thread.holdsLock(mutex));
        return super.add(o);
      }
    
      @Override
      public boolean addAll(Collection<? extends E> c) {
        assertTrue(Thread.holdsLock(mutex));
        return super.addAll(c);
      }
    
      @Override
      public void clear() {
        assertTrue(Thread.holdsLock(mutex));
        super.clear();
      }
    
      @Override
      public boolean contains(@Nullable Object o) {
        assertTrue(Thread.holdsLock(mutex));
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Feb 13 17:34:21 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/collect/LockHeldAssertingSet.java

        assertTrue(Thread.holdsLock(mutex));
        return super.add(o);
      }
    
      @Override
      public boolean addAll(Collection<? extends E> c) {
        assertTrue(Thread.holdsLock(mutex));
        return super.addAll(c);
      }
    
      @Override
      public void clear() {
        assertTrue(Thread.holdsLock(mutex));
        super.clear();
      }
    
      @Override
      public boolean contains(@Nullable Object o) {
        assertTrue(Thread.holdsLock(mutex));
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Feb 13 17:34:21 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/collect/SynchronizedMapTest.java

        }
    
        @Override
        public int size() {
          assertTrue(Thread.holdsLock(mutex));
          return super.size();
        }
    
        @Override
        public boolean isEmpty() {
          assertTrue(Thread.holdsLock(mutex));
          return super.isEmpty();
        }
    
        @Override
        public @Nullable V remove(Object object) {
          assertTrue(Thread.holdsLock(mutex));
          return super.remove(object);
        }
    
        @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 28 19:11:14 UTC 2025
    - 5.9K bytes
    - Viewed (0)
  7. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

          takeEvent()
        }
      }
    
      private fun logEvent(e: ConnectionEvent) {
        if (e.connection != null) {
          assertThat(Thread.holdsLock(e.connection), "Called with lock $${e.connection}")
            .isFalse()
        }
        for (lock in forbiddenLocks) {
          assertThat(Thread.holdsLock(lock), "Called with lock $lock")
            .isFalse()
        }
    
        if (enforceOrder) {
          checkForStartEvent(e)
        }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/Lockable.kt

      }
    }
    
    internal inline fun Lockable.assertLockNotHeld() {
      if (assertionsEnabled && Thread.holdsLock(this)) {
        throw AssertionError("Thread ${Thread.currentThread().name} MUST NOT hold lock on $this")
      }
    }
    
    internal inline fun Lockable.assertLockHeld() {
      if (assertionsEnabled && !Thread.holdsLock(this)) {
        throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this")
      }
    }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt

      fun clearAllEvents() {
        while (eventSequence.isNotEmpty()) {
          takeEvent()
        }
      }
    
      private fun logEvent(e: CallEvent) {
        for (lock in forbiddenLocks) {
          assertThat(Thread.holdsLock(lock), lock.toString()).isFalse()
        }
    
        if (enforceOrder) {
          checkForStartEvent(e)
        }
    
        eventSequence.offer(e)
      }
    
      private fun checkForStartEvent(e: CallEvent) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt

    /** Dispatcher is not [Lockable] because we don't want that type in our public API. */
    internal fun Dispatcher.assertLockNotHeld() {
      if (assertionsEnabled && Thread.holdsLock(this)) {
        throw AssertionError("Thread ${Thread.currentThread().name} MUST NOT hold lock on $this")
      }
    }
    
    /**
     * Returns the string "OkHttp" unless the library has been shaded for inclusion in another library,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 10.2K bytes
    - Viewed (1)
Back to top