- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 138 for timerC (0.23 sec)
-
cmd/tier.go
delete(config.drivercache, k) } // Remove existing tier configs for k := range config.Tiers { delete(config.Tiers, k) } // Copy over the new tier configs for tier, cfg := range newConfig.Tiers { config.Tiers[tier] = cfg } config.lastRefreshedAt = UTCNow() return nil } // Save saves tier configuration onto objAPI
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 08:44:07 UTC 2024 - 15.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/time.go
} return false } // Unix returns the local time corresponding to the given Unix time // by wrapping time.Unix. func Unix(sec int64, nsec int64) Time { return Time{time.Unix(sec, nsec)} } // Rfc3339Copy returns a copy of the Time at second-level precision. func (t Time) Rfc3339Copy() Time { copied, _ := time.Parse(time.RFC3339, t.Format(time.RFC3339)) return Time{copied} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 21:48:09 UTC 2024 - 5.2K bytes - Viewed (0) -
src/runtime/chan.go
// It reports whether any elements were removed. // Because it is only intended for timers, it does not // handle waiting senders at all (all timer channels // use non-blocking sends to fill the buffer). func timerchandrain(c *hchan) bool { // Note: Cannot use empty(c) because we are called // while holding c.timer.sendLock, and empty(c) will // call c.timer.maybeRunChan, which will deadlock. // We are emptying the channel, so we only care about
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
build-logic/lifecycle/src/main/kotlin/PrintStackTracesOnTimeoutBuildService.kt
interface Params : BuildServiceParameters { val timeoutMillis: Property<Long> val projectDirectory: DirectoryProperty } private val timer: Timer = Timer(true).apply { schedule( timerTask { execOperations.exec { commandLine( "${System.getProperty("java.home")}/bin/java",
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 22 07:59:48 UTC 2024 - 1.9K bytes - Viewed (0) -
src/runtime/proc.go
continue } // Steal timers from p2. This call to checkTimers is the only place // where we might hold a lock on a different P's timers. We do this // once on the last pass before checking runnext because stealing // from the other P's runnext should be the last resort, so if there // are timers to steal do that first. // // We only check timers on one of the stealing iterations because
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress.go
pr.stopped = true pr.cond.Signal() }() timer := pr.clock.NewTimer(progressRequestPeriod) defer timer.Stop() for { stopped := func() bool { pr.mux.Lock() defer pr.mux.Unlock() for pr.waiting == 0 && !pr.stopped { pr.cond.Wait() } return pr.stopped }() if stopped { return } select { case <-timer.C(): shouldRequest := func() bool { pr.mux.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 09:56:38 UTC 2024 - 3K bytes - Viewed (0) -
src/testing/benchmark.go
if b.timerOn { b.duration += highPrecisionTimeSince(b.start) runtime.ReadMemStats(&memStats) b.netAllocs += memStats.Mallocs - b.startAllocs b.netBytes += memStats.TotalAlloc - b.startBytes b.timerOn = false } } // ResetTimer zeroes the elapsed benchmark time and memory allocation counters // and deletes user-reported metrics. // It does not affect whether the timer is running.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 23.9K bytes - Viewed (0) -
src/internal/trace/internal/oldtrace/parser.go
Type event.Type // one of Ev* } // Frame is a frame in stack traces. type Frame struct { PC uint64 // string ID of the function name Fn uint64 // string ID of the file name File uint64 Line int } const ( // Special P identifiers: FakeP = 1000000 + iota TimerP // contains timer unblocks NetpollP // contains network unblocks
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 46.8K bytes - Viewed (0) -
platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/steps/CaptureOutputsAfterExecutionStep.java
private OriginMetadata createOriginMetadata(CachingState.CacheKeyCalculatedState cacheKeyCalculatedState, Result result, Timer timer) { long snapshotOutputDuration = timer.getElapsedMillis(); // The origin execution time is recorded as “work duration” + “output snapshotting duration”, // As this is _roughly_ the amount of time that is avoided by reusing the outputs, // which is currently the _only_ thing this value is used for.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 16:02:33 UTC 2024 - 5.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0)