- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 138 for timerC (0.2 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonStateCoordinator.java
import org.gradle.internal.concurrent.ExecutorFactory; import org.gradle.internal.concurrent.ManagedExecutor; import org.gradle.internal.concurrent.Stoppable; import org.gradle.internal.time.CountdownTimer; import org.gradle.internal.time.Time; import org.gradle.internal.time.Timer; import org.gradle.launcher.daemon.server.api.DaemonStateControl; import org.gradle.launcher.daemon.server.api.DaemonStoppedException;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 17.1K bytes - Viewed (0) -
cmd/tier-handlers.go
) var ( // error returned when remote tier already exists errTierAlreadyExists = AdminError{ Code: "XMinioAdminTierAlreadyExists", Message: "Specified remote tier already exists", StatusCode: http.StatusConflict, } // error returned when remote tier is not found errTierNotFound = AdminError{ Code: "XMinioAdminTierNotFound", Message: "Specified remote tier was not found", StatusCode: http.StatusNotFound,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7.5K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/daemon/TestableDaemon.groovy
} protected void waitForState(State state) { def timer = Time.startCountdownTimer(STATE_CHANGE_TIMEOUT) def lastRegistryState = registryProbe.currentState def lastLogState = logFileProbe.currentState while (!timer.hasExpired() && (lastRegistryState != state || lastLogState != state)) { Thread.sleep(200)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 15:22:16 UTC 2024 - 3.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/api/v2/legalize_tf.cc
std::vector<std::vector<xla::Shape>>* per_core_arg_shapes, xla::CompileOnlyClient* client) { CompilationTimer timer; auto record_time = llvm::make_scope_exit([&timer] { phase2_bridge_compilation_time->GetCell(kFullBridge) ->Add(timer.ElapsedCyclesInMilliseconds()); }); auto compilation_result = std::make_unique<XlaCompilationResult>(); DumpComputationInput(computation);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 29 00:40:46 UTC 2024 - 6.8K bytes - Viewed (0) -
src/runtime/trace.go
type traceAdvancerState struct { timer *wakeableSleep done chan struct{} } // start starts a new traceAdvancer. func (s *traceAdvancerState) start() { // Start a goroutine to periodically advance the trace generation. s.done = make(chan struct{}) s.timer = newWakeableSleep() go func() { for traceEnabled() { // Set a timer to wake us up s.timer.sleep(int64(debug.traceadvanceperiod))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 37.1K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-go-create-without-running-g.go
// // GoCreate events can happen on bare Ps in a variety of situations and // and earlier version of the parser assumed this wasn't possible. At // the time of writing, one such example is goroutines created by expiring // timers. package main import ( "internal/trace" "internal/trace/event/go122" testgen "internal/trace/internal/testgen/go122" ) func main() { testgen.Main(gen) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 996 bytes - Viewed (0) -
cmd/mrf.go
continue } } now := time.Now() if now.Sub(u.queued) < time.Second { // let recently failed networks to reconnect // making MRF wait for 1s before retrying, // i.e 4 reconnect attempts. time.Sleep(time.Second) } // wait on timer per heal wait := healSleeper.Timer(context.Background()) scan := madmin.HealNormalScan
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 3.2K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/ztypes_zos_s390x.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 16:12:58 UTC 2024 - 8.6K bytes - Viewed (0) -
src/runtime/lock_sema.go
if gp.m.locks < 0 { throw("runtime·lock: lock count") } gp.m.locks++ // Speculative grab for lock. if atomic.Casuintptr(&l.key, 0, locked) { return } semacreate(gp.m) timer := &lockTimer{lock: l} timer.begin() // On uniprocessor's, no point spinning. // On multiprocessors, spin for ACTIVE_SPIN attempts. spin := 0 if ncpu > 1 { spin = active_spin } Loop: for i := 0; ; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 6.8K bytes - Viewed (0) -
src/time/time_test.go
}}, {"Truncate", func(t1, t2 Time) bool { return t1.Truncate(Hour).Equal(t2.Truncate(Hour)) }}, {"Round", func(t1, t2 Time) bool { return t1.Round(Hour).Equal(t2.Round(Hour)) }}, {"== Time{}", func(t1, t2 Time) bool { return (t1 == Time{}) == (t2 == Time{}) }}, } func TestDefaultLoc(t *testing.T) { // Verify that all of Time's methods behave identically if loc is set to // nil or UTC.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:13:47 UTC 2024 - 56.5K bytes - Viewed (0)