a typo in p2p proxy

This commit is contained in:
Saeed Maleki
2023-03-28 08:07:54 +00:00
parent 81b18cd9f9
commit 17e144c774

View File

@@ -118,7 +118,7 @@ void* mscclppProxyServiceP2P(void* _args)
*(volatile uint64_t*)(&fifo[fifoTailCached % MSCCLPP_PROXY_FIFO_SIZE]) = 0;
fifoTailCached++;
if (((fifoTailCached % MSCCLPP_FLUSH_FIFO_COUNTER) == 0) || (trigger.fields.type & mscclppSync))
PROXYCUDACHECK(cudaMemcpyAsync(fifoTailDevPtr, &fifoTail, sizeof(uint64_t), cudaMemcpyHostToDevice, stream));
PROXYCUDACHECK(cudaMemcpyAsync(fifoTailDevPtr, &fifoTailCached, sizeof(uint64_t), cudaMemcpyHostToDevice, stream));
}
*fifoTail = fifoTailCached;