Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for pickers (0.14 sec)

  1. cmd/admin-handlers.go

    	vars := mux.Vars(r)
    
    	var args dsync.LockArgs
    	var lockers []dsync.NetLocker
    	for _, path := range strings.Split(vars["paths"], ",") {
    		if path == "" {
    			continue
    		}
    		args.Resources = append(args.Resources, path)
    	}
    
    	for _, lks := range z.serverPools[0].erasureLockers {
    		lockers = append(lockers, lks...)
    	}
    
    	for _, locker := range lockers {
    		locker.ForceUnlock(ctx, args)
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  2. cmd/metacache-set.go

    			go mc.setErr(err.Error())
    			cancel()
    		}
    	}()
    
    	defer cancel()
    	// Save continuous updates
    	go func() {
    		var err error
    		ticker := time.NewTicker(10 * time.Second)
    		defer ticker.Stop()
    		var exit bool
    		for !exit {
    			select {
    			case <-ticker.C:
    			case <-ctx.Done():
    				exit = true
    			}
    			metaMu.Lock()
    			meta := *mc.meta
    			meta, err = o.updateMetacacheListing(meta, rpc)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  3. cmd/erasure-sets.go

    		}
    	}
    }
    
    func (s *erasureSets) GetLockers(setIndex int) func() ([]dsync.NetLocker, string) {
    	return func() ([]dsync.NetLocker, string) {
    		lockers := make([]dsync.NetLocker, len(s.erasureLockers[setIndex]))
    		copy(lockers, s.erasureLockers[setIndex])
    		return lockers, s.erasureLockOwner
    	}
    }
    
    func (s *erasureSets) GetEndpointStrings(setIndex int) func() []string {
    	return func() []string {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
  4. internal/bucket/lifecycle/lifecycle_test.go

    	}
    
    	event := lc.eval(opts, time.Time{})
    	if event.Action != TransitionAction {
    		t.Fatalf("Expected %v action but got %v", TransitionAction, event.Action)
    	}
    	// The earlier upcoming lifecycle event must be picked, i.e rule with id "Transition-10"
    	if exp := ExpectedExpiryTime(opts.ModTime, 10); exp != event.Due {
    		t.Fatalf("Expected due %v but got %v, ruleID=%v", exp, event.Due, event.RuleID)
    	}
    
    	// DelMarkerExpiration
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 53.2K bytes
    - Viewed (0)
Back to top