Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newSharedLock (0.2 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
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Feb 13 09:26:38 GMT 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")
    	})
    
    	// Enable background operations on
    	//
    	// - Disk auto healing
    	// - MRF (most recently failed) healing
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 80.1K bytes
    - Viewed (0)
Back to top