Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 48 for SZ (0.03 sec)

  1. internal/handlers/forwarder.go

    	}
    
    	return f
    }
    
    type bufPool struct {
    	sz   int
    	pool sync.Pool
    }
    
    func (b *bufPool) Put(buf []byte) {
    	if cap(buf) < b.sz || cap(buf) > b.sz*2 {
    		// Buffer too small or will likely leak memory after being expanded.
    		// Drop it.
    		return
    	}
    	b.pool.Put(&buf)
    }
    
    func (b *bufPool) Get() []byte {
    	bufp := b.pool.Get().(*[]byte)
    	return (*bufp)[:b.sz]
    }
    
    func newBufPool(sz int) httputil.BufferPool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 07 05:42:10 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  2. cmd/batch-job-common-types.go

    // - sf.LowerBound < sz, when sf.LowerBound alone is specified
    // - sz < sf.UpperBound, when sf.UpperBound alone is specified
    // - sf.LowerBound < sz < sf.UpperBound when both are specified,
    func (sf BatchJobSizeFilter) InRange(sz int64) bool {
    	if sf.UpperBound > 0 && sz > int64(sf.UpperBound) {
    		return false
    	}
    
    	if sf.LowerBound > 0 && sz < int64(sf.LowerBound) {
    		return false
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  3. internal/bucket/lifecycle/and.go

    	}
    
    	return false
    }
    
    // BySize returns true when sz satisfies a
    // ObjectSizeLessThan/ObjectSizeGreaterthan or a logical AND of these predicates
    // Note: And combines size and other predicates like Tags, Prefix, etc. This
    // method applies exclusively to size predicates only.
    func (a And) BySize(sz int64) bool {
    	if a.ObjectSizeGreaterThan > 0 &&
    		sz <= a.ObjectSizeGreaterThan {
    		return false
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. docs/debugging/healing-bin/main.go

    		ht := make(map[string]map[string]interface{})
    		file := c.Args().Get(0)
    		if strings.HasSuffix(file, ".zip") {
    			var sz int64
    			f, err := os.Open(file)
    			if err != nil {
    				return err
    			}
    			if st, err := f.Stat(); err == nil {
    				sz = st.Size()
    			}
    			defer f.Close()
    			zr, err := zip.NewReader(f, sz)
    			if err != nil {
    				return err
    			}
    			for _, file := range zr.File {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.2K bytes
    - Viewed (0)
  7. cmd/xl-storage-meta-inline.go

    	if len(x) == 0 || !x.versionOK() {
    		return 0
    	}
    	sz, _, _ := msgp.ReadMapHeaderBytes(x.afterVersion())
    	return int(sz)
    }
    
    // replace will add or replace a key/value pair.
    func (x *xlMetaInlineData) replace(key string, value []byte) {
    	in := x.afterVersion()
    	sz, buf, _ := msgp.ReadMapHeaderBytes(in)
    	keys := make([][]byte, 0, sz+1)
    	vals := make([][]byte, 0, sz+1)
    
    	// Version plus header...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  8. internal/ringbuffer/ring_buffer_benchmark_test.go

    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		rb.Write(data)
    	}
    }
    
    func BenchmarkRingBuffer_AsyncReadBlocking(b *testing.B) {
    	const sz = 512
    	const buffers = 10
    	rb := New(sz * buffers)
    	rb.SetBlocking(true)
    	data := []byte(strings.Repeat("a", sz))
    	buf := make([]byte, sz)
    
    	go func() {
    		for {
    			rb.Read(buf)
    		}
    	}()
    
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		rb.Write(data)
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top