Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 444 for timeout (0.09 sec)

  1. .github/workflows/tests.yml

            ports:
              - 9910:3306
            options: >-
              --health-cmd "mysqladmin ping -ugorm -pgorm"
              --health-interval 10s
              --health-start-period 10s
              --health-timeout 5s
              --health-retries 10
    
        steps:
        - name: Set up Go 1.x
          uses: actions/setup-go@v4
          with:
            go-version: ${{ matrix.go }}
    
        - name: Check out code into the Go module directory
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Sep 30 03:21:19 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  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. 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)
  7. 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)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

         * @throws CancellationException {@inheritDoc}
         */
        @CanIgnoreReturnValue
        @Override
        public V get(long timeout, TimeUnit unit)
            throws InterruptedException, TimeoutException, ExecutionException {
          return sync.get(unit.toNanos(timeout));
        }
    
        /*
         * Improve the documentation of when InterruptedException is thrown. Our
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  9. 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)
  10. src/main/java/jcifs/util/transport/Response.java

    
        /**
         * Set error status
         */
        void error ();
    
    
        /**
         * 
         * @return the message timeout
         */
        Long getExpiration ();
    
    
        /**
         * 
         * @param exp
         *            message timeout
         */
        void setExpiration ( Long exp );
    
    
        /**
         * 
         */
        public void reset ();
    
    
        /**
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2.3K bytes
    - Viewed (0)
Back to top