- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 177 for Phan (0.16 sec)
-
internal/bucket/lifecycle/rule_test.go
// appropriate errors on validation func TestInvalidRules(t *testing.T) { invalidTestCases := []struct { inputXML string expectedErr error }{ { // Rule with ID longer than 255 characters inputXML: ` <Rule>
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 4.9K bytes - Viewed (0) -
tests/test_tutorial/test_body_fields/test_tutorial001_an_py310.py
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Apr 18 19:40:57 GMT 2024 - 7.3K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
) // if disk max timeout is smaller than checkEvery window // reduce checks by a second. if globalDriveConfig.GetMaxTimeout() <= checkEvery { checkEvery = globalDriveConfig.GetMaxTimeout() - time.Second if checkEvery <= 0 { checkEvery = globalDriveConfig.GetMaxTimeout() } } // if disk max timeout is smaller than skipIfSuccessBefore window // reduce the skipIfSuccessBefore by a second.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
tests/test_tutorial/test_body_fields/test_tutorial001.py
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Apr 18 19:40:57 GMT 2024 - 7.2K bytes - Viewed (0) -
cmd/erasure-server-pool.go
if firstErr == nil { firstErr = err } // Cancel remaining... cancel() mu.Unlock() return } }(resultIndex, erObj) } } updateCloser := make(chan chan struct{}) go func() { updateTicker := time.NewTicker(30 * time.Second) defer updateTicker.Stop() var lastUpdate time.Time // We need to merge since we will get the same buckets from each pool.
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/metacache-entries.go
// The entry not chosen will be discarded. // If the context is canceled the function will return the error, // otherwise the function will return nil. func mergeEntryChannels(ctx context.Context, in []chan metaCacheEntry, out chan<- metaCacheEntry, readQuorum int) error { defer xioutil.SafeClose(out) top := make([]*metaCacheEntry, len(in)) nDone := 0 ctxDone := ctx.Done() // Use simpler forwarder. if len(in) == 1 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0) -
tests/test_tutorial/test_body_fields/test_tutorial001_py310.py
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Apr 18 19:40:57 GMT 2024 - 7.3K bytes - Viewed (0) -
cmd/global-heal.go
globalExpiryState.enqueueByDays(objInfo, evt, lcEventSrc_Heal) return true default: return false } } // Collect updates to tracker from concurrent healEntry calls results := make(chan healEntryResult, 1000) go func() { for res := range results { if res.entryDone { tracker.setObject(res.name) if time.Since(tracker.getLastUpdate()) > time.Minute {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1) -
tests/test_tutorial/test_body_fields/test_tutorial001_an.py
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Apr 18 19:40:57 GMT 2024 - 7.2K bytes - Viewed (0) -
tests/test_tutorial/test_body_fields/test_tutorial001_an_py39.py
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Apr 18 19:40:57 GMT 2024 - 7.3K bytes - Viewed (0)