Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for allocated (0.19 sec)

  1. 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)
  2. 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)
  3. cmd/storage-datatypes.go

    	buf := grid.GetByteBufferCap(32 + 16<<10)
    	return &RenameDataInlineHandlerParams{RenameDataHandlerParams{FI: FileInfo{Data: buf[:0]}}}
    }
    
    // Recycle will reuse the memory allocated for the FileInfo data.
    func (r *RenameDataInlineHandlerParams) Recycle() {
    	if r == nil {
    		return
    	}
    	if cap(r.FI.Data) >= xioutil.SmallBlock {
    		grid.PutByteBuffer(r.FI.Data)
    		r.FI.Data = nil
    	}
    }
    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)
  4. cmd/url_test.go

    	if err != nil {
    		b.Fatal(err)
    	}
    
    	// 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()
    
    	if err := req.ParseForm(); err != nil {
    		b.Fatal(err)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 16 17:28:29 GMT 2021
    - 2K bytes
    - Viewed (0)
  5. 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)
  6. cmd/bucket-lifecycle.go

    	}
    }
    
    // globalExpiryState is the per-node instance which manages all ILM expiry tasks.
    var globalExpiryState *expiryState
    
    // newExpiryState creates an expiryState with buffered channels allocated for
    // each ILM expiry task type.
    func newExpiryState(ctx context.Context, objAPI ObjectLayer, n int) *expiryState {
    	es := &expiryState{
    		ctx:    ctx,
    		objAPI: objAPI,
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  7. cmd/erasure-decode.go

    				readTriggerCh <- true
    				return
    			}
    			bufIdx := p.readerToBuf[i]
    			if p.buf[bufIdx] == nil {
    				// Reading first time on this disk, hence the buffer needs to be allocated.
    				// Subsequent reads will reuse this buffer.
    				p.buf[bufIdx] = make([]byte, p.shardSize)
    			}
    			// For the last shard, the shardsize might be less than previous shard sizes.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  8. internal/crypto/sse-kms.go

    	return key, err
    }
    
    // CreateMetadata encodes the sealed object key into the metadata and returns
    // the modified metadata. If the keyID and the kmsKey is not empty it encodes
    // both into the metadata as well. It allocates a new metadata map if metadata
    // is nil.
    func (ssekms) CreateMetadata(metadata map[string]string, keyID string, kmsKey []byte, sealedKey SealedKey, ctx kms.Context) map[string]string {
    	if sealedKey.Algorithm != SealAlgorithm {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 8.4K bytes
    - Viewed (0)
  9. internal/lock/lock_windows.go

    // path unmodified.
    //
    // See https://msdn.microsoft.com/en-us/library/windows/desktop/aa365247(v=vs.85).aspx#maxpath
    func fixLongPath(path string) string {
    	// Do nothing (and don't allocate) if the path is "short".
    	// Empirically (at least on the Windows Server 2013 builder),
    	// the kernel is arbitrarily okay with < 248 bytes. That
    	// matches what the docs above say:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Oct 18 18:08:15 GMT 2023
    - 7.9K bytes
    - Viewed (0)
  10. 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)
Back to top