- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,268 for itemout (0.13 sec)
-
src/net/dial.go
timeout := timeRemaining / time.Duration(addrsRemaining) // If the time per address is too short, steal from the end of the list. const saneMinimum = 2 * time.Second if timeout < saneMinimum { if timeRemaining < saneMinimum { timeout = timeRemaining } else { timeout = saneMinimum } } return now.Add(timeout), nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 26.9K bytes - Viewed (0) -
internal/ioutil/ioutil.go
} } // DeadlineWorker implements the deadline/timeout resiliency pattern. type DeadlineWorker struct { timeout time.Duration } // NewDeadlineWorker constructs a new DeadlineWorker with the given timeout. // To return values, use the WithDeadline helper instead. func NewDeadlineWorker(timeout time.Duration) *DeadlineWorker { dw := &DeadlineWorker{ timeout: timeout, } return dw }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 10.2K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/util.go
dialer, _ := proxy.SOCKS5("tcp", proxyURL.Host, nil, proxy.Direct) return dialer.(hbone.Dialer) } out := &net.Dialer{ Timeout: common.ConnectionTimeout, } if cfg.forceDNSLookup { out.Resolver = newResolver(common.ConnectionTimeout, "", "") } return out } func newResolver(timeout time.Duration, protocol, dnsServer string) *net.Resolver { return &net.Resolver{ PreferGo: true,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Oct 08 09:39:20 UTC 2023 - 4.4K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/timeout/IntegrationTestTimeout.java
* after the given duration has elapsed. The default time unit is seconds. * * This annotation can be used in similar way with {@link spock.lang.Timeout}, but shouldn't * be used together with {@link spock.lang.Timeout}. It should be annotated on * {@link org.gradle.integtests.fixtures.AbstractIntegrationSpec}. Upon timeout, * all threads' stack traces of current JVM (embedded executer) or forked JVM (forking executer)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.5K bytes - Viewed (0) -
cluster/gce/windows/smoke-test.sh
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 07:02:51 UTC 2024 - 20.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
private final AtomicBoolean executed = new AtomicBoolean(false); private final long timeout; public ProcessDestroyer(final Process p, final InputStreamThread ist, final long timeout) { this.p = p; this.ist = ist; this.timeout = timeout; } @Override public void run() { if (!p.isAlive()) {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.6K bytes - Viewed (0) -
internal/http/transports.go
return tr } } // NewHTTPTransportWithTimeout allows setting a timeout for response headers func (s ConnSettings) NewHTTPTransportWithTimeout(timeout time.Duration) *http.Transport { tr := s.getDefaultTransport(0) // Settings specific to this transport. tr.ResponseHeaderTimeout = timeout return tr } // NewHTTPTransportWithClientCerts returns a new http configuration used for
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/PdfExtractor.java
if (value != null) { extractData.putValue(name, value); } } public long getTimeout() { return timeout; } public void setTimeout(final long timeout) { this.timeout = timeout; } public void setDaemonThread(final boolean isDaemonThread) { this.isDaemonThread = isDaemonThread; }
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 9.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/get.go
return } // TODO: Currently we explicitly ignore ?timeout= and use only ?timeoutSeconds=. timeout := time.Duration(0) if opts.TimeoutSeconds != nil { timeout = time.Duration(*opts.TimeoutSeconds) * time.Second } if timeout == 0 && minRequestTimeout > 0 { timeout = time.Duration(float64(minRequestTimeout) * (rand.Float64() + 1.0)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 10:22:16 UTC 2024 - 10.7K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/ConcurrentSpec.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 3.5K bytes - Viewed (0)