- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 9,237 for ReserveN (0.16 sec)
-
pkg/controlplane/controller/legacytokentracking/controller.go
func (c *Controller) syncConfigMap() error { obj, exists, err := c.configMapCache.GetByKey(queueKey) if err != nil { return err } now := c.clock.Now() if !exists { r := c.creationRatelimiter.ReserveN(now, 1) if delay := r.DelayFrom(now); delay > 0 { c.queue.AddAfter(queueKey, delay) r.CancelAt(now) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
src/runtime/tracebuf.go
if v < 0x80 { pos += i + 1 arr[i] = byte(v) break } arr[i] = 0x80 | byte(v) v >>= 7 } buf.pos = pos } // varintReserve reserves enough space in buf to hold any varint. // // Space reserved this way can be filled in with the varintAt method. func (buf *traceBuf) varintReserve() int { p := buf.pos buf.pos += traceBytesPerNumber return p }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 6.8K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/sparsetree.go
// is the first number not yet assigned or reserved. N should // be larger than zero. For each entry and exit number, the // values one larger and smaller are reserved to indicate // "strictly above" and "strictly below". numberBlock returns // the smallest number not yet assigned or reserved (i.e., the // exit number of the last block visited, plus two, because // last.exit+1 is a reserved value.) // // examples: //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 18 17:59:44 UTC 2022 - 8.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/examples/stateful/stateful.go
func (mp *MultipointExample) Name() string { return Name } // Reserve is the function invoked by the framework at "reserve" extension // point. In this trivial example, the Reserve method allocates an array of // strings. func (mp *MultipointExample) Reserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status { // Reserve is not called concurrently, and so we don't need to lock.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 03:43:17 UTC 2023 - 3.3K bytes - Viewed (0) -
tensorflow/cc/gradients/functional_grad.cc
(*f.mutable_attr())[attr.first] = attr.second; } std::vector<Output> func_inputs; std::vector<DataType> input_dtypes; const int num_inputs = op.num_inputs(); func_inputs.reserve(num_inputs + grad_inputs.size()); input_dtypes.reserve(num_inputs); for (int i = 0; i < num_inputs; i++) { func_inputs.push_back(op.input(i)); input_dtypes.push_back(op.input_type(i)); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Oct 15 20:09:06 UTC 2021 - 2.1K bytes - Viewed (0) -
src/go/internal/gccgoimporter/parser.go
} if p.typeList[i] == reserved { p.errorf("internal error: %d already reserved in parseSavedType", i) } if p.typeList[i] == nil { p.reserve(i) p.parseTypeSpec(pkg, append(nlist, i)) } if p.typeList[i] == nil || p.typeList[i] == reserved { p.errorf("internal error: parseSavedType(%d,%v) reserved/nil", i, nlist) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 02 23:14:07 UTC 2024 - 31.2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/WorkerLeaseRegistry.java
*/ WorkerLease getCurrentWorkerLease(); /** * Creates a new {@link ResourceLock} that can be used to reserve a worker lease. Note that this does not actually reserve a lease, * it simply creates a {@link ResourceLock} representing the worker lease. The worker lease can be reserved only when
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2K bytes - Viewed (0) -
src/cmd/internal/objabi/util.go
// Copyright 2015 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package objabi import ( "fmt" "strings" "internal/buildcfg" ) const ( ElfRelocOffset = 256 MachoRelocOffset = 2048 // reserve enough space for ELF relocations GlobalDictPrefix = ".dict" // prefix for names of global dictionaries )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 16 12:40:45 UTC 2022 - 961 bytes - Viewed (0) -
pkg/registry/core/service/allocator/bitmap.go
} if r.allocated.Bit(offset) == 1 { return false, nil } r.allocated = r.allocated.SetBit(r.allocated, offset, 1) r.count++ return true, nil } // AllocateNext reserves one of the items from the pool. // (0, false, nil) may be returned if there are no items left. func (r *AllocationBitmap) AllocateNext() (int, bool, error) { r.lock.Lock() defer r.lock.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 25 20:32:40 UTC 2023 - 7.6K bytes - Viewed (0) -
src/runtime/mem_bsd.go
mmap(v, n, _PROT_NONE, _MAP_ANON|_MAP_PRIVATE|_MAP_FIXED, -1, 0) } // Indicates not to reserve swap space for the mapping. const _sunosMAP_NORESERVE = 0x40 func sysReserveOS(v unsafe.Pointer, n uintptr) unsafe.Pointer { flags := int32(_MAP_ANON | _MAP_PRIVATE) if GOOS == "solaris" || GOOS == "illumos" { // Be explicit that we don't want to reserve swap space // for PROT_NONE anonymous mappings. This avoids an issue
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 22 19:05:10 UTC 2023 - 2.2K bytes - Viewed (0)