Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 48 for SZ (0.05 sec)

  1. cmd/xl-storage-disk-id-check.go

    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricReadAll, volume, path)
    	if err != nil {
    		return nil, err
    	}
    	var sz int
    	defer func() {
    		sz = len(buf)
    		done(int64(sz), &err)
    	}()
    
    	return xioutil.WithDeadline[[]byte](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) (result []byte, err error) {
    		return p.storage.ReadAll(ctx, volume, path)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  2. cmd/bucket-replication-stats.go

    func (r *ReplicationStats) incQ(bucket string, sz int64, isDeleteRepl bool, opType replication.Type) {
    	r.qCache.Lock()
    	defer r.qCache.Unlock()
    	v, ok := r.qCache.bucketStats[bucket]
    	if !ok {
    		v = newInQueueStats(r.registry, bucket)
    	}
    	atomic.AddInt64(&v.nowBytes, sz)
    	atomic.AddInt64(&v.nowCount, 1)
    	r.qCache.bucketStats[bucket] = v
    	atomic.AddInt64(&r.qCache.srQueueStats.nowBytes, sz)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  3. cmd/admin-bucket-handlers.go

    	// of bucket metadata
    	zipWriter := zip.NewWriter(w)
    	defer zipWriter.Close()
    
    	rawDataFn := func(r io.Reader, filename string, sz int) {
    		header, zerr := zip.FileInfoHeader(dummyFileInfo{
    			name:    filename,
    			size:    int64(sz),
    			mode:    0o600,
    			modTime: time.Now(),
    			isDir:   false,
    			sys:     nil,
    		})
    		if zerr == nil {
    			header.Method = zip.Deflate
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  4. compat/maven-embedder/src/main/java/org/apache/maven/cli/props/MavenProperties.java

            if (str == null) {
                return null;
            }
            int sz = str.length();
            StringBuilder out = new StringBuilder(sz);
            StringBuilder unicode = new StringBuilder(UNICODE_LEN);
            boolean hadSlash = false;
            boolean inUnicode = false;
            for (int i = 0; i < sz; i++) {
                char ch = str.charAt(i);
                if (inUnicode) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 38.2K bytes
    - Viewed (0)
  5. docs/debugging/xl-meta/main.go

    func shardSize(blockSize, dataBlocks int) (sz int) {
    	if dataBlocks == 0 {
    		// do nothing on invalid input
    		return
    	}
    	// Make denominator positive
    	if dataBlocks < 0 {
    		blockSize = -blockSize
    		dataBlocks = -dataBlocks
    	}
    	sz = blockSize / dataBlocks
    	if blockSize > 0 && blockSize%dataBlocks != 0 {
    		sz++
    	}
    	return
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  6. cmd/metacache-stream.go

    			}
    			r.err = err
    			return err
    		}
    		// Read name without allocating more than 1 buffer.
    		sz, err := r.mr.ReadStringHeader()
    		if err != nil {
    			r.err = err
    			return err
    		}
    		if cap(tmp) < int(sz) {
    			tmp = make([]byte, 0, sz+256)
    		}
    		tmp = tmp[:sz]
    		_, err = r.mr.R.ReadFull(tmp)
    		if err != nil {
    			r.err = err
    			return err
    		}
    		if string(tmp) >= s {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  7. cmd/build-constants.go

    	GOPATH = ""
    
    	// GOROOT - GOROOT value at the time of build.
    	GOROOT = ""
    
    	// Version - version time.RFC3339.
    	Version = "DEVELOPMENT.GOGET"
    
    	// ReleaseTag - release tag in TAG.%Y-%m-%dT%H-%M-%SZ.
    	ReleaseTag = "DEVELOPMENT.GOGET"
    
    	// CommitID - latest commit id.
    	CommitID = "DEVELOPMENT.GOGET"
    
    	// ShortCommitID - first 12 characters from CommitID.
    	ShortCommitID = "DEVELOPMENT.GOGET"
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 17:57:52 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  8. cmd/bucket-replication-metrics.go

    	}
    	avg := (x*float64(n1) + y*float64(n2)) / float64(n1+n2)
    	return avg
    }
    
    // Add a new transfer
    func (rx *XferStats) addSize(sz int64, t time.Duration) {
    	if rx.measure == nil {
    		rx.measure = newRateMeasurement(time.Now())
    	}
    	rx.measure.incrementBytes(uint64(sz))
    	rx.Curr = rx.measure.getExpMovingAvgBytesPerSecond()
    	rx.sma.addSample(rx.Curr)
    	rx.Avg = rx.sma.simpleMovingAvg()
    	if rx.Curr > rx.Peak {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  9. cmd/xl-storage.go

    	}
    	if stat.IsDir() {
    		return nil, dmTime, errFileNotFound
    	}
    
    	// Read into appropriate buffer.
    	sz := stat.Size()
    	if sz <= metaDataReadDefault {
    		buf = metaDataPoolGet()
    		buf = buf[:sz]
    	} else {
    		buf = make([]byte, sz)
    	}
    
    	// Read file...
    	_, err = io.ReadFull(f, buf)
    
    	return buf, stat.ModTime().UTC(), osErrToFileErr(err)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  10. internal/grid/connection.go

    	// Add baseflags.
    	msg.Flags.Set(c.baseFlags)
    	// This cannot encode subroute.
    	msg.Flags.Clear(FlagSubroute)
    	if payload != nil {
    		if sz := payload.Msgsize(); cap(msg.Payload) < sz {
    			PutByteBuffer(msg.Payload)
    			msg.Payload = GetByteBufferCap(sz)
    		}
    		var err error
    		msg.Payload, err = payload.MarshalMsg(msg.Payload[:0])
    		msg.Op = payload.Op()
    		if err != nil {
    			return err
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
Back to top