Skip to content
This repository was archived by the owner on Jan 28, 2025. It is now read-only.

Commit 5f38d15

Browse files
committed
fixing scratch buffer index
1 parent 02c2a46 commit 5f38d15

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

msccl/language/mscclpp/instruction_dag.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -487,11 +487,7 @@ def is_scratch(buffer):
487487
return buffer != Buffer.input and buffer != Buffer.output
488488

489489
def get_new_index(rank, buffer, index, size, i):
490-
# Scratch buffers always use batched
491-
if is_scratch(buffer):
492-
buf_instance_len = self.buffers[rank][buffer].instance_size()
493-
return buf_instance_len * i + index
494-
elif replication_policy == ReplicationPolicy.interleaved:
490+
if replication_policy == ReplicationPolicy.interleaved:
495491
return index * instances + i * size
496492
return len(self.buffers[rank][buffer]) * i + index
497493

0 commit comments

Comments
 (0)