Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Cur (0.05 sec)

  1. src/cmd/vendor/golang.org/x/sync/semaphore/semaphore.go

    func (s *Weighted) TryAcquire(n int64) bool {
    	s.mu.Lock()
    	success := s.size-s.cur >= n && s.waiters.Len() == 0
    	if success {
    		s.cur += n
    	}
    	s.mu.Unlock()
    	return success
    }
    
    // Release releases the semaphore with a weight of n.
    func (s *Weighted) Release(n int64) {
    	s.mu.Lock()
    	s.cur -= n
    	if s.cur < 0 {
    		s.mu.Unlock()
    		panic("semaphore: released more than held")
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 03 02:38:00 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  2. src/syscall/rlimit.go

    // which Go of course has no choice but to respect.
    func init() {
    	var lim Rlimit
    	if err := Getrlimit(RLIMIT_NOFILE, &lim); err == nil && lim.Cur != lim.Max {
    		origRlimitNofile.Store(&lim)
    		nlim := lim
    		nlim.Cur = nlim.Max
    		adjustFileLimit(&nlim)
    		setrlimit(RLIMIT_NOFILE, &nlim)
    	}
    }
    
    func Setrlimit(resource int, rlim *Rlimit) error {
    	if resource == RLIMIT_NOFILE {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 20:13:57 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  3. maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/DefaultLifecycleBindingsInjector.java

            }
        }
    
        private void addPlugin(Map<Plugin, Plugin> plugins, Plugin plugin) {
            Plugin cur = plugins.putIfAbsent(plugin, plugin);
            if (cur != null) {
                Map<String, PluginExecution> execs = new LinkedHashMap<>();
                cur.getExecutions().forEach(e -> execs.put(e.getId(), e));
                plugin.getExecutions().forEach(e -> {
                    int i = 0;
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Fri Apr 12 10:50:18 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  4. src/expvar/expvar.go

    }
    
    // Add adds delta to v.
    func (v *Float) Add(delta float64) {
    	for {
    		cur := v.f.Load()
    		curVal := math.Float64frombits(cur)
    		nxtVal := curVal + delta
    		nxt := math.Float64bits(nxtVal)
    		if v.f.CompareAndSwap(cur, nxt) {
    			return
    		}
    	}
    }
    
    // Set sets v to value.
    func (v *Float) Set(value float64) {
    	v.f.Store(math.Float64bits(value))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 21:32:11 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  5. pkg/controller/clusterroleaggregation/clusterroleaggregation_controller.go

    			},
    		),
    	}
    	c.syncHandler = c.syncClusterRole
    
    	clusterRoleInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			c.enqueue()
    		},
    		UpdateFunc: func(old, cur interface{}) {
    			c.enqueue()
    		},
    		DeleteFunc: func(uncast interface{}) {
    			c.enqueue()
    		},
    	})
    	return c
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8K bytes
    - Viewed (0)
  6. src/cmd/vendor/golang.org/x/sys/unix/ztypes_zos_s390x.go

    	Majflt   int64
    	Nswap    int64
    	Inblock  int64
    	Oublock  int64
    	Msgsnd   int64
    	Msgrcv   int64
    	Nsignals int64
    	Nvcsw    int64
    	Nivcsw   int64
    }
    
    type Rlimit struct {
    	Cur uint64
    	Max uint64
    }
    
    // { int, short, short } in poll.h
    type PollFd struct {
    	Fd      int32
    	Events  int16
    	Revents int16
    }
    
    type Stat_t struct { //Linux Definition
    	Dev     uint64
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 16:12:58 UTC 2024
    - 8.6K bytes
    - Viewed (0)
Back to top