removing extra stream and destroying created ones

This commit is contained in:
Saeed Maleki
2023-04-02 02:07:41 +00:00
parent 4c6616e7b9
commit 1731911d00
2 changed files with 4 additions and 1 deletions

View File

@@ -163,6 +163,10 @@ mscclppResult_t mscclppCommDestroy(mscclppComm_t comm)
MSCCLPPCHECK(mscclppCudaHostFree(proxyState->triggerFifo));
MSCCLPPCHECK(mscclppCudaFree(proxyState->fifoHead));
MSCCLPPCHECK(mscclppCudaFree(proxyState->fifoTailDev));
if (proxyState->p2pStream)
CUDACHECK(cudaStreamDestroy(proxyState->p2pStream));
CUDACHECK(cudaStreamDestroy(proxyState->fifoStream));
free(proxyState);
}
}

View File

@@ -39,7 +39,6 @@ struct proxyArgs
{
struct mscclppComm* comm;
struct mscclppProxyState* proxyState;
cudaStream_t stream;
};
static void readTrigger(mscclppTrigger* dst, mscclppTrigger* src)