- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,836 for startm (0.13 sec)
-
pkg/controller/cronjob/utils_test.go
if schedule == nil { t.Errorf("expected 1 start time, got nil") } else if !schedule.Equal(T1) { t.Errorf("expected: %v, got: %v", T1, schedule) } } { // Case 3: known LastScheduleTime, no start needed. // Creation time is before T1. cj.ObjectMeta.CreationTimestamp = metav1.Time{Time: T1.Add(-10 * time.Minute)} // Status shows a start at the expected time.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 22.8K bytes - Viewed (0) -
src/os/exec/exec.go
// order to release associated system resources. func (c *Cmd) Start() error { // Check for doubled Start calls before we defer failure cleanup. If the prior // call to Start succeeded, we don't want to spuriously close its pipes. if c.Process != nil { return errors.New("exec: already started") } started := false defer func() { closeDescriptors(c.childIOFiles)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 41.4K bytes - Viewed (0) -
src/vendor/golang.org/x/text/unicode/norm/composition.go
for i := 0; i < rb.nrune; i++ { start := rb.rune[i].pos end := start + rb.rune[i].size rb.out = append(rb.out, rb.byte[start:end]...) } return true } // flush appends the normalized segment to out and resets rb. func (rb *reorderBuffer) flush(out []byte) []byte { for i := 0; i < rb.nrune; i++ { start := rb.rune[i].pos end := start + rb.rune[i].size out = append(out, rb.byte[start:end]...)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 19:27:51 UTC 2019 - 14.1K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/stub.go
// SetRegisterControlFunc sets RegisterControlFunc of the device plugin func (m *Stub) SetRegisterControlFunc(f stubRegisterControlFunc) { m.registerControlFunc = f } // Start starts the gRPC server of the device plugin. Can only // be called once. func (m *Stub) Start() error { klog.InfoS("Starting device plugin server") err := m.cleanup() if err != nil { return err } sock, err := net.Listen("unix", m.socket)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 11:19:10 UTC 2023 - 11.5K bytes - Viewed (0) -
src/text/template/parse/lex.go
func (l *lexer) nextItem() item { l.item = item{itemEOF, l.pos, "EOF", l.startLine} state := lexText if l.insideAction { state = lexInsideAction } for { state = state(l) if state == nil { return l.item } } } // lex creates a new scanner for the input string. func lex(name, input, left, right string) *lexer { if left == "" { left = leftDelim
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 04 22:36:12 UTC 2022 - 18.1K bytes - Viewed (0) -
cmd/kube-controller-manager/app/controllermanager.go
automation, a control loop is a non-terminating loop that regulates the state of the system. In Kubernetes, a controller is a control loop that watches the shared state of the cluster through the apiserver and makes changes attempting to move the current state towards the desired state. Examples of controllers that ship with Kubernetes today are the replication controller, endpoints controller, namespace
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 13:03:53 UTC 2024 - 37.5K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
} // we're waiting until after the informer start that happens once all the controllers are initialized. This ensures // that they don't get unexpected events on their work queues. <-qm.informersStarted monitors := qm.monitors started := 0 for _, monitor := range monitors { if monitor.stopCh == nil { monitor.stopCh = make(chan struct{}) qm.informerFactory.Start(qm.stopCh) go monitor.Run() started++
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
src/cmd/doc/main.go
// work. var period int // slash+1: if there's no slash, the value is -1 and start is 0; otherwise // start is the byte after the slash. for start := slash + 1; start < len(arg); start = period + 1 { period = strings.Index(arg[start:], ".") symbol := "" if period < 0 { period = len(arg) } else { period += start symbol = arg[period+1:] } // Have we identified a package already?
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 12.2K bytes - Viewed (0) -
src/net/http/pprof/pprof.go
sec = 1 } configureWriteDeadline(w, r, sec) // Set Content Type assuming trace.Start will work, // because if it does it starts writing. w.Header().Set("Content-Type", "application/octet-stream") w.Header().Set("Content-Disposition", `attachment; filename="trace"`) if err := trace.Start(w); err != nil { // trace.Start failed, so no writes yet. serveError(w, http.StatusInternalServerError,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 27 17:34:05 UTC 2024 - 14.1K bytes - Viewed (0) -
src/internal/trace/internal/oldtrace/parser.go
g := gs[ev.G] p := ps[ev.P] if g.state != gRunnable { return fmt.Errorf("g %d is not runnable before start (time %d)", ev.G, ev.Ts) } if p.g != 0 { return fmt.Errorf("p %d is already running g %d while start g %d (time %d)", ev.P, p.g, ev.G, ev.Ts) } g.state = gRunning g.evStart = ev p.g = ev.G if g.evCreate != nil { ev.StkID = uint32(g.evCreate.Args[1])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 46.8K bytes - Viewed (0)