Added FIFO_* function prototypes into fifo.h, and removed from many files
authorMilind Bhandarkar <milind@cs.uiuc.edu>
Fri, 16 Jul 1999 17:49:46 +0000 (17:49 +0000)
committerMilind Bhandarkar <milind@cs.uiuc.edu>
Fri, 16 Jul 1999 17:49:46 +0000 (17:49 +0000)
that redeclared them.

16 files changed:
src/arch/exemplar/machine.c
src/arch/mpi/machine.c
src/arch/ncube2/machine.c
src/arch/net/machine.c
src/arch/origin-pthreads/machine.c
src/arch/origin2000/machine.c
src/arch/paragon/machine.c
src/arch/sim/machine.c
src/arch/sp3/machine.c
src/arch/t3e/machine.c
src/arch/uth/machine.c
src/ck-core/debug-message.C
src/conv-core/convcore.c
src/conv-core/cpthreads.c
src/conv-core/fifo.c
src/conv-core/fifo.h

index c11da03eaed3a58311f2c429e69408e9eca32b9e..40b51f9b4413985951a94e5b26e9e1b6f5656ee8 100644 (file)
@@ -3,6 +3,7 @@
 #include <cps.h>
 #include <math.h>
 #include "converse.h"
+#include "fifo.h"
 
 
 #define BLK_LEN                512
index 600eef172697c9a8da4a8795f5aacc8a3a7bd7af..feb58ac259f81ba14f0db70f5d19fa6e0cef1602 100644 (file)
@@ -2,6 +2,7 @@
 #include <sys/time.h>
 #include "converse.h"
 #include <mpi.h>
+#include "fifo.h"
 
 #define FLIPBIT(node,bitnumber) (node ^ (1 << bitnumber))
 #define MAX_QLEN 200
index 868592fca562665b3ef0d291f8da63cdac5c7d58..42bc84e4dd115c8854fbf956e2c95e646054dfe6 100644 (file)
@@ -1,5 +1,6 @@
 #include <stdio.h>
 #include "converse.h"
+#include "fifo.h"
 
 #define MSG_TYPE 1
 
index 18ce88072fe7e9ef07adb4d7d1950c4381ac38a3..d20917f8d534244c31d7349e5b7439542f127d8a 100644 (file)
@@ -215,6 +215,8 @@ int  CmiScanf();
 #include <sys/time.h>
 #include <varargs.h>
 
+#include "fifo.h"
+
 #if CMK_STRINGS_USE_STRINGS_H
 #include <strings.h>
 #endif
@@ -233,12 +235,6 @@ static void CommunicationServer();
 extern int CmemInsideMem();
 extern void CmemCallWhenMemAvail();
 void ConverseInitPE(void);
