Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 417 for timeouts (0.16 sec)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/SpecificHostSocketFactory.kt

          override fun connect(
            endpoint: SocketAddress?,
            timeout: Int,
          ) {
            val requested = (endpoint as InetSocketAddress)
            val inetSocketAddress = hostMapping[requested.address] ?: defaultAddress ?: requested
            Platform.get().log("Socket connection to: $inetSocketAddress was: $requested")
            super.connect(inetSocketAddress, timeout)
          }
        }
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  2. 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)
  3. common/config/.golangci-format.yml

    # common-files repo, make the change there and check it in. Then come back to this repo and run
    # "make update-common".
    
    run:
      # Timeout for analysis, e.g. 30s, 5m.
      # Default: 1m
      timeout: 20m
      build-tags:
      - integ
      - integfuzz
    linters:
      disable-all: true
      enable:
      - goimports
      - gofumpt
      - gci
      fast: false
    linters-settings:
      gci:
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 05 03:02:37 UTC 2024
    - 2K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java

      public V get() throws InterruptedException, ExecutionException {
        return delegate.get();
      }
    
      @Override
      @ParametricNullness
      public V get(long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException {
        return delegate.get(timeout, unit);
      }
    
      @Override
      public String toString() {
        return delegate.toString();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 05 22:27:35 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

              }
    
              sink.copyTo(cacheBody.buffer, sink.size - bytesRead, bytesRead)
              cacheBody.emitCompleteSegments()
              return bytesRead
            }
    
            override fun timeout(): Timeout = source.timeout()
    
            @Throws(IOException::class)
            override fun close() {
              if (!cacheRequestClosed &&
                !discard(ExchangeCodec.DISCARD_STREAM_TIMEOUT_MILLIS, MILLISECONDS)
              ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Mar 22 07:09:21 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  6. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/TunnelingUnixSocket.java

        super.connect(new UnixSocketAddress(path), 0);
      }
    
      @Override public void connect(SocketAddress endpoint, int timeout) throws IOException {
        this.inetSocketAddress = (InetSocketAddress) endpoint;
        super.connect(new UnixSocketAddress(path), timeout);
      }
    
      @Override public InetAddress getInetAddress() {
        return inetSocketAddress.getAddress();
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Feb 12 16:33:52 UTC 2019
    - 1.9K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

      }
    
      @CanIgnoreReturnValue
      @Override
      @ParametricNullness
      public V get(long timeout, TimeUnit unit)
          throws TimeoutException, InterruptedException, ExecutionException {
    
        long timeoutNanos = unit.toNanos(timeout);
        if (timeoutNanos <= OverflowAvoidingLockSupport.MAX_NANOSECONDS_THRESHOLD) {
          return super.get(timeout, unit);
        }
        // Waiting 68 years should be enough for any program.
        return super.get(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/core/timer/TimeoutTask.java

        private final boolean permanent;
    
        private long startTime;
    
        private int status = ACTIVE;
    
        TimeoutTask(final TimeoutTarget timeoutTarget, final int timeout, final boolean permanent) {
            this.timeoutTarget = timeoutTarget;
            this.timeoutMillis = timeout * 1000L;
            this.permanent = permanent;
            this.startTime = System.currentTimeMillis();
        }
    
        /**
         * 期限切れかどうかを返します。
         *
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/UncheckedThrowingFuture.java

        } catch (ExecutionException e) {
          rethrow(e);
        }
        throw new AssertionError("Unreachable");
      }
    
      @Override
      public V get(long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException {
        try {
          super.get(timeout, unit);
        } catch (ExecutionException e) {
          rethrow(e);
        }
        throw new AssertionError("Unreachable");
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 12 20:02:10 UTC 2018
    - 3.2K bytes
    - Viewed (0)
  10. internal/logger/target/kafka/kafka.go

    	sconfig.Producer.Retry.Max = 2
    	sconfig.Producer.Retry.Backoff = (10 * time.Second)
    	sconfig.Producer.Return.Successes = true
    	sconfig.Producer.Return.Errors = true
    	sconfig.Producer.RequiredAcks = 1
    	sconfig.Producer.Timeout = (10 * time.Second)
    	sconfig.Net.ReadTimeout = (10 * time.Second)
    	sconfig.Net.DialTimeout = (10 * time.Second)
    	sconfig.Net.WriteTimeout = (10 * time.Second)
    	sconfig.Metadata.Retry.Max = 1
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
Back to top