- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 142 for Reset (0.14 sec)
-
cmd/erasure-server-pool-rebalance.go
err := z.saveRebalanceStats(GlobalContext, poolIdx, rebalSaveStats) stopFn(err) rebalanceLogIf(GlobalContext, err) if quit { return } timer.Reset(randSleepFor()) } }() rebalanceLogEvent(ctx, "Pool %d rebalancing is started", poolIdx+1) for { select { case <-ctx.Done(): doneCh <- ctx.Err() return default: }
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) -
cmd/bitrot.go
return errFileCorrupt } bufp := xioutil.ODirectPoolSmall.Get().(*[]byte) defer xioutil.ODirectPoolSmall.Put(bufp) for left > 0 { // Read expected hash... h.Reset() n, err := io.ReadFull(r, hashBuf) if err != nil { // Read's failed for object with right size, file is corrupt. return err } // Subtract hash length.. left -= int64(n)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.6K bytes - Viewed (0) -
cmd/bucket-replication.go
rd.Replicate = true return } // For existing object reset - this condition is needed rd.Replicate = tgtStatus == "" return } if resetID == "" || resetBeforeDate.Equal(timeSentinel) { // no reset in progress return } // if already replicated, return true if a new reset was requested. splits := strings.SplitN(rs, ";", 2)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/site-replication-utils_gen_test.go
if buf.Len() > m { t.Log("WARNING: TestEncodeDecodeSiteResyncStatus Msgsize() is inaccurate") } vn := SiteResyncStatus{} 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) } } func BenchmarkEncodeSiteResyncStatus(b *testing.B) { v := SiteResyncStatus{} var buf bytes.Buffer
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 14 15:16:40 GMT 2022 - 2.4K bytes - Viewed (0) -
cmd/metacache-walk_gen_test.go
if buf.Len() > m { t.Log("WARNING: TestEncodeDecodeWalkDirOptions Msgsize() is inaccurate") } vn := WalkDirOptions{} 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) } } func BenchmarkEncodeWalkDirOptions(b *testing.B) { v := WalkDirOptions{} var buf bytes.Buffer
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 2.3K bytes - Viewed (0) -
cmd/erasure-server-pool.go
return nil, err } // This is a special call attempted first to check for SOS-API calls. gr, err = veeamSOSAPIGetObject(ctx, bucket, object, rs, opts) if err == nil { return gr, nil } // reset any error to 'nil' and any reader to be 'nil' gr = nil err = nil object = encodeDirObject(object) if z.SinglePool() { return z.serverPools[0].GetObjectNInfo(ctx, bucket, object, rs, h, opts) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
docs/debugging/s3-verify/main.go
srcCtnt, srcOk := nextObject(srcCh) tgtCtnt, tgtOk := nextObject(tgtCh) var srcEOF, tgtEOF bool srcSha256 := sha256.New() tgtSha256 := sha256.New() for { srcSha256.Reset() tgtSha256.Reset() srcEOF = !srcOk tgtEOF = !tgtOk // No objects from source AND target: Finish if srcEOF && tgtEOF { break } if !srcEOF && srcCtnt.Err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jun 22 15:12:47 GMT 2022 - 8.4K bytes - Viewed (0) -
cmd/object_api_suite_test.go
var err error GlobalKMS, err = kms.Parse("my-minio-key:5lF+0pJM0OWwlQrvK2S/I7W9mO4a6rJJI7wzj7v09cw=") if err != nil { t.Fatal(err) } } func resetCompressEncryption() { // Reset... globalCompressConfigMu.Lock() globalCompressConfig.Enabled = false globalCompressConfig.AllowEncrypted = false globalCompressConfigMu.Unlock() globalAutoEncryption = false GlobalKMS = nil }
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) -
cmd/test-utils_test.go
// set globalObjectAPI to `nil`. resetGlobalObjectAPI() // Reset config path set. resetGlobalConfigPath() // Reset Global server config. resetGlobalConfig() // Reset global endpoints. resetGlobalEndpoints() // Reset global isErasure flag. resetGlobalIsErasure() // Reset global heal state resetGlobalHealState() // Reset globalIAMSys to `nil` resetGlobalIAMSys() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/erasure-utils.go
if offset >= int64(len(block)) { // Decrement offset. offset -= int64(len(block)) continue } // Skip until offset. block = block[offset:] // Reset the offset for next iteration to read everything // from subsequent blocks. offset = 0 // We have written all the blocks, write the last remaining block. if write < int64(len(block)) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 3.1K bytes - Viewed (0)