Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for isLeader (0.26 sec)

  1. cmd/kube-scheduler/app/server.go

    	configz.InstallHandler(pathRecorderMux)
    	pathRecorderMux.Handle("/metrics", legacyregistry.HandlerWithReset())
    
    	resourceMetricsHandler := resources.Handler(informers.Core().V1().Pods().Lister())
    	pathRecorderMux.HandleFunc("/metrics/resources", func(w http.ResponseWriter, req *http.Request) {
    		if !isLeader() {
    			return
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  2. src/cmd/compile/internal/ssagen/pgen.go

    		fmt.Fprintf(os.Stderr, "=-= sorted DCL for %v:\n", fn)
    		for i, v := range fn.Dcl {
    			if !ssa.IsMergeCandidate(v) {
    				continue
    			}
    			fmt.Fprintf(os.Stderr, " %d: %q isleader=%v subsumed=%v used=%v sz=%d align=%d t=%s\n", i, v.Sym().Name, mls.IsLeader(v), mls.Subsumed(v), v.Used(), v.Type().Size(), v.Type().Alignment(), v.Type().String())
    		}
    	}
    
    	// Reassign stack offsets of the locals that are used.
    	lastHasPtr := false
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 15:44:14 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  3. pilot/pkg/leaderelection/leaderelection_test.go

    	})
    
    	// Need to retry until Run() starts to execute in the goroutine.
    	retry.UntilOrFail(t, gotLeader.Load, retry.Converge(5), retry.Delay(time.Millisecond*100), retry.Timeout(time.Second*10))
    	if !l.isLeader() {
    		t.Errorf("isLeader()=false, want true")
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 28 04:22:19 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  4. tensorflow/compiler/mlir/tensorflow/transforms/convert_control_to_data_outputs.cc

      for (auto class_iter = resource_equivalence_classes.begin();
           class_iter != resource_equivalence_classes.end(); ++class_iter) {
        // Only visit one element per class, the leader.
        if (!class_iter->isLeader()) continue;
    
        // Create chain source and sink identity islands for current equivalence
        // class.
        auto chain_arg = func.getArgument(chain_index++);
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Apr 25 16:01:03 UTC 2024
    - 28.7K bytes
    - Viewed (0)
  5. internal/grid/connection.go

    					if err := controlHandler(hdr, &wsReader); err != nil {
    						return nil, err
    					}
    					continue
    				}
    				if hdr.OpCode&want == 0 {
    					if err := wsReader.Discard(); err != nil {
    						return nil, err
    					}
    					continue
    				}
    				if int64(cap(dst)) < hdr.Length+1 {
    					dst = make([]byte, 0, hdr.Length+hdr.Length>>3)
    				}
    				return readAllInto(dst[:0], &wsReader)
    			}
    		}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  6. subprojects/core/src/main/java/org/gradle/api/internal/tasks/DefaultTaskContainer.java

                return identity.uniqueId;
            }
    
            @Override
            public boolean isReplacement() {
                return replacement;
            }
    
            @Override
            public boolean isEager() {
                return eager;
            }
    
        }
    
        private static final class RegisterDetails implements RegisterTaskBuildOperationType.Details {
    
            private final TaskIdentity<?> identity;
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Apr 17 09:54:40 UTC 2024
    - 32.3K bytes
    - Viewed (0)
Back to top