Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for allocator (0.15 sec)

  1. cmd/erasure-object.go

    	if err != nil {
    		return ObjectInfo{}, toObjectErr(err, minioMetaBucket, key)
    	}
    
    	// Fetch buffer for I/O, returns from the pool if not allocates a new one and returns.
    	var buffer []byte
    	switch size := data.Size(); {
    	case size == 0:
    		buffer = make([]byte, 1) // Allocate at least a byte to reach EOF
    	case size >= fi.Erasure.BlockSize:
    		buffer = globalBytePoolCap.Load().Get()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  2. cmd/globals.go

    	globalBucketObjectLockSys *BucketObjectLockSys
    	globalBucketQuotaSys      *BucketQuotaSys
    	globalBucketVersioningSys *BucketVersioningSys
    
    	// Allocated etcd endpoint for config and bucket DNS.
    	globalEtcdClient *etcd.Client
    
    	// Cluster replication manager.
    	globalSiteReplicationSys SiteReplicationSys
    
    	// Cluster replication resync metrics
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  3. internal/jwt/parser.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package jwt
    
    // This file is a re-implementation of the original code here with some
    // additional allocation tweaks reproduced using GODEBUG=allocfreetrace=1
    // original file https://github.com/golang-jwt/jwt/blob/main/parser.go
    // borrowed under MIT License https://github.com/golang-jwt/jwt/blob/main/LICENSE
    
    import (
    	"bytes"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue May 09 07:53:08 GMT 2023
    - 13.9K bytes
    - Viewed (0)
  4. internal/cachevalue/cache.go

    	valErr atomic.Pointer[struct {
    		v T
    		e error
    	}]
    	lastUpdateMs atomic.Int64
    	updating     sync.Mutex
    }
    
    // New allocates a new cached value instance. Tt must be initialized with
    // `.TnitOnce`.
    func New[T any]() *Cache[T] {
    	return &Cache[T]{}
    }
    
    // NewFromFunc allocates a new cached value instance and initializes it with an
    // update function, making it ready for use.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  5. internal/s3select/csv/reader.go

    		if r.err != nil {
    			return nil, r.err
    		}
    		// Move to next block
    		item, ok := <-r.queue
    		if !ok {
    			r.err = io.EOF
    			return nil, r.err
    		}
    		//nolint:staticcheck // SA6002 Using pointer would allocate more since we would have to copy slice header before taking a pointer.
    		r.csvDstPool.Put(r.current)
    		r.current = <-item.dst
    		r.err = item.err
    		r.recordsRead = 0
    	}
    	csvRecord := r.current[r.recordsRead]
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  6. cmd/metacache-entries.go

    	for i, entry := range m {
    		if entry.name != "" {
    			n++
    			if first == nil {
    				first = &m[i]
    			}
    		}
    	}
    	return first, n
    }
    
    // names will return all names in order.
    // Since this allocates it should not be used in critical functions.
    func (m metaCacheEntries) names() []string {
    	res := make([]string, 0, len(m))
    	for _, obj := range m {
    		res = append(res, obj.name)
    	}
    	return res
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  7. cmd/object-api-utils.go

    		bytebufferpool.Put(sb)
    	}()
    
    	return pathJoinBuf(sb, elem...)
    }
    
    // pathJoinBuf - like path.Join() but retains trailing SlashSeparator of the last element.
    // Provide a string builder to reduce allocation.
    func pathJoinBuf(dst *bytebufferpool.ByteBuffer, elem ...string) string {
    	trailingSlash := len(elem) > 0 && hasSuffixByte(elem[len(elem)-1], SlashSeparatorChar)
    	dst.Reset()
    	added := 0
    	for _, e := range elem {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
  8. cmd/storage-datatypes.go

    }
    
    // VersionPurgeStatusKey denotes purge status in metadata
    const (
    	VersionPurgeStatusKey = ReservedMetadataPrefixLower + "purgestatus"
    )
    
    // newFileInfo - initializes new FileInfo, allocates a fresh erasure info.
    func newFileInfo(object string, dataBlocks, parityBlocks int) (fi FileInfo) {
    	fi.Erasure = ErasureInfo{
    		Algorithm:    erasureAlgorithm,
    		DataBlocks:   dataBlocks,
    		ParityBlocks: parityBlocks,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
  9. cmd/benchmark-utils_test.go

    	// md5sum of the data to written is required as input for PutObject.
    
    	md5hex := getMD5Hash(textData)
    	sha256hex := ""
    
    	// benchmark utility which helps obtain number of allocations and bytes allocated per ops.
    	b.ReportAllocs()
    	// the actual benchmark for PutObject starts here. Reset the benchmark timer.
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		// insert the object.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 23 15:46:00 GMT 2022
    - 8.2K bytes
    - Viewed (0)
  10. cmd/bucket-replication.go

    	}
    
    	resyncStatus := ResyncFailed
    	defer func() {
    		s.markStatus(resyncStatus, opts, objectAPI)
    		globalSiteResyncMetrics.incBucket(opts, resyncStatus)
    		s.workerCh <- struct{}{}
    	}()
    	// Allocate new results channel to receive ObjectInfo.
    	objInfoCh := make(chan ObjectInfo)
    	cfg, err := getReplicationConfig(ctx, opts.bucket)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
Back to top