- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 126 for Reaber (0.14 sec)
-
cmd/metacache-set_gen.go
package cmd // Code generated by github.com/tinylib/msgp DO NOT EDIT. import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *listPathOptions) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 20:23:12 GMT 2024 - 13.8K bytes - Viewed (0) -
docs/config/README.md
`max_io` values thereby increasing the healing speed. The delays between each operation of the healer can be adjusted by the `mc admin config set alias/ heal max_sleep=1s` and maximum concurrent requests allowed before we start slowing things down can be configured with `mc admin config set alias/ heal max_io=30` . By default the wait delay is `250ms` beyond 100 concurrent operations. This means the healer will sleep *250 milliseconds* at max for each heal operation if there are more than *100* concurrent...
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 11 21:48:54 GMT 2023 - 17.7K bytes - Viewed (0) -
cmd/encryption-v1_test.go
defer func(flag bool) { globalIsTLS = flag }(globalIsTLS) globalIsTLS = true for i, test := range encryptRequestTests { content := bytes.NewReader(make([]byte, 64)) req := &http.Request{Header: http.Header{}} for k, v := range test.header { req.Header.Set(k, v) } _, _, err := EncryptRequest(content, req, "bucket", "object", test.metadata) if err != nil { t.Fatalf("Test %d: Failed to encrypt request: %v", i, err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Sep 24 04:17:08 GMT 2022 - 19.9K bytes - Viewed (0) -
internal/hash/checksum.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 11.9K bytes - Viewed (0) -
internal/s3select/select.go
return rsc.offset, errors.New("seek past end of object") } if rsc.reader != nil { _ = rsc.reader.Close() rsc.reader = nil } return rsc.offset, nil } // Read call to implement io.Reader func (rsc *ObjectReadSeekCloser) Read(p []byte) (n int, err error) { if rsc.reader == nil { rsc.reader, err = rsc.segmentReader(rsc.offset) if err != nil { return 0, err } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
if err != nil { return err } if len(data) == 0 { return nil } if len(data) <= 4 { return fmt.Errorf("rebalanceMeta: no data") } // Read header switch binary.LittleEndian.Uint16(data[0:2]) { case rebalMetaFmt: default: return fmt.Errorf("rebalanceMeta: unknown format: %d", binary.LittleEndian.Uint16(data[0:2])) }
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) -
internal/s3select/message.go
// hence the calculation is made accordingly. func totalByteLength(headerLength, payloadLength int) int { return 4 + 4 + 4 + headerLength + payloadLength + 4 } func genMessage(header, payload []byte) []byte { headerLength := len(header) payloadLength := len(payload) totalLength := totalByteLength(headerLength, payloadLength) buf := new(bytes.Buffer) binary.Write(buf, binary.BigEndian, uint32(totalLength))
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) -
cmd/xl-storage-disk-id-check.go
func (p *xlStorageDiskIDCheck) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) (err error) { ctx, done, err := p.TrackDiskHealth(ctx, storageMetricCreateFile, volume, path) if err != nil { return err } defer done(&err) return p.storage.CreateFile(ctx, origvolume, volume, path, size, io.NopCloser(reader)) }
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/metrics-v2_gen.go
import ( "github.com/tinylib/msgp/msgp" ) // MarshalMsg implements msgp.Marshaler func (z *MetricDescription) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize()) // map header, size 5 // string "Namespace" o = append(o, 0x85, 0xa9, 0x4e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65) o = msgp.AppendString(o, string(z.Namespace)) // string "Subsystem"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 19.2K bytes - Viewed (0) -
cmd/object_api_suite_test.go
"testing" "github.com/dustin/go-humanize" "github.com/minio/minio/internal/kms" ) // Return pointer to testOneByteReadEOF{} func newTestReaderEOF(data []byte) io.Reader { return &testOneByteReadEOF{false, data} } // OneByteReadEOF - implements io.Reader which returns 1 byte along with io.EOF error. type testOneByteReadEOF struct { eof bool data []byte } func (r *testOneByteReadEOF) Read(p []byte) (n int, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 32.3K bytes - Viewed (0)