Home Research Papers Posters Manuals Talks Download People Help Internal

util/cmirdmautils.C

Go to the documentation of this file.

#include "cmirdmautils.h"
#include "converse.h" // for CmiAbort usage to avoid undeclared warning

#include <stdio.h>
#include <string.h>

int getNcpyOpInfoTotalSize(
  int srcLayerSize,
  int srcAckSize,
  int destLayerSize,
  int destAckSize) {
  return sizeof(NcpyOperationInfo) + srcLayerSize + destLayerSize + srcAckSize + destAckSize;
}

void setNcpyOpInfo(
    const void *srcPtr,
    char *srcLayerInfo,
    int srcLayerSize,
    char *srcAck,
    int srcAckSize,
    int srcSize,
    unsigned short int srcRegMode,
    unsigned short int srcDeregMode,
    unsigned short int isSrcRegistered,
    int srcPe,
    const void *srcRef,
    const void *destPtr,
    char *destLayerInfo,
    int destLayerSize,
    char *destAck,
    int destAckSize,
    int destSize,
    unsigned short int destRegMode,
    unsigned short int destDeregMode,
    unsigned short int isDestRegistered,
    int destPe,
    const void *destRef,
    NcpyOperationInfo *ncpyOpInfo) {

  char *base = (char *)ncpyOpInfo + sizeof(NcpyOperationInfo);

  ncpyOpInfo->srcLayerInfo = NULL;
  ncpyOpInfo->destLayerInfo = NULL;
  ncpyOpInfo->srcAck = NULL;
  ncpyOpInfo->destAck = NULL;

  // memcpy srcLayerInfo
  if(srcLayerInfo != NULL && srcLayerSize != 0) {
    memcpy(base, srcLayerInfo, srcLayerSize);
    ncpyOpInfo->srcLayerInfo = base;
    base = base + srcLayerSize;
  }

  // memcpy srcAckInfo
  if(srcAck != NULL && srcAckSize != 0) {
    memcpy(base, srcAck, srcAckSize);
    ncpyOpInfo->srcAck = base;
    base = base + srcAckSize;
  }

  // memcpy destLayerInfo
  if(srcLayerInfo != NULL && destLayerSize != 0) {
    memcpy(base, destLayerInfo, destLayerSize);
    ncpyOpInfo->destLayerInfo = base;
    base = base + destLayerSize;
  }

  // memcpy destAck Info
  if(destAck != NULL && destAckSize != 0) {
    memcpy(base, destAck, destAckSize);
    ncpyOpInfo->destAck = base;
  }

  ncpyOpInfo->srcPtr = srcPtr;
  ncpyOpInfo->srcPe = srcPe;
  ncpyOpInfo->srcRef = srcRef;
  ncpyOpInfo->srcLayerSize = srcLayerSize;
  ncpyOpInfo->srcAckSize = srcAckSize;
  ncpyOpInfo->srcSize = srcSize;
  ncpyOpInfo->srcRegMode = srcRegMode;
  ncpyOpInfo->srcDeregMode = srcDeregMode;
  ncpyOpInfo->isSrcRegistered = isSrcRegistered;

  ncpyOpInfo->destPtr = destPtr;
  ncpyOpInfo->destPe = destPe;
  ncpyOpInfo->destRef = destRef;
  ncpyOpInfo->destLayerSize = destLayerSize;
  ncpyOpInfo->destAckSize = destAckSize;
  ncpyOpInfo->destSize = destSize;
  ncpyOpInfo->destRegMode = destRegMode;
  ncpyOpInfo->destDeregMode = destDeregMode;
  ncpyOpInfo->isDestRegistered = isDestRegistered;

  ncpyOpInfo->opMode  = CMK_DIRECT_API; // default operation mode is CMK_DIRECT_API
  ncpyOpInfo->ackMode = CMK_SRC_DEST_ACK; // default ack mode is CMK_SRC_DEST_ACK
  ncpyOpInfo->freeMe  = CMK_FREE_NCPYOPINFO; // default ack mode is CMK_FREE_NCPYOPINFO

  ncpyOpInfo->ncpyOpInfoSize = sizeof(NcpyOperationInfo) + srcLayerSize + destLayerSize + srcAckSize + destAckSize;
}


void resetNcpyOpInfoPointers(NcpyOperationInfo *ncpyOpInfo) {

  char *base = (char *)ncpyOpInfo + sizeof(NcpyOperationInfo);

  if(ncpyOpInfo->srcLayerInfo) {
    ncpyOpInfo->srcLayerInfo = base;
    base = base + ncpyOpInfo->srcLayerSize;
  }

  if(ncpyOpInfo->srcAck) {
    ncpyOpInfo->srcAck = base;
    base = base + ncpyOpInfo->srcAckSize;
  }

  if(ncpyOpInfo->destLayerInfo) {
    ncpyOpInfo->destLayerInfo = base;
    base = base + ncpyOpInfo->destLayerSize;
  }

  if(ncpyOpInfo->destAck) {
    ncpyOpInfo->destAck = base;
  }

}

void setReverseModeForNcpyOpInfo(NcpyOperationInfo *ncpyOpInfo) {
  switch(ncpyOpInfo->opMode) {
    case CMK_EM_API          : ncpyOpInfo->opMode = CMK_EM_API_REVERSE;
                               break;
    case CMK_DIRECT_API      : // Do nothing
                               break;
    case CMK_BCAST_EM_API    : ncpyOpInfo->opMode = CMK_BCAST_EM_API_REVERSE;
                               break;
    default                  : CmiAbort("Unknown opcode");
                               break;
  }
}

---