Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for metArr (0.05 sec)

  1. cmd/erasure-multipart.go

    }
    
    // checkUploadIDExists - verify if a given uploadID exists and is valid.
    func (er erasureObjects) checkUploadIDExists(ctx context.Context, bucket, object, uploadID string, write bool) (fi FileInfo, metArr []FileInfo, err error) {
    	defer func() {
    		if errors.Is(err, errFileNotFound) {
    			err = errUploadIDNotFound
    		}
    	}()
    
    	uploadIDPath := er.getUploadIDDir(bucket, object, uploadID)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  2. cmd/metacache-set.go

    	cancel context.CancelFunc
    }
    
    func (m *metaCacheRPC) setErr(err string) {
    	m.mu.Lock()
    	defer m.mu.Unlock()
    	meta := *m.meta
    	if meta.status != scanStateError {
    		meta.error = err
    		meta.status = scanStateError
    	} else {
    		// An error is already set.
    		return
    	}
    	meta, _ = m.o.updateMetacacheListing(meta, m.rpc)
    	*m.meta = meta
    }
    
    // getErr will return an error if the listing failed.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  3. cmd/erasure-metadata_test.go

    		fi.TransitionStatus = "complete"
    		fi.Size = 1 << 20
    
    		metaArr := make([]FileInfo, N)
    		for i := range N {
    			fi.Erasure.Index = i + 1
    			metaArr[i] = fi
    			if i < agree {
    				continue
    			}
    			metaArr[i].TransitionTier, metaArr[i].TransitionedObjName = "", ""
    			metaArr[i].TransitionStatus = ""
    		}
    		return metaArr
    	}
    	mkParities := func(N, agreedParity, disagreedParity, agree int) []int {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:02:50 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  4. cmd/global-heal.go

    				retErr = err
    				healingLogIf(ctx, err)
    				continue
    			}
    			// Check if bucket is object locked.
    			lr, err = globalBucketObjectLockSys.Get(bucket)
    			if err != nil {
    				retErr = err
    				healingLogIf(ctx, err)
    				continue
    			}
    			rcfg, err = getReplicationConfig(ctx, bucket)
    			if err != nil {
    				retErr = err
    				healingLogIf(ctx, err)
    				continue
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  5. internal/ringbuffer/ring_buffer.go

    	if len(p) == 0 {
    		return 0, r.setErr(nil, false)
    	}
    	r.mu.Lock()
    	defer r.mu.Unlock()
    	if err := r.err; err != nil {
    		if err == io.EOF {
    			err = ErrWriteOnClosed
    		}
    		return 0, err
    	}
    	wrote := 0
    	for len(p) > 0 {
    		n, err = r.write(p)
    		wrote += n
    		if !r.block || err == nil {
    			break
    		}
    		err = r.setErr(err, true)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  6. cmd/metacache-server-pool.go

    	// Save listing...
    	go func() {
    		if err := saver.saveMetaCacheStream(listCtx, &meta, saveCh); err != nil {
    			meta.setErr(err.Error())
    		}
    		cancel()
    	}()
    
    	// Do listing...
    	go func(o listPathOptions) {
    		err := z.listMerged(listCtx, o, inCh)
    		if err != nil {
    			meta.setErr(err.Error())
    		}
    		o.debugln("listAndSave: listing", o.ID, "finished with ", err)
    	}(*o)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  7. cmd/erasure-metadata.go

    	var candidate FileInfo
    	var found bool
    	for i, hash := range metaHashes {
    		if hash == maxHash {
    			if metaArr[i].IsValid() {
    				if !found {
    					candidate = metaArr[i]
    					found = true
    				}
    				props := objProps{
    					succModTime: metaArr[i].SuccessorModTime,
    					numVersions: metaArr[i].NumVersions,
    				}
    				otherPropsMap[props]++
    			}
    		}
    	}
    
    	if found {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  8. cmd/erasure-healing-common_test.go

    		},
    	}
    	for idx, test := range tests {
    		var metaArr []FileInfo
    		for i := 0; i < 12; i++ {
    			fi := test.fi1
    			if i%2 == 0 {
    				fi = test.fi2
    			}
    			metaArr = append(metaArr, fi)
    		}
    
    		parities := listObjectParities(metaArr, make([]error, len(metaArr)))
    		parity := commonParity(parities, 5)
    		var match int
    		for _, fi := range metaArr {
    			if fi.Erasure.ParityBlocks == parity {
    				match++
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  9. cmd/erasure-healing.go

    		}
    	}
    
    	for _, m := range metaArr {
    		if m.IsValid() {
    			validMeta = m
    			break
    		}
    	}
    
    	if !validMeta.IsValid() {
    		// validMeta is invalid because all xl.meta is missing apparently
    		// we should figure out if dataDirs are also missing > dataBlocks.
    		dataBlocks := (len(metaArr) + 1) / 2
    		if notFoundPartsErrs > dataBlocks {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  10. cmd/erasure-metadata-utils.go

    func shuffleDisksAndPartsMetadataByIndex(disks []StorageAPI, metaArr []FileInfo, fi FileInfo) (shuffledDisks []StorageAPI, shuffledPartsMetadata []FileInfo) {
    	shuffledDisks = make([]StorageAPI, len(disks))
    	shuffledPartsMetadata = make([]FileInfo, len(disks))
    	distribution := fi.Erasure.Distribution
    
    	var inconsistent int
    	for i, meta := range metaArr {
    		if disks[i] == nil {
    			// Assuming offline drives as inconsistent,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
Back to top