Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 54 for SZ (0.02 sec)

  1. cmd/data-usage-cache_test.go

    				"BETWEEN_10_MB_AND_64_MB":  1,
    			},
    		},
    	}
    	for i, test := range tests {
    		t.Run(fmt.Sprintf("Test-%d", i), func(t *testing.T) {
    			var h sizeHistogram
    			for _, sz := range test.sizes {
    				h.add(sz)
    			}
    			got := h.toMap()
    			exp := test.want
    			// what is in exp is in got
    			for k := range exp {
    				if exp[k] != got[k] {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jan 13 07:51:08 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  2. internal/bucket/lifecycle/filter.go

    				f.Tag = tag
    				f.tagSet = true
    			case "ObjectSizeLessThan":
    				var sz int64
    				if err = d.DecodeElement(&sz, &se); err != nil {
    					return err
    				}
    				f.ObjectSizeLessThan = sz
    			case "ObjectSizeGreaterThan":
    				var sz int64
    				if err = d.DecodeElement(&sz, &se); err != nil {
    					return err
    				}
    				f.ObjectSizeGreaterThan = sz
    			default:
    				return errUnknownXMLTag
    			}
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 04 17:01:26 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  3. 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)
  4. android/guava-tests/benchmark/com/google/common/io/CharStreamsCopyBenchmark.java

      }
    
      enum TargetSupplier {
        STRING_WRITER {
          @Override
          Appendable get(int sz) {
            return new StringWriter(sz);
          }
        },
        STRING_BUILDER {
          @Override
          Appendable get(int sz) {
            return new StringBuilder(sz);
          }
        };
    
        abstract Appendable get(int sz);
      }
    
      @Param CopyStrategy strategy;
      @Param TargetSupplier target;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 23 18:59:54 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  5. guava-tests/benchmark/com/google/common/io/CharStreamsCopyBenchmark.java

      }
    
      enum TargetSupplier {
        STRING_WRITER {
          @Override
          Appendable get(int sz) {
            return new StringWriter(sz);
          }
        },
        STRING_BUILDER {
          @Override
          Appendable get(int sz) {
            return new StringBuilder(sz);
          }
        };
    
        abstract Appendable get(int sz);
      }
    
      @Param CopyStrategy strategy;
      @Param TargetSupplier target;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 23 18:59:54 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  6. docs/debugging/inspect/export.go

    		return buf.Bytes(), nil
    	}
    
    	fmt.Println("{")
    
    	hasWritten := false
    	var r io.Reader
    	var sz int64
    	f, e := os.Open(downloadPath)
    	if e != nil {
    		return e
    	}
    	if st, e := f.Stat(); e == nil {
    		sz = st.Size()
    	}
    	defer f.Close()
    	r = f
    
    	zr, e := zip.NewReader(r.(io.ReaderAt), sz)
    	if e != nil {
    		return e
    	}
    	for _, file := range zr.File {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 08 15:58:02 UTC 2022
    - 9.1K bytes
    - Viewed (0)
  7. 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)
  8. cmd/site-replication-metrics.go

    				Max:  epHealth.latency.peak,
    			}
    		}
    		m[dID] = metric
    	}
    	return m
    }
    
    func (srs *SRStatus) updateXferRate(sz int64, duration time.Duration) {
    	if sz > minLargeObjSize {
    		srs.XferRateLrg.addSize(sz, duration)
    	} else {
    		srs.XferRateSml.addSize(sz, duration)
    	}
    }
    
    func newSRStats() *SRStats {
    	s := SRStats{
    		M:               make(map[string]*SRStatus),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top