Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 64 for fileInfos (0.05 sec)

  1. docs/debugging/reorder-disks/main.go

    		return nil, err
    	}
    
    	return result, nil
    }
    
    func getDiskUUIDMap() (map[string]string, error) {
    	result := make(map[string]string)
    	err := filepath.Walk("/dev/disk/by-uuid/",
    		func(path string, info os.FileInfo, err error) error {
    			if err != nil {
    				return err
    			}
    			realPath, err := filepath.EvalSymlinks(path)
    			if err != nil {
    				return err
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-decom.go

    			NoAuditLog: true,
    		})
    	if err != nil {
    		err = fmt.Errorf("decommissionObject: PutObject() %w", err)
    	}
    	return err
    }
    
    // versionsSorter sorts FileInfo slices by version.
    //
    //msgp:ignore versionsSorter
    type versionsSorter []FileInfo
    
    func (v versionsSorter) reverse() {
    	sort.Slice(v, func(i, j int) bool {
    		return v[i].ModTime.Before(v[j].ModTime)
    	})
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 42.1K bytes
    - Viewed (1)
  3. cmd/object-api-interface.go

    	NoAuditLog     bool // Only set for decom, rebalance, to avoid double audits.
    }
    
    // WalkOptions provides filtering, marker and other Walk() specific options.
    type WalkOptions struct {
    	Filter       func(info FileInfo) bool // return WalkFilter returns 'true/false'
    	Marker       string                   // set to skip until this object
    	LatestOnly   bool                     // returns only latest versions for all matching objects
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  4. cmd/storage-datatypes_gen_test.go

    	}
    }
    
    func BenchmarkMarshalMsgFileInfo(b *testing.B) {
    	v := FileInfo{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgFileInfo(b *testing.B) {
    	v := FileInfo{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 73.9K bytes
    - Viewed (0)
  5. cmd/global-heal.go

    		}
    
    		rand.Shuffle(len(disks), func(i, j int) {
    			disks[i], disks[j] = disks[j], disks[i]
    		})
    
    		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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  6. src/test/java/jcifs/internal/smb2/lease/DirectoryLeasingIntegrationTest.java

            for (int i = 0; i < readThreads.length; i++) {
                readThreads[i] = new Thread(() -> {
                    for (int j = 0; j < 100; j++) {
                        List<DirectoryCacheEntry.FileInfo> children = entry.getChildren();
                        // Just read, don't assert specific counts due to race conditions
                        assertNotNull(children);
                    }
                });
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 01:47:47 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  7. cmd/format-erasure.go

    // Migrates all previous versions to latest version of `format.json`,
    // this code calls migration in sequence, such as V1 is migrated to V2
    // first before it V2 migrates to V3.n
    func formatErasureMigrate(export string) ([]byte, fs.FileInfo, error) {
    	formatPath := pathJoin(export, minioMetaBucket, formatConfigFile)
    	formatData, formatFi, err := xioutil.ReadFileWithFileInfo(formatPath)
    	if err != nil {
    		return nil, nil, err
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 23.1K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-rebalance.go

    	Participating     bool          `json:"participating" msg:"par"`
    	Info              rebalanceInfo `json:"info" msg:"inf"`
    }
    
    func (rs *rebalanceStats) update(bucket string, fi FileInfo) {
    	if fi.IsLatest {
    		rs.NumObjects++
    	}
    
    	rs.NumVersions++
    	onDiskSz := int64(0)
    	if !fi.Deleted {
    		onDiskSz = fi.Size * int64(fi.Erasure.DataBlocks+fi.Erasure.ParityBlocks) / int64(fi.Erasure.DataBlocks)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  9. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 152K bytes
    - Viewed (0)
Back to top