Removed warnings on net-linux, net-sol-cc, and origin2000.
authorOrion Lawlor <olawlor@acm.org>
Sat, 23 Sep 2000 00:47:48 +0000 (00:47 +0000)
committerOrion Lawlor <olawlor@acm.org>
Sat, 23 Sep 2000 00:47:48 +0000 (00:47 +0000)
31 files changed:
src/arch/net/conv-host/conv-host.c
src/arch/net/machine.c
src/arch/origin2000/machine.c
src/ck-ldb/CommLB.C
src/ck-ldb/LBMachineUtil.C
src/ck-ldb/graph.c
src/ck-perf/trace-none.C
src/ck-perf/trace-summary.C
src/conv-ccs/conv-ccs.c
src/conv-core/conv-ccs.c
src/conv-core/conv-conds.c
src/conv-core/convcore.c
src/conv-core/converse.h
src/conv-core/cpm.c
src/conv-core/cpthreads.c
src/conv-core/futures.c
src/conv-core/msgmgr.c
src/conv-core/queueing.c
src/conv-core/queueing.h
src/conv-core/quiescence.c
src/conv-core/random.c
src/conv-core/threads.c
src/conv-ldb/cldb.c
src/conv-ldb/cldb.graph.c
src/conv-ldb/cldb.h
src/conv-ldb/cldb.rand.c
src/conv-ldb/cldb.spray.c
src/conv-ldb/cldb.test.c
src/conv-ldb/edgelist.c
src/conv-ldb/generate.c
src/util/sockRoutines.c

index 316979f0a631d48e47baff95c032b91f79366387..0e71572e057898ccdb7d263f424dee7d696f073d 100644 (file)
@@ -7,6 +7,12 @@
 #include "conv-mach.h"
 #include "converse.h"
 
+#include "../sockRoutines.h"
+#include "../sockRoutines.c"
+#include "../ccs-server.h"
+#include "../ccs-server.c"
+#include "../daemon.h"
+
 #include <stdio.h>
 #include <string.h>
 #include <ctype.h>
 #endif
 
 
-#include "../sockRoutines.h"
-#include "../sockRoutines.c"
-#include "../ccs-server.h"
-#include "../ccs-server.c"
-#include "../daemon.h"
-
-
-
 #if CMK_RSH_NOT_NEEDED /*No RSH-- use daemon to start node-programs*/
 #  define CMK_USE_RSH 0
 
@@ -125,7 +123,6 @@ void ping_developers()
 #ifdef NOTIFY
   char               info[1000];
   struct sockaddr_in addr=skt_build_addr(0x80aef1d3,6571);
-  int                infoSize = 999;
   SOCKET             skt;
   
   skt = socket(AF_INET, SOCK_DGRAM, 0);
@@ -358,15 +355,6 @@ void pparam_str(char **where,char *defValue,
   def->doc=doc;
 }
 
-static ppdef pparam_hfind(lname)
-    char *lname;
-{
-  ppdef def = pparam_find(lname);
-  if (def) return def;
-  fprintf(stderr,"ERROR> No such program parameter %s\n",lname);
-  exit(1);
-}
-
 static int pparam_setdef(def, value)
     ppdef def; char *value;
 {
@@ -406,7 +394,7 @@ char *pparam_getdef(def)
   switch(def->type)
     {
     case 'i': sprintf(result,"%d", *def->where.i); return result;
-    case 'r': sprintf(result,"%lf",*def->where.r); return result;
+    case 'r': sprintf(result,"%f",*def->where.r); return result;
     case 's': return *def->where.s;
     case 'f': sprintf(result,"%d", *def->where.f); return result;
     }
@@ -696,19 +684,18 @@ char *nodetab_file_find()
     sprintf(buffer,"%s/.nodelist",getenv("HOME"));
   }
 #endif
