- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 66 for waitc (0.05 sec)
-
tests/integration/ambient/baseline_test.go
istioctl.NewOrFail(t, t, istioctl.Config{}).InvokeOrFail(t, []string{ "waypoint", "apply", "--namespace", apps.Namespace.Name(), "--name", "captured-waypoint", "--wait", }) t.Cleanup(func() { istioctl.NewOrFail(t, t, istioctl.Config{}).InvokeOrFail(t, []string{ "waypoint", "delete", "--namespace", apps.Namespace.Name(), "captured-waypoint",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 78.4K bytes - Viewed (0) -
src/testing/testing.go
t.checkRaces() if t.chatty != nil { t.chatty.Updatef(t.name, "=== PAUSE %s\n", t.name) } running.Delete(t.name) t.signal <- true // Release calling test. <-t.parent.barrier // Wait for the parent test to complete. t.context.waitParallel() if t.chatty != nil { t.chatty.Updatef(t.name, "=== CONT %s\n", t.name) } running.Store(t.name, highPrecisionTimeNow())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 76.1K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
if !cache.WaitForNamedCacheSync("job", ctx.Done(), jm.podStoreSynced, jm.jobStoreSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, jm.worker, time.Second) } go wait.UntilWithContext(ctx, jm.orphanWorker, time.Second) <-ctx.Done() } // getPodJobs returns a list of Jobs that potentially match a Pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller.go
} } // Despite the volume being Failed, the controller will retry deleting // the volume in every syncVolume() call. return pluginName, err } if !deleted { // The volume waits for deletion by an external plugin. Do nothing. return pluginName, nil } logger.V(4).Info("DeleteVolumeOperation: success", "volumeName", volume.Name) // Delete the volume
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0) -
src/cmd/go/internal/modload/load.go
return "", err } else if !ok { // This main module could contain the directory but doesn't. Other main // modules might contain the directory, so wait till we finish the loop // to see if another main module contains directory. But if not, // return an error. if len(mainModulePrefix) > len(pkgNotFoundLongestPrefix) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 14:56:56 UTC 2024 - 84K bytes - Viewed (0) -
src/crypto/tls/conn.go
c.quic.cancel = cancel } else if ctx.Done() != nil { // Start the "interrupter" goroutine, if this context might be canceled. // (The background context cannot). // // The interrupter goroutine waits for the input context to be done and // closes the connection if this happens before the function returns. done := make(chan struct{}) interruptRes := make(chan error, 1) defer func() { close(done)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 51.8K bytes - Viewed (0) -
src/crypto/tls/tls_test.go
} if len(data) > 0 { return fmt.Errorf("Read data = %q; want nothing", data) } if err := srv.CloseWrite(); err != nil { return fmt.Errorf("server CloseWrite: %v", err) } // Wait for clientCloseWrite to finish, so we know we // tested the CloseWrite before we defer the // sconn.Close above, which would also cause the // client to unblock like CloseWrite. <-clientDoneChan return nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 60.5K bytes - Viewed (0) -
src/runtime/mgcmark.go
// Try to keep work available on the global queue. We used to // check if there were waiting workers, but it's better to // just keep work available than to make workers wait. In the // worst case, we'll do O(log(_WorkbufSize)) unnecessary // balances. if work.full == 0 { gcw.balance() } b := gcw.tryGetFast() if b == 0 { b = gcw.tryGet()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 21:25:11 UTC 2024 - 52.5K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy_test.go
req.ContentLength = reqLen resp, _ := frontendClient.Transport.RoundTrip(req) if resp != nil { io.Copy(io.Discard, resp.Body) resp.Body.Close() } } }() } wg.Wait() } func TestSelectFlushInterval(t *testing.T) { tests := []struct { name string p *ReverseProxy res *http.Response want time.Duration }{ { name: "default",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 54.6K bytes - Viewed (0) -
src/runtime/mgcscavenge.go
// Spend at least 1 ms scavenging, otherwise the corresponding // sleep time to maintain our desired utilization is too low to // be reliable. minScavWorkTime = 1e6 ) // Sleep/wait state of the background scavenger. var scavenger scavengerState type scavengerState struct { // lock protects all fields below. lock mutex // g is the goroutine the scavenger is bound to. g *g
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:48:45 UTC 2024 - 52.3K bytes - Viewed (0)