- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 1,268 for itemout (0.26 sec)
-
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/resolutionstrategy/DefaultCachePolicySpec.groovy
assert !atTimeout.mustCheck assert atTimeout.keepFor == Duration.ZERO def almostExpired = cachePolicy.versionListExpiry(null, [moduleId] as Set, Duration.ofMillis(timeout - 1)) assert !almostExpired.mustCheck assert almostExpired.keepFor == Duration.ofMillis(1) def expired = cachePolicy.versionListExpiry(null, [moduleId] as Set, Duration.ofMillis(timeout + 1))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Oct 30 22:04:14 UTC 2023 - 22.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/dispatcher.go
if deadline, hasDeadline := ctx.Deadline(); hasDeadline { // compute the timeout if timeout := time.Until(deadline); timeout > 0 { // if it's not an even number of seconds, round up to the nearest second if truncated := timeout.Truncate(time.Second); truncated != timeout { timeout = truncated + time.Second } // set the timeout r.Timeout(timeout) } } do := func() { err = r.Do(ctx).Into(response) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 23 20:24:12 UTC 2023 - 13K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
@Volatile private var canceled = false @Volatile private var exchange: Exchange? = null internal val plansToCancel = CopyOnWriteArrayList<RoutePlanner.Plan>() override fun timeout(): Timeout = timeout @SuppressWarnings("CloneDoesntCallSuperClone") // We are a final type & this saves clearing state. override fun clone(): Call = RealCall(client, originalRequest, forWebSocket)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/ManagedExecutor.java
* timeout has been reached, forcefully stops remaining jobs and throws an exception. * * @throws IllegalStateException on timeout. */ void stop(int timeoutValue, TimeUnit timeoutUnits) throws IllegalStateException; /** * Sets the keep alive time for the thread pool of the executor. */ void setKeepAlive(int timeout, TimeUnit timeUnit);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 1.4K bytes - Viewed (0) -
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: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.6K bytes - Viewed (0) -
src/runtime/os_dragonfly.go
func futexsleep1(addr *uint32, val uint32, ns int64) { var timeout int32 if ns >= 0 { // The timeout is specified in microseconds - ensure that we // do not end up dividing to zero, which would put us to sleep // indefinitely... timeout = timediv(ns, 1000, nil) if timeout == 0 { timeout = 1 } } // sys_umtx_sleep will return EWOULDBLOCK (EAGAIN) when the timeout
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 05 20:34:30 UTC 2023 - 7.1K bytes - Viewed (0) -
src/internal/poll/splice_linux_test.go
poll.PutPipe(p) } ps = nil p = nil // Exploit the timeout of "go test" as a timer for the subsequent verification. timeout := 5 * time.Minute if deadline, ok := t.Deadline(); ok { timeout = deadline.Sub(time.Now()) timeout -= timeout / 10 // Leave 10% headroom for cleanup. } expiredTime := time.NewTimer(timeout) defer expiredTime.Stop()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 2.8K bytes - Viewed (0) -
pkg/test/framework/resource/flags.go
0, "Gateway conformance test timeout for waiting for creating a k8s resource.") flag.DurationVar(&settingsFromCommandLine.GatewayConformanceTimeoutConfig.DeleteTimeout, "istio.test.gatewayConformance.deleteTimeout", 0, "Gateway conformance test timeout for getting a k8s resource.")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 19:04:51 UTC 2024 - 14K bytes - Viewed (0) -
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 3K bytes - Viewed (0) -
src/runtime/netpoll_wasip1.go
lock(&mtx) // If delay >= 0, we include a subscription of type Clock that we use as // a timeout. If delay < 0, we omit the subscription and allow poll_oneoff // to block indefinitely. pollsubs := subs if delay >= 0 { timeout := &subs[0] clock := timeout.u.subscriptionClock() clock.timeout = uint64(delay) } else { pollsubs = subs[1:] } if len(pollsubs) == 0 { unlock(&mtx)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 6.1K bytes - Viewed (0)