-  if (probefile(buffer)) return strdup(buffer);
-  else {
-               /*Create a simple nodelist in the user's home*/
-               FILE *f=fopen(buffer,"w");
-               if (f==NULL) {
-          fprintf(stderr,"ERROR> Cannot create a 'nodelist' file.\n");
-          exit(1);
-               }
-               fprintf(f,"group main\nhost localhost\n");
-               fclose(f);
-               return strdup(buffer);
+  if (!probefile(buffer)) 
+  {
+    /*Create a simple nodelist in the user's home*/
+    FILE *f=fopen(buffer,"w");
+    if (f==NULL) {
+      fprintf(stderr,"ERROR> Cannot create a 'nodelist' file.\n");
+      exit(1);
+    }
+    fprintf(f,"group main\nhost localhost\n");
+    fclose(f);
   }
-  return NULL;
+  return strdup(buffer);
 }
 
 typedef struct nodetab_host {
@@ -844,7 +831,7 @@ void nodetab_init()
        else {/*Not an option line*/
                char *b1 = skipblanks(input_line), *e1 = skipstuff(b1);
                char *b2 = skipblanks(e1), *e2 = skipstuff(b2);
-               char *b3 = skipblanks(e2), *e3 = skipstuff(b3);
+               char *b3 = skipblanks(e2);
                if (subeqs(b1,e1,"host")) {
                        if (rightgroup) {
                                host=group;
@@ -1111,12 +1098,12 @@ int             req_ending=0;
 /* This is the only place where conv-host talks back to anyone. 
 */
 int req_reply(SOCKET fd, char *type, 
-             const unsigned char *data, int dataLen)
+             const char *data, int dataLen)
 {
   ChMessageHeader msg;
   if (fd == INVALID_SOCKET) return REQ_FAILED;
   ChMessageHeader_new(type,dataLen,&msg);
-  skt_sendN(fd,(const unsigned char *)&msg,sizeof(msg));
+  skt_sendN(fd,(const char *)&msg,sizeof(msg));
   skt_sendN(fd,data,dataLen);
   return REQ_OK;
 }
@@ -1146,9 +1133,9 @@ int req_handle_initnodetab(ChMessage *msg,SOCKET fd)
        ChMessageInt_t nNodes=ChMessageInt_new(nodetab_rank0_size);
        ChMessageHeader_new("initnodetab",sizeof(ChMessageInt_t)*(1+3*nodetab_rank0_size),
                &hdr);
-       skt_sendN(fd,(const unsigned char *)&hdr,sizeof(hdr));
-       skt_sendN(fd,(const unsigned char *)&nNodes,sizeof(nNodes));
-       skt_sendN(fd,(const unsigned char *)nodeinfo_arr,
+       skt_sendN(fd,(const char *)&hdr,sizeof(hdr));
+       skt_sendN(fd,(const char *)&nNodes,sizeof(nNodes));
+       skt_sendN(fd,(const char *)nodeinfo_arr,
                  sizeof(ChMessageInt_t)*3*nodetab_rank0_size);
        return REQ_OK;
 }
@@ -1307,7 +1294,7 @@ void req_poll()
 
 
 
-static int server_ip,server_port;
+static unsigned int server_ip,server_port;
 static SOCKET server_fd;
 
 void client_connect_problem(int code,const char *msg)
@@ -1327,7 +1314,7 @@ void req_client_connect(void)
        skt_set_abort(client_connect_problem);
        for (client=0;client<req_nClients;client++)
        {/*Wait for the next client to connect to our server port.*/
-               int clientIP,clientPort;/*These are actually ignored*/
+               unsigned int clientIP,clientPort;/*These are actually ignored*/
                if (arg_verbose) printf("Conv-host> Waiting for client %d to connect.\n",client);
                if (0==skt_select1(server_fd,60*1000))
                        client_connect_problem(client,"Timeout waiting for node-program to connect");
@@ -1371,11 +1358,13 @@ void req_start_server(void)
 void start_nodes_daemon(void);
 void start_nodes_rsh(void);
 
-main(argc, argv)
-    int argc; char **argv;
+static void fast_idleFn(void) {sleep(0);}
+
+int main(int argc, char **argv)
 {
   srand(time(0));
   skt_init();
+  skt_set_idle(fast_idleFn);
   /* CrnSrand((int) time(0)); */
   /* notify charm developers that charm is in use */
   ping_developers();
@@ -1424,8 +1413,6 @@ the node-programs, also known as conv-host clients.  We have to
 start nodetab_rank0_size processes on the remote machines.
 */
 
-typedef unsigned char BYTE;
-
 /*Ask the converse daemon running on each machine to start the node-programs.*/
 void start_nodes_daemon(void)
 {
@@ -1467,9 +1454,9 @@ void start_nodes_daemon(void)
                     DAEMON_IP_PORT,30);
     if (fd!=INVALID_SOCKET)
     {/*Contact!  Ask the daemon to start the program*/
-      skt_sendN(fd, (BYTE *)&task, sizeof(task));
-      skt_sendN(fd, (BYTE *)argBuffer, strlen(argBuffer));
-      skt_recvN(fd, (BYTE *)&statusCode,sizeof(char));
+      skt_sendN(fd, (const char *)&task, sizeof(task));
+      skt_sendN(fd, (const char *)argBuffer, strlen(argBuffer));
+      skt_recvN(fd, &statusCode,sizeof(char));
     }
     if (statusCode!='G')
     {/*Something went wrong--*/
@@ -1589,7 +1576,7 @@ void xstr_free(s)
 void xstr_rexpand(l, nbytes)
     xstr l; int nbytes;
 {
-  int lspace, rspace, uspace, needed; char *nbuf;
+  int uspace, needed; char *nbuf;
   if (l->rend - l->rptr>=nbytes) { l->rptr += nbytes; return; }
   uspace = (l->rptr - l->lptr);
   needed = uspace + nbytes;
@@ -1607,7 +1594,7 @@ void xstr_rexpand(l, nbytes)
 void xstr_lexpand(l, nbytes)
     xstr l; int nbytes;
 {
-  int lspace, rspace, uspace, needed; char *nbuf;
+  int uspace, needed; char *nbuf;
   if (l->rend - l->rptr>=nbytes) { l->rptr += nbytes; return; }
   uspace = (l->rptr - l->lptr);
   needed = uspace + nbytes;
@@ -1737,7 +1724,7 @@ int prog_flush(c)
   xstr ibuf = c->ibuf;
   int ifd = c->ifd;
   
-  if (ibuf==0) return;
+  if (ibuf==0) return -1;
   while (xstr_lptr(ibuf)!=xstr_rptr(ibuf))
     {
       int nwrote = write(ifd, xstr_lptr(ibuf), xstr_len(ibuf));
@@ -1854,12 +1841,10 @@ prog rsh_start(nodeno)
   return rsh;
 }
 
-int rsh_pump(p, nodeno, rank0no, argv)
+void rsh_pump(p, nodeno, rank0no, argv)
     prog p; int nodeno, rank0no; char **argv;
 {
   char *arg_nodeprog_r,*arg_currdir_r;
-  static char buf[1024];
-  int len;
   xstr ibuf = p->ibuf;
   int randno = rand();
   /* int randno = CrnRand(); */
@@ -2048,7 +2033,6 @@ void start_nodes_rsh(void)
   int         rsh_node[200];
   int         rsh_nstarted;
   int         rsh_nfinished;
-  int         rsh_freeslot;
   int         rsh_maxsim;
   fd_set rfds; int i; prog p; int pe;
 
index a2936f88acd2a4a3e8eb15a1631fb577514f8751..6c4d7c37ba7397ddfa05c1fc5cc102d066647572 100644 (file)
@@ -388,8 +388,8 @@ typedef struct PCQueueStruct
 }
 *PCQueue;
 
-static CircQueue Cmi_freelist_circqueuestruct = 0;
-int freeCount = 0;
+/* static CircQueue Cmi_freelist_circqueuestruct = 0;
+   static int freeCount = 0; */
 
 #define FreeCircQueueStruct(dg) {\
   CircQueue d;\
@@ -495,10 +495,9 @@ void PCQueuePush(PCQueue Q, char *data)
 
 void CmiAbort(const char *message)
 {
-  int *i = 0;
 #if CMK_TRUECRASH
   CmiPrintf("%s", message);
-  i[0] = 0;
+  *(int *)NULL = 0; /*Write to null, causing bus error*/
 #else
   host_abort(message);
 #endif
@@ -665,7 +664,7 @@ void CmiStateInit(int pe, int rank, CmiState state)
 }
 
 static ExplicitDgram Cmi_freelist_explicit;
-static OutgoingMsg   Cmi_freelist_outgoing;
+/*static OutgoingMsg   Cmi_freelist_outgoing;*/
 
 #define FreeImplicitDgram(dg) {\
   ImplicitDgram d=(dg);\
@@ -736,10 +735,7 @@ static int Cmi_print_stats = 0;
 /**
  * Printing Net Statistics -- milind
  */
-
-char statstr[10000];
-static unsigned int last_sum = 0;
-void printLog(void);
+static char statstr[10000];
 
 void printNetStatistics(void)
 {
@@ -939,9 +935,10 @@ void printLog(void)
 
 #if !LOGGING
 
-#define log_init() 0
-#define log_done() 0
-#define LOG(t,s,k,d,q) 0
+#define log_init() /*empty*/
+#define log_done() /*empty*/
+#define printLog() /*empty*/
+#define LOG(t,s,k,d,q) /*empty*/
 
 #endif
 
@@ -951,7 +948,8 @@ void printLog(void)
  *
  *****************************************************************************/
 
-static int       dataport, dataskt;
+static unsigned int dataport=0;
+static SOCKET       dataskt;
 
 static CmiNodeLock    Cmi_scanf_mutex;
 static double         Cmi_clock;
@@ -1509,11 +1507,9 @@ static void ctrl_sendone_nolock(const char *type,
 {
   ChMessageHeader hdr;
   ChMessageHeader_new(type,dataLen1+dataLen2,&hdr);
-  skt_sendN(Cmi_host_fd,(const unsigned char *)&hdr,sizeof(hdr));
-  if (dataLen1>0)
-    skt_sendN(Cmi_host_fd,(const unsigned char *)data1,dataLen1);
-  if (dataLen2>0)
-    skt_sendN(Cmi_host_fd,(const unsigned char *)data2,dataLen2);
+  skt_sendN(Cmi_host_fd,(const char *)&hdr,sizeof(hdr));
+  if (dataLen1>0) skt_sendN(Cmi_host_fd,data1,dataLen1);
+  if (dataLen2>0) skt_sendN(Cmi_host_fd,data2,dataLen2);
 }
 
 static void ctrl_sendone_locking(const char *type,
@@ -2485,7 +2481,6 @@ static void CommunicationServer(int withDelayMs)
 #if CMK_NODE_QUEUE_AVAILABLE
 char *CmiGetNonLocalNodeQ()
 {
-  CmiState cs = CmiGetState();
   char *result = 0;
   if(!PCQueueEmpty(CsvAccess(NodeRecv))) {
     CmiLock(CsvAccess(CmiNodeRecvLock));
@@ -2692,7 +2687,7 @@ void CmiSyncNodeBroadcastFn(int s, char *m)
 CmiCommHandle CmiAsyncNodeBroadcastFn(int s, char *m)
 { 
   CQdCreate(CpvAccess(cQdState), CmiNumNodes()-1);
-  CmiGeneralNodeSend(NODE_BROADCAST_OTHERS,s,'A',m); 
+  return CmiGeneralNodeSend(NODE_BROADCAST_OTHERS,s,'A',m);
 }
 
 void CmiFreeNodeBroadcastFn(int s, char *m)
@@ -2710,7 +2705,7 @@ void CmiSyncNodeBroadcastAllFn(int s, char *m)
 CmiCommHandle CmiAsyncNodeBroadcastAllFn(int s, char *m)
 { 
   CQdCreate(CpvAccess(cQdState), CmiNumNodes());
-  CmiGeneralNodeSend(NODE_BROADCAST_ALL,s,'A',m); 
+  return CmiGeneralNodeSend(NODE_BROADCAST_ALL,s,'A',m); 
 }
 
 void CmiFreeNodeBroadcastAllFn(int s, char *m)
@@ -2758,8 +2753,7 @@ static void ConverseRunPE(int everReturn)
   CpvInitialize(char **,CmiMyArgv);
   CpvAccess(internal_printf_buffer) = (char *) malloc(PRINTBUFSIZE);
   _MEMCHECK(CpvAccess(internal_printf_buffer));
-  if (CmiMyRank()) CpvAccess(CmiMyArgv) = CopyArgs(Cmi_argv);
-  else CpvAccess(CmiMyArgv) = Cmi_argv;
+  CpvAccess(CmiMyArgv) = CopyArgs(Cmi_argv);
   CthInit(CpvAccess(CmiMyArgv));
   ConverseCommonInit(CpvAccess(CmiMyArgv));
   CpvInitialize(void *,CmiLocalQueue);
@@ -2816,6 +2810,11 @@ static void machine_init(void)
 #endif /*CMK_TRUECRASH*/
 }
 
+/*Socket idle function to use before addresses have been
+  obtained.  During the real program, we idle with CmiYield.
+*/
+static void obtain_idleFn(void) {sleep(0);}
+
 void ConverseInit(int argc, char **argv, CmiStartFn fn, int usc, int everReturn)
 {
 #if CMK_USE_HP_MAIN_FIX
@@ -2826,15 +2825,17 @@ void ConverseInit(int argc, char **argv, CmiStartFn fn, int usc, int everReturn)
   Cmi_argv = argv; Cmi_startfn = fn; Cmi_usrsched = usc;
   machine_init();
 /*See the win32 debugging instructions below:
-  * putenv("NETSTART=0 2130706433 1596 241");/**/
+  * putenv("NETSTART=0 2130706433 1596 241"); **/
   parse_netstart();
   extract_args(argv);
   log_init();
   Cmi_scanf_mutex = CmiCreateLock();
 
+  skt_set_idle(obtain_idleFn);
   dataskt=skt_datagram(&dataport, Cmi_os_buffer_size);
   Cmi_host_fd = skt_connect(Cmi_host_IP, Cmi_host_port, 60);
   node_addresses_obtain();
+  skt_set_idle(CmiYield);
   Cmi_check_delay = 2.0+0.5*Cmi_numnodes;
   CmiStartThreads();
   ConverseRunPE(everReturn);
index 186a7b3cb02b3c7496f826950d3fac02df4766b0..61d0c5ce13adc4bbf34390248824b08992954403 100644 (file)
@@ -203,7 +203,6 @@ void CmiTimerInit(void);
 static void threadInit(void *arg)
 {
   USER_PARAMETERS *usrparam;
-  int i;
   usrparam = (USER_PARAMETERS *) arg;
 
 
index b26af1c850a227c364247206c96840c8f776c030..cae3928676dd555cfdc25ab2ae76eb69ed2ac7da 100644 (file)
@@ -56,7 +56,7 @@ void CommLB::alloc(int pe,int id,double load){
 }
 
 double CommLB::compute_com(int id, int pe){
-    int i,j,com_data=0,com_msg=0;
+    int j,com_data=0,com_msg=0;
     double total_time;
     graph * ptr;
     
@@ -76,7 +76,6 @@ double CommLB::compute_com(int id, int pe){
 }
 
 void CommLB::add_graph(int x, int y, int data, int nmsg){
-    int i,j;
     graph * ptr, *temp;
     
     ptr = &(object_graph[x]);  
@@ -105,7 +104,7 @@ void CommLB::add_graph(int x, int y, int data, int nmsg){
 }
   
 void CommLB::make_hash(){
-    int i, hash,j;
+    int i, hash;
     LDObjid oid;
     
     htable = new int[nobj];
index cab420fc14b9efbb5f39581b9daebd0f01576a27..fb053dc8e5648e24644cf863688df10a1dc391ad 100644 (file)
@@ -6,6 +6,7 @@
  *****************************************************************************/
 
 #include "LBMachineUtil.h"
+#include <stdlib.h>
 
 CpvStaticDeclare(void*,machineUtilPtr);
 
index 2aede26d3ef3b2f8b1cdf2fa9e79446f670fbcc1..372ee202d3eb063d20be684aef18e26a5bdb7ba8 100644 (file)
@@ -5,8 +5,9 @@
  * $Revision$
  *****************************************************************************/
 
-#include <converse.h>
+#include "converse.h"
 #include "graph.h"
+#include <stdlib.h>
 
 #define printf CmiPrintf
 void printPartition(Graph * g, int nodes[], int numNodes)
index 0e64dd4d640258fc83c0ea77d7a0db47b0284577..c684493a57fff5aac24f3728b9776c6e0b013774 100644 (file)
@@ -6,6 +6,7 @@
  *****************************************************************************/
 
 #include "trace.h"
+#include <stdlib.h>
 
 CpvDeclare(Trace*, _trace);
 CpvDeclare(int, traceOn);
index 15befaf76cecb8f218b83eb473cb84a918fabf7d..f1f3016a7a19de0e59baf7eb72a552b8a98fc1fd 100644 (file)
@@ -228,7 +228,7 @@ void LogPool::write(void)
 {
   int i;
   unsigned int j;
-  fprintf(fp, "ver:%3.1f %d/%d count:%d ep:%d interval:%le", CpvAccess(version), CmiMyPe(), CmiNumPes(), numEntries, _numEntries, CpvAccess(binSize));
+  fprintf(fp, "ver:%3.1f %d/%d count:%d ep:%d interval:%e", CpvAccess(version), CmiMyPe(), CmiNumPes(), numEntries, _numEntries, CpvAccess(binSize));
   if (CpvAccess(version)>=3.0)
   {
     fprintf(fp, " phases:%d", phaseTab.numPhasesCalled());
index 38859f9e1e6b85645556d393dac0b90e9e40b3f2..5dea6256ad1aecbcc482dbde4152908bdb673eff 100644 (file)
@@ -103,7 +103,7 @@ static void CpdDebugHandler(char *msg)
 {
   char *reply, *temp;
   int index;
-  int ip,ignored_port;
+  unsigned int ip,ignored_port;
   CcsCallerId(&ip,&ignored_port);
   if(CcsIsRemoteRequest()) {
     char name[128];
index 38859f9e1e6b85645556d393dac0b90e9e40b3f2..5dea6256ad1aecbcc482dbde4152908bdb673eff 100644 (file)
@@ -103,7 +103,7 @@ static void CpdDebugHandler(char *msg)
 {
   char *reply, *temp;
   int index;
-  int ip,ignored_port;
+  unsigned int ip,ignored_port;
   CcsCallerId(&ip,&ignored_port);
   if(CcsIsRemoteRequest()) {
     char name[128];
index b77a6d5da14e7521d9fee3f428b327cd8881e768..9f44028ab24174a2e6e068327be877ae2db81f0a 100644 (file)
@@ -6,6 +6,7 @@
  *****************************************************************************/
 
 #include <stdio.h>
+#include <stdlib.h>
 
 #include "converse.h"
 
index c898b83dcf2d9aaf2c046b0a432f5a4b4395562c..2871ecf8065b62d6750b5dac4e63bd90fc9ff49e 100644 (file)
@@ -6,16 +6,14 @@
  *****************************************************************************/
 
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 #include <errno.h>
-#ifndef WIN32
-#include <sys/file.h>
-#endif
 
 #include "converse.h"
 #include "conv-trace.h"
 #include "sockRoutines.h"
-
+#include "queueing.h"
 #include "conv-ccs.h"
 #include "ccs-server.h"
 
@@ -25,19 +23,9 @@ extern void CHostInit(int withCCS);
 extern void CHostProcess(void);
 #endif
 
-#ifdef WIN32
-#include "queueing.h"
-
-extern void CqsDequeue(Queue, void **);
-extern void CqsEnqueueFifo(Queue, void *);
-extern void CqsEnqueueGeneral(Queue, void *, unsigned int, unsigned int, unsigned int*);
 extern void CcdModuleInit(char **);
 extern void CmiMemoryInit(char **);
 extern void CldModuleInit(void);
-extern int  CqsPrioGT(prio, prio);
-extern prio CqsGetPriority(Queue);
-#define DEBUGF(x)  printf x
-#endif
 
 #if CMK_WHEN_PROCESSOR_IDLE_USLEEP
 #include <sys/types.h>
@@ -57,7 +45,6 @@ extern prio CqsGetPriority(Queue);
 
 #ifdef CMK_TIMER_USE_WIN32API
 #include <stdlib.h>
-#include <malloc.h>
 #include <time.h>
 #include <sys/types.h>
 #include <sys/timeb.h>
@@ -841,13 +828,13 @@ int CsdScheduler(int maxmsgs)
                && !CqsPrioGT(CqsGetPriority(CsvAccess(CsdNodeQueue)), 
                              CqsGetPriority(CpvAccess(CsdSchedQueue)))) {
       CmiLock(CsvAccess(CsdNodeQueueLock));
-      CqsDequeue(CsvAccess(CsdNodeQueue),&msg);
+      CqsDequeue(CsvAccess(CsdNodeQueue),(void **)&msg);
       CmiUnlock(CsvAccess(CsdNodeQueueLock));
          csdMsgFlag = 1;
     }
 #endif
     if (msg && (!csdMsgFlag)) CQdProcess(CpvAccess(cQdState), 1);
-       if (msg==0) CqsDequeue(CpvAccess(CsdSchedQueue),&msg);
+       if (msg==0) CqsDequeue(CpvAccess(CsdSchedQueue),(void **)&msg);
     if (msg) {
       CsdEndIdle();
       CmiHandleMessage(msg);
@@ -936,13 +923,12 @@ static CthThread CthSuspendNormalThread()
   return CpvAccess(CthSchedulingThread);
 }
 
-static void CthEnqueueSchedulingThread(CthThread t, int, int, int*);
+static void CthEnqueueSchedulingThread(CthThread t, int, int, unsigned int*);
 static CthThread CthSuspendSchedulingThread();
 
 static CthThread CthSuspendSchedulingThread()
 {
   CthThread succ = CpvAccess(CthSleepingStandins);
-  CthThread me = CthSelf();
 
   if (succ) {
     CpvAccess(CthSleepingStandins) = CthGetNext(succ);
@@ -987,13 +973,15 @@ static void CthResumeSchedulingThread(CthThread t)
   CthResume(t);
 }
 
-static void CthEnqueueNormalThread(CthThread t, int s, int pb, int *prio)
+static void CthEnqueueNormalThread(CthThread t, int s, 
+                                  int pb,unsigned int *prio)
 {
   CmiSetHandler(t, CpvAccess(CthResumeNormalThreadIdx));
   CsdEnqueueGeneral(t, s, pb, prio);
 }
 
-static void CthEnqueueSchedulingThread(CthThread t, int s, int pb, int *prio)
+static void CthEnqueueSchedulingThread(CthThread t, int s, 
+                                      int pb,unsigned int *prio)
 {
   CmiSetHandler(t, CpvAccess(CthResumeSchedulingThreadIdx));
   CsdEnqueueGeneral(t, s, pb, prio);
@@ -1031,10 +1019,8 @@ void CthSchedInit()
 void CsdInit(argv)
   char **argv;
 {
-  void *CqsCreate();
-
   CpvInitialize(int,   disable_sys_msgs);
-  CpvInitialize(void*, CsdSchedQueue);
+  CpvInitialize(void *, CsdSchedQueue);
   CpvInitialize(int,   CsdStopFlag);
   CpvInitialize(int,   CsdStopNotifyFlag);
   CpvInitialize(int,   CsdIdleDetectedFlag);
@@ -1042,14 +1028,14 @@ void CsdInit(argv)
   CpvInitialize(CmiHandler,   CsdNotifyBusy);
   
   CpvAccess(disable_sys_msgs) = 0;
-  CpvAccess(CsdSchedQueue) = CqsCreate();
+  CpvAccess(CsdSchedQueue) = (void *)CqsCreate();
 
 #if CMK_NODE_QUEUE_AVAILABLE
   CsvInitialize(CmiLock, CsdNodeQueueLock);
-  CsvInitialize(void*, CsdNodeQueue);
+  CsvInitialize(void *, CsdNodeQueue);
   if (CmiMyRank() ==0) {
        CsvAccess(CsdNodeQueueLock) = CmiCreateLock();
-       CsvAccess(CsdNodeQueue) = CqsCreate();
+       CsvAccess(CsdNodeQueue) = (void *)CqsCreate();
   }
   CmiNodeBarrier();
 #endif
index 27bb8df938bd583d5a7595fbdc22b19bcd99eeee..a85ef11b58b635eb1b6adb7adaf6241e710a14d7 100644 (file)
@@ -77,15 +77,15 @@ extern int Cmi_numpes;
 
 extern void CmiMemLock();
 extern void CmiMemUnlock();
-#define CmiNodeBarrier() 0
+#define CmiNodeBarrier() /*empty*/
 #define CmiSvAlloc CmiAlloc
 
 typedef void *CmiNodeLock;
 #define CmiCreateLock() ((void *)0)
-#define CmiLock(lock) 0
-#define CmiUnlock(lock) 0
-#define CmiTryLock(lock) 0
-#define CmiDestroyLock(lock) do{}while(0)
+#define CmiLock(lock) /*empty*/
+#define CmiUnlock(lock) /*empty*/
+#define CmiTryLock(lock) /*empty*/
+#define CmiDestroyLock(lock) /*empty*/
 
 #endif
 
@@ -543,8 +543,6 @@ double   CmiCpuTimer();
 
 #endif
 
-extern int CqsEmpty(void *);
-
 #define CsdEnqueueGeneral(x,s,i,p)\
     (CqsEnqueueGeneral(CpvAccess(CsdSchedQueue),(x),(s),(i),(p)))
 #define CsdEnqueueFifo(x)     (CqsEnqueueFifo(CpvAccess(CsdSchedQueue),(x)))
@@ -754,6 +752,7 @@ void          CmiFreeNodeBroadcastAllFn(int, char *);
 
 int    CmiDeliverMsgs(int maxmsgs);
 void   CmiDeliverSpecificMsg(int handler);
+void   CmiHandleMessage(void *msg);
 
 /******** CQS: THE QUEUEING SYSTEM ********/
 
@@ -769,7 +768,8 @@ void   CmiDeliverSpecificMsg(int handler);
 typedef struct CthThreadStruct *CthThread;
 
 typedef void        (*CthVoidFn)();
-typedef void        (*CthAwkFn)(CthThread,int,int,int*);
+typedef void        (*CthAwkFn)(CthThread,int,
+                               int prioBits,unsigned int *prioptr);
 typedef CthThread   (*CthThFn)();
 
 int        CthImplemented(void);
@@ -786,11 +786,11 @@ int        CthIsSuspendable(CthThread);
 
 void       CthSuspend(void);
 void       CthAwaken(CthThread);
-void       CthAwakenPrio(CthThread, int, int, int *);
+void       CthAwakenPrio(CthThread, int, int, unsigned int *);
 void       CthSetStrategy(CthThread, CthAwkFn, CthThFn);
 void       CthSetStrategyDefault(CthThread);
 void       CthYield(void);
-void       CthYieldPrio(int,int,int*);
+void       CthYieldPrio(int,int,unsigned int*);
 
 void       CthSetNext(CthThread t, CthThread next);
 CthThread  CthGetNext(CthThread t);
@@ -866,9 +866,9 @@ CpmDestination CpmEnqueueFIFO(int pe);
 CpmDestination CpmEnqueueLIFO(int pe);
 CpmDestination CpmEnqueueIFIFO(int pe, int prio);
 CpmDestination CpmEnqueueILIFO(int pe, int prio);
-CpmDestination CpmEnqueueBFIFO(int pe, int priobits, int *prioptr);
-CpmDestination CpmEnqueueBLIFO(int pe, int priobits, int *prioptr);
-CpmDestination CpmEnqueue(int pe,int qs,int priobits,int *prioptr);
+CpmDestination CpmEnqueueBFIFO(int pe, int priobits, unsigned int *prioptr);
+CpmDestination CpmEnqueueBLIFO(int pe, int priobits, unsigned int *prioptr);
+CpmDestination CpmEnqueue(int pe,int qs,int priobits,unsigned int *prioptr);
 
 /***********************************************************************
  *
index a2f057d767ab6759b0b1fb39035cd1edb5c0d1f8..6b666e4f63cc538e7d8a08d00b8cffd8aba127de 100644 (file)
@@ -5,16 +5,9 @@
  * $Revision$
  *****************************************************************************/
 
-#ifdef WIN32
+#include <stdlib.h>
 #include <string.h>
 #include "queueing.h"
-
-extern void CqsDequeue(Queue, void **);
-extern void CqsEnqueueFifo(Queue, void *);
-extern void CqsEnqueueLifo(Queue, void *);
-extern void CqsEnqueueGeneral(Queue, void *, unsigned int, unsigned int, unsigned int*);
-#endif
-
 #include <converse.h>
 
 static void CpmLSend(int pe, int len, void *msg)
@@ -65,7 +58,8 @@ typedef struct CpmDestinationEnq
 {
   void *(*sendfn)();
   int envsize;
-  int pe, qs, priobits, *prioptr;
+  int pe, qs, priobits;
+  unsigned int *prioptr;
 }
 *CpmDestinationEnq;
 
@@ -81,7 +75,7 @@ void CpmEnqueue2(void *msg)
   CmiGrabBuffer(&msg);
   env = (int *)CpmEnv(msg);
   CmiSetHandler(msg, env[0]);
-  CsdEnqueueGeneral(msg, env[1], env[2], env+3);
+  CsdEnqueueGeneral(msg, env[1], env[2], (unsigned int *)(env+3));
 }
 
 void *CpmEnqueue1(CpmDestinationEnq ctrl, int len, void *msg)
@@ -99,7 +93,7 @@ void *CpmEnqueue1(CpmDestinationEnq ctrl, int len, void *msg)
   return (void *) 0;
 }
 
-CpmDestination CpmEnqueue(int pe, int qs, int priobits, int *prioptr)
+CpmDestination CpmEnqueue(int pe, int qs, int priobits,unsigned int *prioptr)
 {
   int intbits = sizeof(int)*8;
   int prioints = (priobits+intbits-1) / intbits;
@@ -110,7 +104,7 @@ CpmDestination CpmEnqueue(int pe, int qs, int priobits, int *prioptr)
   return (CpmDestination)&CpvAccess(ctrlEnq);
 }
 
-CpvStaticDeclare(int, fiprio);
+CpvStaticDeclare(unsigned int, fiprio);
 
 CpmDestination CpmEnqueueIFIFO(int pe, int prio)
 {
@@ -118,7 +112,7 @@ CpmDestination CpmEnqueueIFIFO(int pe, int prio)
   return CpmEnqueue(pe, CQS_QUEUEING_IFIFO, sizeof(int)*8, &CpvAccess(fiprio));
 }
 
-CpvStaticDeclare(int, liprio);
+CpvStaticDeclare(unsigned int, liprio);
 
 CpmDestination CpmEnqueueILIFO(int pe, int prio)
 {
@@ -126,12 +120,12 @@ CpmDestination CpmEnqueueILIFO(int pe, int prio)
   return CpmEnqueue(pe, CQS_QUEUEING_ILIFO, sizeof(int)*8, &CpvAccess(liprio));
 }
 
-CpmDestination CpmEnqueueBFIFO(int pe, int priobits, int *prioptr)
+CpmDestination CpmEnqueueBFIFO(int pe, int priobits,unsigned int *prioptr)
 {
   return CpmEnqueue(pe, CQS_QUEUEING_BFIFO, priobits, prioptr);
 }
 
-CpmDestination CpmEnqueueBLIFO(int pe, int priobits, int *prioptr)
+CpmDestination CpmEnqueueBLIFO(int pe, int priobits,unsigned int *prioptr)
 {
   return CpmEnqueue(pe, CQS_QUEUEING_BLIFO, priobits, prioptr);
 }
index 1936c0e6d9128aaf8c553e497e1718a799e5331a..56dc356bd8127de063c9cf983a1a6f5b08451c8a 100644 (file)
 #define CPTHREAD_IS_HERE
 #define SUPPRESS_PTHREADS
 #include "cpthreads.h"
-#ifndef  WIN32
-#include <sys/errno.h>
-#else
 #include <stdlib.h>
 #include <errno.h>
-#endif
 #include "fifo.h"
 
 /******************************************************************************
index 84cd62a5192358d65bfe47bc182b8dc08a3f1870..8d4bf9bc2c7bd4042fa4980175ae9818f98df09d 100644 (file)
@@ -5,6 +5,7 @@
  * $Revision$
  *****************************************************************************/
 
+#include <stdlib.h>
 #include "converse.h"
 
 typedef struct Cfuture_data_s
index f8c3ab98002fd164ba83b3d6e26059ad1779df3f..03082e2d3f830b6a88dd8e062c86227d77e27278 100644 (file)
@@ -5,6 +5,7 @@
  * $Revision$
  *****************************************************************************/
 
+#include <stdlib.h>
 #include <converse.h>
 
 typedef struct CmmEntryStruct *CmmEntry;
@@ -163,4 +164,6 @@ CmmTable CmmPup(pup_er p, CmmTable t)
     }
     return t;
   }
+  return NULL;/*<- never executed*/
 }
+
index 192c65f2eda5a36f7369072e9de999aabd4e7785..af7ca4176111d68f44f3a5a069fd06eff0ca7127 100644 (file)
@@ -227,7 +227,7 @@ prioq pq;
   return data;
 }
 
-Queue CqsCreate()
+Queue CqsCreate(void)
 {
   Queue q = (Queue)CmiAlloc(sizeof(struct Queue_struct));
   q->length = 0;
@@ -238,26 +238,23 @@ Queue CqsCreate()
   return q;
 }
 
-unsigned int CqsLength(q)
-Queue q;
+unsigned int CqsLength(Queue q)
 {
   return q->length;
 }
 
-unsigned int CqsMaxLength(q)
-Queue q;
+unsigned int CqsMaxLength(Queue q)
 {
   return q->maxlen;
 }
 
-int CqsEmpty(void *_q)
+int CqsEmpty(Queue q)
 {
-  Queue q = (Queue) _q;;
   return (q->length == 0);
 }
 
-void CqsEnqueueGeneral(q, data, strategy, priobits, prioptr)
-Queue q; void *data; unsigned int strategy, priobits, *prioptr;
+void CqsEnqueueGeneral(Queue q, void *data, int strategy, 
+           int priobits,unsigned int *prioptr)
 {
   deq d; int iprio;
   switch (strategy) {
@@ -300,30 +297,25 @@ Queue q; void *data; unsigned int strategy, priobits, *prioptr;
   q->length++; if (q->length>q->maxlen) q->maxlen=q->length;
 }
 
-void CqsEnqueueFifo(q, data)
-Queue q; void *data;
+void CqsEnqueueFifo(Queue q, void *data)
 {
   CqsDeqEnqueueFifo(&(q->zeroprio), data);
   q->length++; if (q->length>q->maxlen) q->maxlen=q->length;
 }
 
-void CqsEnqueueLifo(q, data)
-Queue q; void *data;
+void CqsEnqueueLifo(Queue q, void *data)
 {
   CqsDeqEnqueueLifo(&(q->zeroprio), data);
   q->length++; if (q->length>q->maxlen) q->maxlen=q->length;
 }
 
-void CqsEnqueue(q, data)
-Queue q; void *data;
+void CqsEnqueue(Queue q, void *data)
 {
   CqsDeqEnqueueFifo(&(q->zeroprio), data);
   q->length++; if (q->length>q->maxlen) q->maxlen=q->length;
 }
 
-void CqsDequeue(q, resp)
-Queue q;
-void **resp;
+void CqsDequeue(Queue q, void **resp)
 {
   if (q->length==0) 
     { *resp = 0; return; }
index 3f6406d17e57e5fa9a63888981b0f9db10cd81d0..2d32907732b8a244744d6a5317e67001b2e91751 100644 (file)
@@ -7,6 +7,11 @@
 
 #ifndef QUEUEING_H
 #define QUEUEING_H
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
 #ifndef CINTBITS
 #define CINTBITS ((unsigned int) (sizeof(int)*8))
 #endif
@@ -58,4 +63,24 @@ typedef struct Queue_struct
 }
 *Queue;
 
+Queue CqsCreate(void);
+void CqsEnqueue(Queue, void *msg);
+void CqsEnqueueFifo(Queue, void *msg);
+void CqsEnqueueLifo(Queue, void *msg);
+void CqsEnqueueGeneral(Queue, void *msg,int strategy, 
+              int priobits, unsigned int *prioPtr);
+
+void CqsEnumerateQueue(Queue q, void ***resp);
+void CqsDequeue(Queue, void **msgPtr);
+
+unsigned int CqsLength(Queue);
+unsigned int CqsMaxLength(Queue);
+int CqsEmpty(Queue);
+int  CqsPrioGT(prio, prio);
+prio CqsGetPriority(Queue);
+
+#ifdef __cplusplus
+};
+#endif
+
 #endif
index 03074329bd2bc44468fb96b5a91969634cf2127a..b48204b6fb1bdd626288dfba181d20172cb8a727 100644 (file)
@@ -9,8 +9,9 @@
 #include "quiescence.h"
 #include <assert.h>
 #include <stdio.h>
+#include <stdlib.h>
 #ifndef  DEBUGF
-#define  DEBUGF(x) printf x 
+#define  DEBUGF(x) /*printf x*/ 
 #endif
 
 CpvDeclare(CQdState, cQdState);
index 67085d023bab1c2fd8826ad8d303740512f11d15..026d151271fb4432060b457faa802ba8a4e4e5d4 100644 (file)
@@ -30,6 +30,7 @@
 
 #include "converse.h"
 #include <limits.h>
+#include <stdlib.h>
 
 #define MAX_STREAMS 15613
 /*
index 2b02be001ea22ab428fbe77d851d228d4a885682..70f90e17060e90aa27a007b41b2d58a6048e8414 100644 (file)
  *
  *****************************************************************************/
  
-#ifdef WIN32
 #include <stdio.h>
 #include <stdlib.h>
-#include <malloc.h>
-#endif
+#include <string.h>
+#include <malloc.h> /*<- for memalign*/
 
 #include "converse.h"
 #ifndef  WIN32
@@ -1616,7 +1615,7 @@ void CthYield()
   CthSuspend();
 }
 
-void CthAwakenPrio(CthThread th, int s, int pb, int *prio)
+void CthAwakenPrio(CthThread th, int s, int pb, unsigned int *prio)
 {
   if (th->awakenfn == 0) CthNoStrategy();
   CpvAccess(curThread) = th;
@@ -1627,7 +1626,7 @@ void CthAwakenPrio(CthThread th, int s, int pb, int *prio)
   th->awakenfn(th, s, pb, prio);
 }
 
-void CthYieldPrio(int s, int pb, int *prio)
+void CthYieldPrio(int s, int pb, unsigned int *prio)
 {
   CthAwakenPrio(CthCpvAccess(CthCurrent), s, pb, prio);
   CthSuspend();
index 8fb4524513db762bffe9a5b9c109979149ce8e75..efc650d83454582b7b04f77e28d13c6cde472290 100644 (file)
@@ -1,11 +1,6 @@
-#ifdef WIN32
+
 #include <stdlib.h>
 #include "queueing.h"
-extern void CqsEnqueueGeneral(Queue, void *, unsigned int, unsigned int, unsigned int *);
-extern void CmiHandleMessage(void *);
-extern unsigned int CqsLength(Queue);
-#endif
-
 #include "cldb.h"
 #include <math.h>
 
index f67cf2db611186fb7f871358a4c55a4f8b442dd1..2b926aeea7d1777f19d4d6279ca030885b78d4af 100644 (file)
@@ -2,18 +2,12 @@
 #define PERIOD 20                /* default: 30 */
 #define MAXOVERLOAD 1
 
-#ifdef WIN32
+#include "converse.h"
 #include "queueing.h"
-extern int  CldLoad(void);
-extern int  CldCountTokens(void);
-extern void CldRestoreHandler(char *);
-extern void CldPutToken(char *);
-extern void CqsEnqueueGeneral(Queue, void *, unsigned int, unsigned int, unsigned int *);
-extern void CldSwitchHandler(char *, int);
-extern void CldModuleGeneralInit(void);
-#endif
+#include "cldb.h"
+#include <stdlib.h>
 
-extern gengraph(int, int, int);
+extern void gengraph(int, int, int);
 
 CpvDeclare(int, CldLoadResponseHandlerIndex);
 CpvDeclare(int, MinLoad);
index 38da154754d6af0777b562acd713f0732384a020..0090f44c0042c9c07a0c5acac6d3cc55bfe5a3b0 100644 (file)
@@ -13,3 +13,10 @@ CpvExtern(int, CldLoadNotify);
 
 void CldMultipleSend(int pe, int numToSend);
 void CldSetPEBitVector(const char *);
+
+int  CldLoad(void);
+int  CldCountTokens(void);
+void CldPutToken(char *);
+void CldRestoreHandler(char *);
+void CldSwitchHandler(char *, int);
+void CldModuleGeneralInit();
index 8913738b3916f3d1c546e547127b97aa4e2d2bb5..845b57413dc77d2cb82aeddc654d6e9f3e0f2b56 100644 (file)
@@ -5,16 +5,10 @@
  * $Revision$
  *****************************************************************************/
 
-#ifdef WIN32
-#include "queueing.h"
-extern void CldRestoreHandler(char *);
-extern void CqsEnqueueGeneral(Queue, void *, unsigned int, unsigned int, unsigned int*);
-extern void CldSwitchHandler(char *, int);
-extern void CldModuleGeneralInit();
-#endif
-
 #include "converse.h"
+#include "queueing.h"
 #include "cldb.h"
+#include <stdlib.h>
 
 void LoadNotifyFn(int l)
 {
index 8a001899b77577e470eebd3f06274a8d06aba9bb..27f117cd38df9e807978e1cc61df5ed3d36c2c64 100644 (file)
@@ -4,21 +4,11 @@
  * $Date$
  * $Revision$
  *****************************************************************************/
-
-#ifdef WIN32
-#include <time.h>
-#include "queueing.h"
-
-extern void CldModuleGeneralInit();
-extern void CmiHandleMessage(void *);
-extern void CqsEnqueueGeneral(Queue, void *, unsigned int, unsigned int, unsigned int *);
-/*
-void srand48(long);
-long lrand48(void);
-*/
-#endif
-
 #include "converse.h"
+#include "queueing.h"
+#include "cldb.h"
+#include <time.h>
+#include <stdlib.h>
 #include <math.h>
 
 void LoadNotifyFn(int l)
index 8fad6bead133ffcbfe067be2681db1f77b010e91..585eb0e4409e2632b338871128eee89f74ed5f3f 100644 (file)
@@ -1,15 +1,7 @@
-#ifdef WIN32
-#include "queueing.h"
-extern void CldRestoreHandler(char *);
-extern void CqsEnqueueGeneral(Queue, void *, unsigned int, unsigned int, unsigned int*);
-extern void CldSwitchHandler(char *, int);
-extern void CldModuleGeneralInit();
-extern void CldPutToken(char *);
-extern int CldPresentPE(int);
-#endif
-
 #include "converse.h"
 #include "cldb.h"
+#include "queueing.h"
+#include <stdlib.h>
 
 void LoadNotifyFn(int l)
 {
index 13677eb3c0ec516fa7819f21964616c62e431f09..392b100f3e3fb450c666dc0208dabe1b0839e31f 100644 (file)
@@ -6,11 +6,8 @@
  *****************************************************************************/
 
 /* The data structure/ ADT for the edge-list */
-#ifdef   WIN32
 #include <stdio.h>
 #include <stdlib.h>
-#endif
-
 #include "typedefs.h"
 
 extern VerticesListType graph;
index c64ba33d864d160afc9cae281f985a96396eafcb..5a7eb3406c275c5e75610a3163b099224693018b 100644 (file)
@@ -14,21 +14,17 @@ Output form: directory graphN/ containing files graph0 ... graphN-1
 
 Modified from the original: changed output format, and converted main to a parametered function
 */
-#ifdef WIN32
 #include <stdio.h>
 #include <stdlib.h>
-#else
-#include "stdio.h"
-#endif
+
 /* comment this out to test and change CmiPrintf to printf */
 #include "converse.h"
 #include "typedefs.h"
 
-#ifdef WIN32
-extern int edgeExists(int, int);
+int addEdge(EdgeListType *l,int fm,int to);
+int edgeExists(int fm, int to);
 int isEmpty(Q*);
 int dequeue(Q*);
-#endif
 
 #define VMAX 2050
 int V; /* no. of vertices */
@@ -58,7 +54,6 @@ void gengraph(int pV, int pC, int pseed)
   EdgeListType * EdgeList;
   /* VerticesListType * vertices; */
   extern EdgeListType * InitEdgeList();
-  extern addEdge();
   char dircmd[20], dirname[10];
 
 
index adc50ffda6c2b34e90536598cc9eee0d373bdd97..0a6dca539a5060c4b46772d10657611a7fff9728 100644 (file)
@@ -9,6 +9,7 @@
 #include <fcntl.h>
 #include <errno.h>
 #include <stdlib.h>
+#include <string.h>
 #include <signal.h>
 #include <time.h>