Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 365 for timeouts (0.17 sec)

  1. guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java

      @Override
      public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offer(e, timeout, unit);
      }
    
      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
      @CheckForNull
      public E poll(long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().poll(timeout, unit);
      }
    
      @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 3K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       *   <li>awaits executor service termination for half of the specified timeout.
       *   <li>if the timeout expires, it calls {@link ExecutorService#shutdownNow()}, cancelling
       *       pending tasks and interrupting running tasks.
       *   <li>awaits executor service termination for the other half of the specified timeout.
       * </ol>
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  3. internal/config/drive/drive.go

    type Config struct {
    	// MaxTimeout - maximum timeout for a drive operation
    	MaxTimeout time.Duration `json:"maxTimeout"`
    }
    
    // Update - updates the config with latest values
    func (c *Config) Update(new Config) error {
    	configLk.Lock()
    	defer configLk.Unlock()
    	c.MaxTimeout = getMaxTimeout(new.MaxTimeout)
    	return nil
    }
    
    // GetMaxTimeout - returns the per call drive operation timeout
    func (c *Config) GetMaxTimeout() time.Duration {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt

    internal fun Source.skipAll(
      duration: Int,
      timeUnit: TimeUnit,
    ): Boolean {
      val nowNs = System.nanoTime()
      val originalDurationNs =
        if (timeout().hasDeadline()) {
          timeout().deadlineNanoTime() - nowNs
        } else {
          Long.MAX_VALUE
        }
      timeout().deadlineNanoTime(nowNs + minOf(originalDurationNs, timeUnit.toNanos(duration.toLong())))
      return try {
        val skipBuffer = Buffer()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon May 13 13:42:37 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  5. mockwebserver/src/test/java/mockwebserver3/RecordedRequestTest.kt

    import java.net.Socket
    import okhttp3.Headers
    import okhttp3.Headers.Companion.headersOf
    import okhttp3.internal.EMPTY_HEADERS
    import okio.Buffer
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.Timeout
    
    @Timeout(30)
    class RecordedRequestTest {
      private val headers: Headers = EMPTY_HEADERS
    
      @Test fun testIPv4() {
        val socket =
          FakeSocket(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  6. internal/grid/grid_test.go

    	connRemoteLocal := remote.Connection(localHost)
    
    	t.Run("testStreamRoundtrip", func(t *testing.T) {
    		defer timeout(5 * time.Second)()
    		testStreamRoundtrip(t, local, remote)
    		assertNoActive(t, connRemoteLocal)
    		assertNoActive(t, connLocalToRemote)
    	})
    	t.Run("testStreamCancel", func(t *testing.T) {
    		defer timeout(5 * time.Second)()
    		testStreamCancel(t, local, remote)
    		assertNoActive(t, connRemoteLocal)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AbstractService.java

        }
      }
    
      /** @since 28.0 */
      @Override
      public final void awaitRunning(Duration timeout) throws TimeoutException {
        Service.super.awaitRunning(timeout);
      }
    
      @Override
      public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
        if (monitor.enterWhenUninterruptibly(hasReachedRunning, timeout, unit)) {
          try {
            checkCurrentState(RUNNING);
          } finally {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.7K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/Interceptor.kt

        fun connectTimeoutMillis(): Int
    
        fun withConnectTimeout(
          timeout: Int,
          unit: TimeUnit,
        ): Chain
    
        fun readTimeoutMillis(): Int
    
        fun withReadTimeout(
          timeout: Int,
          unit: TimeUnit,
        ): Chain
    
        fun writeTimeoutMillis(): Int
    
        fun withWriteTimeout(
          timeout: Int,
          unit: TimeUnit,
        ): Chain
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt

      private fun readHeader() {
        if (closed) throw IOException("closed")
    
        // Disable the timeout to read the first byte of a new frame.
        val b0: Int
        val timeoutBefore = source.timeout().timeoutNanos()
        source.timeout().clearTimeout()
        try {
          b0 = source.readByte() and 0xff
        } finally {
          source.timeout().timeout(timeoutBefore, TimeUnit.NANOSECONDS)
        }
    
        opcode = b0 and B0_MASK_OPCODE
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  10. src/main/resources/fess_config.properties

    index.admin.float.fields=boost
    index.admin.double.fields=
    index.admin.required.fields=url,title,role,boost
    
    # timeout
    index.search.timeout=3m
    index.scroll.search.timeout=3m
    index.index.timeout=3m
    index.bulk.timeout=3m
    index.delete.timeout=3m
    index.health.timeout=10m
    index.indices.timeout=1m
    
    # filetype
    index.filetype=\
    text/html=html\n\
    application/msword=word\n\
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Tue Oct 01 14:13:38 UTC 2024
    - 30.9K bytes
    - Viewed (0)
Back to top