- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 68 for allocators_ (0.26 sec)
-
tensorflow/compiler/jit/xla_device.cc
} Status status; if (alloc_attrs.on_host()) { *tensor = parsed; } else { Allocator* allocator; { mutex_lock lock(mu_); allocator = GetAllocatorLocked(alloc_attrs); } Tensor copy(allocator, parsed.dtype(), parsed.shape()); TF_RETURN_IF_ERROR( device_context->CopyCPUTensorToDeviceSync(&parsed, this, ©)); *tensor = copy;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon May 20 21:05:42 UTC 2024 - 24.3K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator.go
// MetaAllocator maintains a Tree with the ServiceCIDRs containing an IP Allocator // on the nodes. Since each allocator doesn't stored the IPAddresses because it reads // them from the informer cache, it is cheap to create and delete IP Allocators. // MetaAllocator forwards the request to any of the internal allocators that has free // addresses. // MetaAllocator implements current allocator interface using // ServiceCIDR and IPAddress API objects.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_launch_util.h
XlaTensorBuffer(const void* ptr, size_t expected_size, size_t actual_size, Allocator* allocator) : TensorBuffer(const_cast<void*>(ptr)), expected_size_(expected_size), actual_size_(actual_size), allocator_(allocator) {} ~XlaTensorBuffer() override { if (data()) { allocator_->DeallocateRaw(data()); } }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 09:53:30 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/registry/core/service/storage/alloc.go
return allocated, err } func (al *Allocators) allocIPs(service *api.Service, toAlloc map[api.IPFamily]string, dryRun bool) (map[api.IPFamily]string, error) { allocated := make(map[api.IPFamily]string) for family, ip := range toAlloc { allocator := al.serviceIPAllocatorsByFamily[family] // should always be there, as we pre validate if dryRun { allocator = allocator.DryRun() } if ip == "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:05 UTC 2023 - 37.3K bytes - Viewed (0) -
pkg/registry/core/rest/storage_core.go
primaryClusterIPAllocator, err = ipallocator.New(&serviceClusterIPRange, func(max int, rangeSpec string, offset int) (allocator.Interface, error) { var mem allocator.Snapshottable mem = allocator.NewAllocationMapWithOffset(max, rangeSpec, offset) // TODO etcdallocator package to return a storage interface via the storageFactory
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:05 UTC 2023 - 19.1K bytes - Viewed (0) -
pkg/registry/core/service/allocator/bitmap_test.go
limitations under the License. */ package allocator import ( "testing" "k8s.io/apimachinery/pkg/util/sets" ) func TestAllocate(t *testing.T) { testCases := []struct { name string allocator func(max int, rangeSpec string, reserved int) *AllocationBitmap max int reserved int }{ { name: "NewAllocationMap", allocator: NewAllocationMapWithOffset, max: 32,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 10 08:56:31 UTC 2022 - 13.3K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repair.go
err := wait.PollImmediate(time.Second, 10*time.Second, func() (bool, error) { for family, allocator := range c.allocatorByFamily { // get snapshot if it is not there if _, ok := snapshotByFamily[family]; !ok { snapshot, err := allocator.Get() if err != nil { return false, err } snapshotByFamily[family] = snapshot } } return true, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 13.8K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator_test.go
allocator, err := r.getAllocator(netutils.ParseIPSloppy("10.0.0.11")) if err != nil { return false, nil } allocator.ipAddressSynced = func() bool { return true } return allocator.ready.Load(), nil }) if err != nil { t.Fatal(err) } // allocate one IP from the new allocator err = r.Allocate(netutils.ParseIPSloppy("10.0.0.11"))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 13.7K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/ipallocator.go
return len(ips) } // for testing, it assumes this is the allocator is unique for the ipFamily func (a *Allocator) Free() int { return int(a.size) - a.Used() } // Destroy func (a *Allocator) Destroy() { } // DryRun func (a *Allocator) DryRun() Interface { return dryRunAllocator{a} } // EnableMetrics func (a *Allocator) EnableMetrics() { registerMetrics()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:04 UTC 2023 - 17K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator_test.go
// Initialize the range allocator. allocator, err := NewCIDRRangeAllocator(tCtx, tc.fakeNodeHandler, fakeNodeInformer, tc.allocatorParams, nodeList) if err != nil { t.Errorf("%v: failed to create CIDRRangeAllocator with error %v", tc.description, err) return } rangeAllocator, ok := allocator.(*rangeAllocator) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 25.2K bytes - Viewed (0)