Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 13 for fileInfoVersions (0.1 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/storage-datatypes_gen_test.go

    	}
    }
    
    func BenchmarkMarshalMsgFileInfoVersions(b *testing.B) {
    	v := FileInfoVersions{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgFileInfoVersions(b *testing.B) {
    	v := FileInfoVersions{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 73.9K bytes
    - Click Count (0)
  2. cmd/naughty-disk_test.go

    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.Delete(ctx, volume, path, deleteOpts)
    }
    
    func (d *naughtyDisk) DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error {
    	if err := d.calcError(); err != nil {
    		errs := make([]error, len(versions))
    		for i := range errs {
    			errs[i] = err
    		}
    		return errs
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 10.1K bytes
    - Click Count (0)
  3. cmd/global-heal.go

    					return
    				}
    			}
    
    			// erasureObjects layer needs object names to be encoded
    			encodedEntryName := encodeDirObject(entry.name)
    
    			var result healEntryResult
    			fivs, err := entry.fileInfoVersions(bucket)
    			if err != nil {
    				res, err := er.HealObject(ctx, bucket, encodedEntryName, "",
    					madmin.HealOpts{
    						ScanMode: scanMode,
    						Remove:   healDeleteDangling,
    					})
    				if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  4. cmd/erasure-server-pool-decom.go

    			default:
    				return false
    			}
    		}
    
    		decommissionEntry := func(entry metaCacheEntry) {
    			defer wk.Give()
    
    			if entry.isDir() {
    				return
    			}
    
    			fivs, err := entry.fileInfoVersions(bi.Name)
    			if err != nil {
    				return
    			}
    
    			// We need a reversed order for decommissioning,
    			// to create the appropriate stack.
    			versionsSorter(fivs.Versions).reverse()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  5. cmd/erasure-server-pool.go

    						return
    					}
    				}
    				continue
    			}
    			fivs, err := entry.fileInfoVersions(bucket)
    			if err != nil {
    				sendErr(err)
    				return
    			}
    
    			// Note: entry.fileInfoVersions returns versions sorted in reverse chronological order based on ModTime
    			if opts.VersionsSort == WalkVersionsSortAsc {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  6. cmd/storage-rest-client.go

    	})
    	return toStorageErr(err)
    }
    
    // DeleteVersions - deletes list of specified versions if present
    func (client *storageRESTClient) DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) (errs []error) {
    	if len(versions) == 0 {
    		return errs
    	}
    
    	values := make(url.Values)
    	values.Set(storageRESTVolume, volume)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 08 02:38:41 GMT 2025
    - 30.4K bytes
    - Click Count (0)
  7. cmd/erasure-object.go

    		// storage class only needs to be honored for
    		// Read() requests alone which we already do.
    		writeQuorums[i] = len(storageDisks)/2 + 1
    	}
    
    	versionsMap := make(map[string]FileInfoVersions, len(objects))
    	for i := range objects {
    		// Construct the FileInfo data that needs to be preserved on the disk.
    		vr := FileInfo{
    			Name:             objects[i].ObjectName,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  8. cmd/storage-datatypes_gen.go

    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *FileInfoVersions) DecodeMsg(dc *msgp.Reader) (err error) {
    	var zb0001 uint32
    	zb0001, err = dc.ReadArrayHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	if zb0001 != 5 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 151.7K bytes
    - Click Count (0)
  9. cmd/xl-storage-disk-id-check.go

    }
    
    // DeleteVersions deletes slice of versions, it can be same object
    // or multiple objects.
    func (p *xlStorageDiskIDCheck) DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) (errs []error) {
    	// Merely for tracing storage
    	path := ""
    	if len(versions) > 0 {
    		path = versions[0].Name
    	}
    	errs = make([]error, len(versions))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  10. cmd/data-scanner.go

    					}
    
    					if entry.isDir() {
    						return
    					}
    
    					// We got an entry which we should be able to heal.
    					fiv, err := entry.fileInfoVersions(bucket)
    					if err != nil {
    						err := bgSeq.queueHealTask(healSource{
    							bucket:    bucket,
    							object:    entry.name,
    							versionID: "",
    						}, madmin.HealItemObject)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 45.5K bytes
    - Click Count (0)
Back to Top