Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 365 for timeouts (0.09 sec)

  1. guava-tests/test/com/google/common/collect/QueuesTest.java

          BlockingQueue<T> q,
          Collection<? super T> buffer,
          int maxElements,
          long timeout,
          TimeUnit unit,
          boolean interruptibly)
          throws InterruptedException {
        return interruptibly
            ? Queues.drain(q, buffer, maxElements, timeout, unit)
            : Queues.drainUninterruptibly(q, buffer, maxElements, timeout, unit);
      }
    
      public void testMultipleProducers() throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  2. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockWebServer.kt

      fun takeRequest(): RecordedRequest {
        return delegate.takeRequest().unwrap()
      }
    
      @Throws(InterruptedException::class)
      fun takeRequest(
        timeout: Long,
        unit: TimeUnit,
      ): RecordedRequest? {
        return delegate.takeRequest(timeout, unit)?.unwrap()
      }
    
      @JvmName("-deprecated_requestCount")
      @Deprecated(
        message = "moved to val",
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  3. internal/grid/benchmark_test.go

    	// Wait for all to connect
    	// Parallel writes per server.
    	b.Run("bytes", func(b *testing.B) {
    		for par := 1; par <= 32; par *= 2 {
    			b.Run("par="+strconv.Itoa(par*runtime.GOMAXPROCS(0)), func(b *testing.B) {
    				defer timeout(60 * time.Second)()
    				ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    				defer cancel()
    				b.ReportAllocs()
    				b.SetBytes(int64(len(payload) * 2))
    				b.ResetTimer()
    				t := time.Now()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb1/smb1/TransWaitNamedPipe.java

    class TransWaitNamedPipe extends SmbComTransaction {
    
        TransWaitNamedPipe( String pipeName ) {
            name = pipeName;
            command = SMB_COM_TRANSACTION;
            subCommand = TRANS_WAIT_NAMED_PIPE;
            timeout = 0xFFFFFFFF;
            maxParameterCount = 0;
            maxDataCount = 0;
            maxSetupCount = (byte)0x00;
            setupCount = 2;
        }
    
        int writeSetupWireFormat( byte[] dst, int dstIndex ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 2K bytes
    - Viewed (0)
  5. internal/http/dial_linux.go

    				// ~ cat /proc/sys/net/ipv4/tcp_keepalive_intvl (defaults to 75 secs, we reduce it to 15 secs)
    				_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPINTVL, 15)
    			}
    
    			// Set tcp user timeout in addition to the keep-alive - tcp-keepalive is not enough to close a socket
    			// with dead end because tcp-keepalive is not fired when there is data in the socket buffer.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  6. .github/workflows/mint/minio-erasure.yaml

        MINIO_ROOT_PASSWORD: "minio123"
        MINIO_KMS_SECRET_KEY: "my-minio-key:OSMM+vkKUTCvQs9YL/CVMIMt43HFhkUpqJxTmGl6rYw="
      healthcheck:
        test: ["CMD", "mc", "ready", "local"]
        interval: 5s
        timeout: 5s
        retries: 5
    
    # starts 4 docker containers running minio server instances.
    # using nginx reverse proxy, load balancing, you can access
    # it through port 9000.
    services:
      minio1:
        <<: *minio-common
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Nov 03 21:18:18 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  7. internal/config/identity/openid/openid.go

    // GetDefaultExpiration - returns the expiration seconds expected.
    func GetDefaultExpiration(dsecs string) (time.Duration, error) {
    	timeout := env.Get(config.EnvMinioStsDuration, "")
    	defaultExpiryDuration, err := time.ParseDuration(timeout)
    	if err != nil {
    		defaultExpiryDuration = time.Hour
    	}
    	if timeout == "" && dsecs != "" {
    		expirySecs, err := strconv.ParseInt(dsecs, 10, 64)
    		if err != nil {
    			return 0, auth.ErrInvalidDuration
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 10 20:16:44 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt

              // No client for CONNECT tunnels:
              client = null,
              carrier = this,
              source = source,
              sink = sink,
            )
          source.timeout().timeout(readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
          sink.timeout().timeout(writeTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
          tunnelCodec.writeRequest(nextRequest.headers, requestLine)
          tunnelCodec.finishRequest()
          val response =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt

        if (canceled) {
          stream!!.closeLater(ErrorCode.CANCEL)
          throw IOException("Canceled")
        }
        stream!!.readTimeout().timeout(chain.readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
        stream!!.writeTimeout().timeout(chain.writeTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
      }
    
      override fun flushRequest() {
        http2Connection.flush()
      }
    
      override fun finishRequest() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  10. internal/grid/connection_test.go

    	"testing"
    	"time"
    
    	"github.com/minio/minio/internal/logger/target/testlogger"
    )
    
    func TestDisconnect(t *testing.T) {
    	defer testlogger.T.SetLogTB(t)()
    	defer timeout(10 * time.Second)()
    	hosts, listeners, _ := getHosts(2)
    	dialer := &net.Dialer{
    		Timeout: 1 * time.Second,
    	}
    	errFatal := func(err error) {
    		t.Helper()
    		if err != nil {
    			t.Fatal(err)
    		}
    	}
    	wrapServer := func(handler http.Handler) http.Handler {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:44:00 UTC 2024
    - 5.9K bytes
    - Viewed (0)
Back to top