Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 160 for Relay (0.01 sec)

  1. okhttp/src/androidMain/kotlin/okhttp3/internal/platform/Android10Platform.kt

      private val socketAdapters =
        listOfNotNull(
          Android10SocketAdapter.buildIfSupported(),
          DeferredSocketAdapter(AndroidSocketAdapter.playProviderFactory),
          // Delay and Defer any initialisation of Conscrypt and BouncyCastle
          DeferredSocketAdapter(ConscryptSocketAdapter.factory),
          DeferredSocketAdapter(BouncyCastleSocketAdapter.factory),
        ).filter { it.isSupported() }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Jul 20 11:25:50 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  2. okhttp/src/androidMain/kotlin/okhttp3/internal/platform/AndroidPlatform.kt

      private val socketAdapters =
        listOfNotNull(
          StandardAndroidSocketAdapter.buildIfSupported(),
          DeferredSocketAdapter(AndroidSocketAdapter.playProviderFactory),
          // Delay and Defer any initialisation of Conscrypt and BouncyCastle
          DeferredSocketAdapter(ConscryptSocketAdapter.factory),
          DeferredSocketAdapter(BouncyCastleSocketAdapter.factory),
        ).filter { it.isSupported() }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu May 29 16:52:38 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

            }
            interruptee.interrupt();
          }
        }
    
        void stopInterrupting() {
          shouldStop = true;
        }
      }
    
      /** Interrupts the current thread after sleeping for the specified delay. */
      static void requestInterruptIn(long time, TimeUnit unit) {
        checkNotNull(unit);
        Thread interruptee = Thread.currentThread();
        new Thread(
                new Runnable() {
                  @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  4. src/test/java/jcifs/tests/persistent/HandleReconnectorTest.java

        private HandleInfo testHandle;
    
        @BeforeEach
        public void setUp() {
            MockitoAnnotations.openMocks(this);
            reconnector = new HandleReconnector(mockManager, 2, 50); // 2 retries, 50ms delay
    
            HandleGuid guid = new HandleGuid();
            byte[] fileId = new byte[16];
            for (int i = 0; i < 16; i++) {
                fileId[i] = (byte) (i + 1);
            }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 04:51:33 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

     *
     * This test uses [TaskFaker] to deterministically test racy code. Each function in this test has
     * the same structure:
     *
     *  * prepare a set of plans, each with a predictable connect delay
     *  * attempt to find a connection
     *  * step through time, asserting that the expected side effects are performed.
     */
    internal class FastFallbackExchangeFinderTest {
      private val taskFaker = TaskFaker()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

        }
        @RetainedLocalRef Object localValue = valueField;
        if (localValue != null & notInstanceOfDelegatingToFuture(localValue)) {
          return getDoneValue(localValue);
        }
        // we delay calling nanoTime until we know we will need to either park or spin
        long endNanos = remainingNanos > 0 ? System.nanoTime() + remainingNanos : 0;
        long_wait_loop:
        if (remainingNanos >= SPIN_THRESHOLD_NANOS) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

        }
        @RetainedLocalRef Object localValue = valueField;
        if (localValue != null & notInstanceOfDelegatingToFuture(localValue)) {
          return getDoneValue(localValue);
        }
        // we delay calling nanoTime until we know we will need to either park or spin
        long endNanos = remainingNanos > 0 ? System.nanoTime() + remainingNanos : 0;
        long_wait_loop:
        if (remainingNanos >= SPIN_THRESHOLD_NANOS) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  8. src/main/webapp/js/admin/adminlte.min.js.map

    \n\n    toast.data('autohide', this._config.autohide)\n    toast.data('animation', this._config.fade)\n\n    if (this._config.class) {\n      toast.addClass(this._config.class)\n    }\n\n    if (this._config.delay && this._config.delay != 500) {\n      toast.data('delay', this._config.delay)\n    }\n\n    const toastHeader = $('<div class=\"toast-header\">')\n\n    if (this._config.image != null) {\n      const toastImage = $('<img />').addClass('rounded mr-2').attr('src', this._config.image).attr('alt',...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 132.4K bytes
    - Viewed (0)
  9. src/test/java/jcifs/smb/SmbSessionImplSecurityTest.java

                            // Verify we can acquire the tree
                            tree.acquire();
                            successCount.incrementAndGet();
    
                            // Small delay to increase chance of race conditions
                            Thread.yield();
                        }
                    } catch (Exception e) {
                        exceptions.add(e);
                    } finally {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 11K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

          eachQueue@ for (queue in readyQueues) {
            val candidate = queue.futureTasks[0]
            val candidateDelay = maxOf(0L, candidate.nextExecuteNanoTime - now)
    
            when {
              // Compute the delay of the soonest-executable task.
              candidateDelay > 0L -> {
                minDelayNanos = minOf(candidateDelay, minDelayNanos)
                continue@eachQueue
              }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 10.4K bytes
    - Viewed (0)
Back to top