Removed CmiGrabBuffer.
authorMilind Bhandarkar <milind@cs.uiuc.edu>
Mon, 25 Dec 2000 08:13:42 +0000 (08:13 +0000)
committerMilind Bhandarkar <milind@cs.uiuc.edu>
Mon, 25 Dec 2000 08:13:42 +0000 (08:13 +0000)
25 files changed:
src/ck-core/ck.C
src/ck-core/init.C
src/ck-core/qd.C
src/conv-ccs/conv-ccs.c
src/conv-core/conv-ccs.c
src/conv-core/convcore.c
src/conv-core/converse.h
src/conv-core/cpm.c
src/conv-core/futures.c
src/conv-core/quiescence.c
src/conv-core/threads.c
src/conv-ldb/cldb.graph.c
src/conv-ldb/cldb.rand.c
src/conv-ldb/cldb.spray.c
src/conv-ldb/cldb.test.c
src/langs/pvmc/pvmc_comm.c
src/langs/simplemsg/simplemsg.c
src/langs/simplemsg/sm.c
src/langs/streams/Communicate.C
src/langs/streams/Communicate.h
src/libs/conv-libs/commlib/commlib.C
src/libs/conv-libs/lrpc/lrpc.c
tests/converse/megacon/multisend.c
tests/converse/megacon/ringsimple.c
tests/converse/megacon/vecsend.c

