Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 47 for len (0.01 sec)

  1. cmd/erasure-healing-common.go

    	availableDisks = make([]StorageAPI, len(onlineDisks))
    
    	dataErrsByDisk = make(map[int][]int, len(onlineDisks))
    	for i := range onlineDisks {
    		dataErrsByDisk[i] = make([]int, len(latestMeta.Parts))
    	}
    
    	dataErrsByPart = make(map[int][]int, len(latestMeta.Parts))
    	for i := range latestMeta.Parts {
    		dataErrsByPart[i] = make([]int, len(onlineDisks))
    	}
    
    	inconsistent := 0
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/table/writer.go

    	return Cell{value, attrs}
    }
    
    func (cell Cell) String() string {
    	if len(cell.Attributes) == 0 {
    		return cell.Value
    	}
    	s := color.New(cell.Attributes...)
    	s.EnableColor()
    	return s.Sprintf("%s", cell.Value)
    }
    
    func (c *ColoredTableWriter) getTableOutput(allRows []Row) [][]Cell {
    	output := [][]Cell{}
    	if len(c.header.Cells) != 0 {
    		output = append(output, c.header.Cells)
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 06 09:43:25 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  3. istioctl/pkg/describe/describe.go

    		}
    	}
    
    	if matches == 0 {
    		if len(vs.Spec.Http) > 0 {
    			fmt.Fprintf(writer, "%sWARNING: No destinations match pod subsets (checked %d HTTP routes)\n",
    				printSpaces(initPrintNum+printLevel1), len(vs.Spec.Http))
    		}
    		if len(vs.Spec.Tcp) > 0 {
    			fmt.Fprintf(writer, "%sWARNING: No destinations match pod subsets (checked %d TCP routes)\n",
    				printSpaces(initPrintNum+printLevel1), len(vs.Spec.Tcp))
    		}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  4. src/bufio/bufio_test.go

    	var texts [31]string
    	str := ""
    	all := ""
    	for i := 0; i < len(texts)-1; i++ {
    		texts[i] = str + "\n"
    		all += texts[i]
    		str += string(rune(i%26 + 'a'))
    	}
    	texts[len(texts)-1] = all
    
    	for h := 0; h < len(texts); h++ {
    		text := texts[h]
    		for i := 0; i < len(readMakers); i++ {
    			for j := 0; j < len(bufreaders); j++ {
    				for k := 0; k < len(bufsizes); k++ {
    					readmaker := readMakers[i]
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  5. cmd/global-heal.go

    		if len(disks) == healing {
    			// All drives in this erasure set were reformatted for some reasons, abort healing and mark it as successful
    			healingLogIf(ctx, errors.New("all drives are in healing state, aborting.."))
    			return nil
    		}
    
    		disks = disks[:len(disks)-healing] // healing drives are always at the end of the list
    
    		if len(disks) < er.setDriveCount/2 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  6. istioctl/pkg/proxyconfig/proxyconfig.go

    `,
    		Aliases: []string{"es"},
    		Args: func(cmd *cobra.Command, args []string) error {
    			if len(args) != 1 && (labelSelector == "") {
    				cmd.Println(cmd.UsageString())
    				return fmt.Errorf("stats requires pod name or label selector")
    			}
    			if len(args) == 1 && (labelSelector != "") {
    				cmd.Println(cmd.UsageString())
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 15:53:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  7. cmd/erasure-object.go

    	metadataArray := make([]*xlMetaV2, len(rawFileInfos))
    	metaFileInfos := make([]FileInfo, len(rawFileInfos))
    	metadataShallowVersions := make([][]xlMetaV2ShallowVersion, len(rawFileInfos))
    	var v2bufs [][]byte
    	if !readData {
    		v2bufs = make([][]byte, len(rawFileInfos))
    	}
    
    	// Read `xl.meta` in parallel across disks.
    	for index := range rawFileInfos {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  8. src/bytes/buffer.go

    	return string(b.buf[b.off:])
    }
    
    // empty reports whether the unread portion of the buffer is empty.
    func (b *Buffer) empty() bool { return len(b.buf) <= b.off }
    
    // Len returns the number of bytes of the unread portion of the buffer;
    // b.Len() == len(b.Bytes()).
    func (b *Buffer) Len() int { return len(b.buf) - b.off }
    
    // Cap returns the capacity of the buffer's underlying byte slice, that is, the
    // total space allocated for the buffer's data.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Oct 29 16:47:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/ObjectArrays.java

          @Nullable Object[] src, int offset, int len, T[] dst) {
        checkPositionIndexes(offset, offset + len, src.length);
        if (dst.length < len) {
          dst = newArray(dst, len);
        } else if (dst.length > len) {
          @Nullable Object[] unsoundlyCovariantArray = dst;
          unsoundlyCovariantArray[len] = null;
        }
        arraycopy(src, offset, dst, 0, len);
        return dst;
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 9K bytes
    - Viewed (0)
  10. cmd/erasure-metadata.go

    	if defaultParityCount == 0 {
    		return len(partsMetaData), len(partsMetaData), nil
    	}
    
    	parities := listObjectParities(partsMetaData, errs)
    	parityBlocks := commonParity(parities, defaultParityCount)
    	if parityBlocks < 0 {
    		return -1, -1, InsufficientReadQuorum{Err: errErasureReadQuorum, Type: RQInsufficientOnlineDrives}
    	}
    
    	dataBlocks := len(partsMetaData) - parityBlocks
    
    	writeQuorum := dataBlocks
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
Back to top