Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 98 for Allocate (0.37 sec)

  1. pkg/registry/core/service/portallocator/storage/storage_test.go

    		t.Fatalf("unexpected error: %v", err)
    	}
    
    	// Allocate a port inside the valid port range
    	if err := storage.Allocate(30100); err != nil {
    		t.Fatal(err)
    	}
    
    	// Try to allocate the same port in the local bitmap
    	// The local bitmap stores the offset of the port
    	// offset = port - base (30100 - 30000 = 100)
    	ok, err := backing.Allocate(100)
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 07:15:02 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  2. src/runtime/traceregion.go

    		}
    
    		// Add the existing block to the full list.
    		block.next = a.full
    		a.full = block
    	}
    
    	// Allocate a new block.
    	block = (*traceRegionAllocBlock)(sysAlloc(unsafe.Sizeof(traceRegionAllocBlock{}), &memstats.other_sys))
    	if block == nil {
    		throw("traceRegion: out of memory")
    	}
    
    	// Allocate space for our current request, so we always make
    	// progress.
    	block.off.Store(n)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:47:01 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  3. pkg/registry/core/service/portallocator/allocator.go

    		// include valid port range in error
    		validPorts := r.portRange.String()
    		return &ErrNotInRange{validPorts}
    	}
    
    	allocated, err := r.alloc.Allocate(offset)
    	if err != nil {
    		// update metrics
    		r.metrics.incrementAllocationErrors("static")
    		return err
    	}
    	if !allocated {
    		// update metrics
    		r.metrics.incrementAllocationErrors("static")
    		return ErrAllocated
    	}
    
    	// update metrics
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 07:15:02 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  4. test/fixedbugs/issue67255.go

    	for i := 10; i < 200; i++ {
    		// The objects we're allocating here are pointer-ful. Some will
    		// max out their size class, which are the ones we want.
    		// We also allocate from small to large, so that the object which
    		// maxes out its size class is the last one allocated in that class.
    		// This allocation pattern leaves the next object in the class
    		// unallocated, which we need to reproduce the bug.
    		objs = append(objs, make([]*byte, i))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:09:06 UTC 2024
    - 922 bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/list_work_estimator.go

    	numStored, err := e.countGetterFn(key(requestInfo))
    	switch {
    	case err == ObjectCountStaleErr:
    		// object count going stale is indicative of degradation, so we should
    		// be conservative here and allocate maximum seats to this list request.
    		// NOTE: if a CRD is removed, its count will go stale first and then the
    		// pruner will eventually remove the CRD from the cache.
    		return WorkEstimate{InitialSeats: maxSeats}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 7K bytes
    - Viewed (0)
  6. src/runtime/msize.go

    // Malloc small size classes.
    //
    // See malloc.go for overview.
    // See also mksizeclasses.go for how we decide what size classes to use.
    
    package runtime
    
    // Returns size of the memory block that mallocgc will allocate if you ask for the size,
    // minus any inline space for metadata.
    func roundupsize(size uintptr, noscan bool) (reqSize uintptr) {
    	reqSize = size
    	if reqSize <= maxSmallSize-mallocHeaderSize {
    		// Small object.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 09 04:07:57 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  7. pkg/util/tail/tail.go

    	blockSize = 1024
    )
    
    // ReadAtMost reads at most max bytes from the end of the file identified by path or
    // returns an error. It returns true if the file was longer than max. It will
    // allocate up to max bytes.
    func ReadAtMost(path string, max int64) ([]byte, bool, error) {
    	f, err := os.Open(path)
    	if err != nil {
    		return nil, false, err
    	}
    	defer f.Close()
    	fi, err := f.Stat()
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 13:13:22 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  8. src/runtime/mklockrank.go

    traceBuf < traceStrings;
    
    # Malloc
    allg,
      allocmR,
      allp, # procresize
      execR, # May grow stack
      execW, # May allocate after BeforeFork
      hchan,
      notifyList,
      reflectOffs,
      timer,
      traceStrings,
      userArenaState
    # Above MALLOC are things that can allocate memory.
    < MALLOC
    # Below MALLOC is the malloc implementation.
    < fin,
      spanSetSpine,
      mspanSpecial,
      traceTypeTab,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:47:01 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  9. pilot/pkg/serviceregistry/serviceentry/store_test.go

    	}
    	if !store.allocateNeeded {
    		t.Errorf("expected allocate needed")
    	}
    	store.allocateNeeded = false
    	store.deleteServices(httpDNSRR.NamespacedName())
    	got = store.getAllServices()
    	if len(got) != 0 {
    		t.Errorf("got unexpected services %v", got)
    	}
    	if store.allocateNeeded {
    		t.Errorf("expected no allocate needed")
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  10. tensorflow/c/tf_buffer.cc

      }
      const size_t proto_size = in.ByteSizeLong();
      void* buf = port::Malloc(proto_size);
      if (buf == nullptr) {
        return tensorflow::errors::ResourceExhausted(
            "Failed to allocate memory to serialize message of type '",
            in.GetTypeName(), "' and size ", proto_size);
      }
      if (!in.SerializeWithCachedSizesToArray(static_cast<uint8_t*>(buf))) {
        port::Free(buf);
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Sun Apr 14 21:57:32 UTC 2024
    - 3K bytes
    - Viewed (0)
Back to top