Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newSharedLock (1.07 sec)

  1. cmd/shared-lock.go

    		cancel()
    	}()
    	return ctx, cancel
    }
    
    func (ld sharedLock) GetLock(ctx context.Context) (context.Context, context.CancelFunc) {
    	l := <-ld.lockContext
    	return mergeContext(l.Context(), ctx)
    }
    
    func newSharedLock(ctx context.Context, objAPI ObjectLayer, lockName string) *sharedLock {
    	l := &sharedLock{
    		lockContext: make(chan LockContext),
    	}
    	go l.backgroundRoutine(ctx, objAPI, lockName)
    
    	return l
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Feb 13 09:26:38 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool.go

    	// When z.Init below has loaded the poolmeta will be initialized,
    	// and allowed to save.
    	z.poolMeta = newPoolMeta(z, poolMeta{})
    	z.poolMeta.dontSave = true
    
    	bootstrapTrace("newSharedLock", func() {
    		globalLeaderLock = newSharedLock(GlobalContext, z, "leader.lock")
    	})
    
    	// Start self healing after the object initialization
    	// so various tasks will be useful
    	bootstrapTrace("initAutoHeal", func() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
Back to top