Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 256 for len (0.21 sec)

  1. cmd/xl-storage-meta-inline.go

    func (x *xlMetaInlineData) serialize(plSize int, keys [][]byte, vals [][]byte) {
    	if len(keys) != len(vals) {
    		panic(fmt.Errorf("xlMetaInlineData.serialize: keys/value number mismatch"))
    	}
    	if len(keys) == 0 {
    		*x = nil
    		return
    	}
    	if plSize <= 0 {
    		plSize = 1 + msgp.MapHeaderSize
    		for i := range keys {
    			plSize += len(keys[i]) + len(vals[i]) + msgp.StringPrefixSize + msgp.ArrayHeaderSize
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  2. cmd/metacache_gen_test.go

    		t.Fatal(err)
    	}
    	left, err := v.UnmarshalMsg(bts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left)
    	}
    
    	left, err = msgp.Skip(bts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgmetacache(b *testing.B) {
    	v := metacache{}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 2.3K bytes
    - Viewed (0)
  3. cmd/tier_gen_test.go

    		t.Fatal(err)
    	}
    	left, err := v.UnmarshalMsg(bts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left)
    	}
    
    	left, err = msgp.Skip(bts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgTierConfigMgr(b *testing.B) {
    	v := TierConfigMgr{}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 2.3K bytes
    - Viewed (0)
  4. internal/s3select/sql/stringfuncs.go

    	if !leadingPercent {
    		res = strings.TrimPrefix(text, pat)
    		if len(text) == len(res) {
    			return "", false
    		}
    	} else {
    		parts := strings.SplitN(text, pat, 2)
    		if len(parts) == 1 {
    			return "", false
    		}
    		res = parts[1]
    	}
    	return res, true
    }
    
    func dropRune(text string) (res string, ok bool) {
    	r := []rune(text)
    	if len(r) == 0 {
    		return "", false
    	}
    	return string(r[1:]), true
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 4.2K bytes
    - Viewed (0)
  5. cmd/erasure-common.go

    	resps := make([]chan ReadMultipleResp, len(disks))
    	for i := range resps {
    		resps[i] = make(chan ReadMultipleResp, len(req.Files))
    	}
    	g := errgroup.WithNErrs(len(disks))
    	// Read files in parallel across disks.
    	for index := range disks {
    		index := index
    		g.Go(func() (err error) {
    			if disks[index] == nil {
    				return errDiskNotFound
    			}
    			return disks[index].ReadMultiple(ctx, req, resps[index])
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  6. cmd/bootstrap-peer-server.go

    		}
    	}
    	msg := "Expected same MINIO_ environment variables and values across all servers: "
    	if len(missing) > 0 {
    		msg += fmt.Sprintf(`Missing environment values: %v. `, missing)
    	}
    	if len(mismatching) > 0 {
    		msg += fmt.Sprintf(`Mismatching environment values: %v. `, mismatching)
    	}
    	if len(extra) > 0 {
    		msg += fmt.Sprintf(`Extra environment values: %v. `, extra)
    	}
    
    	return errors.New(strings.TrimSpace(msg))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  7. internal/logger/console.go

    		msg = ansiRE.ReplaceAllLiteralString(msg, "")
    		console.json(msg, args...)
    	case quietFlag:
    		if len(msg) != 0 && len(args) == 0 {
    			args = append(args, msg)
    			msg = "%s"
    		}
    		console.quiet(msg+"\n", args...)
    	default:
    		if len(msg) != 0 && len(args) == 0 {
    			args = append(args, msg)
    			msg = "%s"
    		}
    		console.pretty(msg+"\n", args...)
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  8. cmd/api-utils.go

    	spaceCount, hexCount := 0, 0
    	for i := 0; i < len(s); i++ {
    		c := s[i]
    		if shouldEscape(c) {
    			if c == ' ' {
    				spaceCount++
    			} else {
    				hexCount++
    			}
    		}
    	}
    
    	if spaceCount == 0 && hexCount == 0 {
    		return s
    	}
    
    	var buf [64]byte
    	var t []byte
    
    	required := len(s) + 2*hexCount
    	if required <= len(buf) {
    		t = buf[:required]
    	} else {
    		t = make([]byte, required)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  9. cmd/listen-notification-handlers.go

    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    			return
    		}
    	}
    
    	values := r.Form
    
    	var prefix string
    	if len(values[peerRESTListenPrefix]) > 1 {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrFilterNamePrefix), r.URL)
    		return
    	}
    
    	if len(values[peerRESTListenPrefix]) == 1 {
    		if err := event.ValidateFilterRuleValue(values[peerRESTListenPrefix][0]); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  10. internal/config/lambda/event/targetlist.go

    	list.RLock()
    	defer list.RUnlock()
    
    	targets := make([]Target, 0, len(list.targets))
    	for _, tgt := range list.targets {
    		targets = append(targets, tgt)
    	}
    
    	return targets
    }
    
    // Empty returns true if targetList is empty.
    func (list *TargetList) Empty() bool {
    	list.RLock()
    	defer list.RUnlock()
    
    	return len(list.targets) == 0
    }
    
    // List - returns available target IDs.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 07 16:12:41 GMT 2023
    - 4.3K bytes
    - Viewed (0)
Back to top