Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 138 for timerC (0.23 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    			// is running, not only the first ones in the list.
    			timer := c.timer
    			for _, watcher := range c.blockedWatchers {
    				if !watcher.add(event, timer) {
    					// fired, clean the timer by set it to nil.
    					timer = nil
    				}
    			}
    
    			// Stop the timer if it is not fired
    			if timer != nil && !timer.Stop() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
Back to top