- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 2,113 for Forever (0.12 sec)
-
pkg/volume/csi/csi_plugin.go
if err := nim.UninstallCSIDriver(driverName); err != nil { return errors.New(log("Error uninstalling CSI driver: %v", err)) } return nil } // waitForAPIServerForever waits forever to get a CSINode instance as a proxy // for a healthy APIServer func waitForAPIServerForever(client clientset.Interface, nodeName types.NodeName) error { var lastErr error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
} /** * Awaits the next HTTP request, removes it, and returns it. Callers should use this to verify the * request was sent as intended. This method will block until the request is available, possibly * forever. * * @return the head of the request queue */ @Throws(InterruptedException::class) fun takeRequest(): RecordedRequest = requestQueue.take() /**
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 37.4K bytes - Viewed (0) -
cluster/gce/windows/common.psm1
Throw ("$Path corrupted, $Algorithm $actual doesn't match expected $Hash") } } # Attempts to download the file from URLs, trying each URL until it succeeds. # It will loop through the URLs list forever until it has a success. If # successful, it will write the file to OutFile. You can optionally provide a # Hash argument with an optional Algorithm, in which case it will attempt to
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 19 14:47:38 UTC 2022 - 25.4K bytes - Viewed (0) -
src/crypto/tls/tls_test.go
// in a handshake. Cancel our context and see if we get unstuck. // (Our TCP listener above never reads or writes, so the Handshake // would otherwise be stuck forever) cancel() return len(b), nil }), ServerName: "foo", }} _, err := d.DialContext(ctx, "tcp", ln.Addr().String()) if err != context.Canceled { t.Errorf("err = %v; want context.Canceled", err)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 60.5K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
downstreamDeltas DeltaDiscoveryStream upstreamDeltas DeltaDiscoveryClient } // sendRequest is a small wrapper around sending to con.requestsChan. This ensures that we do not // block forever on func (con *ProxyConnection) sendRequest(req *discovery.DiscoveryRequest) { con.requestsChan.Put(req) } func (con *ProxyConnection) isClosed() bool { select { case <-con.stopChan: return true
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/istio-agent/agent.go
// nolint: unparam func (a *Agent) getWorkloadCerts(st *cache.SecretManagerClient) (sk *security.SecretItem, err error) { b := backoff.NewExponentialBackOff(backoff.DefaultOption()) // This will loop forever until success err = b.RetryWithContext(context.TODO(), func() error { sk, err = st.GenerateSecret(security.WorkloadKeyCertResourceName) if err == nil { return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 26.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/scheme.go
// Whenever an object of this type is serialized, it is serialized with the provided group version and is not // converted. Thus unversioned objects are expected to remain backwards compatible forever, as if they were in an // API group and version that would never be updated. // // TODO: there is discussion about removing unversioned and replacing it with objects that are manifest into
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 25.2K bytes - Viewed (0) -
src/cmd/go/internal/modload/import.go
return err == nil && !fi.IsDir() }) if haveGoMod { return "", false, nil } parent := filepath.Dir(d) if parent == d { // Break the loop, as otherwise we'd loop // forever if d=="." and mdir=="". break } d = parent } } // Now committed to returning dir (not ""). // Are there Go source files in the directory?
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 07 15:21:14 UTC 2024 - 27.7K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2.go
updateStatus = true } } } // Remove any job reference from the active list if the corresponding job does not exist any more. // Otherwise, the cronjob may be stuck in active mode forever even though there is no matching // job running. for _, j := range cronJob.Status.Active { _, found := childrenJobs[j.UID] if found { continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0) -
src/cmd/vet/testdata/print/print.go
Printf("%p", someFunction) // ok: maybe someone wants to see the pointer Printf("%T", someFunction) // ok: maybe someone wants to see the type // Bug: used to recur forever. Printf("%p %x", recursiveStructV, recursiveStructV.next) Printf("%p %x", recursiveStruct1V, recursiveStruct1V.next) // ERROR "Printf format %x has arg recursiveStruct1V\.next of wrong type \*.*print\.RecursiveStruct2"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 09 01:28:01 UTC 2023 - 27.5K bytes - Viewed (0)