index f0d69d9a763f9b05f113f8a640d4db096d047dae..7e283f4697ea4a030d7e1dc418d7e109a5eaf9d7 100644 (file)
@@ -519,7 +519,6 @@ void _processNodeBocInitMsg(envelope *env)
 
 void _processHandler(void *msg)
 {
-  CmiGrabBuffer(&msg);
   register envelope *env = (envelope *) msg;
   switch(env->getMsgtype()) {
     case NewChareMsg :
@@ -645,7 +644,6 @@ void _unpackFn(void **pEnv)
 static int index_skipCldHandler;
 static void _skipCldHandler(void *msg)
 {
-  CmiGrabBuffer(&msg);
   register envelope *env = (envelope *)(msg);
   CmiSetHandler(msg, CmiGetXHandler(msg));
   CqsEnqueueGeneral((Queue)CpvAccess(CsdSchedQueue),
index d0ea20dcc068ca94c9e17186e3d8e4dd827c79bf..1d429c7c3527d8ee42859098e7f0025e9bedd5e9 100644 (file)
@@ -89,13 +89,11 @@ static inline void _parseCommandLineOpts(char **argv)
 
 static void _bufferHandler(void *msg)
 {
-  CmiGrabBuffer(&msg);
   CpvAccess(_buffQ)->enq(msg);
 }
 
 static void _discardHandler(envelope *env)
 {
-  CmiGrabBuffer((void **)&env);
   CmiFree(env);
 }
 
@@ -155,7 +153,6 @@ static inline void _sendStats(void)
 
 static void _exitHandler(envelope *env)
 {
-  CmiGrabBuffer((void **)&env);
   switch(env->getMsgtype()) {
     case ExitMsg:
       assert(CkMyPe()==0);
@@ -295,7 +292,6 @@ static inline void _initDone(void)
 
 static void _triggerHandler(envelope *env)
 {
-  CmiGrabBuffer((void **) &env);
   if (_numInitMsgs && CpvAccess(_numInitsRecd) + _numInitNodeMsgs == _numInitMsgs)
   {
     DEBUGF(("Calling Init Done from _triggerHandler\n"));
@@ -323,7 +319,6 @@ static inline void _processRODataMsg(envelope *env)
 static void _initHandler(void *msg)
 {
   assert(CkMyPe()!=0);
-  CmiGrabBuffer(&msg);
   register envelope *env = (envelope *) msg;
   switch (env->getMsgtype()) {
     case BocInitMsg:
index e0f78d250d52c6c6f85071d2bc3dc2482e3212f0..b1e6701cd8c9ad3cbfb23148575dbf8bcbcfe71c 100644 (file)
@@ -126,7 +126,6 @@ static void _callWhenIdle(QdMsg *msg)
 
 void _qdHandler(envelope *env)
 {
-  CmiGrabBuffer((void **)&env);
   register QdMsg *msg = (QdMsg*) EnvToUsr(env);
   CcdCallOnCondition(CcdPROCESSORIDLE, (CcdVoidFn)_callWhenIdle, (void*) msg);
 }
index 2c984c8c5a3f12f81333a08688bb2a7f4dd5ac8f..af693258f21d7218a0be611e6359c5bfe9f465d5 100644 (file)
@@ -43,7 +43,7 @@ static void ccs_getinfo(char *msg)
     table[1+n]=ChMessageInt_new(CmiNodeSize(n));
   CcsSendReply(len,(const char *)table);
   free(table);
-  CmiGrabBuffer((void **)&msg);CmiFree(msg);
+  CmiFree(msg);
 }
 
 typedef struct killPortStruct{
@@ -63,7 +63,7 @@ static void ccs_killport(char *msg)
   killList->ip=ip;
   killList->port=port;
   killList->next=oldList;
-  CmiGrabBuffer((void **)&msg);CmiFree(msg);
+  CmiFree(msg);
 }
 /*Send any registered clients kill messages before we exit*/
 static int noMoreErrors(int c,const char *m) {return -1;}
@@ -400,7 +400,6 @@ static void CWeb_Reduce(void *msg){
   if(CmiMyPe() != 0){
     CmiAbort("CWeb performance data sent to wrong processor...\n");
   }
-  CmiGrabBuffer((void **)&msg);
   cur=(CWeb_CollectedData *)msg;
   src=cur->fromPE;
   prev = collectedValues[src]; /* Previous value, ideally 0 */
@@ -678,7 +677,7 @@ static void req_fw_handler(char *msg)
 {
   CcsHandleRequest((CcsImplHeader *)(msg+CmiMsgHeaderSizeBytes),
                   msg+CmiMsgHeaderSizeBytes+sizeof(CcsImplHeader));
-  CmiGrabBuffer((void **)&msg); CmiFree(msg);  
+  CmiFree(msg);  
 }
 
 
@@ -776,7 +775,7 @@ static void rep_fw_handler(char *msg)
   SOCKET fd=*(SOCKET *)r; r+=sizeof(SOCKET);
   len=*(int *)r; r+=sizeof(int);
   CcsImpl_reply(fd,len,r);
-  CmiGrabBuffer((void **)&msg); CmiFree(msg);
+  CmiFree(msg);
 }
 
 #endif /*NODE_0_IS_CONVHOST*/
index 2c984c8c5a3f12f81333a08688bb2a7f4dd5ac8f..af693258f21d7218a0be611e6359c5bfe9f465d5 100644 (file)
@@ -43,7 +43,7 @@ static void ccs_getinfo(char *msg)
     table[1+n]=ChMessageInt_new(CmiNodeSize(n));
   CcsSendReply(len,(const char *)table);
   free(table);
-  CmiGrabBuffer((void **)&msg);CmiFree(msg);
+  CmiFree(msg);
 }
 
 typedef struct killPortStruct{
@@ -63,7 +63,7 @@ static void ccs_killport(char *msg)
   killList->ip=ip;
   killList->port=port;
   killList->next=oldList;
-  CmiGrabBuffer((void **)&msg);CmiFree(msg);
+  CmiFree(msg);
 }
 /*Send any registered clients kill messages before we exit*/
 static int noMoreErrors(int c,const char *m) {return -1;}
@@ -400,7 +400,6 @@ static void CWeb_Reduce(void *msg){
   if(CmiMyPe() != 0){
     CmiAbort("CWeb performance data sent to wrong processor...\n");
   }
-  CmiGrabBuffer((void **)&msg);
   cur=(CWeb_CollectedData *)msg;
   src=cur->fromPE;
   prev = collectedValues[src]; /* Previous value, ideally 0 */
@@ -678,7 +677,7 @@ static void req_fw_handler(char *msg)
 {
   CcsHandleRequest((CcsImplHeader *)(msg+CmiMsgHeaderSizeBytes),
                   msg+CmiMsgHeaderSizeBytes+sizeof(CcsImplHeader));
-  CmiGrabBuffer((void **)&msg); CmiFree(msg);  
+  CmiFree(msg);  
 }
 
 
@@ -776,7 +775,7 @@ static void rep_fw_handler(char *msg)
   SOCKET fd=*(SOCKET *)r; r+=sizeof(SOCKET);
   len=*(int *)r; r+=sizeof(int);
   CcsImpl_reply(fd,len,r);
-  CmiGrabBuffer((void **)&msg); CmiFree(msg);
+  CmiFree(msg);
 }
 
 #endif /*NODE_0_IS_CONVHOST*/
index e73af72a5627a4cd65a7955fc8d11872e1c3c9d8..9e70862ef301612a2c51567628c4cc1dcbf60287 100644 (file)
@@ -994,7 +994,6 @@ CthThread CthSuspendSchedulingThread()
 
 void CthResumeNormalThread(CthThread t)
 {
-  CmiGrabBuffer((void**)&t);
   /** addition for tracing */
   CpvAccess(curThread) = t;
 #ifndef CMK_OPTIMIZE
@@ -1011,7 +1010,6 @@ void CthResumeNormalThread(CthThread t)
 void CthResumeSchedulingThread(CthThread t)
 {
   CthThread me = CthSelf();
-  CmiGrabBuffer((void**)&t);
   if (me == CpvAccess(CthMainThread)) {
     CthEnqueueSchedulingThread(me,CQS_QUEUEING_FIFO, 0, 0);
   } else {
@@ -1173,7 +1171,6 @@ void CmiGroupHandler(GroupDef def)
   /* receive group definition, insert into group table */
   GroupDef *table = CpvAccess(CmiGroupTable);
   unsigned int hashval, bucket;
-  CmiGrabBuffer((void*)&def);
   hashval = (def->group.id ^ def->group.pe);
   bucket = hashval % GROUPTAB_SIZE;
   def->core.next = table[bucket];
@@ -1307,7 +1304,6 @@ void CmiMulticastDeliver(MultiMsg msg)
 
 void CmiMulticastHandler(MultiMsg msg)
 {
-  CmiGrabBuffer((void*)&msg);
   CmiMulticastDeliver(msg);
 }
 
index 4a21655a02bc884eecbd25dbd3de03ebaeb602a8..952cacb3e74031129e04d58c63b125cb5159453e 100644 (file)
@@ -594,11 +594,6 @@ extern void CsdExitScheduler(void);
 #define CsdExitScheduler()  (CpvAccess(CsdStopFlag)++)
 #endif
 
-#define CmiGrabBuffer(x) /*empty*/
-/*void     CmiGrabBuffer(void **ppbuf);
-void     CmiReleaseBuffer(void *pbuf);
-*/
-
 #if CMK_SPANTREE_USE_COMMON_CODE
 
 #define SPANTREE_W  (CMK_SPANTREE_MAXSPAN)
index 6b666e4f63cc538e7d8a08d00b8cffd8aba127de..22321da6eb344fe800c93e2173291b6a31d79bc2 100644 (file)
@@ -72,7 +72,6 @@ CpvDeclare(int, CpmEnqueue2_Index);
 void CpmEnqueue2(void *msg)
 {
   int *env;
-  CmiGrabBuffer(&msg);
   env = (int *)CpmEnv(msg);
   CmiSetHandler(msg, env[0]);
   CsdEnqueueGeneral(msg, env[1], env[2], (unsigned int *)(env+3));
@@ -141,7 +140,6 @@ CpvDeclare(int, CpmEnqueueFIFO2_Index);
 void CpmEnqueueFIFO2(void *msg)
 {
   int *env;
-  CmiGrabBuffer(&msg);
   env = (int *)CpmEnv(msg);
   CmiSetHandler(msg, env[0]);
   CsdEnqueueFifo(msg);
@@ -177,7 +175,6 @@ CpvDeclare(int, CpmEnqueueLIFO2_Index);
 void CpmEnqueueLIFO2(void *msg)
 {
   int *env;
-  CmiGrabBuffer(&msg);
   env = (int *)CpmEnv(msg);
   CmiSetHandler(msg, env[0]);
   CsdEnqueueLifo(msg);
@@ -221,7 +218,6 @@ void CpmThread3(void *msg)
 void CpmThread2(void *msg)
 {
   CthThread t;
-  CmiGrabBuffer(&msg);
   t = CthCreate(CpmThread3, msg, 0);
   CthSetStrategyDefault(t); CthAwaken(t);
 }
@@ -267,7 +263,6 @@ void CpmThreadSize2(void *msg)
 {
   int *env = (int *)CpmEnv(msg);
   CthThread t;
-  CmiGrabBuffer(&msg);
   t = CthCreate(CpmThread3, msg, env[1]);
   CthSetStrategyDefault(t); CthAwaken(t);
 }
index 8d4bf9bc2c7bd4042fa4980175ae9818f98df09d..25fb84fa892464efaacad0b98f046456e23615b3 100644 (file)
@@ -55,7 +55,6 @@ static void CfutureAwaken(futdata data, CfutureValue val)
 
 static void CfutureStore(CfutureValue m)
 {
-  CmiGrabBuffer((void **)&m);
   CfutureAwaken(m->data, m);
 }
 
index b48204b6fb1bdd626288dfba181d20172cb8a727..da63010868ca82bbe4a79d7c58d7f83389577324 100644 (file)
@@ -258,7 +258,6 @@ static void CQdCallWhenIdle(CQdMsg msg)
 
 void CQdHandler(CQdMsg msg)
 {
-  CmiGrabBuffer((void **)&msg);
   CQdProcess(CpvAccess(cQdState), -1);
   CcdCallOnCondition(CcdPROCESSORIDLE, 
                     (CcdVoidFn)CQdCallWhenIdle, (void*) msg);  
index 1ca3f9262bfd796279c469fb0c0c5d945a02f3f4..a6735f41b6e20a4a0dc7bc43a479b2ebedc98119 100644 (file)
@@ -989,7 +989,6 @@ static void
 reqslots(slotmsg *msg)
 {
   int slot, pe;
-  CmiGrabBuffer((void**)&msg);
   if(msg->pe == CmiMyPe())
     CmiAbort("All stack slots have been exhausted!\n");
   slot = get_slots(CpvAccess(myss),msg->nslots);
index 2b926aeea7d1777f19d4d6279ca030885b78d4af..c4a60593438380c812e7dda0b88a7194207a3057 100644 (file)
@@ -112,7 +112,6 @@ void CldLoadResponseHandler(loadmsg *msg)
 
 void CldBalanceHandler(void *msg)
 {
-  CmiGrabBuffer((void **)&msg);
   CldRestoreHandler(msg);
   CldPutToken(msg);
 }
@@ -122,7 +121,6 @@ void CldHandler(void *msg)
   CldInfoFn ifn; CldPackFn pfn;
   int len, queueing, priobits; unsigned int *prioptr;
   
-  CmiGrabBuffer((void **)&msg);
   CldRestoreHandler(msg);
   ifn = (CldInfoFn)CmiHandlerToFunction(CmiGetInfo(msg));
   ifn(msg, &pfn, &len, &queueing, &priobits, &prioptr);
index 845b57413dc77d2cb82aeddc654d6e9f3e0f2b56..692f9c083819a93b329a5d868c441c848ae5dd2e 100644 (file)
@@ -23,7 +23,6 @@ void CldHandler(char *msg)
 {
   int len, queueing, priobits;
   unsigned int *prioptr; CldInfoFn ifn; CldPackFn pfn;
-  CmiGrabBuffer((void **)&msg);
   CldRestoreHandler(msg);
   ifn = (CldInfoFn)CmiHandlerToFunction(CmiGetInfo(msg));
   ifn(msg, &pfn, &len, &queueing, &priobits, &prioptr);
index 27f117cd38df9e807978e1cc61df5ed3d36c2c64..3746c2e59ae129cc4cd5973c6159d1e90634f74f 100644 (file)
@@ -106,7 +106,6 @@ void CldEnqueueHandler(char *msg)
 {
   int len, queueing, priobits; unsigned int *prioptr;
   CldInfoFn ifn; CldPackFn pfn;
-  CmiGrabBuffer((void **)&msg);
   ifn = (CldInfoFn)CmiHandlerToFunction(CmiGetInfo(msg));
   ifn(msg, &pfn, &len, &queueing, &priobits, &prioptr);
   CmiSetHandler(msg, CmiGetXHandler(msg));
@@ -119,7 +118,6 @@ void CldHopHandler(char *msg)
   int len, queueing, priobits; unsigned int *prioptr;
   CldInfoFn ifn; CldPackFn pfn; int pe;
 
-  CmiGrabBuffer((void **)&msg);
   if (pinf->rebalance) {
     ifn = (CldInfoFn)CmiHandlerToFunction(CmiGetInfo(msg));
     ifn(msg, &pfn, &len, &queueing, &priobits, &prioptr);
index 585eb0e4409e2632b338871128eee89f74ed5f3f..d7b16c94f7ba0b9c68aa55c7f3a6d12b22a12602 100644 (file)
@@ -14,7 +14,6 @@ char *CldGetStrategy(void)
 
 void CldBalanceHandler(void *msg)
 {
-  CmiGrabBuffer((void **)&msg);
   CldRestoreHandler(msg);
   CldPutToken(msg);
 }
@@ -25,7 +24,6 @@ void CldHandler(char *msg)
   unsigned int *prioptr; 
   CldInfoFn ifn; CldPackFn pfn;
 
-  CmiGrabBuffer((void **)&msg);
   CldRestoreHandler(msg);
   ifn = (CldInfoFn)CmiHandlerToFunction(CmiGetInfo(msg));
   ifn(msg, &pfn, &len, &queueing, &priobits, &prioptr);
index 492745c6495cddb6ec0050a2f1e0751774ecfdf6..94b6d7dca18e01559f7c7ec30dbe3cc90e65bede 100644 (file)
@@ -111,8 +111,6 @@ static void pvmc_msg_handler_func(void *msg)
   int tags[2];
   int rtags[2];
 
-  CmiGrabBuffer(&msg);
-
   sender=((msg_hdr *)msg)->sender;
   seq_num=((msg_hdr *)msg)->seq_num;
   
index fd1b8ab2bee6c92b1e0716e441a3876a7b846748..319712aaaa847b0d4284d0966e3c812fc723e337 100644 (file)
@@ -27,7 +27,6 @@ void CsmHandler(m)
 CsmMessage m;
 {
   CthThread t;
-  CmiGrabBuffer((void **)&m);
   CmmPut(CpvAccess(CsmMessages), m->ntags, m->tags, m);
   t = (CthThread)CmmGet(CpvAccess(CsmSleepers), m->ntags, m->tags, (int *)0);
   if (t) CthAwaken(t);
index fb8f576288e04d56aadd32f950a0acc04a0310a4..980fedfcbdfc5a7799d4df9eb36d13db6292d6eb 100644 (file)
@@ -25,7 +25,6 @@ CpvStaticDeclare(CmmTable, SMMessages);
 void SMHandler(m)
 SMMessage m;
 {
-  CmiGrabBuffer(&m);
   CmmPut(CpvAccess(SMMessages), m->ntags, m->tags, m);
 }
 
index 1d77b9d30e05bb90d6ce93c60b2c001491ec2907..701b992f99125fa3dee318291bb405bdb95e8890 100644 (file)
@@ -13,7 +13,6 @@ CpvStaticDeclare(CmmTable, CsmMessages);
 
 static void CsmHandler(void *msg)
 {
-  CmiGrabBuffer((char **)&msg);
   // get start of user message
   int *m = (int *) ((char *)msg+CmiMsgHeaderSizeBytes);
   // sending node  & tag act as tags
index b6c5894a5c0b40f8da95cd7d9c4b305a3e9761a8..8721804d3672ed2b87615df973503e8de8e4c8c1 100644 (file)
@@ -10,7 +10,6 @@
 
 extern "C" {
 #include "converse.h"
-extern void CmiGrabBuffer(char **msg);
 }
 
 class MIStream;
index 67d7ba749feb57160f88f73218c2963adbeb17f1..9098aa62d342b9bffdcfa74cbefaabb1af35bb44 100644 (file)
@@ -167,7 +167,6 @@ void NumDeposits(comID id, int num)
 void KRecvManyCombinedMsg(char *msg)
 {
   comID id;
-  CmiGrabBuffer((void **)&msg);
   memcpy(&id,(msg+CmiMsgHeaderSizeBytes+sizeof(int)), sizeof(comID));
 
   UpdateImplTable(id);
@@ -177,7 +176,6 @@ void KRecvManyCombinedMsg(char *msg)
 void KProcManyCombinedMsg(char *msg)
 {
   comID id;
-  CmiGrabBuffer((void **)&msg);
   memcpy(&id,(msg+CmiMsgHeaderSizeBytes+sizeof(int)), sizeof(comID));
 
   UpdateImplTable(id);
@@ -265,7 +263,6 @@ void KGMsgHandler(GMsg *msg)
   //CmiPrintf("grppe=%d, grpindex=%d\n", grp.pe, grp.id);
   CmiLookupGroup((msg->id).grp, &npes, &pes);
   if (pes==0) {
-       CmiGrabBuffer((void **)&msg);
        //CmiSyncSendAndFree(CmiMyPe(),sizeof(GMsg), msg);
        KCsdEnqueue(msg);
   }
index 140118d97b5d03b7efc32d56aa52279478a5f852..74ef518cc41759c4cc1fdaf2d937c82ad132e6ea 100644 (file)
@@ -48,8 +48,6 @@ void internal_handler(void *msg)
   struct threadArgs args;
   CthThread th;
 
-  CmiGrabBuffer(&msg);
-
   switch(hdr->lrpc_type) {
     case NORMAL:
       args.funcnum = hdr->funcnum;
index badd77e0f48f1cb3f3b0f7f106a598ae3f17d1db..b9b802823cddb9e0a22384212d8fa2ead8243b89 100644 (file)
@@ -33,7 +33,6 @@ void multisend_first_handler(multisendmsg *msg)
     if(msg->data[i] != (double) (i+1))
       multisend_fail();
   }
-  CmiGrabBuffer((void **) &msg);
   CmiSetHandler(msg, CpvAccess(multisend_recv_index));
   CmiSyncSendAndFree(0, sizeof(multisendmsg), msg);
 }
@@ -48,7 +47,6 @@ void multisend_second_handler(multisendmsg *msg)
     if(msg->data[i] != (double) (i+2))
       multisend_fail();
   }
-  CmiGrabBuffer((void **) &msg);
   CmiSetHandler(msg, CpvAccess(multisend_recv_index));
   CmiSyncSendAndFree(0, sizeof(multisendmsg), msg);
 }
index bd264766b685d858f492aad043bd9cc0b871274d..a07e03b5a380e6ad078b25db5f95ac1021578452 100644 (file)
@@ -23,7 +23,6 @@ void ringsimple_hop(ringmsg *msg)
   int thispe = CmiMyPe();
   int nextpe = (thispe+1) % CmiNumPes();
   int i;
-  CmiGrabBuffer((void **)&msg);
   for (i=0; i<10; i++)
     if (msg->data[i] != i) ringsimple_fail();
   if (msg->hops) {
index fbedd7dd3a8177188785079cbee1dffeda14035d..acdac78cd92d334dbd28d97bcbe7698a158eb559 100644 (file)
@@ -28,7 +28,6 @@ void vecsend_handler(int *msg)
     sizes[0] = 3600*sizeof(int);
     msgs[0] = (char *)msg;
     CmiSyncVectorSend(next, 1, sizes, msgs);
-    CmiGrabBuffer((void **)&msg);
     CmiFree(msg);
   }
 }