- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 622 for continua (0.05 sec)
-
cmd/erasure-server-pool-decom.go
var newPools []PoolStatus for _, pool := range p.Pools { if pool.Decommission == nil { continue } if pool.Decommission.Complete || pool.Decommission.Canceled { // Do not resume decommission upon startup for // - decommission complete // - decommission canceled continue } // In all other situations we need to resume newPools = append(newPools, pool) } return newPools }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 42.2K bytes - Viewed (1) -
cmd/object-api-putobject_test.go
t.Errorf("Test %d: %s: Expected to pass, but failed with: error %s.", i, instanceType, actualErr.Error()) continue } if actualErr == nil && testCase.expectedError != nil { t.Errorf("Test %d: %s: Expected to fail with error \"%s\", but passed instead.", i, instanceType, testCase.expectedError.Error()) continue } // Failed as expected, but does it fail for the expected reason.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 25.8K bytes - Viewed (0) -
cmd/os-reliable.go
i := 0 for { // Removes all the directories and files. if err = RemoveAll(dirPath); err != nil { // Retry only for the first retryable error. if isSysErrNotEmpty(err) && i == 0 { i++ continue } } break } return err } // Wrapper functions to os.MkdirAll, which calls reliableMkdirAll // this is to ensure that if there is a racy parent directoryRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Apr 22 17:49:30 UTC 2024 - 5.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/contents/DefaultContentsParser.java
if (textObj == null) { continue; } final String text = textObj.toString(); final String lang = document.get(langFieldName) == null ? null : document.get(langFieldName).toString(); final List<AnalyzeToken> tokens = analyzeText(analyzer, field, text, lang); if (tokens == null) { continue; }
Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Mon Nov 24 03:40:05 UTC 2025 - 14.9K bytes - Viewed (0) -
internal/grid/connection.go
atomic.StoreInt64(&c.LastPong, time.Now().UnixNano()) continue } toSend, err = pingFrame.MarshalMsg(GetByteBuffer()[:0]) if err != nil { gridLogIf(ctx, err) // Fake it... Though this should never fail. atomic.StoreInt64(&c.LastPong, time.Now().UnixNano()) continue } case toSend = <-c.outQueue: if len(toSend) == 0 { continue } }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 46.9K bytes - Viewed (0) -
cmd/config.go
} if withData { data, err := readConfig(ctx, objAPI, obj.Name) if err != nil { // ignore history file if not readable. continue } data, err = decryptData(data, obj.Name) if err != nil { // ignore history file that cannot be loaded. continue } cfgEntry.Data = string(data) } configHistory = append(configHistory, cfgEntry) count-- if count == 0 {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.9K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
if err != nil { return err } for _, disk := range disks { if disk == nil { continue } t, err := loadHealingTracker(ctx, disk) if err != nil { if !errors.Is(err, errFileNotFound) { healingLogIf(ctx, err) } continue } if t.HealID == tracker.HealID { t.Finished = true t.update(ctx) } } return nil }Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.5K bytes - Viewed (0) -
internal/grid/muxclient.go
if debugPrint { fmt.Println("Client sending disconnect to mux", m.MuxID) } m.addErrorNonBlockingClose(errResp, context.Cause(m.ctx)) errState = true continue case <-pingTimer: if !m.doPing(errResp) { errState = true continue } case req, ok := <-requests: if !ok { // Done send EOF if debugPrint { fmt.Println("Client done, sending EOF to mux", m.MuxID) }Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 15.9K bytes - Viewed (0) -
cmd/batch-expire.go
toDel = append(toDel, expireObjInfo{ ObjectInfo: result.Item, ExpireAll: true, }) continue } } else if prevObj.Name == result.Item.Name { if matchedFilter.Purge.RetainVersions == 0 { continue // including latest version in toDel suffices, skipping other versions } versionsCount++ } else { // switch the object
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Apr 22 11:16:32 UTC 2025 - 23K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
for i := range 16 { // Have 13 good xl.meta, 12 for default parity count = 4 (EC:4) and one // to be tampered with. if i > 12 { modTimesThreeFour[i] = fourNanoSecs modTimesThreeNone[i] = timeSentinel continue } modTimesThreeFour[i] = threeNanoSecs modTimesThreeNone[i] = threeNanoSecs } testCases := []struct { modTimes []time.Time expectedTime time.Time errs []errorRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 22.4K bytes - Viewed (0)