Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 29 for NewEndlessReader (0.23 sec)

  1. cmd/bucket-replication-utils_gen_test.go

    }
    
    func BenchmarkDecodeBucketReplicationResyncStatus(b *testing.B) {
    	v := BucketReplicationResyncStatus{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Aug 22 23:53:06 UTC 2022
    - 23K bytes
    - Viewed (0)
  2. cmd/batch-job-common-types_gen_test.go

    		v.EncodeMsg(en)
    	}
    	en.Flush()
    }
    
    func BenchmarkDecodeBatchJobKV(b *testing.B) {
    	v := BatchJobKV{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sat Dec 02 10:51:33 UTC 2023
    - 11.3K bytes
    - Viewed (0)
  3. cmd/batch-rotate_gen_test.go

    	en.Flush()
    }
    
    func BenchmarkDecodeBatchJobKeyRotateEncryption(b *testing.B) {
    	v := BatchJobKeyRotateEncryption{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 29 18:27:23 UTC 2023
    - 11.8K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom_gen_test.go

    	}
    	en.Flush()
    }
    
    func BenchmarkDecodePoolDecommissionInfo(b *testing.B) {
    	v := PoolDecommissionInfo{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jan 12 02:48:43 UTC 2022
    - 11K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v2_gen_test.go

    	}
    	en.Flush()
    }
    
    func BenchmarkDecodexlMetaDataDirDecoder(b *testing.B) {
    	v := xlMetaDataDirDecoder{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Nov 18 20:15:22 UTC 2021
    - 11.5K bytes
    - Viewed (0)
  6. cmd/storage-datatypes_test.go

    	"github.com/tinylib/msgp/msgp"
    )
    
    func BenchmarkDecodeVolInfoMsgp(b *testing.B) {
    	v := VolInfo{
    		Name:    "uuid",
    		Created: time.Now(),
    	}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.Log("Size:", buf.Len(), "bytes")
    	b.SetBytes(1)
    	b.ReportAllocs()
    
    	for b.Loop() {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  7. cmd/metacache_gen_test.go

    		v.EncodeMsg(en)
    	}
    	en.Flush()
    }
    
    func BenchmarkDecodemetacache(b *testing.B) {
    	v := metacache{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.3K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-rebalance_gen_test.go

    	}
    	en.Flush()
    }
    
    func BenchmarkDecoderebalanceInfo(b *testing.B) {
    	v := rebalanceInfo{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Oct 25 19:36:57 UTC 2022
    - 11K bytes
    - Viewed (0)
  9. cmd/background-newdisks-heal-ops_gen_test.go

    	}
    	en.Flush()
    }
    
    func BenchmarkDecodehealingTracker(b *testing.B) {
    	v := healingTracker{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.3K bytes
    - Viewed (0)
  10. cmd/tier-last-day-stats_gen_test.go

    	}
    	en.Flush()
    }
    
    func BenchmarkDecodeDailyAllTierStats(b *testing.B) {
    	v := DailyAllTierStats{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 4.6K bytes
    - Viewed (0)
Back to top