Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 85 for idle (0.22 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

    import okio.IOException
    
    class RealConnectionPool internal constructor(
      private val taskRunner: TaskRunner,
      /**
       * The maximum number of idle connections across all addresses.
       * Connections needed to satisfy a [ConnectionPool.AddressPolicy] are not considered idle.
       */
      private val maxIdleConnections: Int,
      keepAliveDuration: Long,
      timeUnit: TimeUnit,
      internal val connectionListener: ConnectionListener,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

                    log.debug("Error checking connection idle time: {}", e.getMessage());
                }
            }
    
            // Remove at most half of the idle connections
            int toRemoveCount = Math.min(idle.size(), Math.max(1, idle.size() / 2));
            for (int i = 0; i < toRemoveCount; i++) {
                SmbTransportImpl transport = idle.get(i);
                if (connections.remove(transport)) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt

        }
    
      /**
       * A callback to be invoked each time the dispatcher becomes idle (when the number of running
       * calls returns to zero).
       *
       * Note: The time at which a [call][Call] is considered idle is different depending on whether it
       * was run [asynchronously][Call.enqueue] or [synchronously][Call.execute]. Asynchronous calls
       * become idle after the [onResponse][Callback.onResponse] or [onFailure][Callback.onFailure]
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.base.Preconditions.checkNotNull;
    import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.IDLE;
    import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.QUEUED;
    import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.QUEUING;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/ConnectionPool.kt

      /** Returns the number of idle connections in the pool. */
      fun idleConnectionCount(): Int = delegate.idleConnectionCount()
    
      /** Returns total number of connections in the pool. */
      fun connectionCount(): Int = delegate.connectionCount()
    
      internal val connectionListener: ConnectionListener
        get() = delegate.connectionListener
    
      /** Close and remove all idle connections in the pool. */
      fun evictAll() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt

      }
    
      @Test
      fun idleCallbackInvokedWhenIdle() {
        val idle = AtomicBoolean()
        dispatcher.idleCallback = Runnable { idle.set(true) }
        client.newCall(newRequest("http://a/1")).enqueue(callback)
        client.newCall(newRequest("http://a/2")).enqueue(callback)
        executor.finishJob("http://a/1")
        assertThat(idle.get()).isFalse()
        val ready = CountDownLatch(1)
        val proceed = CountDownLatch(1)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 12.7K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

              block()
              return -1L
            }
          },
          delayNanos,
        )
      }
    
      /** Returns a latch that reaches 0 when the queue is next idle. */
      fun idleLatch(): CountDownLatch {
        taskRunner.withLock {
          // If the queue is already idle, that's easy.
          if (activeTask == null && futureTasks.isEmpty()) {
            return CountDownLatch(0)
          }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/multichannel/ChannelInfo.java

        /**
         * Update activity timestamp
         */
        public void updateActivity() {
            this.lastActivityTime = System.currentTimeMillis();
        }
    
        /**
         * Get idle time since last activity
         *
         * @return idle time in milliseconds
         */
        public long getIdleTime() {
            return System.currentTimeMillis() - lastActivityTime;
        }
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 10.6K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/AddressPolicy.kt

    class AddressPolicy(
      /**
       * How many concurrent calls should be possible to make at any time.
       * The pool will routinely try to pre-emptively open connections to satisfy this minimum.
       * Connections will still be closed if they idle beyond the keep-alive but will be replaced.
       */
      @JvmField val minimumConcurrentCalls: Int = 0,
      /** How long to wait to retry pre-emptive connection attempts that fail. */
      @JvmField val backoffDelayMillis: Long = 60 * 1000,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  10. cmd/metrics-resource.go

    			if ts != nil {
    				tot := ts.User + ts.System + ts.Idle + ts.Iowait + ts.Nice + ts.Steal
    				cpuUserVal := math.Round(ts.User/tot*100*100) / 100
    				updateResourceMetrics(cpuSubsystem, cpuUser, cpuUserVal, labels, false)
    				cpuSystemVal := math.Round(ts.System/tot*100*100) / 100
    				updateResourceMetrics(cpuSubsystem, cpuSystem, cpuSystemVal, labels, false)
    				cpuIdleVal := math.Round(ts.Idle/tot*100*100) / 100
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 17.2K bytes
    - Viewed (0)
Back to top