Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for lris (0.01 sec)

  1. cmd/local-locker.go

    	defer l.getMutex()()
    
    	var readers, writers int32
    	for k, lris := range l.lockMap {
    		modified := false
    		for i := 0; i < len(lris); {
    			lri := &lris[i]
    			if time.Since(time.Unix(0, lri.TimeLastRefresh)) > interval {
    				delete(l.lockUID, formatUUID(lri.UID, lri.idx))
    				if len(lris) == 1 {
    					// Remove the write lock.
    					delete(l.lockMap, lri.Name)
    					modified = false
    					break
    				}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 12K bytes
    - Viewed (0)
  2. cmd/admin-handlers_test.go

    		resource := fmt.Sprintf("bucket/get-object-%d", i)
    		lri := lockRequesterInfo{
    			Name:   resource,
    			UID:    mustGetUUID(),
    			Owner:  owners[i%len(owners)],
    			Quorum: 2,
    		}
    		lris = append(lris, lri)
    		locksHeld[resource] = append(locksHeld[resource], lri)
    		// concurrent read lock, same resource different uid
    		lri.UID = mustGetUUID()
    		lris = append(lris, lri)
    		locksHeld[resource] = append(locksHeld[resource], lri)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (1)
  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)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  4. src/main/resources/fess_message_fr.properties

    errors.invalid_query_sort_value = Le tri spécifié {0} n'est pas valide.
    errors.invalid_query_unsupported_sort_field = Le tri spécifié {0} n'est pas pris en charge.
    errors.invalid_query_unsupported_sort_order = L'ordre de tri spécifié {0} n'est pas pris en charge.
    errors.invalid_query_cannot_process=Impossible de traiter la requête spécifiée.
    errors.crud_invalid_mode = Le mode est incorrect. (pas {0}, mais {1})
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Jul 05 02:36:47 UTC 2025
    - 13.1K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/admin/fileconfig/CreateForm.java

        public String name;
    
        /** The description of the file configuration (maximum 1000 characters). */
        @Size(max = 1000)
        public String description;
    
        /** The file paths to crawl (required, must be valid file URIs). */
        @Required
        @UriType(protocolType = ProtocolType.FILE)
        @CustomSize(maxKey = "form.admin.max.input.size")
        public String paths;
    
        /** The paths to include during crawling (pattern-based). */
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  6. cmd/fmt-gen.go

      filesystem separated by space. You may also use a '...' convention
      to abbreviate the directory arguments. Remote directories in a
      distributed setup are encoded as HTTP(s) URIs.
    {{if .VisibleFlags}}
    FLAGS:
      {{range .VisibleFlags}}{{.}}
      {{end}}{{end}}
    EXAMPLES:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  7. cmd/site-replication.go

    			if err != nil {
    				return err
    			}
    			sris[depIdx[globalDeploymentID()]] = srInfo
    			return nil
    		},
    		func(deploymentID string, p madmin.PeerInfo) error {
    			admClient, err := c.getAdminClient(ctx, deploymentID)
    			if err != nil {
    				switch err.(type) {
    				case RemoteTargetConnectionErr:
    					sris[depIdx[deploymentID]] = madmin.SRInfo{}
    					return nil
    				default:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 184.8K bytes
    - Viewed (1)
  8. 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,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.3K bytes
    - Viewed (0)
  9. docs/distributed/DESIGN.md

      filesystem separated by space. You may also use a '...' convention
      to abbreviate the directory arguments. Remote directories in a
      distributed setup are encoded as HTTP(s) URIs.
    ```
    
    ## Common usage
    
    Standalone erasure coded configuration with 4 sets with 16 drives each.
    
    ```
    minio server dir{1...64}
    ```
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Feb 26 09:25:50 UTC 2025
    - 8K bytes
    - Viewed (2)
  10. 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 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 99.7K bytes
    - Viewed (0)
Back to top