-void *FIFO_Create(void);
-int   FIFO_Fill(void *);
-void *FIFO_Peek(void *);
-void  FIFO_Pop(void *);
-void  FIFO_EnQueue(void *, void *);
-void  FIFO_EnQueue_Front(void *, void *);
 void CmiYield();
 
 /****************************************************************************
index 36ee7abdcd5399dbf858dab758ce998266de50b8..18f8e648d971fa739315ab4c64aea1115357cf4a 100644 (file)
@@ -13,9 +13,7 @@
 #include <unistd.h>
 
 #include "converse.h"
-
-extern void *FIFO_Create(void);
-extern void FIFO_EnQueue(void *, void *);
+#include "fifo.h"
 
 #define BLK_LEN  512
 
index 6729edb03f65d962ab59674bb17a9375917ee555..a50b9170fdc764ab7400806dff499937aad2da46 100644 (file)
@@ -8,13 +8,11 @@
 #include <stdlib.h>
 #include "converse.h"
 #include <time.h>
+#include "fifo.h"
 
 usptr_t *arena;
 static barrier_t *barr;
 
-extern void *FIFO_Create(void);
-extern void FIFO_EnQueue(void *, void *);
-
 #define BLK_LEN  512
 typedef struct {
   usema_t  *sema;
index 91a9a6f4590229c68eb48e838e660d89de492955..35ac3a2196e44561b003473fe3c0c914b51b6250 100644 (file)
@@ -1,6 +1,7 @@
 #include <nx.h>
 #include <math.h>
 #include "converse.h"
+#include "fifo.h"
 
 #define MSG_TYPE 1
 #define PROCESS_PID 0
index de1f397af778b6bed05dd98a306901eb05fad753..f5c41e557db0fb79d4cc94f8d7448996ae70bb7b 100644 (file)
@@ -2,6 +2,7 @@
 #include <math.h>
 #include "machine.h"
 #include "converse.h"
+#include "fifo.h"
 
 #if CMK_TIMER_SIM_USE_TIMES
 #include <sys/times.h>
index cf5a023269de1af7058552804bc7e3ea5367eae7..6a5a47ab05c045e6e37d07df449a19ef8bbb8e42 100644 (file)
@@ -3,6 +3,7 @@
 #include "converse.h"
 #include <mpproto.h>
 #include <sys/systemcfg.h>
+#include "fifo.h"
 
 #define FLIPBIT(node,bitnumber) (node ^ (1 << bitnumber))
 
index c94390cdfe3137e3e4fb5d55f9eb1a055d13bc9d..66be0c91c1619f34e57a3d889a013e97fa3282fb 100644 (file)
@@ -9,6 +9,7 @@
 #include <malloc.h>
 #include <mpp/shmem.h>
 #include "converse.h"
+#include "fifo.h"
 
 /*
  *  We require statically allocated variables for locks.  This defines
@@ -36,9 +37,6 @@ int Cmi_myrank;
  * to my own node efficiently.  These are used when 
  * CMK_CMIDELIVERS_USE_COMMON_CODE is true.
  */
-extern void *FIFO_Create(void);
-extern void FIFO_EnQueue(void *, void *);
-
 /*
  * Distributed list declarations.  This linked list goes across machines,
  * storing all the messages for this node until this processor copies them
index af416311110380cfb0ba8169e2f9dce6bdf4d790..dc21a3158da0c29fdb073979a2ea8b3c10f02538 100644 (file)
@@ -1,6 +1,7 @@
 #include <stdio.h>
 #include <math.h>
 #include "converse.h"
+#include "fifo.h"
 
 static char *DeleteArg(argv)
   char **argv;
@@ -37,8 +38,6 @@ void CmiAbort(const char *message)
  * 
  ****************************************************************************/
 
-typedef void *Fifo;
-
 int        Cmi_mype;
 int        Cmi_myrank;
 int        Cmi_numpes;
@@ -48,12 +47,11 @@ char     **CmiArgv;
 CmiStartFn CmiStart;
 int        CmiUsched;
 CthThread *CmiThreads;
-Fifo      *CmiQueues;
+void*      *CmiQueues;
 int       *CmiBarred;
 int        CmiNumBarred=0;
 
