/*********************************************************************** * * * The JIAJIA Software Distributed Shared Memory System * * * * Copyright (C) 1997 the Center of High Performance Computing * * of Institute of Computing Technology, Chinese Academy of * * Sciences. All rights reserved. * * * * Permission to use, copy, modify and distribute this software * * is hereby granted provided that (1) source code retains these * * copyright, permission, and disclaimer notices, and (2) redistri- * * butions including binaries reproduce the notices in supporting * * documentation, and (3) all advertising materials mentioning * * features or use of this software display the following * * acknowledgement: ``This product includes software developed by * * the Center of High Performance Computing, Institute of Computing * * Technology, Chinese Academy of Sciences." * * * * This program is distributed in the hope that it will be useful, * * but WITHOUT ANY WARRANTY; without even the implied warranty of * * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. * * * * Center of High Performance Computing requests users of this * * software to return to dsm@water.chpc.ict.ac.cn any * * improvements that they make and grant CHPC redistribution rights. * * * * Author: Weiwu Hu, Weisong Shi, Zhimin Tang * * =================================================================== * * This software is ported to SP2 by * * * * M. Rasit Eskicioglu * * University of Alberta * * Dept. of Computing Science * * Edmonton, Alberta T6G 2H1 CANADA * * =================================================================== * **********************************************************************/ #ifndef NULL_LIB #include "global.h" #include "init.h" #include "mem.h" #include "syn.h" #include "comm.h" extern void asendmsg(jia_msg_t *msg); void inittools(); void assert0(int, char *); void assert(int, char *); void jiaexitserver(jia_msg_t *req); jia_msg_t *newmsg(); void freemsg(jia_msg_t *msg); void appendmsg(jia_msg_t *msg, unsigned char *str, int len); void printmsg(jia_msg_t *msg,int right); void printstack(int ptr); unsigned long jia_current_time(); float jia_clock(); void jiasleep(unsigned long); void disable_sigio(); void enable_sigio(); void freewtntspace(wtnt_t *ptr); wtnt_t *newwtnt(); void newtwin(address_t *twin); void freetwin(address_t *twin); void emptyprintf(); extern int jia_pid; extern int hostc; extern jiastack_t lockstack[Maxstacksize]; extern int totalhome; extern host_t hosts[Maxhosts]; extern char argv0[Wordsize]; extern jiapage_t page[Maxmempages]; extern jiahome_t home[Homepages+1]; extern unsigned long globaladdr; extern int firsttime; extern float caltime; char errstr[Linesize]; jia_msg_t msgarray[Maxmsgs]; volatile int msgbusy[Maxmsgs]; int msgcnt; jia_msg_t assertmsg; int H_MIG=OFF,AD_WD=OFF,B_CAST=OFF,LOAD_BAL=OFF; int W_VEC=OFF; void inittools() { H_MIG=OFF; AD_WD=OFF; B_CAST=OFF; LOAD_BAL=OFF; W_VEC=OFF; } /*-----------------------------------------------------------*/ void assert0(int cond,char *amsg) { if (!cond){ fprintf(stderr,"Assert0 error from host %d --- %s\n", jia_pid, amsg); perror("Unix Error"); fflush(stderr); fflush(stdout); exit(-1); } } /*-----------------------------------------------------------*/ void assert(int cond, char *amsg) { int hosti; if (!cond){ assertmsg.op=JIAEXIT; assertmsg.frompid=jia_pid; memcpy(assertmsg.data,amsg,strlen(amsg)); assertmsg.data[strlen(amsg)]='\0'; assertmsg.size=strlen(amsg)+1; for (hosti=0;hostifrompid, (char*)req->data); fflush(stderr); fflush(stdout); exit(-1); } /*-----------------------------------------------------------*/ void newtwin(address_t *twin) { if (*twin==((address_t)NULL)) *twin=(address_t)valloc(Pagesize); assert(((*twin)!=(address_t)NULL),"Cannot allocate twin space!"); } /*-----------------------------------------------------------*/ void freetwin(address_t *twin) { #ifndef RESERVE_TWIN_SPACE free(*twin); *twin=(address_t) NULL; #endif } /*-----------------------------------------------------------*/ jia_msg_t *newmsg() {int i,j; msgcnt++; for (i=0;(iindex]=0; msgcnt--; } /*-----------------------------------------------------------*/ void appendmsg(jia_msg_t *msg, unsigned char *str, int len) { assert(((msg->size+len)<=Maxmsgsize),"Message too large"); memcpy(msg->data+msg->size,str,len); msg->size+=len; } wtnt_t *newwtnt() {wtnt_t *wnptr; #ifdef SOLARIS wnptr=memalign((size_t)Pagesize, (size_t)sizeof(wtnt_t)); #else /* SOLARIS */ wnptr=valloc((size_t)sizeof(wtnt_t)); #endif /* SOLARIS */ assert((wnptr!=WNULL),"Can not allocate space for write notices!"); wnptr->more=WNULL; wnptr->wtntc=0; return(wnptr); } /*-----------------------------------------------------------*/ void freewtntspace(wtnt_t *ptr) {wtnt_t *last,*wtntp; wtntp=ptr->more; while(wtntp!=WNULL){ last=wtntp; wtntp=wtntp->more; free(last); } ptr->wtntc=0; ptr->more=WNULL; } /*-----------------------------------------------------------*/ void printmsg(jia_msg_t *msg, int right) { SPACE(right);printf("********Print message********\n"); SPACE(right); switch (msg->op){ case DIFF: printf("msg.op = DIFF \n"); break; case DIFFGRANT: printf("msg.op = DIFFGRANT\n"); break; case GETP: printf("msg.op = GETP \n"); break; case GETPGRANT: printf("msg.op = GETPGRANT\n"); break; case ACQ: printf("msg.op = ACQ \n"); break; case ACQGRANT: printf("msg.op = ACQGRANT \n"); break; case INVLD: printf("msg.op = INVLD \n"); break; case BARR: printf("msg.op = BARR \n"); break; case BARRGRANT: printf("msg.op = BARRGRANT\n"); break; case WAIT: printf("msg.op = WAIT \n"); break; case WAITGRANT: printf("msg.op = WAITGRANT\n"); break; case REL: printf("msg.op = REL \n"); break; case WTNT: printf("msg.op = WTNT \n"); break; case STAT: printf("msg.op = STAT \n"); break; case STATGRANT: printf("msg.op = STATGRANT\n"); break; case JIAEXIT: printf("msg.op = JIAEXIT \n"); break; default: printf("msg.op = %d \n",msg->op); break; } SPACE(right); printf("msg.frompid = %d\n",msg->frompid); SPACE(right); printf("msg.topid = %d\n",msg->topid); SPACE(right); printf("msg.temp =%d\n",msg->temp); SPACE(right); printf("msg.seqno = %d\n",msg->seqno); SPACE(right); printf("msg.index = %d\n",msg->index); SPACE(right); printf("msg.size = %d\n",msg->size); SPACE(right); printf("msg.data = 0x%8x\n",stol(msg->data)); SPACE(right); printf("msg.data = 0x%8x\n",stol(msg->data+4)); SPACE(right); printf("msg.data = 0x%8x\n",stol(msg->data+8)); } /*-----------------------------------------------------------*/ /* Following programs are used by Shi. 9.10 */ unsigned long start_sec = 0; unsigned long start_time_sec = 0; unsigned long start_time_usec = 0; unsigned long start_msec = 0; /*-----------------------------------------------------------*/ unsigned long jia_current_time() {struct timeval tp; /* Return the time, in milliseconds, elapsed after the first call * to this routine. */ gettimeofday(&tp, NULL); if (!start_sec) { start_sec = tp.tv_sec; start_msec = (unsigned long) (tp.tv_usec/1000); } return (1000*(tp.tv_sec-start_sec) + (tp.tv_usec/1000 - start_msec)); } /*-----------------------------------------------------------*/ float jia_clock() { float time; struct timeval val; gettimeofday(&val,NULL); if (!start_time_sec) { start_time_sec= val.tv_sec; start_time_usec = val.tv_usec; } time=(float)((val.tv_sec*1000000.0+val.tv_usec*1.0- start_time_sec*1000000.0-start_time_usec*1.0)/1000000.0); return(time); } /*-----------------------------------------------------------*/ void disable_sigio() { sigset_t set,oldset; sigemptyset(&set); sigaddset(&set, SIGIO); sigprocmask(SIG_BLOCK, &set, &oldset); } /*-----------------------------------------------------------*/ void enable_sigio() { sigset_t set; sigemptyset(&set); sigaddset(&set,SIGIO); sigprocmask(SIG_UNBLOCK, &set, NULL); } /*-----------------------------------------------------------*/ void emptyprintf() { } /*-----------------------------------------------------------*/ void jia_error(char *str, ... ) { va_list ap; va_start(ap, str); vsprintf(errstr, str, ap); va_end(ap); assert(0, errstr); } extern void setwtvect(int homei,wtvect_t wv); void jia_config(int dest,int value) {int i; switch (dest){ case HMIG : H_MIG=value; break; case ADWD : AD_WD=value; break; case BROADCAST: B_CAST=value; break; case LOADBAL : LOAD_BAL=value; if (LOAD_BAL==ON) firsttime=1; caltime=0.0; break; case WVEC : if ((W_VEC==OFF)&&(value==ON)){ for (i=0;i<=Homepages;i++){ home[i].wtvect=(wtvect_t*)malloc(hostc*sizeof(wtvect_t)); setwtvect(i,WVFULL); } }else if ((W_VEC==ON)&&(value==OFF)){ for (i=0;i<=Homepages;i++){ free(home[i].wtvect); } } W_VEC=value; break; default : printf("Null configuration!\n"); break; } } #else /* NULL_LIB */ #include unsigned long start_sec = 0; unsigned long start_time_sec = 0; unsigned long start_time_usec = 0; unsigned long start_msec = 0; float jia_clock() { struct timeval val; gettimeofday(&val,NULL); if (!start_time_sec) { start_time_sec= val.tv_sec; start_time_usec = val.tv_usec; } return (float)(((val.tv_sec*1000000.0+val.tv_usec)- (start_time_sec*1000000.0+start_time_usec))/1000000.0); } void jia_error(char *errstr) { printf("JIAJIA error --- %s\n", errstr); exit(-1); } #endif /* NULL_LIB */ /*-----------------------------------------------------------*/ unsigned int get_usecs() { #ifdef AIX41 register unsigned int seconds asm("5"); register unsigned int nanosecs asm("6"); register unsigned int seconds2 asm("7"); /* Need to read the first value twice to make sure it doesn't role * over while we are reading it. */ retry: asm("mfspr 5,4"); /* read high into register 5 - seconds */ asm("mfspr 6,5"); /* read low into register 6 - nanosecs */ asm("mfspr 7,4"); /* read high into register 7 - seconds2 */ if (seconds != seconds2) { goto retry; } /* convert to correct form. */ return seconds * 1000000 + nanosecs / 1000; #else /* AIX41 */ static struct timeval base; struct timeval time; gettimeofday(&time, NULL); if (!base.tv_usec) { base = time; } return ((time.tv_sec - base.tv_sec) * 1000000 + (time.tv_usec - base.tv_usec)); #endif /* AIX41 */ }