Optimize function that loads pointers on GPU#3001
Conversation
Avoid constructing temporary std::vector when converting NVTEBasicTensor to SimpleTensor. Avoid string operations in multi-tensor swizzle. Avoid temporary std::vector when checking scale tensors. Signed-off-by: Tim Moon <tmoon@nvidia.com>
Tensor::shape() returns a std::vector<size_t> by value, allocating on the heap. flat_first_dim and flat_last_dim only need to walk the dims, so the allocation was pure overhead in hot paths. Introduce Tensor::compute_shape() returning an NVTEShape (fixed inline buffer, no heap) as the single source of truth for the format-dependent shape logic. shape() is now a thin std::vector wrapper around it for callers that want a vector; flat_first_dim and flat_last_dim call compute_shape() directly. Signed-off-by: Tim Moon <tmoon@nvidia.com> Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com> Signed-off-by: Tim Moon <tmoon@nvidia.com>
flat_first_dim() and flat_last_dim() each called compute_shape() independently. flat_2d_dims() computes both in a single pass; the scalar helpers now delegate to it. Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> Signed-off-by: Tim Moon <tmoon@nvidia.com>
Replace all paired flat_first_dim() + flat_last_dim() calls on the same tensor with a single flat_2d_dims() call. Saves one compute_shape() per tensor in CheckScaleTensorShape, the multi-tensor swizzle loop, and various cast/GEMM dispatch paths. Also adds reserve() to the local vectors in nvte_multi_tensor_swizzle_scaling_factors to avoid reallocation. Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> Signed-off-by: Tim Moon <tmoon@nvidia.com>
Signed-off-by: Tim Moon <tmoon@nvidia.com>
Replace the inline swizzle implementation with a call to multi_tensor_swizzle_scales_for_gemm, which has identical logic (16B-aligned contiguous output buffer, TensorWrapper construction, nvte_multi_tensor_swizzle_scaling_factors kernel). Swizzled pointers are read back from the updated TensorWrappers after the call. Add reserve() to vectors in multi_tensor_swizzle_scales_for_gemm_impl now that this function is on the hot path for get_device_pointer_for_data_and_scales. Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> Signed-off-by: Tim Moon <tmoon@nvidia.com>
Signed-off-by: Tim Moon <tmoon@nvidia.com>
Signed-off-by: Tim Moon <tmoon@nvidia.com>
Greptile SummaryThis PR refactors the GPU pointer-loading path for grouped MLP kernels, replacing
Confidence Score: 5/5Safe to merge; all refactored paths produce the same outputs as before with no data-corruption or functional regression identified. The nvte_load_value_on_device kernel correctly handles aligned vector writes and byte-level tail writes with only one thread writing tail bytes. The Shape class's only resize call site explicitly sets the element after resizing, so no uninitialized reads occur today. The dropped is_cuda() guard and Shape::resize() zero-init difference are style-level observations that do not affect any currently exercised code path. No files require special attention; the most structurally novel file is transformer_engine/common/util/utils.cu with its payload-via-kernel-args design, which is straightforward once the CUDA Graph motivation is understood. Important Files Changed
Sequence DiagramsequenceDiagram
participant PY as Python caller
participant LD as load_data_ptrs_on_device
participant TR as transform_and_load_data_ptrs_on_device
participant NV as nvte_load_value_on_device
participant SW as nvte_multi_tensor_swizzle_scaling_factors
participant GPU as Device memory
PY->>LD: tensors, device
LD->>LD: collect data_ptr() to ptrs_host[]
LD->>NV: "ptrs_host, ptrs_device, N*8 bytes"
NV->>GPU: kernel (payload in args) writes pointers
LD-->>PY: ptrs_device tensor
PY->>TR: transform_type, scale tensors, device
TR->>TR: allocate swizzled_scales buffer (uniform stride)
TR->>SW: input/output TensorWrapper pairs
SW->>GPU: swizzle kernel writes swizzled scales
TR->>TR: collect swizzled_scales_dptr offsets to ptrs_host[]
TR->>NV: "ptrs_host, ptrs_device, N*8 bytes"
NV->>GPU: kernel (payload in args) writes pointers
TR-->>PY: (ptrs_device, swizzled_scales keepalive)
Reviews (5): Last reviewed commit: "Make Shape conversion constructors expli..." | Re-trigger Greptile |
| dtype(static_cast<DType>(tensor.dtype)) {} | ||
|
|
||
| SimpleTensor() : SimpleTensor(nullptr, std::vector<size_t>{0}, DType::kFloat32) {} | ||
| SimpleTensor &operator=(const NVTEBasicTensor &tensor) { |
There was a problem hiding this comment.
Without this assignment operator, assigning from a NVTEBasicTensor triggers a heap allocator in the NVTEBasicTensor constructor. We do this assignment frequently within nvte_set_tensor_param_v2.
| NVTE_CHECK(data_tensors[0].is_cuda(), "data_tensors must be on CUDA."); | ||
| const auto device = data_tensors[0].device(); | ||
| auto stream = at::cuda::getCurrentCUDAStream(); | ||
| std::tuple<at::Tensor, std::optional<at::Tensor>> transform_and_load_data_ptrs_on_device( |
There was a problem hiding this comment.
I'm not committed to this name. I based it on std::transform. I suppose "map" would be more Python-focused, but that sounds worse.
- Use size_t in kernel tail loop (was int64_t)
- Zero-initialize Payload before memcpy (Payload{})
- Rename Payload members to kMaxBytes/kVectorSize/kMaxVectors (linter)
- Consistent at::empty shape pattern: {static_cast<int64_t>(N)}
- Drop intermediate swizzled_scales_bytes variable
- Add comment explaining uniform-stride assumption in
transform_and_load_data_ptrs_on_device
- Rename sfb_buffer -> _sfb_buffer (keepalive, not directly used)
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
Signed-off-by: Tim Moon <tmoon@nvidia.com>
Signed-off-by: Tim Moon <tmoon@nvidia.com>
7946e5d to
48cc585
Compare
|
/te-ci |
|
Seems a lot of those changes would basically not be needed if we did not use the std::vector in Tensor/SimpleTensor and just used NVTEShape everywhere - this would effectively make SimpleTensor and NVTEBasicTensor the same thing (we could even do the constructor in the public header, just behing the |
vthumbe1503
left a comment
There was a problem hiding this comment.
Thanks for cleaning up the APIs. Looks much nicer now. CPU overheads being caused by heap allocations of shape, makes me wonder whether we should revive this PR to standardize on NVTEShape yo avoid back and forth between vector<size_t> and NVTE_Shape
| fc2_sfb_ptrs, _fc2_sfb_buffer = tex.transform_and_load_data_ptrs_on_device( | ||
| "uniform_mxfp8_columnwise_swizzle", | ||
| [w._columnwise_scale_inv for w in grouped_fc2_weight], | ||
| swizzle=True, | ||
| rowwise=False, | ||
| data_dtype=grouped_fc2_weight[0]._fp8_dtype, | ||
| device, |
There was a problem hiding this comment.
The other optimization can be to load both fc1 and fc2 data and scale inv togegther at the start of backward. I am hoping it wouldnt make the code ugly.
| SimpleTensor() : SimpleTensor(nullptr, std::vector<size_t>{0}, DType::kFloat32) {} | ||
| SimpleTensor &operator=(const NVTEBasicTensor &tensor) { | ||
| dptr = tensor.data_ptr; | ||
| shape.assign(tensor.shape.data, tensor.shape.data + tensor.shape.ndim); |
There was a problem hiding this comment.
So when you say heap allocations being done redundantly again and again. Do you mean the vector to NVTEShape conversions?
I rememember this problem being observed even with a basic te linear profiling. And I hadnt gotten this PR merged.
#2514
which essentially standadizes to use NVTEShape everywhere instead of using vector at all to avoid bouncing back and forth between the two allocations. Maybe it might be worth to revive the PR?
There was a problem hiding this comment.
Previously, assigning an NVTEBasicTensor to a SimpleTensor would trigger the constructor and then the move operator. This would allocate an std::vector, move it, and deallocate the old std::vector.
One other approach I was thinking about was implementing a Shape class that wraps around NVTEShape and has a similar API as std::vector. That way we can keep the nice ergonomics, while avoiding heap allocations.
There was a problem hiding this comment.
I had tried your other approach in the 2514 PR above, but eventually had removed it due to some complications. I have refer back to my notes on why it didnt work out for me.
But here is the commit that reverted it
b599776
I had called it NVTEShapeWrapper and implemented all the vector based APIs.
There was a problem hiding this comment.
One complication I do remember was to change a lot of attention interfaces to have NVTEShapeWrapper instead of using vector.
There was a problem hiding this comment.
I've found that adding a cast operator to std::vector helps reduce the number of places we need to change the interfaces.
Provides a std::vector<size_t>-like interface around NVTEShape without heap allocation, used as the return type of Tensor::shape() in place of the previous std::vector. Disambiguate cute::Shape from transformer_engine::Shape in the hadamard_transform kernels. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com> Signed-off-by: Tim Moon <tmoon@nvidia.com>
Store shape in Shape class rather than std::vector. Signed-off-by: Tim Moon <tmoon@nvidia.com>
for more information, see https://pre-commit.ci
Signed-off-by: Tim Moon <tmoon@nvidia.com>
|
/te-ci |
Description
tex.get_device_pointer_for_data_and_scaleshas two problems:ints. But actually it takes the buffers from multiple MXFP8/NVFP4 tensors (all assumed to have the same shape), swizzles the scaling factors, and transfers the pointers to a GPU array in a CUDA Graph-friendly way.This PR makes several optimizations to reduce CPU overhead, mostly to reduce unnecessary heap allocations. I've also attempted to make the functionality more general and logical:
nvte_load_value_on_device: A general function for copying a small amount of data to GPU in a CUDA Graph-friendly way. Unlikenvte_convert_pointers_to_tensor, it makes no assumptions that the data is a list of pointers.tex.load_data_ptrs_on_device: Takes a list of tensors and puts their data pointers into a GPU buffer.tex.transform_and_load_data_ptrs_on_device: Performs a user-specified transform on a list of tensors and puts the resulting data pointers into a GPU buffer. Currently it only supports scale swizzles on uniformly shaped tensors, but the transform names help make the contracts explicit.With these changes, per-call CPU runtime has dropped from 72 us to 41 us on a GB200 node.
This is progress toward #2897.
Type of change
Changes
NVTEBasicTensortotransformer_engine::SimpleTensortransformer_engine::Tensorshape functionstransformer_engine::Tensor::flat_2d_dimsto compute first and last dims simultaneouslynvte_load_value_on_devicetex.load_data_ptrs_on_deviceandtex.transform_and_load_data_ptrs_on_deviceChecklist: