Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 9,237 for ReserveN (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top