Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 645 for len (0.14 sec)

  1. 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)
  2. internal/grid/msg.go

    	}
    	if len(m.Payload) == 0 && m.Flags&FlagPayloadIsZero == 0 {
    		PutByteBuffer(m.Payload)
    		m.Payload = nil
    	}
    	if m.Flags&FlagCRCxxh3 != 0 {
    		const hashLen = 4
    		if len(h) < hashLen {
    			return nil, nil, fmt.Errorf("want crc len 4, got %v", len(h))
    		}
    		got := uint32(xxh3.Hash(b[:len(b)-hashLen]))
    		want := binary.LittleEndian.Uint32(h[len(h)-hashLen:])
    		if got != want {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 28 19:22:29 GMT 2023
    - 7.3K bytes
    - Viewed (0)
  3. cmd/erasure-object_test.go

    		VersioningEnabled: true,
    	})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	names := make([]ObjectToDelete, len(testCases))
    	for i, testCase := range testCases {
    		objInfo, err := obj.PutObject(ctx, testCase.bucket, testCase.object,
    			mustGetPutObjReader(t, bytes.NewReader([]byte("abcd")), int64(len("abcd")), "", ""), ObjectOptions{
    				Versioned: true,
    			})
    		if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  4. cmd/local-locker_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 BenchmarkMarshalMsglocalLockMap(b *testing.B) {
    	v := localLockMap{}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 6.7K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-rebalance.go

    	workerSize, err := env.GetInt(envRebalanceWorkers, len(pool.sets))
    	if err != nil {
    		rebalanceLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets)))
    		workerSize = len(pool.sets)
    	}
    
    	// Each decom worker needs one List() goroutine/worker
    	// add that many extra workers.
    	workerSize += len(pool.sets)
    
    	wk, err := workers.New(workerSize)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  6. internal/bpool/bpool_test.go

    	}
    
    	b = bufPool.Get()
    	if len(b) != width {
    		t.Fatalf("bytepool length invalid: got %v want %v", len(b), width)
    	}
    	if cap(b) != capWidth {
    		t.Fatalf("bytepool length invalid: got %v want %v", cap(b), capWidth)
    	}
    
    	bufPool.Put(b)
    
    	// Close the channel so we can iterate over it.
    	close(bufPool.c)
    
    	// Check the size of the pool.
    	if uint64(len(bufPool.c)) != size {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 19:13:27 GMT 2024
    - 2.6K bytes
    - Viewed (0)
  7. cmd/xl-storage-format-v2_gen.go

    	for za0005 := range z.PartETags {
    		s += msgp.StringPrefixSize + len(z.PartETags[za0005])
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 53.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. src/cmd/asm/internal/asm/endtoend_test.go

    		// giving the absolute form.
    		if len(f) > 0 && strings.Contains(printed, "(PC)") {
    			index := len(f) - 1
    			suf := "(PC)"
    			for !strings.HasSuffix(f[index], suf) {
    				index--
    				suf = "(PC),"
    			}
    			str := f[index]
    			n, err := strconv.Atoi(str[:len(str)-len(suf)])
    			if err == nil {
    				f[index] = fmt.Sprintf("%d%s", seq+n, suf)
    			}
    		}
    
    		if len(f) == 1 {
    			printed = f[0]
    		} else {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Dec 07 18:42:59 GMT 2023
    - 11.6K bytes
    - Viewed (0)
  10. internal/dsync/lock-args_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 BenchmarkMarshalMsgLockArgs(b *testing.B) {
    	v := LockArgs{}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 4.4K bytes
    - Viewed (0)
Back to top