-Fifo FIFO_Create();
-CpvDeclare(Fifo, CmiLocalQueue);
+CpvDeclare(void*, CmiLocalQueue);
 
 /******************************************************************************
  *
@@ -377,7 +375,7 @@ int usched, initret;
   CpvInitialize(void*, CmiLocalQueue);
   CmiThreads = (CthThread *)CmiAlloc(CmiNumPes()*sizeof(CthThread));
   CmiBarred  = (int       *)CmiAlloc(CmiNumPes()*sizeof(int));
-  CmiQueues  = (Fifo      *)CmiAlloc(CmiNumPes()*sizeof(Fifo));
+  CmiQueues  = (void**)CmiAlloc(CmiNumPes()*sizeof(void*));
   
   /* Create threads for all PE except PE 0 */
   for(i=0; i<CmiNumPes(); i++) {
index c392d7c0e3785dc823dfc46704097af536cda5ca..49e26e71286cf5a34a3ca62c457a373327f1f7f4 100644 (file)
@@ -33,7 +33,6 @@ extern char* getEnvInfo(envelope *env);
 extern char* getSymbolTableInfo(void);
 
 extern "C" void  CqsEnumerateQueue(Queue, void ***);
-extern "C" void  FIFO_Enumerate(FIFO_QUEUE*, void***);
 
 CpvDeclare(handlerType, handlerArray);
 
index 0b26f661e463cee2206acac7e91e696ad2909033..e52270d6dc1845ba0b0bfb97253fb244f86881eb 100644 (file)
@@ -27,6 +27,7 @@
 #include <sys/resource.h>
 #endif
 
+#include "fifo.h"
 
 /*****************************************************************************
  *
@@ -1037,8 +1038,6 @@ static void CpdDebugHandler(char *msg)
   }
 }
 
-void *FIFO_Create(void);
-
 void CpdInit(void)
 {
   CpvInitialize(int, freezeModeFlag);
@@ -1563,13 +1562,13 @@ int CsdScheduler(int maxmsgs)
         /* If the debugQueue contains any messages, process them */
         while((!FIFO_Empty(CpvAccess(debugQueue))) && (CpvAccess(freezeModeFlag)==0)){
           char *queuedMsg;
-          FIFO_DeQueue(CpvAccess(debugQueue), &queuedMsg);
+          FIFO_DeQueue(CpvAccess(debugQueue), (void **)&queuedMsg);
           CmiHandleMessage(queuedMsg);
           maxmsgs--; if (maxmsgs==0) return maxmsgs;
         }
       }
 #endif
-      if (msg==0) FIFO_DeQueue(localqueue, &msg);
+      if (msg==0) FIFO_DeQueue(localqueue, (void **)&msg);
 #if CMK_NODE_QUEUE_AVAILABLE
       if (msg==0) {
        CmiLock(CsvAccess(NodeQueueLock));
@@ -1616,13 +1615,13 @@ int CsdScheduler(int maxmsgs)
       /* If the debugQueue contains any messages, process them */
       while(((!FIFO_Empty(CpvAccess(debugQueue))) && (CpvAccess(freezeModeFlag)==0))){
         char *queuedMsg;
-       FIFO_DeQueue(CpvAccess(debugQueue), &queuedMsg);
+       FIFO_DeQueue(CpvAccess(debugQueue), (void**)&queuedMsg);
        CmiHandleMessage(queuedMsg);
        maxmsgs--; if (maxmsgs==0) return maxmsgs;      
       }
     }
 #endif
