- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 42 for npidle (0.26 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/interface.go
// IsIdle returns a bool indicating whether the QueueSet was idle // at the moment of the return. Idle means the QueueSet has zero // requests queued and zero executing. This bit can change only // (1) during a call to StartRequest and (2) during a call to // Request::Finish. In the latter case idleness can only change // from false to true. IsIdle() bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 6.4K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcecho_test.go
cw := tt.dialEcho("xds:///echo-app.default.svc.cluster.local:7070") distribution := map[string]int{} for i := 0; i < 100; i++ { res, err := cw.Echo(context.Background(), &proto.EchoRequest{Message: "needle"}) if err != nil { return err } distribution[res.Version]++ } if err := expectAlmost(distribution["v1"], 20); err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 8.3K bytes - Viewed (0) -
src/runtime/tracestatus.go
func (w traceWriter) writeProcStatusForP(pp *p, inSTW bool) traceWriter { if !pp.trace.acquireStatus(w.gen) { return w } var status traceProcStatus switch pp.status { case _Pidle, _Pgcstop: status = traceProcIdle if pp.status == _Pgcstop && inSTW { // N.B. a P that is running and currently has the world stopped will be // in _Pgcstop, but we model it as running in the tracer.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 7.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/testing/DaemonsEventSequence.groovy
} } processChanges() } private checkForDaemonsStateChange() { def busy = registry.notIdle.size() def idle = registry.idle.size() def currentState = new DaemonsState(busy, idle) if (!lastDaemonsState.matches(currentState)) { putOnChangeQueue(currentState) lastDaemonsState = currentState
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.5K bytes - Viewed (0) -
src/net/tcpconn_keepalive_conf_solaris_test.go
Enable: true, Idle: 20 * time.Second, Interval: -1, Count: 10, }, { Enable: true, Idle: 20 * time.Second, Interval: 10 * time.Second, Count: -1, }, { Enable: true, Idle: -1, Interval: -1, Count: 10, }, { Enable: true, Idle: -1, Interval: 10 * time.Second, Count: -1, }, { Enable: true, Idle: 20 * time.Second,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 03:10:07 UTC 2024 - 1.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/testing/DaemonsState.groovy
*/ package org.gradle.launcher.daemon.testing /** * Represents the number of given busy and idle daemons in a registry at a particular time. */ class DaemonsState { final int busy final int idle DaemonsState(int busy, int idle) { this.busy = Math.max(busy, 0) this.idle = Math.max(idle, 0) } static getWildcardState() { new DaemonsState() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.3K bytes - Viewed (0) -
src/cmd/go/internal/par/queue.go
if len(st.backlog) == 0 { if st.active--; st.active == 0 && st.idle != nil { close(st.idle) } q.st <- st return } f, st.backlog = st.backlog[0], st.backlog[1:] q.st <- st } }() } // Idle returns a channel that will be closed when q has no (active or enqueued) // work outstanding. func (q *Queue) Idle() <-chan struct{} { st := <-q.st defer func() { q.st <- st }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 24 21:08:46 UTC 2020 - 1.9K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/text/cases/context.go
offset := 2 + e[0]&lengthMask // size of header + fold string nFirst := (e[1] >> lengthBits) & lengthMask if nTitle := e[1] & lengthMask; nTitle != noChange { if nFirst != noChange { e = e[nFirst:] } return c.writeString(e[offset : offset+nTitle]) } if ct == cLower && nFirst != noChange { // Use the uppercase version instead. return c.writeString(e[offset : offset+nFirst]) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 9.5K bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/v1beta4/defaults_windows.go
DefaultCACertPath = "C:/etc/kubernetes/pki/ca.crt" // DefaultContainerRuntimeURLScheme defines default socket url prefix DefaultContainerRuntimeURLScheme = "npipe"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 11:33:30 UTC 2023 - 879 bytes - Viewed (0) -
cmd/kubeadm/app/util/runtime/runtime_windows.go
func isExistingSocket(path string) bool { u, err := url.Parse(path) if err != nil { // should not happen, since we are trying to access known / hardcoded sockets return false } // the dial path must be without "npipe://" _, err = winio.DialPipe(u.Path, nil) if err != nil { return false } return true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 12 15:15:45 UTC 2022 - 1K bytes - Viewed (0)