Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for wr (0.01 sec)

  1. cmd/metacache-walk.go

    func (p *xlStorageDiskIDCheck) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) (err error) {
    	if err := p.checkID(opts.DiskID); err != nil {
    		return err
    	}
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricWalkDir, opts.Bucket, opts.BaseDir)
    	if err != nil {
    		return err
    	}
    	defer done(0, &err)
    
    	return p.storage.WalkDir(ctx, opts, wr)
    }
    
    // WalkDir will traverse a directory and return all entries found.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon May 26 07:06:43 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/SmbFileOutputStream.java

                    if (this.smb2) {
                        final Smb2WriteRequest wr = new Smb2WriteRequest(th.getConfig(), fh.getFileId());
                        wr.setOffset(this.fp);
                        wr.setData(b, off, w);
    
                        final Smb2WriteResponse resp = th.send(wr, RequestParam.NO_RETRY);
                        final long cnt = resp.getCount();
                        this.fp += cnt;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  3. cmd/storage-interface.go

    	DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error)
    
    	// WalkDir will walk a directory on disk and return a metacache stream on wr.
    	WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error
    
    	// Metadata operations
    	DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) error
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  4. src/bufio/bufio.go

    	}
    	if b.buf == nil {
    		b.buf = make([]byte, defaultBufSize)
    	}
    	b.err = nil
    	b.n = 0
    	b.wr = w
    }
    
    // Flush writes any buffered data to the underlying [io.Writer].
    func (b *Writer) Flush() error {
    	if b.err != nil {
    		return b.err
    	}
    	if b.n == 0 {
    		return nil
    	}
    	n, err := b.wr.Write(b.buf[0:b.n])
    	if n < b.n && err == nil {
    		err = io.ErrShortWrite
    	}
    	if err != nil {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Sep 03 14:04:47 UTC 2025
    - 22K bytes
    - Viewed (0)
  5. cmd/naughty-disk_test.go

    		return err
    	}
    	return d.disk.DeleteVol(ctx, volume, forceDelete)
    }
    
    func (d *naughtyDisk) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error {
    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.WalkDir(ctx, opts, wr)
    }
    
    func (d *naughtyDisk) ListDir(ctx context.Context, origvolume, volume, dirPath string, count int) (entries []string, err error) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  6. cmd/admin-handlers.go

    	owner := cred.AccessKey == globalActiveCred.AccessKey
    
    	// Set prefix value for "s3:prefix" policy conditionals.
    	r.Header.Set("prefix", "")
    
    	// Set delimiter value for "s3:delimiter" policy conditionals.
    	r.Header.Set("delimiter", SlashSeparator)
    
    	isAllowedAccess := func(bucketName string) (rd, wr bool) {
    		if globalIAMSys.IsAllowed(policy.Args{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  7. cmd/admin-handlers-users.go

    			BucketName:      bucketName,
    			ConditionValues: getConditionValues(r, "", cred),
    			IsOwner:         owner,
    			ObjectName:      "",
    			Claims:          cred.Claims,
    		}) {
    			wr = true
    		}
    
    		return rd, wr
    	}
    
    	// If etcd, dns federation configured list buckets from etcd.
    	var err error
    	var buckets []BucketInfo
    	if globalDNSConfig != nil && globalBucketFederation {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 90.6K bytes
    - Viewed (0)
Back to top