Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for SZ (0.02 sec)

  1. cmd/bucket-stats.go

    	return bs.FailStats.SinceUptime.Count > 0 ||
    		bs.ReplicatedSize > 0 ||
    		bs.ReplicaSize > 0
    }
    
    func (bs *BucketReplicationStat) updateXferRate(sz int64, duration time.Duration) {
    	if sz > minLargeObjSize {
    		bs.XferRateLrg.addSize(sz, duration)
    	} else {
    		bs.XferRateSml.addSize(sz, duration)
    	}
    }
    
    // RMetricName - name of replication metric
    type RMetricName string
    
    const (
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  2. cmd/sftp-server-driver.go

    			"param":  s.Filepath,
    			"source": source,
    		},
    	}
    }
    
    func (m *sftpMetrics) log(s *sftp.Request, user string) func(sz int64, err error) {
    	startTime := time.Now()
    	source := getSource(2)
    	return func(sz int64, err error) {
    		globalTrace.Publish(sftpTrace(s, startTime, source, user, err, sz))
    	}
    }
    
    // NewSFTPDriver initializes sftp.Handlers implementation of following interfaces
    //
    // - sftp.Fileread
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. internal/grid/types.go

    }
    
    // NewJSONPool returns a new JSONPool.
    func NewJSONPool[T any]() *JSONPool[T] {
    	var t T
    	sz := 128
    	if b, err := json.Marshal(t); err != nil {
    		sz = len(b)
    	}
    	return &JSONPool[T]{
    		pool: sync.Pool{
    			New: func() interface{} {
    				var t T
    				return &t
    			},
    		},
    		emptySz: sz,
    	}
    }
    
    func (p *JSONPool[T]) new() *T {
    	var zero T
    	t := p.pool.Get().(*T)
    	*t = zero
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  4. cmd/global-heal.go

    		}
    	}
    
    	healEntrySuccess := func(sz uint64) healEntryResult {
    		return healEntryResult{
    			bytes:   sz,
    			success: true,
    		}
    	}
    
    	healEntryFailure := func(sz uint64) healEntryResult {
    		return healEntryResult{
    			bytes: sz,
    		}
    	}
    
    	healEntrySkipped := func(sz uint64) healEntryResult {
    		return healEntryResult{
    			bytes:   sz,
    			skipped: true,
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  5. cmd/ftp-server-driver.go

    			"source": source,
    		},
    	}
    }
    
    func (m *ftpMetrics) log(s *ftp.Context, paths ...string) func(sz int64, err error) {
    	startTime := time.Now()
    	source := getSource(2)
    	return func(sz int64, err error) {
    		globalTrace.Publish(ftpTrace(s, startTime, source, strings.Join(paths, " "), err, sz))
    	}
    }
    
    // Stat implements ftpDriver
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14K bytes
    - Viewed (0)
  6. cmd/bucket-replication-utils.go

    	Targets              []replicatedTargetInfo
    }
    
    func (ri replicatedInfos) CompletedSize() (sz int64) {
    	for _, t := range ri.Targets {
    		if t.Empty() {
    			continue
    		}
    		if t.ReplicationStatus == replication.Completed && t.PrevReplicationStatus != replication.Completed {
    			sz += t.Size
    		}
    	}
    	return sz
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  7. 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)
  8. src/cmd/asm/internal/asm/asm.go

    		return
    	}
    	p.dataAddr[name] = nameAddr.Offset + int64(sz)
    
    	switch valueAddr.Type {
    	case obj.TYPE_CONST:
    		switch sz {
    		case 1, 2, 4, 8:
    			nameAddr.Sym.WriteInt(p.ctxt, nameAddr.Offset, int(sz), valueAddr.Offset)
    		default:
    			p.errorf("bad int size for DATA argument: %d", sz)
    		}
    	case obj.TYPE_FCONST:
    		switch sz {
    		case 4:
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 21 14:11:44 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top