Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for timeSize (0.17 sec)

  1. cmd/data-scanner-metric.go

    		atomic.AddUint64(&p.operations[s], 1)
    		if s < scannerMetricLastRealtime {
    			p.latency[s].add(duration)
    		}
    	}
    }
    
    // timeSize add time and size of a scanner action.
    // Use for s < scannerMetricLastRealtime
    func (p *scannerMetrics) timeSize(s scannerMetric) func(sz int) {
    	startTime := time.Now()
    	return func(sz int) {
    		duration := time.Since(startTime)
    
    		atomic.AddUint64(&p.operations[s], 1)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  2. cmd/bucket-replication-utils_gen.go

    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z *TargetReplicationResyncStatus) Msgsize() (s int) {
    	s = 1 + 3 + msgp.TimeSize + 4 + msgp.TimeSize + 3 + msgp.StringPrefixSize + len(z.ResyncID) + 4 + msgp.TimeSize + 4 + msgp.IntSize + 3 + msgp.Int64Size + 4 + msgp.Int64Size + 3 + msgp.Int64Size + 4 + msgp.Int64Size + 4 + msgp.StringPrefixSize + len(z.Bucket) + 4 + msgp.StringPrefixSize + len(z.Object)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Apr 03 06:45:06 UTC 2025
    - 59.8K bytes
    - Viewed (0)
  3. cmd/storage-datatypes_gen.go

    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z VolInfo) Msgsize() (s int) {
    	s = 1 + msgp.StringPrefixSize + len(z.Name) + msgp.TimeSize + msgp.TimeSize
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *VolsInfo) DecodeMsg(dc *msgp.Reader) (err error) {
    	var zb0002 uint32
    	zb0002, err = dc.ReadArrayHeader()
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 152K bytes
    - Viewed (0)
  4. cmd/data-scanner.go

    						return
    					}
    
    					custom["versions"] = fmt.Sprint(len(fiv.Versions))
    					var successVersions, failVersions int
    					for _, ver := range fiv.Versions {
    						stopFn := globalScannerMetrics.timeSize(scannerMetricHealAbandonedVersion)
    						err := bgSeq.queueHealTask(healSource{
    							bucket:    bucket,
    							object:    fiv.Name,
    							versionID: ver.VersionID,
    						}, madmin.HealItemObject)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  5. cmd/xl-storage.go

    		res := make(map[string]string, 8)
    		defer func() {
    			stopFn(res)
    		}()
    
    		doneSz := globalScannerMetrics.timeSize(scannerMetricReadMetadata)
    		buf, err := s.readMetadata(ctx, item.Path)
    		doneSz(len(buf))
    		res["metasize"] = strconv.Itoa(len(buf))
    		if err != nil {
    			res["err"] = err.Error()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  6. docs/SMB3_IMPLEMENTATION_PLAN.md

    ## Resource Requirements
    
    ### Development Team
    - 2-3 Senior Java developers with SMB protocol expertise
    - 1 QA engineer for test infrastructure
    - 1 DevOps engineer for CI/CD setup
    
    ### Timeline
    - **Total Duration**: 6-8 months for all features
    - **Phases 1-2**: 2-3 months (High priority)
    - **Phases 3-4**: 2 months (Medium priority)
    - **Phases 5-6**: 2-3 months (Low priority)
    
    ### Infrastructure
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 10.7K bytes
    - Viewed (0)
Back to top