Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 417 for timeouts (0.2 sec)

  1. 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)
  2. istioctl/pkg/clioptions/central.go

    	XdsPodLabel string
    
    	// XdsPodPort is a port exposing XDS (typically 15010 or 15012)
    	XdsPodPort int
    
    	// CertDir is the local directory containing certificates
    	CertDir string
    
    	// Timeout is how long to wait before giving up on XDS
    	Timeout time.Duration
    
    	// InsecureSkipVerify skips client verification the server's certificate chain and host name.
    	InsecureSkipVerify bool
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jun 06 03:39:27 UTC 2022
    - 3.2K bytes
    - Viewed (0)
  3. 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)
  4. .teamcity/src/main/kotlin/model/CIBuildModel.kt

        val displayName: String,
        val timeout: Int,
        val defaultBaselines: String = "",
        val channel: String,
        val extraParameters: String = ""
    ) {
        per_commit(
            displayName = "Performance Regression Test",
            timeout = 420,
            channel = "commits"
        ),
        per_day(
            displayName = "Slow Performance Regression Test",
            timeout = 420,
            channel = "commits"
        ),
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Oct 16 06:14:14 UTC 2024
    - 22.9K bytes
    - Viewed (0)
  5. 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)
  6. src/main/java/jcifs/Configuration.java

         * 
         * Property <tt>jcifs.smb.client.soTimeout</tt> (int, default 35000)
         * 
         * @return socket timeout, in milliseconds
         */
        int getSoTimeout ();
    
    
        /**
         * 
         * Property <tt>jcifs.smb.client.connTimeout</tt> (int, default 35000)
         * 
         * @return timeout for establishing a socket connection, in milliseconds
         */
        int getConnTimeout ();
    
    
        /**
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:06:39 UTC 2023
    - 18K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/timer/HotThreadMonitorTarget.java

                        esClient.admin().cluster().prepareNodesHotThreads().setIgnoreIdleThreads(ignoreIdleThreads).setInterval(interval)
                                .setThreads(threads).setTimeout(timeout).setType(type).execute().actionGet(timeout);
                append(buf, "cluster_name", () -> response.getClusterName().value()).append(',');
                final String hotThreads = response.getNodesMap().entrySet().stream().map(e -> {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  8. 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)
  9. internal/ioutil/ioutil_test.go

    package ioutil
    
    import (
    	"bytes"
    	"context"
    	"errors"
    	"io"
    	"os"
    	"strings"
    	"testing"
    	"time"
    )
    
    type sleepWriter struct {
    	timeout time.Duration
    }
    
    func (w *sleepWriter) Write(p []byte) (n int, err error) {
    	time.Sleep(w.timeout)
    	return len(p), nil
    }
    
    func (w *sleepWriter) Close() error {
    	return nil
    }
    
    func TestDeadlineWorker(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/core/timer/TimeoutManager.java

         *
         * @param timeoutTarget target
         * @param timeout timeout
         * @param permanent permanent
         * @return {@link TimeoutTask}
         */
        public synchronized TimeoutTask addTimeoutTarget(final TimeoutTarget timeoutTarget, final int timeout, final boolean permanent) {
            final TimeoutTask task = new TimeoutTask(timeoutTarget, timeout, permanent);
            timeoutTaskList.addLast(task);
            start();
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 8K bytes
    - Viewed (0)
Back to top