Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for scanStateStarted (0.1 sec)

  1. cmd/metacache.go

    		if m.lastHandout.After(now) {
    			m.lastHandout = now
    		}
    	}
    	if m.status == scanStateStarted && update.status == scanStateSuccess {
    		m.ended = now
    	}
    
    	if m.status == scanStateStarted && update.status != scanStateStarted {
    		m.status = update.status
    	}
    
    	if m.status == scanStateStarted && time.Since(m.lastHandout) > metacacheMaxClientWait {
    		// Drop if client hasn't been seen for 3 minutes.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. cmd/metacache_test.go

    		dataVersion:  metacacheStreamVersion,
    	},
    	4: {
    		id:           "case-5-noupdate",
    		bucket:       "bucket",
    		root:         "folder/prefix",
    		recursive:    false,
    		status:       scanStateStarted,
    		fileNotFound: false,
    		error:        "",
    		started:      metaCacheTestsetTimestamp.Add(-time.Minute),
    		ended:        time.Time{},
    		lastUpdate:   metaCacheTestsetTimestamp.Add(-time.Minute),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 08 18:06:45 UTC 2021
    - 6.8K bytes
    - Viewed (0)
  3. cmd/metacache-manager.go

    	if err != nil {
    		return err
    	}
    	cache := *c
    
    	if cache.status == scanStateNone || cache.fileNotFound {
    		return errFileNotFound
    	}
    	if cache.status == scanStateSuccess || cache.status == scanStateStarted {
    		if time.Since(cache.lastUpdate) > metacacheMaxRunningAge {
    			// We got a stale entry, mark error on handling server.
    			err := fmt.Errorf("timeout: list %s not updated", cache.id)
    			cache.error = err.Error()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
Back to top