Modified AsyncSend functions to return 0 as CmiCommHandle when
authorMilind Bhandarkar <milind@cs.uiuc.edu>
Mon, 3 May 1999 22:12:42 +0000 (22:12 +0000)
committerMilind Bhandarkar <milind@cs.uiuc.edu>
Mon, 3 May 1999 22:12:42 +0000 (22:12 +0000)
buffer is already ready to use.

src/arch/exemplar-mpi/machine.c
src/arch/exemplar/machine.c
src/arch/origin-mpi/machine.c
src/arch/origin-pthreads/machine.c
src/arch/origin2000/machine.c
src/arch/sp3/machine.c
src/arch/t3e/machine.c
src/arch/uth/machine.c

index 10c26bb0ab1856d72f3d79aad2cbf4e064705cfa..75a529be5ab699dcf52fe1c21017c9a97ca63081 100644 (file)
@@ -192,7 +192,7 @@ CmiCommHandle CmiAsyncSendFn(int destPE, int size, char *msg)
     char *dupmsg = (char *) CmiAlloc(size);
     memcpy(dupmsg, msg, size);
     FIFO_EnQueue(CpvAccess(CmiLocalQueue),dupmsg);
-    return;
+    return 0;
   }
   msg_tmp = (SMSG_LIST *) CmiAlloc(sizeof(SMSG_LIST));
   msg_tmp->msg = msg;
@@ -203,6 +203,7 @@ CmiCommHandle CmiAsyncSendFn(int destPE, int size, char *msg)
   else
     end_sent->next = msg_tmp;
   end_sent = msg_tmp;
+  return (CmiCommHandle) &(msg_tmp->req);
 }
 
 void CmiFreeSendFn(int destPE, int size, char *msg)
index e0f467c8c775f3d5745850756a5c99147eb8ab12..ad9497843cef55fb3f281f16742d50263cce9c0c 100644 (file)
@@ -87,7 +87,7 @@ int CmiProbeLock(CmiNodeLock lock)
 int CmiAsyncMsgSent(msgid)
 CmiCommHandle msgid;
 {
-   return 0;
+   return 1;
 }
 
 typedef struct {
index 2b401ae3c0d94c1930d351cb7a59ca15e0d1f976..d273d09b044d36a627dd5e0c0fdcb2599fc7daef 100644 (file)
@@ -201,7 +201,7 @@ CmiCommHandle CmiAsyncSendFn(int destPE, int size, char *msg)
     char *dupmsg = (char *) CmiAlloc(size);
     memcpy(dupmsg, msg, size);
     FIFO_EnQueue(CpvAccess(CmiLocalQueue),dupmsg);
-    return;
+    return 0;
   }
   msg_tmp = (SMSG_LIST *) CmiAlloc(sizeof(SMSG_LIST));
   msg_tmp->msg = msg;
@@ -217,6 +217,7 @@ CmiCommHandle CmiAsyncSendFn(int destPE, int size, char *msg)
   else
     end_sent->next = msg_tmp;
   end_sent = msg_tmp;
+  return (CmiCommHandle) &(msg_tmp->req);
 }
 
 void CmiFreeSendFn(int destPE, int size, char *msg)
index 36a1f2cc737d6430dc5c604dfa8087d703eb8ab3..499ad2c52ecea5028d4e5b9ef9b7c10a14431db9 100644 (file)
@@ -117,7 +117,7 @@ void CmiAbort(char *message)
 
 int CmiAsyncMsgSent(CmiCommHandle msgid)
 {
-  return 0;
+  return 1;
 }
 
 
index ca2fc3e9747cc1570c98ef5c443f690b3f21574f..9526e596a72de2735da54f04a2e3d4bbef00e7bf 100644 (file)
@@ -66,7 +66,7 @@ void CmiAbort(char *message)
 
 int CmiAsyncMsgSent(CmiCommHandle msgid)
 {
-  return 0;
+  return 1;
 }
 
 
index fcc98e684c04225767b258bb2be89239e21265b3..0873f6e873b0fe5ba2a37846322c6c0e203e17a0 100644 (file)
@@ -188,6 +188,7 @@ CmiCommHandle CmiAsyncSendFn(int destPE, int size, char *msg)
   else
     end_sent->next = msg_tmp;
   end_sent = msg_tmp;
+  return (CmiCommHandle) msgid;
 }
 
 void CmiFreeSendFn(int destPE, int size, char *msg)
index 650728f83deb719f668f9e5390be05bd26819a10..42f0bc5d3e89dfc8a044dc230179c56d12b54cb0 100644 (file)
@@ -185,7 +185,7 @@ void CmiSyncSendFn(int dest_pe, int size, char *msg)
 CmiCommHandle CmiAsyncSendFn(int dest_pe, int size, char *msg)
 {
   CmiSyncSendFn(dest_pe, size, msg);
-  return 1;
+  return 0;
 }
 
 void CmiFreeSendFn(int dest_pe, int size, char *msg)
@@ -250,7 +250,7 @@ void CmiSyncBroadcastFn(int size, char *msg)
 CmiCommHandle CmiAsyncBroadcastFn(int size, char *msg)
 {
   CmiSyncBroadcastFn(size,msg);
-  return 1;
+  return 0;
 }
 
 void CmiFreeBroadcastFn(int size, char *msg)
@@ -269,7 +269,7 @@ void CmiSyncBroadcastAllFn(int size, char *msg)
 CmiCommHandle CmiAsyncBroadcastAllFn(int size, char *msg)
 {
   CmiSyncBroadcastAllFn(size,msg);
-  return 1;
+  return 0;
 }
 
 void CmiFreeBroadcastAllFn(int size, char *msg)
@@ -344,7 +344,7 @@ void CmiSyncListSendFn(int npes, int *pes, int size, char *msg)
 CmiCommHandle CmiAsyncListSendFn(int npes, int *pes, int size, char *msg)
 {
   CmiSyncListSendFn(npes, pes, size, msg);
-  return 1;
+  return 0;
 }
 
 void CmiFreeListSendFn(int npes, int *pes, int size, char *msg)
@@ -404,7 +404,7 @@ void CmiMulticastInit(void)
 CmiCommHandle CmiAsyncMulticastFn(CmiGroup grp, int size, char *msg)
 {
   CmiSyncMulticastFn(grp, size, msg);
-  return 1;
+  return 0;
 }
 
 void CmiFreeMulticastFn(CmiGroup grp, int size, char *msg)
index 91b84ce07f73ab3db44458c69ba1d12b8a27d4dd..7ae0a70c125ddbed95b4540270a73a1ae4e52015 100644 (file)
@@ -227,6 +227,7 @@ char * msg;
   char *buf = (char *)CmiAlloc(size);
   memcpy(buf,msg,size);
   FIFO_EnQueue(CmiQueues[destPE],buf);
+  return 0;
 }
 
 void CmiFreeSendFn(destPE, size, msg)