We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 70d26c2 commit 560d2f8Copy full SHA for 560d2f8
flagcx/core/group.cc
@@ -387,7 +387,8 @@ static flagcxResult_t groupLaunch(struct flagcxAsyncJob *job_) {
387
// Pass the remote address to sender for zero-copy
388
// peerRmtAddr is the remote address itself (cast as uintptr_t*)
389
if (op->args.regBufFlag && peerRmtAddr) {
390
- op->args.p2pRmtAddr = (void *)peerRmtAddr;
+ op->args.p2pRmtAddr =
391
+ (void *)((uintptr_t)peerRmtAddr + regOffset);
392
}
393
} else if (op->connection->transport == TRANSPORT_NET) {
394
op->args.chunkSize = flagcxNetChunkSize;
0 commit comments