-    if (msg==0) FIFO_DeQueue(localqueue, &msg);
+    if (msg==0) FIFO_DeQueue(localqueue, (void**)&msg);
 #if CMK_NODE_QUEUE_AVAILABLE
     if (msg==0) {
       CmiLock(CsvAccess(NodeQueueLock));
@@ -1665,7 +1664,7 @@ int handler;
   while (1) {
     side ^= 1;
     if (side) msg = CmiGetNonLocal();
-    else      FIFO_DeQueue(localqueue, &msg);
+    else      FIFO_DeQueue(localqueue, (void**)&msg);
     if (msg) {
       if (CmiGetHandler(msg)==handler) {
        CsdEndIdle();
index d95e6e0ada97580008eb91f720659f06de9842b7..9c95b4415ae0f97403dddccfbe9cbeb72a2424a3 100644 (file)
@@ -23,6 +23,7 @@
 #define SUPPRESS_PTHREADS
 #include "cpthreads.h"
 #include <sys/errno.h>
+#include "fifo.h"
 
 /******************************************************************************
  *
@@ -421,7 +422,6 @@ int Cpthread_mutexattr_setpshared(Cpthread_mutexattr_t *mattr, int pshared)
 
 int Cpthread_mutex_init(Cpthread_mutex_t *mutex, Cpthread_mutexattr_t *mattr)
 {
-  extern void *FIFO_Create();
   if (mattr->magic != MATTR_MAGIC) errcode(EINVAL);
   mutex->magic = MUTEX_MAGIC;
   mutex->onpe = CmiMyPe();
@@ -441,7 +441,6 @@ int Cpthread_mutex_destroy(Cpthread_mutex_t *mutex)
 
 int Cpthread_mutex_lock(Cpthread_mutex_t *mutex)
 {
-  extern CthThread FIFO_Peek(void *);
   CthThread self = CthSelf();
   if (mutex->magic != MUTEX_MAGIC) errcode(EINVAL);
   if (mutex->onpe != CmiMyPe()) errspan();
@@ -462,7 +461,6 @@ int Cpthread_mutex_trylock(Cpthread_mutex_t *mutex)
 
 int Cpthread_mutex_unlock(Cpthread_mutex_t *mutex)
 {
-  extern CthThread FIFO_Peek(void *);
   CthThread self = CthSelf();
   CthThread sleeper;
   if (mutex->magic != MUTEX_MAGIC) errcode(EINVAL);
@@ -508,7 +506,6 @@ int Cpthread_condattr_setpshared(Cpthread_condattr_t *cattr, int pshared)
 
 int Cpthread_cond_init(Cpthread_cond_t *cond, Cpthread_condattr_t *cattr)
 {
-  extern void *FIFO_Create();
   if (cattr->magic != CATTR_MAGIC) errcode(EINVAL);
   cond->magic = COND_MAGIC;
   cond->onpe = CmiMyPe();
@@ -527,7 +524,6 @@ int Cpthread_cond_destroy(Cpthread_cond_t *cond)
 
 int Cpthread_cond_wait(Cpthread_cond_t *cond, Cpthread_mutex_t *mutex)
 {
-  extern CthThread FIFO_Peek(void *);
   CthThread self = CthSelf();
   CthThread sleeper;
 
@@ -552,7 +548,7 @@ int Cpthread_cond_signal(Cpthread_cond_t *cond)
   CthThread sleeper;
   if (cond->magic != COND_MAGIC) errcode(EINVAL);
   if (cond->onpe != CmiMyPe()) errspan();
-  FIFO_DeQueue(cond->users, &sleeper);
+  FIFO_DeQueue(cond->users, (void**)&sleeper);
   if (sleeper) CthAwaken(sleeper);
   return 0;
 }
@@ -563,7 +559,7 @@ int Cpthread_cond_broadcast(Cpthread_cond_t *cond)
   if (cond->magic != COND_MAGIC) errcode(EINVAL);
   if (cond->onpe != CmiMyPe()) errspan();
   while (1) {
-    FIFO_DeQueue(cond->users, &sleeper);
+    FIFO_DeQueue(cond->users, (void**)&sleeper);
     if (sleeper==0) break;
     CthAwaken(sleeper);
   }
index d4d73c8454c626f5ebab8faa7c5fb17271da00dd..aee7edd78f9c481946bf64df5926cfa942526bb8 100644 (file)
@@ -1,34 +1,30 @@
-
-#include <stdio.h>
+#include <stdlib.h>
 #include "converse.h"
 #include "fifo.h"
 
 
-void *FIFO_Create()
+FIFO_QUEUE *FIFO_Create(void)
 {
   FIFO_QUEUE *queue;
   queue = (FIFO_QUEUE *)malloc(sizeof(FIFO_QUEUE));
-  queue->block = (void **) malloc(BLK_LEN * sizeof(void *));
-  queue->size = BLK_LEN;
+  queue->block = (void **) malloc(_FIFO_BLK_LEN * sizeof(void *));
+  queue->size = _FIFO_BLK_LEN;
   queue->push = queue->pull = 0;
   queue->fill = 0;
-  return (void *)queue;
+  return queue;
 }
 
-int FIFO_Fill(queue)
-     FIFO_QUEUE *queue;
+int FIFO_Fill(FIFO_QUEUE *queue)
 {
   return queue->fill;
 }
 
-int FIFO_Empty(queue)
-     FIFO_QUEUE *queue;
+int FIFO_Empty(FIFO_QUEUE *queue)
 {
-  return (queue->fill == 0) ? 1 : 0;
+  return !(queue->fill);
 }
 
-void FIFO_Expand(queue)
-     FIFO_QUEUE *queue;
+static void FIFO_Expand(FIFO_QUEUE *queue)
 {
   int newsize; void **newblock; int rest;
   int    pull  = queue->pull;
@@ -47,9 +43,7 @@ void FIFO_Expand(queue)
   queue->fill = size;
 }
 
-void FIFO_EnQueue(queue, elt)
-     FIFO_QUEUE *queue;
-     void       *elt;
+void FIFO_EnQueue(FIFO_QUEUE *queue, void *elt)
 {
   if (queue->fill == queue->size) FIFO_Expand(queue);
   queue->block[queue->push] = elt;
@@ -57,9 +51,7 @@ void FIFO_EnQueue(queue, elt)
   queue->fill++;
 }
 
-void FIFO_EnQueue_Front(queue, elt)
-     FIFO_QUEUE *queue;
-     void *elt;
+void FIFO_EnQueue_Front(FIFO_QUEUE *queue, void *elt)
 {
   if (queue->fill == queue->size) FIFO_Expand(queue);
   queue->pull = ((queue->pull + queue->size - 1) % queue->size);
@@ -67,15 +59,13 @@ void FIFO_EnQueue_Front(queue, elt)
   queue->fill++;
 }
 
-void *FIFO_Peek(queue)
-     FIFO_QUEUE *queue;
+void *FIFO_Peek(FIFO_QUEUE *queue)
 {
   if (queue->fill == 0) return 0;
   return queue->block[queue->pull];
 }
 
-void FIFO_Pop(queue)
-     FIFO_QUEUE *queue;
+void FIFO_Pop(FIFO_QUEUE *queue)
 {
   if (queue->fill) {
     queue->pull = (queue->pull+1) % queue->size;
@@ -83,24 +73,21 @@ void FIFO_Pop(queue)
   }
 }
 
-void FIFO_DeQueue(queue, element)
-     FIFO_QUEUE     *queue;
-     void      **element;
+void FIFO_DeQueue(FIFO_QUEUE *queue, void **element)
 {
+  *element = 0;
   if (queue->fill) {
     *element = queue->block[queue->pull];
     queue->pull = (queue->pull+1) % queue->size;
     queue->fill--;
-  } else *element = 0;
+  }
 }
 
 
 /* This assumes the the caller has not allocated
    memory for element 
 */
-void FIFO_Enumerate(queue, element)
-     FIFO_QUEUE     *queue;
-     void      ***element;
+void FIFO_Enumerate(FIFO_QUEUE *queue, void ***element)
 {
   int i = 0;
   int num = queue->fill;
@@ -116,8 +103,7 @@ void FIFO_Enumerate(queue, element)
   }
 }
 
-void FIFO_Destroy(queue)
-     FIFO_QUEUE *queue;
+void FIFO_Destroy(FIFO_QUEUE *queue)
 {
   if (!FIFO_Empty(queue)) {
     CmiError("Tried to FIFO_Destroy a non-empty queue.\n");
index a474f17b737e9ca7185c4e0196a9b29be8773dc6..0d434b5e936be2a11cdec2d5249addd2d61fbf70 100644 (file)
@@ -9,7 +9,25 @@ typedef struct fifo_queue {
   unsigned int fill;
 } FIFO_QUEUE;
 
+#define _FIFO_BLK_LEN 512
 
-#define BLK_LEN 512
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+FIFO_QUEUE *FIFO_Create(void);
+int FIFO_Fill(FIFO_QUEUE *);
+int FIFO_Empty(FIFO_QUEUE *);
+void FIFO_EnQueue(FIFO_QUEUE *queue, void *elt);
+void FIFO_EnQueue_Front(FIFO_QUEUE *queue, void *elt);
+void *FIFO_Peek(FIFO_QUEUE *queue);
+void FIFO_Pop(FIFO_QUEUE *queue);
+void FIFO_DeQueue(FIFO_QUEUE *queue, void **element);
+void FIFO_Enumerate(FIFO_QUEUE *queue, void ***element);
+void FIFO_Destroy(FIFO_QUEUE *queue);
+
+#ifdef __cplusplus
+};
+#endif
 
 #endif