Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for lockMap (0.06 sec)

  1. cmd/namespace-lock.go

    	defer n.lockMapMutex.Unlock()
    	if _, found := n.lockMap[resource]; !found {
    		return
    	}
    	if readLock {
    		n.lockMap[resource].RUnlock()
    	} else {
    		n.lockMap[resource].Unlock()
    	}
    	n.lockMap[resource].ref--
    	if n.lockMap[resource].ref < 0 {
    		logger.CriticalIf(GlobalContext, errors.New("resource reference count was lower than 0"))
    	}
    	if n.lockMap[resource].ref == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  2. internal/dsync/dsync-server_test.go

    	var locksHeld int64
    	if locksHeld, reply = l.lockMap[args.Resources[0]]; !reply {
    		l.lockMap[args.Resources[0]] = ReadLock // No locks held on the given name, so claim (first) read lock
    		reply = true
    	} else if reply = locksHeld != WriteLock; reply { // Unless there is a write lock
    		l.lockMap[args.Resources[0]] = locksHeld + ReadLock // Grant another read lock
    	}
    	return reply, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jan 23 16:46:37 UTC 2023
    - 8.3K bytes
    - Viewed (0)
  3. cmd/lock-rest-server-common_test.go

    		Writer:          true,
    		UID:             "89ab-cdef",
    		Timestamp:       UTCNow().UnixNano(),
    		TimeLastRefresh: UTCNow().UnixNano(),
    	}
    
    	locker.ll.lockMap["name"] = []lockRequesterInfo{
    		lockRequesterInfo1,
    		lockRequesterInfo2,
    	}
    
    	lri := locker.ll.lockMap["name"]
    
    	// test unknown uid
    	if locker.ll.removeEntry("name", dsync.LockArgs{
    		Owner: "owner",
    		UID:   "unknown-uid",
    	}, &lri) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  4. cmd/namespace-lock_test.go

    		//    successfully acquiring the lock.
    		// 2) lk2 then needs to advance and remove the resource from lockMap.
    		// 3) lk3 or lk4 (whichever didn't execute in step 1) then executes and creates
    		//    a new entry in lockMap and acquires a lock for the same resource.
    
    		<-lk2ch
    		lk3ok := <-lk3ch
    		lk4ok := <-lk4ch
    
    		if lk3ok && lk4ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 3.1K bytes
    - Viewed (0)
Back to top