Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 56 for acquire (0.44 sec)

  1. cmd/license-update.go

    	go func() {
    		r := rand.New(rand.NewSource(time.Now().UnixNano()))
    		// Leader node (that successfully acquires the lock inside licenceUpdaterLoop)
    		// will keep performing the license update. If the leader goes down for some
    		// reason, the lock will be released and another node will acquire it and
    		// take over because of this loop.
    		for {
    			licenceUpdaterLoop(ctx, objAPI)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 3.3K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-rebalance.go

    		}
    	}
    	if ok {
    		lock := z.serverPools[0].NewNSLock(minioMetaBucket, rebalMetaName)
    		lkCtx, err := lock.GetLock(ctx, globalOperationTimeout)
    		if err != nil {
    			rebalanceLogIf(ctx, fmt.Errorf("failed to acquire write lock on %s/%s: %w", minioMetaBucket, rebalMetaName, err))
    			return err
    		}
    		defer lock.Unlock(lkCtx)
    
    		ctx = lkCtx.Context()
    
    		noLockOpts := ObjectOptions{NoLock: true}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  3. helm/minio/README.md

    | `rootPassword`          | `rootPassword`         | Root password. | yes      |
    
    All corresponding variables will be ignored in values file.
    
    ### Configure TLS
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 24 07:27:57 GMT 2024
    - 10.9K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool.go

    	}
    
    	var unlockOnDefer bool
    	nsUnlocker := func() {}
    	defer func() {
    		if unlockOnDefer {
    			nsUnlocker()
    		}
    	}()
    
    	// Acquire lock
    	if !opts.NoLock {
    		lock := z.NewNSLock(bucket, object)
    		lkctx, err := lock.GetRLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return nil, err
    		}
    		ctx = lkctx.Context()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, object, &er)
    	}
    
    	var unlockOnDefer bool
    	nsUnlocker := func() {}
    	defer func() {
    		if unlockOnDefer {
    			nsUnlocker()
    		}
    	}()
    
    	// Acquire lock
    	if !opts.NoLock {
    		lock := er.NewNSLock(bucket, object)
    		lkctx, err := lock.GetRLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return nil, err
    		}
    		ctx = lkctx.Context()
    
    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. internal/dsync/drwmutex.go

    	quorumLocked := checkQuorumLocked(locks, quorum) && locksFailed <= tolerance
    	if !quorumLocked {
    		log("dsync: Unable to acquire lock in quorum %#v\n", args)
    		// Release all acquired locks without quorum.
    		if !releaseAll(ctx, ds, tolerance, owner, locks, isReadLock, restClnts, names...) {
    			log("Unable to release acquired locks, these locks will expire automatically %#v\n", args)
    		}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  7. cmd/metrics-v2_gen.go

    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // MarshalMsg implements msgp.Marshaler
    func (z *MetricDescription) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 5
    	// string "Namespace"
    	o = append(o, 0x85, 0xa9, 0x4e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65)
    	o = msgp.AppendString(o, string(z.Namespace))
    	// string "Subsystem"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 19.2K bytes
    - Viewed (0)
  8. internal/grid/msg_gen.go

    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z Flags) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendUint8(o, uint8(z))
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *Flags) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	{
    		var zb0001 uint8
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 18.8K bytes
    - Viewed (0)
  9. cmd/batch-job-common-types_gen.go

    	if err != nil {
    		err = msgp.WrapError(err, "Value")
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z BatchJobKV) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 2
    	// string "Key"
    	o = append(o, 0x82, 0xa3, 0x4b, 0x65, 0x79)
    	o = msgp.AppendString(o, z.Key)
    	// string "Value"
    	o = append(o, 0xa5, 0x56, 0x61, 0x6c, 0x75, 0x65)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 02 10:51:33 GMT 2023
    - 21.9K bytes
    - Viewed (0)
  10. cmd/xl-storage-format-v2_gen.go

    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z ChecksumAlgo) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendUint8(o, uint8(z))
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *ChecksumAlgo) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	{
    		var zb0001 uint8
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 53.8K bytes
    - Viewed (0)
Back to top