- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 823 for cdone (0.15 sec)
-
cmd/erasure-server-pool-decom.go
Decommission *PoolDecommissionInfo `json:"decommissionInfo,omitempty" msg:"dec"` } // Clone returns a copy of PoolStatus func (ps PoolStatus) Clone() PoolStatus { return PoolStatus{ ID: ps.ID, CmdLine: ps.CmdLine, LastUpdate: ps.LastUpdate, Decommission: ps.Decommission.Clone(), } } //go:generate msgp -file $GOFILE -unexported type poolMeta struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
maven-artifact/src/main/java/org/apache/maven/artifact/versioning/VersionRange.java
Iterator<Restriction> i1 = r1.iterator(); Iterator<Restriction> i2 = r2.iterator(); Restriction res1 = i1.next(); Restriction res2 = i2.next(); boolean done = false; while (!done) { if (res1.getLowerBound() == null || res2.getUpperBound() == null || res1.getLowerBound().compareTo(res2.getUpperBound()) <= 0) {
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Feb 28 07:40:37 GMT 2024 - 18.9K bytes - Viewed (0) -
cmd/background-heal-ops.go
httpServer := newHTTPServerFn() if httpServer == nil { return 0 } return httpServer.GetRequestCount() - activeListeners() } func waitForLowHTTPReq() { maxIO, maxWait, _ := globalHealConfig.Clone() waitForLowIO(maxIO, maxWait, currentHTTPIO) } func initBackgroundHealing(ctx context.Context, objAPI ObjectLayer) { bgSeq := newBgHealSequence() // Run the background healer
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/bucket-targets.go
t.LastOnline = hs.lastOnline t.Latency = madmin.LatencyStat{ Curr: hs.latency.curr, Avg: hs.latency.avg, Max: hs.latency.peak, } } targets = append(targets, t.Clone()) } } } return targets } sys.RLock() defer sys.RUnlock() for _, tgts := range sys.targetsMap { for _, t := range tgts { if string(t.Type) == arnType || arnType == "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/data-scanner.go
if i.heal.enabled { done := globalScannerMetrics.time(scannerMetricHealCheck) size = i.applyHealing(ctx, o, oi) done() if healDeleteDangling { done := globalScannerMetrics.time(scannerMetricCleanAbandoned) err := o.CheckAbandonedParts(ctx, i.bucket, i.objectPath(), madmin.HealOpts{Remove: healDeleteDangling}) done() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 47.6K bytes - Viewed (0) -
cmd/data-scanner-metric.go
} val := p.actionsLatency[a].total() return val } // setCycle updates the current cycle metrics. func (p *scannerMetrics) setCycle(c *currentScannerCycle) { if c != nil { c2 := c.clone() c = &c2 } p.cycleInfoMu.Lock() p.cycleInfo = c p.cycleInfoMu.Unlock() } // getCycle returns the current cycle metrics. // If not nil, the returned value can safely be modified.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 25 05:15:31 GMT 2023 - 9.1K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java
MavenProject forkedProject = projectIndex.getProjects().get(projectId); forkedProjects.add(forkedProject); MavenProject executedProject = forkedProject.clone(); forkedProject.setExecutionProject(executedProject); List<MojoExecution> mojoExecutions = fork.getValue(); if (mojoExecutions.isEmpty()) {
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Feb 28 23:31:09 GMT 2024 - 20.7K bytes - Viewed (0) -
src/bytes/bytes.go
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Feb 19 19:51:15 GMT 2024 - 33.8K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
t.lastDayMu.RLock() defer t.lastDayMu.RUnlock() res := make(DailyAllTierStats, len(t.lastDayStats)) for tier, st := range t.lastDayStats { res[tier] = st.clone() } return res } // UpdateWorkers at the end of this function leaves n goroutines waiting for // transition tasks func (t *transitionState) UpdateWorkers(n int) { t.mu.Lock() defer t.mu.Unlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/format-erasure.go
if format == nil { continue } if format.Drives() == maxDrives { format := formats[i].Clone() format.Erasure.This = "" return format, nil } } return nil, errErasureReadQuorum } func formatErasureV3Check(reference *formatErasureV3, format *formatErasureV3) error { tmpFormat := format.Clone() this := tmpFormat.Erasure.This tmpFormat.Erasure.This = ""
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)