Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 61 for Merged (0.24 sec)

  1. cmd/tier-last-day-stats.go

    	return clone
    }
    
    func (l lastDayTierStats) merge(m lastDayTierStats) (merged lastDayTierStats) {
    	cl := l.clone()
    	cm := m.clone()
    
    	if cl.UpdatedAt.After(cm.UpdatedAt) {
    		cm.forwardTo(cl.UpdatedAt)
    		merged.UpdatedAt = cl.UpdatedAt
    	} else {
    		cl.forwardTo(cm.UpdatedAt)
    		merged.UpdatedAt = cm.UpdatedAt
    	}
    
    	for i := range cl.Bins {
    		merged.Bins[i] = cl.Bins[i].add(cm.Bins[i])
    	}
    
    	return merged
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool.go

    			return ListObjectsInfo{}, ctx.Err()
    		}
    	}
    
    	merged, err := z.listPath(ctx, &opts)
    	if err != nil && err != io.EOF {
    		if !isErrBucketNotFound(err) {
    			storageLogOnceIf(ctx, err, "erasure-list-objects-path-"+bucket)
    		}
    		return loi, toObjectErr(err, bucket)
    	}
    
    	merged.forwardPast(opts.Marker)
    	defer merged.truncate(0) // Release when returning
    
    	if contextCanceled(ctx) {
    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)
  3. docs/hotfixes.md

        prefixes instead of exact match.
    ```
    
    - There is always a possibility of a fix that is new, it is advised that the developer must make sure that the fix is sent upstream, reviewed and merged to the master branch.
    
    ## Creating a hotfix branch
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 14 21:36:02 GMT 2024
    - 5K bytes
    - Viewed (0)
  4. internal/grid/msg.go

    	// When a response is received, the mux is already removed from the remote.
    	OpResponse
    
    	// OpDisconnect instructs that remote wants to disconnect
    	OpDisconnect
    
    	// OpMerged is several operations merged into one.
    	OpMerged
    )
    
    const (
    	// FlagCRCxxh3 indicates that, the lower 32 bits of xxhash3 of the serialized
    	// message will be sent after the serialized message as little endian.
    	FlagCRCxxh3 Flags = 1 << iota
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 28 19:22:29 GMT 2023
    - 7.3K bytes
    - Viewed (0)
  5. cmd/last-minute.go

    	Totals  [60]AccElem
    	LastSec int64
    }
    
    // Merge data of two lastMinuteLatency structure
    func (l lastMinuteLatency) merge(o lastMinuteLatency) (merged lastMinuteLatency) {
    	if l.LastSec > o.LastSec {
    		o.forwardTo(l.LastSec)
    		merged.LastSec = l.LastSec
    	} else {
    		l.forwardTo(o.LastSec)
    		merged.LastSec = o.LastSec
    	}
    
    	for i := range merged.Totals {
    		merged.Totals[i] = AccElem{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jul 05 17:40:45 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  6. cmd/xl-storage-format-v2_test.go

    				}
    				vMod = append(vMod, newVers)
    			}
    			merged := mergeXLV2Versions(i, true, 0, vMod...)
    			if len(merged) == 0 && i < 2 {
    				t.Error("Did not get any results")
    				return
    			}
    			if len(merged) > 0 && i >= 2 {
    				t.Error("Got unexpected results", len(merged), merged[0].header)
    				return
    			}
    			for _, ver := range merged {
    				if ver.header.Type == invalidVersionType {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 08 17:50:48 GMT 2024
    - 36.4K bytes
    - Viewed (0)
  7. cmd/metacache-server-pool.go

    		} else {
    			entries.listID = o.ID
    		}
    	}
    	if !truncated {
    		return entries, io.EOF
    	}
    	return entries, nil
    }
    
    // listMerged will list across all sets and return a merged results stream.
    // The result channel is closed when no more results are expected.
    func (z *erasureServerPools) listMerged(ctx context.Context, o listPathOptions, results chan<- metaCacheEntry) error {
    	var mu sync.Mutex
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  8. cmd/bucket-stats.go

    	Totals  [60]AccElem
    	LastMin int64
    }
    
    // Merge data of two ReplicationLastHour structure
    func (l ReplicationLastHour) merge(o ReplicationLastHour) (merged ReplicationLastHour) {
    	if l.LastMin > o.LastMin {
    		o.forwardTo(l.LastMin)
    		merged.LastMin = l.LastMin
    	} else {
    		l.forwardTo(o.LastMin)
    		merged.LastMin = o.LastMin
    	}
    
    	for i := range merged.Totals {
    		merged.Totals[i] = AccElem{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 13.1K bytes
    - Viewed (0)
  9. cmd/metacache-entries.go

    			// Same, discard one.
    			merged = append(merged, a[0])
    			a = a[1:]
    			b = b[1:]
    		case a[0].name < b[0].name:
    			merged = append(merged, a[0])
    			a = a[1:]
    		default:
    			merged = append(merged, b[0])
    			b = b[1:]
    		}
    		if limit > 0 && len(merged) >= limit {
    			break
    		}
    	}
    	// Append anything left.
    	if limit < 0 || len(merged) < limit {
    		merged = append(merged, a...)
    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)
  10. cmd/metrics.go

    			Name:    "s3_ttfb_seconds",
    			Help:    "Time taken by requests served by current MinIO server instance",
    			Buckets: []float64{.05, .1, .25, .5, 1, 2.5, 5, 10},
    		},
    		[]string{"api"},
    	)
    	bucketHTTPRequestsDuration = prometheus.NewHistogramVec(
    		prometheus.HistogramOpts{
    			Name:    "s3_ttfb_seconds",
    			Help:    "Time taken by requests served by current MinIO server instance per bucket",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 06:48:36 GMT 2024
    - 16.9K bytes
    - Viewed (0)
Back to top