- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 871 for waits (0.4 sec)
-
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) -
common-protos/k8s.io/api/storage/v1/generated.proto
// operation (because it implements the CSI ControllerPublishVolume() // method), and that the Kubernetes attach detach controller should call // the attach volume interface which checks the volumeattachment status // and waits until the volume is attached before proceeding to mounting. // The CSI external-attacher coordinates with CSI volume driver and updates // the volumeattachment status when the attach operation is complete.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 24.7K bytes - Viewed (0) -
common-protos/k8s.io/api/storage/v1beta1/generated.proto
// operation (because it implements the CSI ControllerPublishVolume() // method), and that the Kubernetes attach detach controller should call // the attach volume interface which checks the volumeattachment status // and waits until the volume is attached before proceeding to mounting. // The CSI external-attacher coordinates with CSI volume driver and updates // the volumeattachment status when the attach operation is complete.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 24.9K 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) -
staging/src/k8s.io/api/storage/v1/types.go
// operation (because it implements the CSI ControllerPublishVolume() // method), and that the Kubernetes attach detach controller should call // the attach volume interface which checks the volumeattachment status // and waits until the volume is attached before proceeding to mounting. // The CSI external-attacher coordinates with CSI volume driver and updates // the volumeattachment status when the attach operation is complete.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 32K bytes - Viewed (0) -
pkg/apis/storage/types.go
// operation (because it implements the CSI ControllerPublishVolume() // method), and that the Kubernetes attach detach controller should call // the attach volume interface which checks the volumeattachment status // and waits until the volume is attached before proceeding to mounting. // The CSI external-attacher coordinates with CSI volume driver and updates // the volumeattachment status when the attach operation is complete.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 13 20:24:57 UTC 2023 - 29.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go
}() // wait for all in-flight non-long running requests to finish nonLongRunningRequestDrainedCh := make(chan struct{}) go func() { defer close(nonLongRunningRequestDrainedCh) defer klog.V(1).Info("[graceful-termination] in-flight non long-running request(s) have drained") // wait for the delayed stopCh before closing the handler chain (it rejects everything after Wait has been called).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 42.9K bytes - Viewed (0) -
staging/src/k8s.io/api/storage/v1beta1/types.go
// operation (because it implements the CSI ControllerPublishVolume() // method), and that the Kubernetes attach detach controller should call // the attach volume interface which checks the volumeattachment status // and waits until the volume is attached before proceeding to mounting. // The CSI external-attacher coordinates with CSI volume driver and updates // the volumeattachment status when the attach operation is complete.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 27 20:06:32 UTC 2023 - 33.1K bytes - Viewed (0)