- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 57 for buf (0.13 sec)
-
cmd/bucket-replication-utils_gen_test.go
v := MRFReplicateEntry{} var buf bytes.Buffer msgp.Encode(&buf, &v) m := v.Msgsize() if buf.Len() > m { t.Log("WARNING: TestEncodeDecodeMRFReplicateEntry Msgsize() is inaccurate") } vn := MRFReplicateEntry{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v) err = msgp.NewReader(&buf).Skip() if err != nil { t.Error(err)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Aug 22 23:53:06 GMT 2022 - 23K bytes - Viewed (0) -
cmd/batch-rotate_gen_test.go
v := BatchJobKeyRotateEncryption{} var buf bytes.Buffer msgp.Encode(&buf, &v) m := v.Msgsize() if buf.Len() > m { t.Log("WARNING: TestEncodeDecodeBatchJobKeyRotateEncryption Msgsize() is inaccurate") } vn := BatchJobKeyRotateEncryption{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v) err = msgp.NewReader(&buf).Skip() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 29 18:27:23 GMT 2023 - 11.8K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
if err != nil { return x, buf, err } x.metaVer, buf, err = msgp.ReadUintBytes(buf) if err != nil { return x, buf, err } if x.headerVer > xlHeaderVersion { return x, buf, fmt.Errorf("decodeXLHeaders: Unknown xl header version %d", x.headerVer) } if x.metaVer > xlMetaVersion { return x, buf, fmt.Errorf("decodeXLHeaders: Unknown xl meta version %d", x.metaVer) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:56:22 GMT 2024 - 20.2K bytes - Viewed (1) -
internal/jwt/parser.go
} headerDec := buf[:n] buf = buf[n:] alg, _, _, err := jsonparser.Get(headerDec, "alg") if err != nil { return nil, &jwtgo.ValidationError{Inner: err, Errors: jwtgo.ValidationErrorMalformed} } n, err = base64DecodeBytes(token[i+1:j], buf) if err != nil { return nil, &jwtgo.ValidationError{Inner: err, Errors: jwtgo.ValidationErrorMalformed} } if err = claims.UnmarshalJSON(buf[:n]); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 09 07:53:08 GMT 2023 - 13.9K bytes - Viewed (0) -
internal/s3select/select.go
return err } if buf.Bytes()[buf.Len()-1] == '\n' { buf.Truncate(buf.Len() - 1) } buf.WriteString(s3Select.Output.CSVArgs.RecordDelimiter) return nil case jsonFormat: err := record.WriteJSON(buf) if err != nil { return err } // Trim trailing newline from non-simd output if buf.Bytes()[buf.Len()-1] == '\n' { buf.Truncate(buf.Len() - 1) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (1) -
internal/s3select/message.go
buf := new(bytes.Buffer) binary.Write(buf, binary.BigEndian, uint32(totalLength)) binary.Write(buf, binary.BigEndian, uint32(headerLength)) prelude := buf.Bytes() binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(prelude)) buf.Write(header) if payload != nil { buf.Write(payload) } message := buf.Bytes() binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(message))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
internal/grid/types.go
if len(m) == 0 { return "" } var buf strings.Builder buf.WriteByte('?') keys := make([]string, 0, len(m)) for k := range m { keys = append(keys, k) } sort.Strings(keys) for _, k := range keys { v := m[k] keyEscaped := url.QueryEscape(k) if buf.Len() > 1 { buf.WriteByte('&') } buf.WriteString(keyEscaped) buf.WriteByte('=') buf.WriteString(url.QueryEscape(v)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
cmd/data-usage_test.go
FailedCount: 5, PendingCount: 6, }, }, } want.replace("abucket/dir2", "", *e) var buf bytes.Buffer err = want.serializeTo(&buf) if err != nil { t.Fatal(err) } t.Log("serialized size:", buf.Len(), "bytes") var got dataUsageCache err = got.deserialize(&buf) if err != nil { t.Fatal(err) } if got.Info.LastUpdate.IsZero() { t.Error("lastupdate not set") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 14.1K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
return p.storage.ReadFile(ctx, volume, path, offset, buf, verifier) }) } // Legacy API - does not have any deadlines func (p *xlStorageDiskIDCheck) AppendFile(ctx context.Context, volume string, path string, buf []byte) (err error) { ctx, done, err := p.TrackDiskHealth(ctx, storageMetricAppendFile, volume, path) if err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/erasure-object_test.go
bucket := "bucket" object := "object" opts := ObjectOptions{} buf := make([]byte, smallFileThreshold*16) if _, err = io.ReadFull(crand.Reader, buf); err != nil { t.Fatal(err) } // Test use case 1: All disks are online, xl.meta are present, but data are missing _, err = obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(buf), int64(len(buf)), "", ""), opts) if err != nil { t.Fatal(err) }
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)