Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for asReader (0.18 sec)

  1. platforms/jvm/plugins-application/src/main/java/org/gradle/api/internal/plugins/DefaultTemplateBasedStartScriptGenerator.java

        public TextResource getTemplate() {
            return template;
        }
    
        private String generateStartScriptContentFromTemplate(final Map<String, String> binding) {
            try (Reader reader = getTemplate().asReader()) {
                SimpleTemplateEngine engine = new SimpleTemplateEngine();
                Template template = engine.createTemplate(reader);
                String output = template.make(binding).toString();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 20:20:16 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. pilot/pkg/leaderelection/leaderelection.go

    		ttl:   time.Second * 30,
    		cycle: atomic.NewInt32(0),
    		mu:    sync.RWMutex{},
    	}
    }
    
    func (l *LeaderElection) isLeader() bool {
    	l.mu.RLock()
    	defer l.mu.RUnlock()
    	if !l.enabled {
    		return true
    	}
    	if l.le == nil {
    		return false
    	}
    	return l.le.IsLeader()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 12 16:44:32 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  6. 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)
  7. src/cmd/pack/pack.go

    				usage()
    			}
    			op = r
    		case 'v':
    			if verbose {
    				// Can be set only once.
    				usage()
    			}
    			verbose = true
    		default:
    			usage()
    		}
    	}
    }
    
    const (
    	arHeader = "!<arch>\n"
    )
    
    // An Archive represents an open archive file. It is always scanned sequentially
    // from start to end, without backing up.
    type Archive struct {
    	a        *archive.Archive
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 19:41:17 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  8. 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)
  9. src/runtime/malloc.go

    				// Note: disabled when race detector is on, see comment near end of this function.
    				c.tiny = uintptr(x)
    				c.tinyoffset = size
    			}
    			size = maxTinySize
    		} else {
    			hasHeader := !noscan && !heapBitsInSpan(size)
    			if hasHeader {
    				size += mallocHeaderSize
    			}
    			var sizeclass uint8
    			if size <= smallSizeMax-8 {
    				sizeclass = size_to_class8[divRoundUp(size, smallSizeDiv)]
    			} else {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 59.6K bytes
    - Viewed (0)
  10. src/runtime/mbitmap.go

    			}
    		}
    	}
    	if !bad {
    		var addr uintptr
    		tp, addr = tp.next(x + span.elemsize)
    		if addr == 0 {
    			return
    		}
    		println("runtime: extra pointer:", hex(addr))
    	}
    	print("runtime: hasHeader=", header != nil, " typ.Size_=", typ.Size_, " hasGCProg=", typ.Kind_&abi.KindGCProg != 0, "\n")
    	print("runtime: x=", hex(x), " dataSize=", dataSize, " elemsize=", span.elemsize, "\n")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 00:18:55 UTC 2024
    - 60K bytes
    - Viewed (0)
Back to top