ZC Direct API: Rename ncpyTransferMode enum to CkNcpyMode 74/4674/3
authorNitin Bhat <nbhat4@illinois.edu>
Tue, 9 Oct 2018 18:55:18 +0000 (14:55 -0400)
committerEvan Ramos <evan@hpccharm.com>
Tue, 30 Oct 2018 00:21:35 +0000 (19:21 -0500)
Change-Id: I23a40ee1c9afe7407b93e4dfd6a6314b5edb9068

src/ck-core/ckrdma.C
src/ck-core/ckrdma.h

index 3232b8071ee36ee3b0bf910f684bc04f66475cf1..1486a918436cf73a55e298ea323fbadc4b6c3973 100644 (file)
@@ -385,18 +385,18 @@ void CkRdmaDirectAckHandler(void *ack) {
     CmiFree(info);
 }
 
-// Returns ncpyTransferMode::MEMCPY if both the PEs are the same and memcpy can be used
-// Returns ncpyTransferMode::CMA if both the PEs are in the same physical node and CMA can be used
-// Returns ncpyTransferMode::RDMA if RDMA needs to be used
-ncpyTransferMode findTransferMode(int srcPe, int destPe) {
+// Returns CkNcpyMode::MEMCPY if both the PEs are the same and memcpy can be used
+// Returns CkNcpyMode::CMA if both the PEs are in the same physical node and CMA can be used
+// Returns CkNcpyMode::RDMA if RDMA needs to be used
+CkNcpyMode findTransferMode(int srcPe, int destPe) {
   if(CmiNodeOf(srcPe)==CmiNodeOf(destPe))
-    return ncpyTransferMode::MEMCPY;
+    return CkNcpyMode::MEMCPY;
 #if CMK_USE_CMA
   else if(CmiDoesCMAWork() && CmiPeOnSamePhysicalNode(srcPe, destPe))
-    return ncpyTransferMode::CMA;
+    return CkNcpyMode::CMA;
 #endif
   else
-    return ncpyTransferMode::RDMA;
+    return CkNcpyMode::RDMA;
 }
 
 // Get Methods
@@ -475,10 +475,10 @@ void CkNcpyBuffer::get(CkNcpyBuffer &source){
   // Check that this object is local when get is called
   CkAssert(CkNodeOf(pe) == CkMyNode());
 
-  ncpyTransferMode transferMode = findTransferMode(source.pe, pe);
+  CkNcpyMode transferMode = findTransferMode(source.pe, pe);
 
   //Check if it is a within-process sending
-  if(transferMode == ncpyTransferMode::MEMCPY) {
+  if(transferMode == CkNcpyMode::MEMCPY) {
     memcpyGet(source);
 
     //Invoke the source callback
@@ -488,7 +488,7 @@ void CkNcpyBuffer::get(CkNcpyBuffer &source){
     cb.send(sizeof(CkNcpyBuffer), this);
 
 #if CMK_USE_CMA
-  } else if(transferMode == ncpyTransferMode::CMA) {
+  } else if(transferMode == CkNcpyMode::CMA) {
 
     cmaGet(source);
 
@@ -499,7 +499,7 @@ void CkNcpyBuffer::get(CkNcpyBuffer &source){
     cb.send(sizeof(CkNcpyBuffer), this);
 
 #endif
-  } else if (transferMode == ncpyTransferMode::RDMA) {
+  } else if (transferMode == CkNcpyMode::RDMA) {
 
     int outstandingRdmaOps = 1; // used by true-RDMA layers
 
@@ -517,7 +517,7 @@ void CkNcpyBuffer::get(CkNcpyBuffer &source){
     rdmaGet(source);
 
   } else {
-    CkAbort("Invalid ncpyTransferMode");
+    CkAbort("Invalid CkNcpyMode");
   }
 }
 
@@ -596,10 +596,10 @@ void CkNcpyBuffer::put(CkNcpyBuffer &destination){
   // Check that this object is local when put is called
   CkAssert(CkNodeOf(pe) == CkMyNode());
 
-  ncpyTransferMode transferMode = findTransferMode(pe, destination.pe);
+  CkNcpyMode transferMode = findTransferMode(pe, destination.pe);
 
   //Check if it is a within-process sending
-  if(transferMode == ncpyTransferMode::MEMCPY) {
+  if(transferMode == CkNcpyMode::MEMCPY) {
     memcpyPut(destination);
 
     //Invoke the destination callback
@@ -609,7 +609,7 @@ void CkNcpyBuffer::put(CkNcpyBuffer &destination){
     cb.send(sizeof(CkNcpyBuffer), this);
 
 #if CMK_USE_CMA
-  } else if(transferMode == ncpyTransferMode::CMA) {
+  } else if(transferMode == CkNcpyMode::CMA) {
     cmaPut(destination);
 
     //Invoke the destination callback
@@ -619,7 +619,7 @@ void CkNcpyBuffer::put(CkNcpyBuffer &destination){
     cb.send(sizeof(CkNcpyBuffer), this);
 
 #endif
-  } else if (transferMode == ncpyTransferMode::RDMA) {
+  } else if (transferMode == CkNcpyMode::RDMA) {
 
     int outstandingRdmaOps = 1; // used by true-RDMA layers
 
@@ -637,6 +637,6 @@ void CkNcpyBuffer::put(CkNcpyBuffer &destination){
     rdmaPut(destination);
 
   } else {
-    CkAbort("Invalid ncpyTransferMode");
+    CkAbort("Invalid CkNcpyMode");
   }
 }
index 2334135b248ffc01e377b4566dc3ae36b1a9c06a..86778b06686d4868b662e4a66c8b45a9e995fe10 100644 (file)
@@ -242,6 +242,6 @@ class CkNcpyBuffer{
   friend void CkRdmaDirectAckHandler(void *ack);
 };
 
-enum class ncpyTransferMode : char { MEMCPY, CMA, RDMA };
+enum class CkNcpyMode : char { MEMCPY, CMA, RDMA };
 
 #endif