- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for Cur (1.31 sec)
-
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) -
pkg/controller/daemon/update.go
// Create a new history if the current one isn't found cur, err = dsc.snapshot(ctx, ds, currRevision) if err != nil { return nil, nil, err } default: cur, err = dsc.dedupCurHistories(ctx, ds, currentHistories) if err != nil { return nil, nil, err } // Update revision number if necessary if cur.Revision < currRevision { toUpdate := cur.DeepCopy() toUpdate.Revision = currRevision
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 16:53:53 UTC 2024 - 24.4K bytes - Viewed (0) -
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) -
src/runtime/mpallocbits.go
// Final region that might span to next uint64 cur = l } if start == notSetYet { // Made it all the way through without finding a single 1 bit. const n = uint(64 * len(b)) return packPallocSum(n, n, n) } most = max(most, cur) if most >= 64-2 { // There is no way an internal run of zeros could beat max. return packPallocSum(start, most, cur) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 18 15:13:43 UTC 2024 - 12.5K bytes - Viewed (0) -
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) -
src/cmd/vendor/github.com/google/pprof/internal/graph/graph.go
// children to make them each roots of their own trees. if len(cur.In) == 0 { for _, outEdge := range cur.Out { delete(outEdge.Dest.In, cur) } continue } // Get the parent. This works since at this point cur.In must contain only // one element. if len(cur.In) != 1 { panic("Get parent assertion failed. cur.In expected to be of length 1.") } var parent *Node
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 31K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod.go
} } return -1, nil } func (pc *PodCache) labelFilter(old, cur *v1.Pod) bool { // If labels/annotations updated, trigger proxy push labelsChanged := !maps.Equal(old.Labels, cur.Labels) // Annotations are only used in endpoints in one case, so just compare that one relevantAnnotationsChanged := old.Annotations[constants.AmbientRedirection] != cur.Annotations[constants.AmbientRedirection]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0) -
operator/pkg/compare/compare.go
} cur := obj for _, nname := range nodeList { ndata, ok := cur[nname] if !ok || ndata == nil { // target path does not exist return fmt.Errorf("targetPath '%v' does not exist in obj: '%v' is missing", targetPath, nname) } switch nnode := ndata.(type) { case map[string]any: cur = nnode default: // target path type does not match
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 15 01:29:35 UTC 2024 - 13.3K bytes - Viewed (0) -
src/cmd/vendor/rsc.io/markdown/inline.go
func longestSequence(s string, b byte) int { max := 0 cur := 0 for i := range s { if s[i] == b { cur++ } else { if cur > max { max = cur } cur = 0 } } if cur > max { max = cur } return max } func (x *Code) PrintText(buf *bytes.Buffer) { htmlEscaper.WriteString(buf, x.Text) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 21.9K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection_test.go
}) } } func alreadyHit(cur instance, chain []instance) bool { for _, cc := range chain { if cur == cc { return true } } return false } func checkCycles(t *testing.T, start instance, cases []instance, chain []instance) { if alreadyHit(start, chain) { t.Fatalf("cycle on leader election: cur %v, chain %v", start, chain) } for _, nextHop := range cases {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 11.4K bytes - Viewed (0)