Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 417 for timeouts (0.07 sec)

  1. ci/official/containers/linux_arm64/Dockerfile

    RUN wget --retry-connrefused --waitretry=1 --read-timeout=20 --timeout=15 --tries=5 https://github.com/bazelbuild/bazelisk/releases/download/v1.12.0/bazelisk-linux-arm64 -O /usr/local/bin/bazel && chmod +x /usr/local/bin/bazel
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Nov 01 08:30:33 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  2. android/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)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocket.kt

      }
    
      @Throws(SocketException::class)
      override fun setSoLinger(
        on: Boolean,
        timeout: Int,
      ) {
        delegate!!.setSoLinger(on, timeout)
      }
    
      @Throws(SocketException::class)
      override fun setSoTimeout(timeout: Int) {
        delegate!!.soTimeout = timeout
      }
    
      @Throws(SocketException::class)
      override fun setTcpNoDelay(on: Boolean) {
        delegate!!.tcpNoDelay = on
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractIdleService.java

      @Override
      public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
        delegate.awaitRunning(timeout, unit);
      }
    
      /** @since 15.0 */
      @Override
      public final void awaitTerminated() {
        delegate.awaitTerminated();
      }
    
      /** @since 15.0 */
      @Override
      public final void awaitTerminated(long timeout, TimeUnit unit) throws TimeoutException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 17 13:59:28 UTC 2023
    - 5.3K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/ResponseCommonTest.kt

              sink: Buffer,
              byteCount: Long,
            ): Long {
              check(!closed)
              return data.read(sink, byteCount)
            }
    
            override fun timeout(): Timeout {
              return Timeout.NONE
            }
          }
        return source.buffer().asResponseBody(null, -1)
      }
    
      private fun newResponse(
        responseBody: ResponseBody,
        code: Int = 200,
      ): Response {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/CommandExtractor.java

            private final Process process;
    
            private final long timeout;
    
            private boolean finished = false;
    
            private boolean teminated = false;
    
            public MonitorThread(final Process process, final long timeout) {
                this.process = process;
                this.timeout = timeout;
            }
    
            @Override
            public void run() {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 13.6K bytes
    - Viewed (0)
Back to top