- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 94 for butter (1.44 sec)
-
cmd/object-multipart-handlers.go
partEncryptionKey := objectEncryptionKey.DerivePartKey(uint32(partID)) in := io.Reader(hashReader) if size > encryptBufferThreshold { // The encryption reads in blocks of 64KB. // We add a buffer on bigger files to reduce the number of syscalls upstream. in = bufio.NewReaderSize(hashReader, encryptBufferSize) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
cmd/sts-handlers_test.go
} } `, } exportContent := map[string][]byte{} for k, v := range exportContentStrings { exportContent[k] = []byte(v) } var importContent []byte { var b bytes.Buffer zipWriter := zip.NewWriter(&b) rawDataFn := func(r io.Reader, filename string, sz int) error { header, zerr := zip.FileInfoHeader(dummyFileInfo{ name: filename, size: int64(sz),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0) -
cmd/object-handlers.go
} const ( compressionAlgorithmV1 = "golang/snappy/LZ77" compressionAlgorithmV2 = "klauspost/compress/s2" // When an upload exceeds encryptBufferThreshold ... encryptBufferThreshold = 1 << 20 // add an input buffer of this size. encryptBufferSize = 1 << 20 // minCompressibleSize is the minimum size at which we enable compression. minCompressibleSize = 4096 )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/data-usage-cache_gen_test.go
v := allTierStats{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) en := msgp.NewWriter(msgp.Nowhere) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.EncodeMsg(en) } en.Flush() } func BenchmarkDecodeallTierStats(b *testing.B) { v := allTierStats{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Jan 13 07:51:08 GMT 2024 - 28.1K bytes - Viewed (0) -
cmd/batch-replicate_gen_test.go
v := BatchJobReplicateCredentials{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) en := msgp.NewWriter(msgp.Nowhere) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.EncodeMsg(en) } en.Flush() } func BenchmarkDecodeBatchJobReplicateCredentials(b *testing.B) { v := BatchJobReplicateCredentials{} var buf bytes.Buffer msgp.Encode(&buf, &v)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 29 18:27:23 GMT 2023 - 14.2K bytes - Viewed (1) -
cmd/batch-expire_gen_test.go
v := BatchJobExpire{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) en := msgp.NewWriter(msgp.Nowhere) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.EncodeMsg(en) } en.Flush() } func BenchmarkDecodeBatchJobExpire(b *testing.B) { v := BatchJobExpire{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 6.9K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
} if b != '\n' { cr.err = errMalformedEncoding return n, cr.err } if cap(cr.buffer) < size { cr.buffer = make([]byte, size) } else { cr.buffer = cr.buffer[:size] } // Now, we read the payload and compute its SHA-256 hash. _, err = io.ReadFull(cr.reader, cr.buffer) if err == io.EOF && size != 0 { err = io.ErrUnexpectedEOF } if err != nil && err != io.EOF {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 18.2K bytes - Viewed (0) -
cmd/tier-last-day-stats_gen_test.go
v := DailyAllTierStats{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) en := msgp.NewWriter(msgp.Nowhere) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.EncodeMsg(en) } en.Flush() } func BenchmarkDecodeDailyAllTierStats(b *testing.B) { v := DailyAllTierStats{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/os_unix.go
if osIsExist(err) { return nil } return err } return nil } // The buffer must be at least a block long. // refer https://github.com/golang/go/issues/24015 const blockSize = 8 << 10 // 8192 // By default at least 128 entries in single getdents call (1MiB buffer) var ( direntPool = sync.Pool{ New: func() interface{} { buf := make([]byte, blockSize*128) return &buf
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/storage-rest-client.go
values.Set(storageRESTTotalVersions, strconv.Itoa(len(versions))) var buffer bytes.Buffer encoder := msgp.NewWriter(&buffer) for _, version := range versions { version.EncodeMsg(encoder) } storageLogIf(ctx, encoder.Flush()) errs = make([]error, len(versions)) respBody, err := client.call(ctx, storageRESTMethodDeleteVersions, values, &buffer, -1) defer xhttp.DrainBody(respBody) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0)