Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 281 - 290 of 539 for timedOut (0.08 seconds)

  1. cmd/prepare-storage.go

    func isServerResolvable(endpoint Endpoint, timeout time.Duration) error {
    	serverURL := &url.URL{
    		Scheme: endpoint.Scheme,
    		Host:   endpoint.Host,
    		Path:   pathJoin(healthCheckPathPrefix, healthCheckLivenessPath),
    	}
    
    	httpClient := &http.Client{
    		Transport: globalInternodeTransport,
    	}
    
    	ctx, cancel := context.WithTimeout(GlobalContext, timeout)
    	defer cancel()
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jul 12 20:51:54 GMT 2024
    - 11.1K bytes
    - Click Count (1)
  2. internal/event/target/kafka.go

    			return errors.New("batch should be enabled only if queue dir is enabled")
    		}
    	}
    	if k.BatchCommitTimeout > 0 {
    		if k.QueueDir == "" || k.BatchSize <= 1 {
    			return errors.New("batch commit timeout should be set only if queue dir is enabled and batch size > 1")
    		}
    	}
    	return nil
    }
    
    // KafkaTarget - Kafka target.
    type KafkaTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 13.6K bytes
    - Click Count (0)
  3. docs/changelogs/changelog_3x.md

        reading the full response body. If a call requires redirects or retries all must complete within
        one timeout period.
    
        Use `OkHttpClient.Builder.callTimeout()` to specify the default duration and `Call.timeout()` to
        specify the timeout of an individual call.
    
     *  New: Return values and fields are now non-null unless otherwise annotated.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 14:55:54 GMT 2022
    - 50.8K bytes
    - Click Count (0)
  4. docs/smb3-features/01-smb3-lease-design.md

    ## 10. Error Handling
    
    ### 10.1 Lease Break Timeout
    ```java
    public void handleLeaseBreakWithTimeout(Smb2LeaseKey key, int newState) {
        CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
            handleLeaseBreak(key, newState);
        });
        
        try {
            future.get(5, TimeUnit.SECONDS);  // 5 second timeout
        } catch (TimeoutException e) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 22K bytes
    - Click Count (0)
  5. src/test/java/org/codelibs/fess/exception/SsoProcessExceptionTest.java

            assertNull(exception.getCause());
        }
    
        @Test
        public void test_exceptionChaining() {
            // Test exception chaining with multiple levels
            Exception rootCause = new Exception("Network timeout");
            Exception middleCause = new Exception("SSO provider unreachable", rootCause);
            SsoProcessException topException = new SsoProcessException("SSO authentication failed", middleCause);
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 11 08:43:05 GMT 2026
    - 13.8K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb1/smb1/TransCallNamedPipe.java

            name = pipeName;
            pipeData = data;
            pipeDataOff = off;
            pipeDataLen = len;
            command = SMB_COM_TRANSACTION;
            subCommand = TRANS_CALL_NAMED_PIPE;
            timeout = 0xFFFFFFFF;
            maxParameterCount = 0;
            maxDataCount = 0xFFFF;
            maxSetupCount = (byte) 0x00;
            setupCount = 2;
        }
    
        @Override
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 2.8K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java

        String INDEX_SEARCH_TIMEOUT = "index.search.timeout";
    
        /** The key of the configuration. e.g. 3m */
        String INDEX_SCROLL_SEARCH_TIMEOUT = "index.scroll.search.timeout";
    
        /** The key of the configuration. e.g. 3m */
        String INDEX_INDEX_TIMEOUT = "index.index.timeout";
    
        /** The key of the configuration. e.g. 3m */
        String INDEX_BULK_TIMEOUT = "index.bulk.timeout";
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 576.9K bytes
    - Click Count (2)
  8. src/main/java/jcifs/internal/smb1/trans/TransPeekNamedPipe.java

            super(config, SMB_COM_TRANSACTION, TRANS_PEEK_NAMED_PIPE);
            this.name = pipeName;
            this.fid = fid;
            this.timeout = 0xFFFFFFFF;
            this.maxParameterCount = 6;
            this.maxDataCount = 1;
            this.maxSetupCount = (byte) 0x00;
            this.setupCount = 2;
        }
    
        @Override
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 3K bytes
    - Click Count (0)
  9. src/test/java/jcifs/config/DelegatingConfigurationTest.java

            // Then
            assertEquals(300L, dfsTtl, "Should delegate DFS TTL");
            assertEquals(30000, responseTimeout, "Should delegate response timeout");
            assertEquals(35000, socketTimeout, "Should delegate socket timeout");
            assertEquals(35000, connTimeout, "Should delegate connection timeout");
            assertEquals(10, maxMpx, "Should delegate max MPX count");
    
            verify(mockDelegate).getDfsTtl();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 20.7K bytes
    - Click Count (0)
  10. cmd/server-main.go

    		EnvVar: "MINIO_CONSOLE_ADDRESS",
    	},
    	cli.DurationFlag{
    		Name:   "shutdown-timeout",
    		Value:  time.Second * 30,
    		Usage:  "shutdown timeout to gracefully shutdown server (DEPRECATED)",
    		EnvVar: "MINIO_SHUTDOWN_TIMEOUT",
    		Hidden: true,
    	},
    
    	cli.DurationFlag{
    		Name:   "idle-timeout",
    		Value:  xhttp.DefaultIdleTimeout,
    		Usage:  "idle timeout is the maximum amount of time to wait for the next request when keep-alive are enabled",
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
Back to Top