Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for fileInfo (0.12 sec)

  1. cmd/erasure-metadata.go

    // pickValidFileInfo - picks one valid FileInfo content and returns from a
    // slice of FileInfo.
    func pickValidFileInfo(ctx context.Context, metaArr []FileInfo, modTime time.Time, etag string, quorum int) (FileInfo, error) {
    	return findFileInfoInQuorum(ctx, metaArr, modTime, etag, quorum)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  2. cmd/erasure-healing-common.go

    		// the etag.
    		if count >= quorum {
    			return etags
    		}
    	}
    
    	return make([]string, len(partsMetadata))
    }
    
    // Extracts list of times from FileInfo slice and returns, skips
    // slice elements which have errors.
    func listObjectModtimes(partsMetadata []FileInfo, errs []error) (modTimes []time.Time) {
    	modTimes = bootModtimes(len(partsMetadata))
    	for index, metadata := range partsMetadata {
    		if errs[index] != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  3. cmd/storage-datatypes.go

    		quorum++
    	}
    	return quorum
    }
    
    // ReadQuorum returns expected read quorum for this FileInfo
    func (fi FileInfo) ReadQuorum(dquorum int) int {
    	if fi.Deleted {
    		return dquorum
    	}
    	return fi.Erasure.DataBlocks
    }
    
    // Equals checks if fi(FileInfo) matches ofi(FileInfo)
    func (fi FileInfo) Equals(ofi FileInfo) (ok bool) {
    	typ1, ok1 := crypto.IsEncrypted(fi.Metadata)
    	typ2, ok2 := crypto.IsEncrypted(ofi.Metadata)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    	}
    
    	calcQuorum := func(metaArr []FileInfo, errs []error) (FileInfo, []FileInfo, []StorageAPI, time.Time, string, error) {
    		readQuorum, _, err := objectQuorumFromMeta(ctx, metaArr, errs, er.defaultParityCount)
    		if err != nil {
    			return FileInfo{}, nil, nil, time.Time{}, "", err
    		}
    		if err := reduceReadQuorumErrs(ctx, errs, objectOpIgnoredErrs, readQuorum); err != nil {
    			return FileInfo{}, nil, nil, time.Time{}, "", err
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v2.go

    	case DeleteType:
    		return j.DeleteMarker.VersionID
    	case LegacyType:
    		return [16]byte{}
    	}
    	return [16]byte{}
    }
    
    // ToFileInfo returns FileInfo of the underlying type.
    func (j *xlMetaV2Version) ToFileInfo(volume, path string, allParts bool) (fi FileInfo, err error) {
    	if j == nil {
    		return fi, errFileNotFound
    	}
    	switch j.Type {
    	case ObjectType:
    		fi, err = j.ObjectV2.ToFileInfo(volume, path, allParts)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (1)
  6. cmd/xl-storage-format-v1.go

    	return nil
    }
    
    // constant and shouldn't be changed.
    const (
    	legacyDataDir = "legacy"
    )
    
    func (m *xlMetaV1Object) ToFileInfo(volume, path string) (FileInfo, error) {
    	if !m.valid() {
    		return FileInfo{}, errFileCorrupt
    	}
    
    	fi := FileInfo{
    		Volume:      volume,
    		Name:        path,
    		ModTime:     m.Stat.ModTime,
    		Size:        m.Stat.Size,
    		Metadata:    m.Meta,
    		Parts:       m.Parts,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  7. cmd/xl-storage-disk-id-check.go

    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricReadVersion, volume, path)
    	if err != nil {
    		return fi, err
    	}
    	defer done(0, &err)
    
    	return xioutil.WithDeadline[FileInfo](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) (result FileInfo, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  8. cmd/xl-storage.go

    }
    
    // GetDiskID - returns the cached disk uuid
    func (s *xlStorage) GetDiskID() (string, error) {
    	s.RLock()
    	diskID := s.diskID
    	fileInfo := s.formatFileInfo
    	lastCheck := s.formatLastCheck
    
    	// check if we have a valid disk ID that is less than 1 seconds old.
    	if fileInfo != nil && diskID != "" && time.Since(lastCheck) <= 1*time.Second {
    		s.RUnlock()
    		return diskID, nil
    	}
    	s.RUnlock()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  9. cmd/global-heal.go

    			disks[i], disks[j] = disks[j], disks[i]
    		})
    
    		expectedDisks := len(disks)/2 + 1
    		fallbackDisks := disks[expectedDisks:]
    		disks = disks[:expectedDisks]
    
    		filterLifecycle := func(bucket, object string, fi FileInfo) bool {
    			if lc == nil {
    				return false
    			}
    			versioned := vc != nil && vc.Versioned(object)
    			objInfo := fi.ToObjectInfo(bucket, object, versioned)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  10. cmd/storage-datatypes_gen.go

    		}
    	}
    	s += 13 + msgp.Uint32Size + 24 + msgp.Uint64Size + 19 + msgp.Uint64Size + 12 + msgp.Uint64Size + 13 + msgp.Uint64Size
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *FileInfo) DecodeMsg(dc *msgp.Reader) (err error) {
    	var zb0001 uint32
    	zb0001, err = dc.ReadArrayHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	if zb0001 != 28 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 150.2K bytes
    - Viewed (0)
Back to top