- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 62 for chanOf (0.16 sec)
-
pkg/kubelet/kubelet_test.go
kubelet.resyncInterval = time.Second * 30 ch := make(chan kubetypes.PodUpdate) close(ch) // sanity check (also prevent this test from hanging in the next step) ok := kubelet.syncLoopIteration(ctx, ch, kubelet, make(chan time.Time), make(chan time.Time), make(chan *pleg.PodLifecycleEvent, 1)) require.False(t, ok, "Expected syncLoopIteration to return !ok since update chan was closed")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/registry/batch/job/strategy_test.go
ObjectMeta: getValidObjectMeta(1), Spec: batch.JobSpec{ Selector: validSelector, Template: validPodTemplateSpec, }, }, }, "attempt status update and verify it doesn't change": { job: batch.Job{ ObjectMeta: getValidObjectMeta(0), Spec: batch.JobSpec{ Selector: validSelector, Template: validPodTemplateSpec, }, Status: batch.JobStatus{ Active: 1,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 101.5K bytes - Viewed (0) -
cluster/gce/util.sh
# change during a cluster upgrade.) local templates templates=$(get-template "${PROJECT}") # Deliberately allow globbing, do not change unless a bug is found # shellcheck disable=SC2206 local all_instance_groups=(${INSTANCE_GROUPS[@]:-} ${WINDOWS_INSTANCE_GROUPS[@]:-}) # Deliberately do not quote, do not change unless a bug is found # shellcheck disable=SC2068
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 21:47:17 UTC 2024 - 161.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/shape_inference.cc
// set, operand types are set as result types if associated body result types // match the operand type (does not change per loop iteration). If operand and // body result types are not the same, only handle types are propagated to // result types. This is necessary to not incorrectly change result shapes // when the While op will have a different result shape. Otherwise operand // shapes are propagated to result shapes.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Jun 08 07:28:49 UTC 2024 - 134.1K bytes - Viewed (0) -
src/cmd/go/internal/load/pkg.go
// modified by modload.LoadPackages. type preload struct { cancel chan struct{} sema chan struct{} } // newPreload creates a new preloader. flush must be called later to avoid // accessing global state while it is being modified. func newPreload() *preload { pre := &preload{ cancel: make(chan struct{}), sema: make(chan struct{}, preloadWorkerCount), } return pre }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 28 17:00:51 UTC 2024 - 120K bytes - Viewed (0) -
src/cmd/link/internal/ld/data.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 12 15:10:50 UTC 2024 - 100.5K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/transform/ArtifactTransformCachingIntegrationTest.groovy
output.count("Transformed") == 0 } def "transform is supplied with a different output directory when parameters change"() { given: // Use another script to define the value, so that transform implementation does not change when the value is changed def otherScript = file("other.gradle") otherScript.text = "ext.value = 123" buildFile << """
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 11:52:44 UTC 2024 - 97.8K bytes - Viewed (0) -
src/net/http/server.go
ctx, cancelCtx = context.WithTimeout(r.Context(), h.dt) defer cancelCtx() } r = r.WithContext(ctx) done := make(chan struct{}) tw := &timeoutWriter{ w: w, h: make(Header), req: r, } panicChan := make(chan any, 1) go func() { defer func() { if p := recover(); p != nil { panicChan <- p } }() h.handler.ServeHTTP(tw, r)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
succeededPods: 2, expectedDeletions: 1, expectedActive: 2, expectedSucceeded: 2, expectedPodPatches: 3, expectedReady: ptr.To[int32](0), }, "status change": { parallelism: 2, completions: 5, backoffLimit: 6, activePods: 2, succeededPods: 2, expectedActive: 2, expectedSucceeded: 2,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
src/cmd/go/alldocs.go
// will be written to that directory. // // The build flags are shared by the build, clean, get, install, list, run, // and test commands: // // -C dir // Change to dir before running the command. // Any files named on the command line are interpreted after // changing directories. // If used, this flag must be the first one in the command line. // -a
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 16:54:28 UTC 2024 - 142.4K bytes - Viewed (0)