- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 182 for Deallocator (0.42 sec)
-
pkg/registry/core/service/ipallocator/bitmap_test.go
} func TestClusterIPMetrics(t *testing.T) { clearMetrics() // create IPv4 allocator cidrIPv4 := "10.0.0.0/24" _, clusterCIDRv4, _ := netutils.ParseCIDRSloppy(cidrIPv4) a, err := NewInMemory(clusterCIDRv4) if err != nil { t.Fatalf("unexpected error creating CidrSet: %v", err) } a.EnableMetrics() // create IPv6 allocator cidrIPv6 := "2001:db8::/112" _, clusterCIDRv6, _ := netutils.ParseCIDRSloppy(cidrIPv6)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 25 20:32:40 UTC 2023 - 21.1K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/controller/repair.go
} // If not yet initialized. if snapshot.Range == "" { snapshot.Range = c.portRange.String() } // Create an allocator because it is easy to use. stored, err := portallocator.NewFromSnapshot(snapshot) if err != nil { return fmt.Errorf("unable to rebuild allocator from snapshot: %v", err) } // We explicitly send no resource version, since the resource version
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 10.4K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_launch_util.cc
const std::map<int, const Tensor*>& resource_vars) { se::Stream* stream = ctx->op_device_context() ? ctx->op_device_context()->stream() : nullptr; Allocator* allocator = ctx->device()->GetAllocator({}); // Computation output should always be a tuple. VLOG(2) << "Result tuple shape: " << output.on_host_shape().DebugString(); VLOG(2) << "Result tuple shape (on device): "
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 16 00:36:08 UTC 2024 - 40.4K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/cidr_allocator.go
"k8s.io/klog/v2" ) // CIDRAllocatorType is the type of the allocator to use. type CIDRAllocatorType string const ( // RangeAllocatorType is the allocator that uses an internal CIDR // range allocator to do node CIDR range allocations. RangeAllocatorType CIDRAllocatorType = "RangeAllocator" // CloudAllocatorType is the allocator that uses cloud platform // support to do node CIDR range allocations.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 13:03:57 UTC 2024 - 5.3K bytes - Viewed (0) -
tensorflow/c/experimental/next_pluggable_device/tensor_pjrt_buffer_util_test.cc
return new PJRT_Buffer{std::move(*buffer), c_api_client->pjrt_c_client()}; } TEST(TensorPjRtBufferUtilTest, GetPjRtCBufferFromTensorNoBuffer) { auto allocator = std::make_unique<AsyncValueAllocator>(); tensorflow::Tensor tensor(allocator.get(), DT_FLOAT, {1}); EXPECT_THAT( GetPjRtCBufferFromTensor(&tensor), StatusIs(error::INTERNAL, HasSubstr(absl::StrCat(
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Apr 01 16:29:40 UTC 2024 - 7.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/tests/ir/fallback_opt.mlir
func.func @custom_allocator(%ch: !tfrt.chain, %arg: !tfrt_fallback.tf_tensor, %allocator: !tfrt_fallback.tf_allocator) -> (!tfrt.chain, !tfrt_fallback.tf_tensor) { // CHECK: tfrt_fallback_async.executeop.allocator(%{{.*}}) key(200) cost(100) device("cpu") "tf.Cast"(%{{.*}}) {Truncate = false, T = f32} : 1 %0 = tfrt_fallback_async.executeop.allocator(%allocator) key(200) cost(100) device("cpu") "tf.Cast"(%arg) {Truncate = false, T = f32} : 1
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Mar 25 11:03:04 UTC 2022 - 4.8K bytes - Viewed (0) -
pkg/registry/core/service/allocator/storage/storage.go
destroyFn func() } // Etcd implements allocator.Interface and rangeallocation.RangeRegistry var _ allocator.Interface = &Etcd{} var _ rangeallocation.RangeRegistry = &Etcd{} // NewEtcd returns an allocator that is backed by Etcd and can manage // persisting the snapshot state of allocation after each allocation is made.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 6.5K 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) -
pkg/registry/core/service/portallocator/storage/storage_test.go
"k8s.io/kubernetes/pkg/registry/core/service/allocator" allocatorstore "k8s.io/kubernetes/pkg/registry/core/service/allocator/storage" "k8s.io/kubernetes/pkg/registry/core/service/portallocator" "k8s.io/kubernetes/pkg/registry/registrytest" ) const ( basePortRange = 30000 sizePortRange = 2768 )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 07:15:02 UTC 2024 - 8.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/allocator_test.go
newBuff := target.Allocate(uint64(i)) if cap(newBuff) < initialSize { t.Fatalf("allocator is now allowed to shrink memory") } if len(newBuff) != i { t.Fatalf("unexpected length of the buffer, expected: %v, got: %v", i, len(newBuff)) } } } func TestAllocatorZero(t *testing.T) { target := &Allocator{} initialSize := 1000000 // 1MB buff := target.Allocate(uint64(initialSize))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 23 13:38:29 UTC 2022 - 2.4K bytes - Viewed (0)