- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 315 for waits (0.07 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
payload2: Int, ) { try { writer.ping(reply, payload1, payload2) } catch (e: IOException) { failConnection(e) } } /** For testing: sends a ping and waits for a pong. */ @Throws(InterruptedException::class) fun writePingAndAwaitPong() { writePing() awaitPong() } /** For testing: sends a ping to be awaited with [awaitPong]. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
src/internal/poll/fd_unix.go
fd.pd.evict() // The call to decref will call destroy if there are no other // references. err := fd.decref() // Wait until the descriptor is closed. If this was the only // reference, it is already closed. Only wait if the file has // not been set to blocking mode, as otherwise any current I/O // may be blocking, and that would block the Close.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 04:09:44 UTC 2024 - 17.9K bytes - Viewed (0) -
src/runtime/metrics_test.go
// See issue #60276. func TestCPUMetricsSleep(t *testing.T) { if runtime.GOOS == "wasip1" { // Since wasip1 busy-waits in the scheduler, there's no meaningful idle // time. This is accurately reflected in the metrics, but it means this // test is basically meaningless on this platform. t.Skip("wasip1 currently busy-waits in idle time; test not applicable") } names := []string{ "/cpu/classes/idle:cpu-seconds",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:52:17 UTC 2024 - 45K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/deployment.go
shouldCreateWLE: cfg.DeployAsVM && !cfg.AutoRegisterVM, }, nil } // Restart performs restarts of all the pod of the deployment. // This is analogous to `kubectl rollout restart` on the echo deployment and waits for // `kubectl rollout status` to complete before returning, but uses direct API calls. func (d *deployment) Restart() error { var errs error var deploymentNames []string for _, s := range d.cfg.Subsets {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 12:26:52 UTC 2024 - 24.1K bytes - Viewed (0) -
src/runtime/netpoll.go
} if mode == 'r' { pd.rg.Store(pdNil) } else if mode == 'w' { pd.wg.Store(pdNil) } return pollNoError } // poll_runtime_pollWait, which is internal/poll.runtime_pollWait, // waits for a descriptor to be ready for reading or writing, // according to mode, which is 'r' or 'w'. // This returns an error code; the codes are defined above. // //go:linkname poll_runtime_pollWait internal/poll.runtime_pollWait
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 20.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
} // List returns list of pointers to <storeElement> objects. func (w *watchCache) List() []interface{} { return w.store.List() } // waitUntilFreshAndBlock waits until cache is at least as fresh as given <resourceVersion>. // NOTE: This function acquired lock and doesn't release it. // You HAVE TO explicitly call w.RUnlock() after this function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go
e.workLock.Lock() defer e.workLock.Unlock() ns := a.attributes.GetNamespace() // this Add can trigger a Get BEFORE the work is added to a list, but this is ok because the getWork routine // waits the worklock before retrieving the work to do, so the writes in this method will be observed e.queue.Add(ns) if e.inProgress.Has(ns) { e.dirtyWork[ns] = append(e.dirtyWork[ns], a) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 25.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go
// /readyz must return an error, but we need to give it some time err := wait.PollImmediate(100*time.Millisecond, wait.ForeverTestTimeout, func() (done bool, err error) { resultGot := doer.Do(newClient(true), func(httptrace.GotConnInfo) {}, "/readyz", time.Second) // wait until we have a non 200 response if resultGot.response != nil && resultGot.response.StatusCode == http.StatusOK {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 38.3K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
log.Infof("fail to write debug response: %v", err) return } } } // initDebugInterface() listens on localhost:${PORT} for path /debug/... // forwards the paths to Istiod as xDS requests // waits for response from Istiod, sends it as JSON func (p *XdsProxy) initDebugInterface(port int) error { p.tapResponseChannel = make(chan *discovery.DiscoveryResponse) tapGrpcHandler, err := NewTapGrpcHandler(p)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
} // Backoff parameters tuned to retry over 140 seconds. Will fail and restart the Kubelet // after max retry steps. initBackoff := wait.Backoff{ Steps: 6, Duration: 15 * time.Millisecond, Factor: 6.0, Jitter: 0.1, } err = wait.ExponentialBackoff(initBackoff, func() (bool, error) { klog.V(4).Infof("Initializing migrated drivers on CSINode")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0)