- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 140 for init (0.32 sec)
-
cmd/server-main.go
}) // Initialize site replication manager after bucket metadata bootstrapTrace("globalSiteReplicationSys.Init", func() { globalSiteReplicationSys.Init(GlobalContext, newObject) }) // Initialize quota manager. bootstrapTrace("globalBucketQuotaSys.Init", func() { globalBucketQuotaSys.Init(newObject) }) // Populate existing buckets to the etcd backend if globalDNSConfig != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 34.9K bytes - Viewed (2) -
cmd/format-erasure.go
func ecDrivesNoConfig(setDriveCount int) (int, error) { sc, err := storageclass.LookupConfig(config.KVS{}, setDriveCount) if err != nil { return 0, err } return sc.GetParityForSC(storageclass.STANDARD), nil } // Initialize a new set of set formats which will be written to all disks.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/storage-datatypes.go
func (fi FileInfo) WriteQuorum(dquorum int) int { if fi.Deleted { return dquorum } quorum := fi.Erasure.DataBlocks if fi.Erasure.DataBlocks == fi.Erasure.ParityBlocks { quorum++ } return quorum } // ReadQuorum returns expected read quorum for this FileInfo func (fi FileInfo) ReadQuorum(dquorum int) int { if fi.Deleted { return dquorum }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0) -
cmd/storage-rest-client.go
values := make(url.Values) values.Set(storageRESTVolume, volume) values.Set(storageRESTFilePath, path) values.Set(storageRESTOffset, strconv.Itoa(int(offset))) values.Set(storageRESTLength, strconv.Itoa(int(length))) respBody, err := client.call(ctx, storageRESTMethodReadFileStream, values, nil, -1) if err != nil { return nil, err } return respBody, 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) -
cmd/streaming-signature-v4.go
// a size of 16 is encoded as `10` while a size of 64 KB // is `10000`. switch { case b >= '0' && b <= '9': size = size<<4 | int(b-'0') case b >= 'a' && b <= 'f': size = size<<4 | int(b-('a'-10)) case b >= 'A' && b <= 'F': size = size<<4 | int(b-('A'-10)) default: cr.err = errMalformedEncoding return n, cr.err } if size > maxChunkSize { cr.err = errChunkTooBig
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/encryption-v1.go
// Current part index partIndex int // Parts information parts []ObjectPartInfo header http.Header bucket, object string metadata map[string]string partDecRelOffset, partEncRelOffset int64 copySource bool // Customer Key customerKeyHeader string } func (d *DecryptBlocksReader) buildDecrypter(partID int) error { m := cloneMSS(d.metadata)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 36.5K bytes - Viewed (0) -
cmd/post-policy_test.go
if err != nil { // Failed to create newbucket, abort. t.Fatalf("%s : %s", instanceType, err.Error()) } // Test cases for signature-V2. testCasesV2 := []struct { expectedStatus int accessKey string secretKey string }{ {http.StatusForbidden, "invalidaccesskey", credentials.SecretKey}, {http.StatusForbidden, credentials.AccessKey, "invalidsecretkey"},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0) -
internal/grid/grid_test.go
const testPayload = "Hello Grid World!" start := time.Now() stream, err := remoteConn.NewStream(context.Background(), handlerTest, []byte(testPayload)) errFatal(err) var n int stream.Requests <- []byte(strconv.Itoa(n)) for resp := range stream.responses { errFatal(resp.Err) t.Logf("got resp: %+v", string(resp.Msg)) if string(resp.Msg) != testPayload+strconv.Itoa(n) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
cmd/bucket-object-lock.go
} // Pass in relative days from current time, to additionally // to verify "object-lock-remaining-retention-days" policy if any. days := int(math.Ceil(math.Abs(objRetention.RetainUntilDate.Sub(t).Hours()) / 24)) ret := objectlock.GetObjectRetentionMeta(oi.UserDefined) if ret.Mode.Valid() { // Retention has expired you may change whatever you like.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 13.2K bytes - Viewed (0) -
cmd/metacache-server-pool.go
defer cancelList() for _, pool := range z.serverPools { for _, set := range pool.sets { wg.Add(1) innerResults := make(chan metaCacheEntry, 100) inputs = append(inputs, innerResults) go func(i int, set *erasureObjects) { defer wg.Done() err := set.listPath(listCtx, o, innerResults) mu.Lock() defer mu.Unlock() if err == nil { allAtEOF = false } errs[i] = err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0)