- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for Slough (0.18 sec)
-
cmd/httprange_test.go
} if isErrInvalidRange(err) { t.Errorf("Case %d: Got invalid range error instead of a parse error", i) } if rs != nil { t.Errorf("Case %d: Got non-nil rs though err != nil: %v", i, rs) } } invalidRangeSpecs := []string{ "bytes=5-3", "bytes=10-10", "bytes=10-", "bytes=100-", "bytes=-0", } for i, irs := range invalidRangeSpecs {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 3.7K bytes - Viewed (0) -
cmd/erasure-server-pool.go
return -1 } // getServerPoolsAvailableSpace will return the available space of each pool after storing the content. // If there is not enough space the pool will return 0 bytes available. // The size of each will be multiplied by the number of sets. // Negative sizes are seen as 0 bytes.
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) -
cmd/sts-handlers_test.go
openIDServer := os.Getenv(EnvTestOpenIDServer) openIDServer2 := os.Getenv(EnvTestOpenIDServer2) if openIDServer == "" || openIDServer2 == "" { t.Skip("Skipping OpenID test as enough OpenID servers are not provided.") } testApps := testClientApps rolePolicies := []string{ "", // Treated as claim-based provider as no role policy is given. "readwrite", }
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-api-errors.go
func (e SlowDown) Error() string { return "Please reduce your request rate" } // RQErrType reason for read quorum error. type RQErrType int const ( // RQInsufficientOnlineDrives - not enough online drives. RQInsufficientOnlineDrives RQErrType = 1 << iota // RQInconsistentMeta - inconsistent metadata. RQInconsistentMeta ) func (t RQErrType) String() string { switch t {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 21.3K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
return err } func (z *erasureServerPools) checkIfRebalanceDone(poolIdx int) bool { z.rebalMu.Lock() defer z.rebalMu.Unlock() // check if enough objects have been rebalanced r := z.rebalMeta poolStats := r.PoolStats[poolIdx] if poolStats.Info.Status == rebalCompleted { return true }
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/storage-datatypes.go
// Earlier MinIO versions didn't reset "x-minio-internal-inline-data" // from fi.Metadata when the object was tiered. So, tiered objects // would return true for InlineData() in these versions even though the // object isn't inlined in xl.meta return ok && !fi.IsRemote() } // SetInlineData marks object (version) as inline. func (fi *FileInfo) SetInlineData() { if fi.Metadata == nil {
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-server.go
// Windows can lock up with this optimization, so we fall back to regular copy. sr, ok := rc.(*sendFileReader) if ok { // Sendfile sends in 4MiB chunks per sendfile syscall which is more than enough // for most setups. _, err = rf.ReadFrom(sr.Reader) if !xnet.IsNetworkOrHostDown(err, true) { // do not need to log disconnected clients storageLogIf(r.Context(), err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/xl-storage.go
return res, osErrToFileErr(err) } if srcVolume != minioMetaMultipartBucket { // srcFilePath is some-times minioMetaTmpBucket, an attempt to // remove the temporary folder is enough since at this point // ideally all transaction should be complete. Remove(pathutil.Dir(srcFilePath)) } else { s.deleteFile(srcVolumeDir, pathutil.Dir(srcFilePath), true, false) } return res, nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
cmd/erasure-metadata.go
// In this case, parity == 0 implies that this object version is a // delete marker readQuorum = N/2 + 1 } if occ < readQuorum { // Ignore this parity since we don't have enough shards for read quorum continue } if occ > maxOcc { maxOcc = occ cparity = parity } } if maxOcc == 0 { // Did not found anything useful return -1 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 19.2K bytes - Viewed (1) -
cmd/test-utils_test.go
} return req, nil } var src = rand.NewSource(time.Now().UnixNano()) func randString(n int) string { b := make([]byte, n) // A src.Int63() generates 63 random bits, enough for letterIdxMax characters! for i, cache, remain := n-1, src.Int63(), letterIdxMax; i >= 0; { if remain == 0 { cache, remain = src.Int63(), letterIdxMax }
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)