Changed CmiMsgHeaderSizeBytes to CmiReservedHeaderSize (the first one is not good...
authorFilippo Gioachin <gioachin@uiuc.edu>
Fri, 19 Mar 2010 07:02:05 +0000 (02:02 -0500)
committerFilippo Gioachin <gioachin@uiuc.edu>
Fri, 19 Mar 2010 07:02:05 +0000 (02:02 -0500)
src/ck-core/ck.C
src/ck-core/debug-charm.C
src/conv-ccs/ccs-builtins.C
src/conv-ccs/conv-ccs.c

index f03355c84bbc6c9b2487f6bc89936a8aa1c7a609..234421a2d3637df3aee83525699ad031e7cea534 100644 (file)
@@ -1994,7 +1994,7 @@ private:
       bool wasPacked = env->isPacked();
       if (!wasPacked) CkPackMessage(&env);
       //unsigned int crc = crc32_initial(((unsigned char*)env)+CmiMsgHeaderSizeBytes, env->getTotalsize()-CmiMsgHeaderSizeBytes);
-      unsigned int crc1 = crc32_initial(((unsigned char*)env)+CmiMsgHeaderSizeBytes, sizeof(*env)-CmiMsgHeaderSizeBytes);
+      unsigned int crc1 = crc32_initial(((unsigned char*)env)+CmiReservedHeaderSize, sizeof(*env)-CmiReservedHeaderSize);
       unsigned int crc2 = crc32_initial(((unsigned char*)env)+sizeof(*env), env->getTotalsize()-sizeof(*env));
       fprintf(f,"%d %d %d %hhd %x %x\n",env->getSrcPe(),env->getTotalsize(),env->getEvent(), env->getMsgtype()==NodeBocInitMsg || env->getMsgtype()==ForNodeBocMsg, crc1, crc2);
       if (!wasPacked) CkUnpackMessage(&env);
index 07d5cd5dbf517c46f890a293c0cd4b1ae0afbddb..e95667be686f726e2aa5a29bade8a0f50b84db75 100644 (file)
@@ -640,7 +640,7 @@ void CpdSetBreakPoint (char *msg)
   char functionName[128];
   int tableSize, tableIdx = 0;
   int reply = 0;
-  sscanf(msg+CmiMsgHeaderSizeBytes, "%s", functionName);
+  sscanf(msg+CmiReservedHeaderSize, "%s", functionName);
   if (strlen(functionName) > 0)
   {
     tableSize = _entryTable.size();
@@ -687,7 +687,7 @@ void CpdRemoveBreakPoint (char *msg)
 {
   char functionName[128];
   int reply = 0;
-  sscanf(msg+CmiMsgHeaderSizeBytes, "%s", functionName);
+  sscanf(msg+CmiReservedHeaderSize, "%s", functionName);
   if (strlen(functionName) > 0) {
     int idx = atoi(functionName);
     if (idx >= 0 && idx < _entryTable.size()) {
index c5cf82981bb9fb7293f4741da29ba2571623c8c1..e3213b90fb75b7532c94dc1b12fe23c56d03bf80 100644 (file)
@@ -61,7 +61,7 @@ static killPortStruct *killList=NULL;
 static void ccs_killport(char *msg)
 {
   killPortStruct *oldList=killList;
-  int port=ChMessageInt(*(ChMessageInt_t *)(msg+CmiMsgHeaderSizeBytes));
+  int port=ChMessageInt(*(ChMessageInt_t *)(msg+CmiReservedHeaderSize));
   skt_ip_t ip;
   unsigned int connPort;
   CcsCallerId(&ip,&connPort);
@@ -175,7 +175,7 @@ static CpdListAccessor *CpdListLookup(const ChMessageInt_t *lenAndPath)
 //Get the length of the given list:
 static void CpdList_ccs_list_len(char *msg)
 {
-  const ChMessageInt_t *req=(const ChMessageInt_t *)(msg+CmiMsgHeaderSizeBytes);
+  const ChMessageInt_t *req=(const ChMessageInt_t *)(msg+CmiReservedHeaderSize);
   CpdListAccessor *acc=CpdListLookup(req);
   if (acc!=NULL) {
     ChMessageInt_t reply=ChMessageInt_new(acc->getLength());
@@ -194,9 +194,9 @@ static void CpdList_ccs_list_len(char *msg)
 static CpdListAccessor *CpdListHeader_ccs_list_items(char *msg,
             CpdListItemsRequest &h)
 {
-  int msgLen=CmiSize((void *)msg)-CmiMsgHeaderSizeBytes;
+  int msgLen=CmiSize((void *)msg)-CmiReservedHeaderSize;
   CpdListAccessor *ret=NULL;
-  const ChMessageInt_t *req=(const ChMessageInt_t *)(msg+CmiMsgHeaderSizeBytes);
+  const ChMessageInt_t *req=(const ChMessageInt_t *)(msg+CmiReservedHeaderSize);
   h.lo=ChMessageInt(req[0]); // first item to send
   h.hi=ChMessageInt(req[1]); // last item to send+1
   h.extraLen=ChMessageInt(req[2]); // extra data length
@@ -454,7 +454,7 @@ CCS Client->CWebHandler->...  (processor 0)
 #define MAXFNS 20 /*Largest number of performance functions to expect*/
 
 typedef struct {
-       char hdr[CmiMsgHeaderSizeBytes];
+       char hdr[CmiReservedHeaderSize];
        int fromPE;/*Source processor*/
        int perfData[MAXFNS];/*Performance numbers*/
 } CWeb_CollectedData;
@@ -582,9 +582,9 @@ static void CWebHandler(void){
       
       /*Start collecting data on each processor*/
       for(i = 0; i < CmiNumPes(); i++){
-        char *msg = (char *)CmiAlloc(CmiMsgHeaderSizeBytes);
+        char *msg = (char *)CmiAlloc(CmiReservedHeaderSize);
         CmiSetHandler(msg, CWeb_CollectIndex);
-        CmiSyncSendAndFree(i, CmiMsgHeaderSizeBytes,msg);
+        CmiSyncSendAndFree(i, CmiReservedHeaderSize,msg);
       }
     }
   }
index bd183a9a90ae0ffc81ce78cd1778d4e53acb2586..4571f4fec4487bf2f47c44572c4fbb101503d5b3 100644 (file)
@@ -55,8 +55,8 @@ static void callHandlerRec(CcsHandlerRec *c,int reqLen,const void *reqData) {
            Pack user data into a converse message (cripes! why bother?);
            user will delete the message. 
          */
-               char *cmsg = (char *) CmiAlloc(CmiMsgHeaderSizeBytes+reqLen);
-               memcpy(cmsg+CmiMsgHeaderSizeBytes, reqData, reqLen);
+               char *cmsg = (char *) CmiAlloc(CmiReservedHeaderSize+reqLen);
+               memcpy(cmsg+CmiReservedHeaderSize, reqData, reqLen);
                (c->fnOld)(cmsg);
        }
        else { /* Pass read-only copy of data straight to user */
@@ -99,17 +99,17 @@ void * CcsMerge_concat(int *size,void *local,void **remote,int n) {
   char *ptr;
   int i;
   for (i=0; i<n; ++i) {
-    hdr = (CcsImplHeader*)(((char*)remote[i])+CmiMsgHeaderSizeBytes);
+    hdr = (CcsImplHeader*)(((char*)remote[i])+CmiReservedHeaderSize);
     total += ChMessageInt(hdr->len);
   }
   reply = CmiAlloc(total);
   memcpy(reply, local, *size);
-  ((CcsImplHeader*)(((char*)reply)+CmiMsgHeaderSizeBytes))->len = ChMessageInt_new(total-CmiMsgHeaderSizeBytes-sizeof(CcsImplHeader));
+  ((CcsImplHeader*)(((char*)reply)+CmiReservedHeaderSize))->len = ChMessageInt_new(total-CmiReservedHeaderSize-sizeof(CcsImplHeader));
   CmiFree(local);
   ptr = ((char*)reply)+*size;
   for (i=0; i<n; ++i) {
-    int len = ChMessageInt(((CcsImplHeader*)(((char*)remote[i])+CmiMsgHeaderSizeBytes))->len);
-    memcpy(ptr, ((char*)remote[i])+CmiMsgHeaderSizeBytes+sizeof(CcsImplHeader), len);
+    int len = ChMessageInt(((CcsImplHeader*)(((char*)remote[i])+CmiReservedHeaderSize))->len);
+    memcpy(ptr, ((char*)remote[i])+CmiReservedHeaderSize+sizeof(CcsImplHeader), len);
     ptr += len;
   }
   *size = total;
@@ -119,7 +119,7 @@ void * CcsMerge_concat(int *size,void *local,void **remote,int n) {
 #define SIMPLE_REDUCTION(name, dataType, loop) \
 void * CcsMerge_##name(int *size,void *local,void **remote,int n) { \
   int i, m; \
-  CcsImplHeader *hdrLocal = (CcsImplHeader*)(((char*)local)+CmiMsgHeaderSizeBytes); \
+  CcsImplHeader *hdrLocal = (CcsImplHeader*)(((char*)local)+CmiReservedHeaderSize); \
   int lenLocal = ChMessageInt(hdrLocal->len); \
   int nElem = lenLocal / sizeof(dataType); \
   dataType *ret = (dataType *) (hdrLocal+1); \
@@ -127,7 +127,7 @@ void * CcsMerge_##name(int *size,void *local,void **remote,int n) { \
   for (m=0; m<n; ++m) { \
     int len; \
     dataType *value; \
-    hdr = (CcsImplHeader*)(((char*)remote[m])+CmiMsgHeaderSizeBytes); \
+    hdr = (CcsImplHeader*)(((char*)remote[m])+CmiReservedHeaderSize); \
     len = ChMessageInt(hdr->len); \
     value = (dataType *)(hdr+1); \
     CmiAssert(lenLocal == len); \
@@ -182,9 +182,9 @@ int CcsReply(CcsImplHeader *rep,int repLen,const void *repData) {
   if (repPE <= -1) {
     /* Reduce the message to get the final reply */
     CcsHandlerRec *fn;
-    int len=CmiMsgHeaderSizeBytes+sizeof(CcsImplHeader)+repLen;
+    int len=CmiReservedHeaderSize+sizeof(CcsImplHeader)+repLen;
     char *msg=CmiAlloc(len);
-    char *r=msg+CmiMsgHeaderSizeBytes;
+    char *r=msg+CmiReservedHeaderSize;
     char *handlerStr;
     rep->len = ChMessageInt_new(repLen);
     *(CcsImplHeader *)r=*rep; r+=sizeof(CcsImplHeader);
@@ -290,19 +290,19 @@ static void CcsHandleRequest(CcsImplHeader *hdr,const char *reqData)
 int _ccsHandlerIdx = 0;/*Converse handler index of below routine*/
 static void req_fw_handler(char *msg)
 {
-  int offset = CmiMsgHeaderSizeBytes + sizeof(CcsImplHeader);
-  CcsImplHeader *hdr = (CcsImplHeader *)(msg+CmiMsgHeaderSizeBytes);
+  int offset = CmiReservedHeaderSize + sizeof(CcsImplHeader);
+  CcsImplHeader *hdr = (CcsImplHeader *)(msg+CmiReservedHeaderSize);
   int destPE = (int)ChMessageInt(hdr->pe);
   if (CmiMyPe() == 0 && destPE == -1) {
     /* Broadcast message to all other processors */
-    int len=CmiMsgHeaderSizeBytes+sizeof(CcsImplHeader)+ChMessageInt(hdr->len);
+    int len=CmiReservedHeaderSize+sizeof(CcsImplHeader)+ChMessageInt(hdr->len);
     CmiSyncBroadcast(len, msg);
   }
   else if (destPE < -1) {
     /* Multicast the message to your children */
-    int len=CmiMsgHeaderSizeBytes+sizeof(CcsImplHeader)+ChMessageInt(hdr->len)-destPE*sizeof(ChMessageInt_t);
+    int len=CmiReservedHeaderSize+sizeof(CcsImplHeader)+ChMessageInt(hdr->len)-destPE*sizeof(ChMessageInt_t);
     int index, child, i;
-    int *pes = (int*)(msg+CmiMsgHeaderSizeBytes+sizeof(CcsImplHeader));
+    int *pes = (int*)(msg+CmiReservedHeaderSize+sizeof(CcsImplHeader));
     ChMessageInt_t *pes_nbo = (ChMessageInt_t *)pes;
     offset -= destPE * sizeof(ChMessageInt_t);
     if (ChMessageInt(pes_nbo[0]) == CmiMyPe()) {
@@ -364,10 +364,10 @@ char *CcsImpl_ccs2converse(const CcsImplHeader *hdr,const void *data,int *ret_le
   int len;
   char *msg;
   if (destPE < -1) reqLen -= destPE*sizeof(int);
-  len=CmiMsgHeaderSizeBytes+sizeof(CcsImplHeader)+reqLen;
+  len=CmiReservedHeaderSize+sizeof(CcsImplHeader)+reqLen;
   msg=(char *)CmiAlloc(len);
-  memcpy(msg+CmiMsgHeaderSizeBytes,hdr,sizeof(CcsImplHeader));
-  memcpy(msg+CmiMsgHeaderSizeBytes+sizeof(CcsImplHeader),data,reqLen);
+  memcpy(msg+CmiReservedHeaderSize,hdr,sizeof(CcsImplHeader));
+  memcpy(msg+CmiReservedHeaderSize+sizeof(CcsImplHeader),data,reqLen);
   if (ret_len!=NULL) *ret_len=len;
   if (_ccsHandlerIdx != 0) {
     CmiSetHandler(msg, _ccsHandlerIdx);
@@ -387,7 +387,7 @@ converse to node 0.*/
 static void rep_fw_handler(char *msg)
 {
   int len;
-  char *r=msg+CmiMsgHeaderSizeBytes;
+  char *r=msg+CmiReservedHeaderSize;
   CcsImplHeader *hdr=(CcsImplHeader *)r; 
   r+=sizeof(CcsImplHeader);
   len=ChMessageInt(hdr->len);
@@ -444,10 +444,10 @@ void CcsImpl_reply(CcsImplHeader *rep,int repLen,const void *repData)
     CcsServer_sendReply(rep,repLen,repData);
   } else {
     /*Forward data & socket # to the replyPE*/
-    int len=CmiMsgHeaderSizeBytes+
+    int len=CmiReservedHeaderSize+
            sizeof(CcsImplHeader)+repLen;
     char *msg=CmiAlloc(len);
-    char *r=msg+CmiMsgHeaderSizeBytes;
+    char *r=msg+CmiReservedHeaderSize;
     *(CcsImplHeader *)r=*rep; r+=sizeof(CcsImplHeader);
     memcpy(r,repData,repLen);
     CmiSetHandler(msg,rep_fw_handler_idx);