Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 62 for chanOf (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. src/cmd/link/internal/ld/data.go

    				}
    
    				break
    			}
    
    			// On AIX, a second relocation must be done by the loader,
    			// as section addresses can change once loaded.
    			// The "default" symbol address is still needed by the loader so
    			// the current relocation can't be skipped.
    			if target.IsAIX() && rst != sym.SDYNIMPORT {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 12 15:10:50 UTC 2024
    - 100.5K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top