return r < 0 && r+rwmutexMaxReaders > 0
}

// RLocker returns a [Locker] interface that implements
// the [RWMutex.Lock] and [RWMutex.Unlock] methods by calling rw.RLock and rw.RUnlock.
func (rw *RWMutex) RLocker() Locker {
	return (*rlocker)(rw)
}

type rlocker RWMutex

func (r *rlocker) Lock()   { (*RWMutex)(r).RLock() }

	// possible, Locker obtained through RLocker() is provided.
	lock sync.Locker
}

type attrFunc func(runtime.Object) (labels.Set, fields.Set, error)
type indexerFunc func(int) *watchCacheEvent
type indexValidator func(int) bool

func newCacheInterval(startIndex, endIndex int, indexer indexerFunc, indexValidator indexValidator, locker sync.Locker) *watchCacheInterval {
	return &watchCacheInterval{

type Cond struct {
	noCopy noCopy

	// L is held while observing or changing the condition
	L Locker

	notify  notifyList
	checker copyChecker
}

// NewCond returns a new Cond with Locker l.
func NewCond(l Locker) *Cond {
	return &Cond{L: l}
}

// Wait atomically unlocks c.L and suspends execution
// of the calling goroutine. After later resuming execution,

	// Make sure only 1 callhome is running on the cluster.
	locker := objAPI.NewNSLock(minioMetaBucket, "callhome/runCallhome.lock")
	lkctx, err := locker.GetLock(ctx, callhomeLeaderLockTimeout)
	if err != nil {
		// lock timedout means some other node is the leader,
		// cycle back return 'true'
		return true
	}

	ctx = lkctx.Context()
	defer locker.Unlock(lkctx)

func TestPluck(t *testing.T) {
	users := []*User{
		GetUser("pluck-user1", Config{}),
		GetUser("pluck-user2", Config{}),
		GetUser("pluck-user3", Config{}),
	}

	DB.Create(&users)

	var names []string
	if err := DB.Model(User{}).Where("name like ?", "pluck-user%").Order("name").Pluck("name", &names).Error; err != nil {
		t.Errorf("got error when pluck name: %v", err)
	}

	var names2 []string

                BuildOperationProgressEventEmitter buildOperationProgressEventEmitter,
                TemporaryFileProvider temporaryFileProvider,
                BuildCacheEntryPacker packer,
                OriginMetadataFactory originMetadataFactory,
                StringInterner stringInterner
            ) {
                return new DefaultBuildCacheControllerFactory(

	}

	// We're looking for cases in which a pointer to this type
	// is a sync.Locker, but a value is not. This differentiates
	// embedded interfaces from embedded values.
	if types.Implements(types.NewPointer(typ), lockerType) && !types.Implements(typ, lockerType) {
		return []string{typ.String()}
	}

	// In go1.10, sync.noCopy did not implement Locker.
	// (The Unlock method was added only in CL 121876.)

      "targetWWNs": [
        "targetWWNsValue"
      ],
      "lun": 2,
      "fsType": "fsTypeValue",
      "readOnly": true,
      "wwids": [
        "wwidsValue"
      ]
    },
    "flocker": {
      "datasetName": "datasetNameValue",
      "datasetUUID": "datasetUUIDValue"
    },
    "flexVolume": {
      "driver": "driverValue",
      "fsType": "fsTypeValue",
      "secretRef": {

        fsType: fsTypeValue
        options:
          optionsKey: optionsValue
        readOnly: true
        secretRef:
          name: nameValue
          namespace: namespaceValue
      flocker:
        datasetName: datasetNameValue
        datasetUUID: datasetUUIDValue
      gcePersistentDisk:
        fsType: fsTypeValue
        partition: 3
        pdName: pdNameValue
        readOnly: true

  flexVolume:
    driver: driverValue
    fsType: fsTypeValue
    options:
      optionsKey: optionsValue
    readOnly: true
    secretRef:
      name: nameValue
      namespace: namespaceValue
  flocker:
    datasetName: datasetNameValue
    datasetUUID: datasetUUIDValue
  gcePersistentDisk:
    fsType: fsTypeValue
    partition: 3
    pdName: pdNameValue
    readOnly: true
  glusterfs: