Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for lri (0.13 sec)

  1. cmd/local-locker.go

    	// Find correct entry to remove based on uid.
    	for index, entry := range *lri {
    		if entry.UID == args.UID && (args.Owner == "" || entry.Owner == args.Owner) {
    			if len(*lri) == 1 {
    				// Remove the write lock.
    				delete(l.lockMap, name)
    			} else {
    				// Remove the appropriate read lock.
    				*lri = append((*lri)[:index], (*lri)[index+1:]...)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  2. cmd/admin-handlers_test.go

    	}
    	var exp madmin.LockEntries
    	for _, lri := range lris {
    		lockType := func(lri lockRequesterInfo) string {
    			if lri.Writer {
    				return "WRITE"
    			}
    			return "READ"
    		}
    		exp = append(exp, madmin.LockEntry{
    			Resource:   lri.Name,
    			Type:       lockType(lri),
    			ServerList: owners,
    			Owner:      lri.Owner,
    			ID:         lri.UID,
    			Quorum:     lri.Quorum,
    		})
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  3. cmd/lock-rest-server-common_test.go

    		lockRequesterInfo1,
    		lockRequesterInfo2,
    	}
    
    	lri := locker.ll.lockMap["name"]
    
    	// test unknown uid
    	if locker.ll.removeEntry("name", dsync.LockArgs{
    		Owner: "owner",
    		UID:   "unknown-uid",
    	}, &lri) {
    		t.Errorf("Expected %#v, got %#v", false, true)
    	}
    
    	if !locker.ll.removeEntry("name", dsync.LockArgs{
    		Owner: "owner",
    		UID:   "0123-4567",
    	}, &lri) {
    		t.Errorf("Expected %#v, got %#v", true, false)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Mar 23 17:26:21 GMT 2023
    - 3.1K bytes
    - Viewed (0)
  4. internal/dsync/drwmutex.go

    	dsyncLog = env.Get("_MINIO_DSYNC_TRACE", "0") == "1"
    
    	lockRetryMinInterval = 250 * time.Millisecond
    	if lri := env.Get("_MINIO_LOCK_RETRY_INTERVAL", ""); lri != "" {
    		v, err := strconv.Atoi(lri)
    		if err != nil {
    			panic(err)
    		}
    		lockRetryMinInterval = time.Duration(v) * time.Millisecond
    	}
    
    	lockRetryBackOff = backoffWait(
    		lockRetryMinInterval,
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  5. cmd/admin-handlers.go

    }
    
    func topLockEntries(peerLocks []*PeerLocks, stale bool) madmin.LockEntries {
    	now := time.Now().UTC()
    	entryMap := make(map[string]*madmin.LockEntry)
    	toEntry := func(lri lockRequesterInfo) string {
    		return fmt.Sprintf("%s/%s", lri.Name, lri.UID)
    	}
    	for _, peerLock := range peerLocks {
    		if peerLock == nil {
    			continue
    		}
    		for k, v := range peerLock.Locks {
    			for _, lockReqInfo := range v {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
Back to top