12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217 |
- /***** spin: pangen1.c *****/
- /* Copyright (c) 1989-2003 by Lucent Technologies, Bell Laboratories. */
- /* All Rights Reserved. This software is for educational purposes only. */
- /* No guarantee whatsoever is expressed or implied by the distribution of */
- /* this code. Permission is given to distribute this code provided that */
- /* this introductory message is not removed and no monies are exchanged. */
- /* Software written by Gerard J. Holzmann. For tool documentation see: */
- /* http://spinroot.com/ */
- /* Send all bug-reports and/or questions to: bugs@spinroot.com */
- #include "spin.h"
- #ifdef PC
- #include "y_tab.h"
- #else
- #include "y.tab.h"
- #endif
- #include "pangen1.h"
- #include "pangen3.h"
- extern FILE *tc, *th, *tt;
- extern Label *labtab;
- extern Ordered *all_names;
- extern ProcList *rdy;
- extern Queue *qtab;
- extern Symbol *Fname;
- extern int lineno, verbose, Pid, separate;
- extern int nrRdy, nqs, mst, Mpars, claimnr, eventmapnr;
- extern short has_sorted, has_random, has_provided;
- int Npars=0, u_sync=0, u_async=0, hastrack = 1;
- short has_io = 0;
- short has_state=0; /* code contains c_state */
- static Symbol *LstSet=ZS;
- static int acceptors=0, progressors=0, nBits=0;
- static int Types[] = { UNSIGNED, BIT, BYTE, CHAN, MTYPE, SHORT, INT, STRUCT };
- static int doglobal(char *, int);
- static void dohidden(void);
- static void do_init(FILE *, Symbol *);
- static void end_labs(Symbol *, int);
- static void put_ptype(char *, int, int, int);
- static void tc_predef_np(void);
- static void put_pinit(ProcList *);
- void walk_struct(FILE *, int, char *, Symbol *, char *, char *, char *);
- static void
- reverse_names(ProcList *p)
- {
- if (!p) return;
- reverse_names(p->nxt);
- fprintf(th, " \"%s\",\n", p->n->name);
- }
- void
- genheader(void)
- { ProcList *p; int i;
- if (separate == 2)
- { putunames(th);
- goto here;
- }
- fprintf(th, "#define SYNC %d\n", u_sync);
- fprintf(th, "#define ASYNC %d\n\n", u_async);
- putunames(th);
- fprintf(tc, "short Air[] = { ");
- for (p = rdy, i=0; p; p = p->nxt, i++)
- fprintf(tc, "%s (short) Air%d", (p!=rdy)?",":"", i);
- fprintf(tc, ", (short) Air%d", i); /* np_ */
- fprintf(tc, " };\n");
- fprintf(th, "char *procname[] = {\n");
- reverse_names(rdy);
- fprintf(th, " \":np_:\",\n");
- fprintf(th, "};\n\n");
- here:
- for (p = rdy; p; p = p->nxt)
- put_ptype(p->n->name, p->tn, mst, nrRdy+1);
- /* +1 for np_ */
- put_ptype("np_", nrRdy, mst, nrRdy+1);
- ntimes(th, 0, 1, Head0);
- if (separate != 2)
- { extern void c_add_stack(FILE *);
- ntimes(th, 0, 1, Header);
- c_add_stack(th);
- ntimes(th, 0, 1, Header0);
- }
- ntimes(th, 0, 1, Head1);
- LstSet = ZS;
- (void) doglobal("", PUTV);
- hastrack = c_add_sv(th);
- fprintf(th, " uchar sv[VECTORSZ];\n");
- fprintf(th, "} State");
- #ifdef SOLARIS
- fprintf(th,"\n#ifdef GCC\n");
- fprintf(th, "\t__attribute__ ((aligned(8)))");
- fprintf(th, "\n#endif\n\t");
- #endif
- fprintf(th, ";\n\n");
- fprintf(th, "#define HAS_TRACK %d\n", hastrack);
- if (separate != 2)
- dohidden();
- }
- void
- genaddproc(void)
- { ProcList *p;
- int i = 0;
- if (separate ==2) goto shortcut;
- fprintf(tc, "int\naddproc(int n");
- for (i = 0; i < Npars; i++)
- fprintf(tc, ", int par%d", i);
- ntimes(tc, 0, 1, Addp0);
- ntimes(tc, 1, nrRdy+1, R5); /* +1 for np_ */
- ntimes(tc, 0, 1, Addp1);
- if (has_provided)
- { fprintf(tt, "\nint\nprovided(int II, unsigned char ot, ");
- fprintf(tt, "int tt, Trans *t)\n");
- fprintf(tt, "{\n\tswitch(ot) {\n");
- }
- shortcut:
- tc_predef_np();
- for (p = rdy; p; p = p->nxt)
- { Pid = p->tn;
- put_pinit(p);
- }
- if (separate == 2) return;
- Pid = 0;
- if (has_provided)
- { fprintf(tt, "\tdefault: return 1; /* e.g., a claim */\n");
- fprintf(tt, "\t}\n\treturn 0;\n}\n");
- }
- ntimes(tc, i, i+1, R6);
- if (separate == 0)
- ntimes(tc, 1, nrRdy+1, R5); /* +1 for np_ */
- else
- ntimes(tc, 1, nrRdy, R5);
- ntimes(tc, 0, 1, R8a);
- }
- void
- do_locinits(FILE *fd)
- { ProcList *p;
- for (p = rdy; p; p = p->nxt)
- c_add_locinit(fd, p->tn, p->n->name);
- }
- void
- genother(void)
- { ProcList *p;
- switch (separate) {
- case 2:
- if (claimnr >= 0)
- ntimes(tc, claimnr, claimnr+1, R0); /* claim only */
- break;
- case 1:
- ntimes(tc, 0, 1, Code0);
- ntimes(tc, 0, claimnr, R0); /* all except claim */
- ntimes(tc, claimnr+1, nrRdy, R0);
- break;
- case 0:
- ntimes(tc, 0, 1, Code0);
- ntimes(tc, 0, nrRdy+1, R0); /* +1 for np_ */
- break;
- }
- for (p = rdy; p; p = p->nxt)
- end_labs(p->n, p->tn);
- switch (separate) {
- case 2:
- if (claimnr >= 0)
- ntimes(tc, claimnr, claimnr+1, R0a); /* claim only */
- return;
- case 1:
- ntimes(tc, 0, claimnr, R0a); /* all except claim */
- ntimes(tc, claimnr+1, nrRdy, R0a);
- fprintf(tc, " if (state_tables)\n");
- fprintf(tc, " ini_claim(%d, 0);\n", claimnr);
- break;
- case 0:
- ntimes(tc, 0, nrRdy, R0a); /* all */
- break;
- }
- ntimes(tc, 0, 1, R0b);
- if (separate == 1 && acceptors == 0)
- acceptors = 1; /* assume at least 1 acceptstate */
- ntimes(th, acceptors, acceptors+1, Code1);
- ntimes(th, progressors, progressors+1, Code3);
- ntimes(th, nrRdy+1, nrRdy+2, R2); /* +1 for np_ */
- fprintf(tc, " iniglobals();\n");
- ntimes(tc, 0, 1, Code2a);
- ntimes(tc, 0, 1, Code2b); /* bfs option */
- ntimes(tc, 0, 1, Code2c);
- ntimes(tc, 0, nrRdy, R4);
- fprintf(tc, "}\n\n");
- fprintf(tc, "void\n");
- fprintf(tc, "iniglobals(void)\n{\n");
- if (doglobal("", INIV) > 0)
- { fprintf(tc, "#ifdef VAR_RANGES\n");
- (void) doglobal("logval(\"", LOGV);
- fprintf(tc, "#endif\n");
- }
- ntimes(tc, 1, nqs+1, R3);
- fprintf(tc, "\tMaxbody = max(Maxbody, sizeof(State)-VECTORSZ);");
- fprintf(tc, "\n}\n\n");
- }
- void
- gensvmap(void)
- {
- ntimes(tc, 0, 1, SvMap);
- }
- static struct {
- char *s, *t; int n, m, p;
- } ln[] = {
- {"end", "stopstate", 3, 0, 0},
- {"progress", "progstate", 8, 0, 1},
- {"accept", "accpstate", 6, 1, 0},
- {0, 0, 0, 0, 0},
- };
- static void
- end_labs(Symbol *s, int i)
- { int oln = lineno;
- Symbol *ofn = Fname;
- Label *l;
- int j; char foo[128];
- if ((i == claimnr && separate == 1)
- || (i != claimnr && separate == 2))
- return;
- for (l = labtab; l; l = l->nxt)
- for (j = 0; ln[j].n; j++)
- if (strncmp(l->s->name, ln[j].s, ln[j].n) == 0
- && strcmp(l->c->name, s->name) == 0)
- { fprintf(tc, "\t%s[%d][%d] = 1;\n",
- ln[j].t, i, l->e->seqno);
- acceptors += ln[j].m;
- progressors += ln[j].p;
- if (l->e->status & D_ATOM)
- { sprintf(foo, "%s label inside d_step",
- ln[j].s);
- goto complain;
- }
- if (j > 0 && (l->e->status & ATOM))
- { sprintf(foo, "%s label inside atomic",
- ln[j].s);
- complain: lineno = l->e->n->ln;
- Fname = l->e->n->fn;
- printf("spin: %3d:%s, warning, %s - is invisible\n",
- lineno, Fname?Fname->name:"-", foo);
- }
- }
- /* visible states -- through remote refs: */
- for (l = labtab; l; l = l->nxt)
- if (l->visible
- && strcmp(l->s->context->name, s->name) == 0)
- fprintf(tc, "\tvisstate[%d][%d] = 1;\n",
- i, l->e->seqno);
- lineno = oln;
- Fname = ofn;
- }
- void
- ntimes(FILE *fd, int n, int m, char *c[])
- {
- int i, j;
- for (j = 0; c[j]; j++)
- for (i = n; i < m; i++)
- { fprintf(fd, c[j], i, i, i, i, i, i);
- fprintf(fd, "\n");
- }
- }
- void
- prehint(Symbol *s)
- { Lextok *n;
- printf("spin: warning, ");
- if (!s) return;
- n = (s->context != ZS)?s->context->ini:s->ini;
- if (n)
- printf("line %3d %s, ", n->ln, n->fn->name);
- }
- void
- checktype(Symbol *sp, char *s)
- { char buf[128]; int i;
- if (!s
- || (sp->type != BYTE
- && sp->type != SHORT
- && sp->type != INT))
- return;
- if (sp->hidden&16) /* formal parameter */
- { ProcList *p; Lextok *f, *t;
- int posnr = 0;
- for (p = rdy; p; p = p->nxt)
- if (p->n->name
- && strcmp(s, p->n->name) == 0)
- break;
- if (p)
- for (f = p->p; f; f = f->rgt) /* list of types */
- for (t = f->lft; t; t = t->rgt, posnr++)
- if (t->sym
- && strcmp(t->sym->name, sp->name) == 0)
- { checkrun(sp, posnr);
- return;
- }
- } else if (!(sp->hidden&4))
- { if (!(verbose&32)) return;
- sputtype(buf, sp->type);
- i = (int) strlen(buf);
- while (buf[--i] == ' ') buf[i] = '\0';
- prehint(sp);
- if (sp->context)
- printf("proctype %s:", s);
- else
- printf("global");
- printf(" '%s %s' could be declared 'bit %s'\n",
- buf, sp->name, sp->name);
- } else if (sp->type != BYTE && !(sp->hidden&8))
- { if (!(verbose&32)) return;
- sputtype(buf, sp->type);
- i = (int) strlen(buf);
- while (buf[--i] == ' ') buf[i] = '\0';
- prehint(sp);
- if (sp->context)
- printf("proctype %s:", s);
- else
- printf("global");
- printf(" '%s %s' could be declared 'byte %s'\n",
- buf, sp->name, sp->name);
- }
- }
- int
- dolocal(FILE *ofd, char *pre, int dowhat, int p, char *s)
- { int h, j, k=0; extern int nr_errs;
- Ordered *walk;
- Symbol *sp;
- char buf[64], buf2[128], buf3[128];
- for (j = 0; j < 8; j++)
- for (h = 0; h <= 1; h++)
- for (walk = all_names; walk; walk = walk->next)
- { sp = walk->entry;
- if (sp->context
- && !sp->owner
- && sp->type == Types[j]
- && ((h == 0 && sp->nel == 1) || (h == 1 && sp->nel > 1))
- && strcmp(s, sp->context->name) == 0)
- { switch (dowhat) {
- case LOGV:
- if (sp->type == CHAN
- && verbose == 0)
- break;
- sprintf(buf, "%s%s:", pre, s);
- { sprintf(buf2, "\", ((P%d *)pptr(h))->", p);
- sprintf(buf3, ");\n");
- }
- do_var(ofd, dowhat, "", sp, buf, buf2, buf3);
- break;
- case INIV:
- checktype(sp, s); /* fall through */
- if (sp->hidden&16) { k++; break; }
- case PUTV:
- sprintf(buf, "((P%d *)pptr(h))->", p);
- do_var(ofd, dowhat, buf, sp, "", " = ", ";\n");
- k++;
- break;
- }
- if (strcmp(s, ":never:") == 0)
- { printf("error: %s defines local %s\n",
- s, sp->name);
- nr_errs++;
- } } }
- return k;
- }
- void
- c_chandump(FILE *fd)
- { Queue *q;
- char buf[256];
- int i;
- if (!qtab)
- { fprintf(fd, "void\nc_chandump(int unused) ");
- fprintf(fd, "{ unused = unused++; /* avoid complaints */ }\n");
- return;
- }
- fprintf(fd, "void\nc_chandump(int from)\n");
- fprintf(fd, "{ uchar *z; int slot;\n");
- fprintf(fd, " from--;\n");
- fprintf(fd, " if (from >= (int) now._nr_qs || from < 0)\n");
- fprintf(fd, " { printf(\"pan: bad qid %%d\\n\", from+1);\n");
- fprintf(fd, " return;\n");
- fprintf(fd, " }\n");
- fprintf(fd, " z = qptr(from);\n");
- fprintf(fd, " switch (((Q0 *)z)->_t) {\n");
- for (q = qtab; q; q = q->nxt)
- { fprintf(fd, " case %d:\n\t\t", q->qid);
- sprintf(buf, "((Q%d *)z)->", q->qid);
- fprintf(fd, "for (slot = 0; slot < %sQlen; slot++)\n\t\t", buf);
- fprintf(fd, "{ printf(\" [\");\n\t\t");
- for (i = 0; i < q->nflds; i++)
- { if (q->fld_width[i] == MTYPE)
- { fprintf(fd, "\tprintm(%scontents[slot].fld%d);\n\t\t",
- buf, i);
- } else
- fprintf(fd, "\tprintf(\"%%d,\", %scontents[slot].fld%d);\n\t\t",
- buf, i);
- }
- fprintf(fd, " printf(\"],\");\n\t\t");
- fprintf(fd, "}\n\t\t");
- fprintf(fd, "break;\n");
- }
- fprintf(fd, " }\n");
- fprintf(fd, " printf(\"\\n\");\n}\n");
- }
- void
- c_var(FILE *fd, char *pref, Symbol *sp)
- { char buf[256];
- int i;
- switch (sp->type) {
- case STRUCT:
- /* c_struct(fd, pref, sp); */
- fprintf(fd, "\t\tprintf(\"\t(struct %s)\\n\");\n",
- sp->name);
- sprintf(buf, "%s%s.", pref, sp->name);
- c_struct(fd, buf, sp);
- break;
- case BIT: case BYTE:
- case SHORT: case INT:
- case UNSIGNED:
- sputtype(buf, sp->type);
- if (sp->nel == 1)
- fprintf(fd, "\tprintf(\"\t%s %s:\t%%d\\n\", %s%s);\n",
- buf, sp->name, pref, sp->name);
- else
- for (i = 0; i < sp->nel; i++)
- fprintf(fd, "\tprintf(\"\t%s %s[%d]:\t%%d\\n\", %s%s[%d]);\n",
- buf, sp->name, i, pref, sp->name, i);
- break;
- case CHAN:
- if (sp->nel == 1)
- { fprintf(fd, "\tprintf(\"\tchan %s (=%%d):\tlen %%d:\\t\", ",
- sp->name);
- fprintf(fd, "%s%s, q_len(%s%s));\n",
- pref, sp->name, pref, sp->name);
- fprintf(fd, "\tc_chandump(%s%s);\n", pref, sp->name);
- } else
- for (i = 0; i < sp->nel; i++)
- { fprintf(fd, "\tprintf(\"\tchan %s[%d] (=%%d):\tlen %%d:\\t\", ",
- sp->name, i);
- fprintf(fd, "%s%s[%d], q_len(%s%s[%d]));\n",
- pref, sp->name, i, pref, sp->name, i);
- fprintf(fd, "\tc_chandump(%s%s[%d]);\n",
- pref, sp->name, i);
- }
- break;
- }
- }
- void
- c_splurge(FILE *fd, ProcList *p)
- { Ordered *walk;
- Symbol *sp;
- char pref[64];
- if (strcmp(p->n->name, ":never:") != 0
- && strcmp(p->n->name, ":trace:") != 0
- && strcmp(p->n->name, ":notrace:") != 0)
- for (walk = all_names; walk; walk = walk->next)
- { sp = walk->entry;
- if (!sp->context
- || strcmp(sp->context->name, p->n->name) != 0
- || sp->owner || (sp->hidden&1)
- || (sp->type == MTYPE && ismtype(sp->name)))
- continue;
- sprintf(pref, "((P%d *)pptr(pid))->", p->tn);
- c_var(fd, pref, sp);
- }
- }
- void
- c_wrapper(FILE *fd) /* allow pan.c to print out global sv entries */
- { Ordered *walk;
- ProcList *p;
- Symbol *sp;
- Lextok *n;
- extern Lextok *Mtype;
- int j;
- fprintf(fd, "void\nc_globals(void)\n{\t/* int i; */\n");
- fprintf(fd, " printf(\"global vars:\\n\");\n");
- for (walk = all_names; walk; walk = walk->next)
- { sp = walk->entry;
- if (sp->context || sp->owner || (sp->hidden&1)
- || (sp->type == MTYPE && ismtype(sp->name)))
- continue;
- c_var(fd, "now.", sp);
- }
- fprintf(fd, "}\n");
- fprintf(fd, "void\nc_locals(int pid, int tp)\n{\t/* int i; */\n");
- fprintf(fd, " switch(tp) {\n");
- for (p = rdy; p; p = p->nxt)
- { fprintf(fd, " case %d:\n", p->tn);
- fprintf(fd, " \tprintf(\"local vars proc %%d (%s):\\n\", pid);\n",
- p->n->name);
- c_splurge(fd, p);
- fprintf(fd, " \tbreak;\n");
- }
- fprintf(fd, " }\n}\n");
- fprintf(fd, "void\nprintm(int x)\n{\n");
- fprintf(fd, " switch (x) {\n");
- for (n = Mtype, j = 1; n && j; n = n->rgt, j++)
- fprintf(fd, "\tcase %d: Printf(\"%s\"); break;\n",
- j, n->lft->sym->name);
- fprintf(fd, " default: Printf(\"%%d\", x);\n");
- fprintf(fd, " }\n");
- fprintf(fd, "}\n");
- }
- static int
- doglobal(char *pre, int dowhat)
- { Ordered *walk;
- Symbol *sp;
- int j, cnt = 0;
- for (j = 0; j < 8; j++)
- for (walk = all_names; walk; walk = walk->next)
- { sp = walk->entry;
- if (!sp->context
- && !sp->owner
- && sp->type == Types[j])
- { if (Types[j] != MTYPE || !ismtype(sp->name))
- switch (dowhat) {
- case LOGV:
- if (sp->type == CHAN
- && verbose == 0)
- break;
- if (sp->hidden&1)
- break;
- do_var(tc, dowhat, "", sp,
- pre, "\", now.", ");\n");
- break;
- case INIV:
- checktype(sp, (char *) 0);
- cnt++; /* fall through */
- case PUTV:
- do_var(tc, dowhat, (sp->hidden&1)?"":"now.", sp,
- "", " = ", ";\n");
- break;
- } } }
- return cnt;
- }
- static void
- dohidden(void)
- { Ordered *walk;
- Symbol *sp;
- int j;
- for (j = 0; j < 8; j++)
- for (walk = all_names; walk; walk = walk->next)
- { sp = walk->entry;
- if ((sp->hidden&1)
- && sp->type == Types[j])
- { if (sp->context || sp->owner)
- fatal("cannot hide non-globals (%s)", sp->name);
- if (sp->type == CHAN)
- fatal("cannot hide channels (%s)", sp->name);
- fprintf(th, "/* hidden variable: */");
- typ2c(sp);
- } }
- fprintf(th, "int _; /* a predefined write-only variable */\n\n");
- }
- void
- do_var(FILE *ofd, int dowhat, char *s, Symbol *sp,
- char *pre, char *sep, char *ter)
- { int i;
- switch(dowhat) {
- case PUTV:
- if (sp->hidden&1) break;
- typ2c(sp);
- break;
- case LOGV:
- case INIV:
- if (sp->type == STRUCT)
- { /* struct may contain a chan */
- walk_struct(ofd, dowhat, s, sp, pre, sep, ter);
- break;
- }
- if (!sp->ini && dowhat != LOGV) /* it defaults to 0 */
- break;
- if (sp->nel == 1)
- { fprintf(ofd, "\t\t%s%s%s%s",
- pre, s, sp->name, sep);
- if (dowhat == LOGV)
- fprintf(ofd, "%s%s", s, sp->name);
- else
- do_init(ofd, sp);
- fprintf(ofd, "%s", ter);
- } else
- for (i = 0; i < sp->nel; i++)
- { fprintf(ofd, "\t\t%s%s%s[%d]%s",
- pre, s, sp->name, i, sep);
- if (dowhat == LOGV)
- fprintf(ofd, "%s%s[%d]",
- s, sp->name, i);
- else
- do_init(ofd, sp);
- fprintf(ofd, "%s", ter);
- }
- break;
- }
- }
- static void
- do_init(FILE *ofd, Symbol *sp)
- { int i; extern Queue *ltab[];
- if (sp->ini
- && sp->type == CHAN
- && ((i = qmake(sp)) > 0))
- { if (sp->ini->ntyp == CHAN)
- fprintf(ofd, "addqueue(%d, %d)",
- i, ltab[i-1]->nslots == 0);
- else
- fprintf(ofd, "%d", i);
- } else
- putstmnt(ofd, sp->ini, 0);
- }
- static int
- blog(int n) /* for small log2 without rounding problems */
- { int m=1, r=2;
- while (r < n) { m++; r *= 2; }
- return 1+m;
- }
- static void
- put_ptype(char *s, int i, int m0, int m1)
- { int k;
- if (strcmp(s, ":init:") == 0)
- fprintf(th, "#define Pinit ((P%d *)this)\n", i);
- if (strcmp(s, ":never:") != 0
- && strcmp(s, ":trace:") != 0
- && strcmp(s, ":notrace:") != 0
- && strcmp(s, ":init:") != 0
- && strcmp(s, "_:never_template:_") != 0
- && strcmp(s, "np_") != 0)
- fprintf(th, "#define P%s ((P%d *)this)\n", s, i);
- fprintf(th, "typedef struct P%d { /* %s */\n", i, s);
- fprintf(th, " unsigned _pid : 8; /* 0..255 */\n");
- fprintf(th, " unsigned _t : %d; /* proctype */\n", blog(m1));
- fprintf(th, " unsigned _p : %d; /* state */\n", blog(m0));
- LstSet = ZS;
- nBits = 8 + blog(m1) + blog(m0);
- k = dolocal(tc, "", PUTV, i, s); /* includes pars */
- c_add_loc(th, s);
- fprintf(th, "} P%d;\n", i);
- if ((!LstSet && k > 0) || has_state)
- fprintf(th, "#define Air%d 0\n", i);
- else
- { fprintf(th, "#define Air%d (sizeof(P%d) - ", i, i);
- if (k == 0)
- { fprintf(th, "%d", (nBits+7)/8);
- goto done;
- }
- if ((LstSet->type != BIT && LstSet->type != UNSIGNED)
- || LstSet->nel != 1)
- { fprintf(th, "Offsetof(P%d, %s) - %d*sizeof(",
- i, LstSet->name, LstSet->nel);
- }
- switch(LstSet->type) {
- case UNSIGNED:
- fprintf(th, "%d", (nBits+7)/8);
- break;
- case BIT:
- if (LstSet->nel == 1)
- { fprintf(th, "%d", (nBits+7)/8);
- break;
- } /* else fall through */
- case MTYPE: case BYTE: case CHAN:
- fprintf(th, "uchar)"); break;
- case SHORT:
- fprintf(th, "short)"); break;
- case INT:
- fprintf(th, "int)"); break;
- default:
- fatal("cannot happen Air %s",
- LstSet->name);
- }
- done: fprintf(th, ")\n");
- }
- }
- static void
- tc_predef_np(void)
- { int i = nrRdy; /* 1+ highest proctype nr */
- fprintf(th, "#define _NP_ %d\n", i);
- if (separate == 2) fprintf(th, "extern ");
- fprintf(th, "uchar reached%d[3]; /* np_ */\n", i);
- fprintf(th, "#define nstates%d 3 /* np_ */\n", i);
- fprintf(th, "#define endstate%d 2 /* np_ */\n\n", i);
- fprintf(th, "#define start%d 0 /* np_ */\n", i);
- fprintf(tc, "\tcase %d: /* np_ */\n", i);
- if (separate == 1)
- { fprintf(tc, "\t\tini_claim(%d, h);\n", i);
- } else
- { fprintf(tc, "\t\t((P%d *)pptr(h))->_t = %d;\n", i, i);
- fprintf(tc, "\t\t((P%d *)pptr(h))->_p = 0;\n", i);
- fprintf(tc, "\t\treached%d[0] = 1;\n", i);
- fprintf(tc, "\t\taccpstate[%d][1] = 1;\n", i);
- }
- fprintf(tc, "\t\tbreak;\n");
- }
- static void
- put_pinit(ProcList *P)
- { Lextok *fp, *fpt, *t;
- Element *e = P->s->frst;
- Symbol *s = P->n;
- Lextok *p = P->p;
- int i = P->tn;
- int ini, j, k;
- if (i == claimnr
- && separate == 1)
- { fprintf(tc, "\tcase %d: /* %s */\n", i, s->name);
- fprintf(tc, "\t\tini_claim(%d, h);\n", i);
- fprintf(tc, "\t\tbreak;\n");
- return;
- }
- if (i != claimnr
- && separate == 2)
- return;
- ini = huntele(e, e->status, -1)->seqno;
- fprintf(th, "#define start%d %d\n", i, ini);
- if (i == claimnr)
- fprintf(th, "#define start_claim %d\n", ini);
- if (i == eventmapnr)
- fprintf(th, "#define start_event %d\n", ini);
- fprintf(tc, "\tcase %d: /* %s */\n", i, s->name);
- fprintf(tc, "\t\t((P%d *)pptr(h))->_t = %d;\n", i, i);
- fprintf(tc, "\t\t((P%d *)pptr(h))->_p = %d;", i, ini);
- fprintf(tc, " reached%d[%d]=1;\n", i, ini);
- if (has_provided)
- { fprintf(tt, "\tcase %d: /* %s */\n\t\t", i, s->name);
- if (P->prov)
- { fprintf(tt, "if (");
- putstmnt(tt, P->prov, 0);
- fprintf(tt, ")\n\t\t\t");
- }
- fprintf(tt, "return 1;\n");
- if (P->prov)
- fprintf(tt, "\t\tbreak;\n");
- }
- fprintf(tc, "\t\t/* params: */\n");
- for (fp = p, j=0; fp; fp = fp->rgt)
- for (fpt = fp->lft; fpt; fpt = fpt->rgt, j++)
- { t = (fpt->ntyp == ',') ? fpt->lft : fpt;
- if (t->sym->nel != 1)
- { lineno = t->ln;
- Fname = t->fn;
- fatal("array in parameter list, %s",
- t->sym->name);
- }
- fprintf(tc, "\t\t((P%d *)pptr(h))->", i);
- if (t->sym->type == STRUCT)
- { if (full_name(tc, t, t->sym, 1))
- { lineno = t->ln;
- Fname = t->fn;
- fatal("hidden array in parameter %s",
- t->sym->name);
- }
- } else
- fprintf(tc, "%s", t->sym->name);
- fprintf(tc, " = par%d;\n", j);
- }
- fprintf(tc, "\t\t/* locals: */\n");
- k = dolocal(tc, "", INIV, i, s->name);
- if (k > 0)
- { fprintf(tc, "#ifdef VAR_RANGES\n");
- (void) dolocal(tc, "logval(\"", LOGV, i, s->name);
- fprintf(tc, "#endif\n");
- }
- fprintf(tc, "#ifdef HAS_CODE\n");
- fprintf(tc, "\t\tlocinit%d(h);\n", i);
- fprintf(tc, "#endif\n");
- dumpclaims(tc, i, s->name);
- fprintf(tc, "\t break;\n");
- }
- Element *
- huntstart(Element *f)
- { Element *e = f;
- Element *elast = (Element *) 0;
- int cnt = 0;
- while (elast != e && cnt++ < 20) /* new 4.0.8 */
- { elast = e;
- if (e->n)
- { if (e->n->ntyp == '.' && e->nxt)
- e = e->nxt;
- else if (e->n->ntyp == UNLESS)
- e = e->sub->this->frst;
- } }
- if (cnt >= 20 || !e)
- fatal("confusing control structure", (char *) 0);
- return e;
- }
- Element *
- huntele(Element *f, int o, int stopat)
- { Element *g, *e = f;
- int cnt=0; /* a precaution against loops */
- if (e)
- for (cnt = 0; cnt < 20 && e->n; cnt++)
- {
- if (e->seqno == stopat)
- break;
- switch (e->n->ntyp) {
- case GOTO:
- g = get_lab(e->n,1);
- cross_dsteps(e->n, g->n);
- break;
- case '.':
- case BREAK:
- if (!e->nxt)
- return e;
- g = e->nxt;
- break;
- case UNLESS:
- g = huntele(e->sub->this->frst, o, stopat);
- break;
- case D_STEP:
- case ATOMIC:
- case NON_ATOMIC:
- default:
- return e;
- }
- if ((o & ATOM) && !(g->status & ATOM))
- return e;
- e = g;
- }
- if (cnt >= 20 || !e)
- fatal("confusing control structure", (char *) 0);
- return e;
- }
- void
- typ2c(Symbol *sp)
- { int wsbits = sizeof(long)*8; /* wordsize in bits */
- switch (sp->type) {
- case UNSIGNED:
- if (sp->hidden&1)
- fprintf(th, "\tuchar %s;", sp->name);
- else
- fprintf(th, "\tunsigned %s : %d",
- sp->name, sp->nbits);
- LstSet = sp;
- if (nBits%wsbits > 0
- && wsbits - nBits%wsbits < sp->nbits)
- { /* must padd to a word-boundary */
- nBits += wsbits - nBits%wsbits;
- }
- nBits += sp->nbits;
- break;
- case BIT:
- if (sp->nel == 1 && !(sp->hidden&1))
- { fprintf(th, "\tunsigned %s : 1", sp->name);
- LstSet = sp;
- nBits++;
- break;
- } /* else fall through */
- if (!(sp->hidden&1) && (verbose&32))
- printf("spin: warning: bit-array %s[%d] mapped to byte-array\n",
- sp->name, sp->nel);
- nBits += 8*sp->nel; /* mapped onto array of uchars */
- case MTYPE:
- case BYTE:
- case CHAN: /* good for up to 255 channels */
- fprintf(th, "\tuchar %s", sp->name);
- LstSet = sp;
- break;
- case SHORT:
- fprintf(th, "\tshort %s", sp->name);
- LstSet = sp;
- break;
- case INT:
- fprintf(th, "\tint %s", sp->name);
- LstSet = sp;
- break;
- case STRUCT:
- if (!sp->Snm)
- fatal("undeclared structure element %s", sp->name);
- fprintf(th, "\tstruct %s %s",
- sp->Snm->name,
- sp->name);
- LstSet = ZS;
- break;
- case CODE_FRAG:
- case PREDEF:
- return;
- default:
- fatal("variable %s undeclared", sp->name);
- }
- if (sp->nel != 1)
- fprintf(th, "[%d]", sp->nel);
- fprintf(th, ";\n");
- }
- static void
- ncases(FILE *fd, int p, int n, int m, char *c[])
- { int i, j;
- for (j = 0; c[j]; j++)
- for (i = n; i < m; i++)
- { fprintf(fd, c[j], i, p, i);
- fprintf(fd, "\n");
- }
- }
- void
- qlen_type(int qmax)
- {
- fprintf(th, "\t");
- if (qmax < 256)
- fprintf(th, "uchar");
- else if (qmax < 65535)
- fprintf(th, "ushort");
- else
- fprintf(th, "uint");
- fprintf(th, " Qlen; /* q_size */\n");
- }
- void
- genaddqueue(void)
- { char buf0[256];
- int j, qmax = 0;
- Queue *q;
- ntimes(tc, 0, 1, Addq0);
- if (has_io && !nqs)
- fprintf(th, "#define NQS 1 /* nqs=%d, but has_io */\n", nqs);
- else
- fprintf(th, "#define NQS %d\n", nqs);
- fprintf(th, "short q_flds[%d];\n", nqs+1);
- fprintf(th, "short q_max[%d];\n", nqs+1);
- for (q = qtab; q; q = q->nxt)
- if (q->nslots > qmax)
- qmax = q->nslots;
- for (q = qtab; q; q = q->nxt)
- { j = q->qid;
- fprintf(tc, "\tcase %d: j = sizeof(Q%d);", j, j);
- fprintf(tc, " q_flds[%d] = %d;", j, q->nflds);
- fprintf(tc, " q_max[%d] = %d;", j, max(1,q->nslots));
- fprintf(tc, " break;\n");
- fprintf(th, "typedef struct Q%d {\n", j);
- qlen_type(qmax); /* 4.2.2 */
- fprintf(th, " uchar _t; /* q_type */\n");
- fprintf(th, " struct {\n");
- for (j = 0; j < q->nflds; j++)
- { switch (q->fld_width[j]) {
- case BIT:
- if (q->nflds != 1)
- { fprintf(th, "\t\tunsigned");
- fprintf(th, " fld%d : 1;\n", j);
- break;
- } /* else fall through: smaller struct */
- case MTYPE:
- case CHAN:
- case BYTE:
- fprintf(th, "\t\tuchar fld%d;\n", j);
- break;
- case SHORT:
- fprintf(th, "\t\tshort fld%d;\n", j);
- break;
- case INT:
- fprintf(th, "\t\tint fld%d;\n", j);
- break;
- default:
- fatal("bad channel spec", "");
- }
- }
- fprintf(th, " } contents[%d];\n", max(1, q->nslots));
- fprintf(th, "} Q%d;\n", q->qid);
- }
- fprintf(th, "typedef struct Q0 {\t/* generic q */\n");
- qlen_type(qmax); /* 4.2.2 */
- fprintf(th, " uchar _t;\n");
- fprintf(th, "} Q0;\n");
- ntimes(tc, 0, 1, Addq1);
- if (has_random)
- { fprintf(th, "int Q_has(int");
- for (j = 0; j < Mpars; j++)
- fprintf(th, ", int, int");
- fprintf(th, ");\n");
- fprintf(tc, "int\nQ_has(int into");
- for (j = 0; j < Mpars; j++)
- fprintf(tc, ", int want%d, int fld%d", j, j);
- fprintf(tc, ")\n");
- fprintf(tc, "{ int i;\n\n");
- fprintf(tc, " if (!into--)\n");
- fprintf(tc, " uerror(\"ref to unknown chan ");
- fprintf(tc, "(recv-poll)\");\n\n");
- fprintf(tc, " if (into >= now._nr_qs || into < 0)\n");
- fprintf(tc, " Uerror(\"qrecv bad queue#\");\n\n");
- fprintf(tc, " for (i = 0; i < ((Q0 *)qptr(into))->Qlen;");
- fprintf(tc, " i++)\n");
- fprintf(tc, " {\n");
- for (j = 0; j < Mpars; j++)
- { fprintf(tc, " if (want%d && ", j);
- fprintf(tc, "qrecv(into+1, i, %d, 0) != fld%d)\n",
- j, j);
- fprintf(tc, " continue;\n");
- }
- fprintf(tc, " return i+1;\n");
- fprintf(tc, " }\n");
- fprintf(tc, " return 0;\n");
- fprintf(tc, "}\n");
- }
- fprintf(tc, "#if NQS>0\n");
- fprintf(tc, "void\nqsend(int into, int sorted");
- for (j = 0; j < Mpars; j++)
- fprintf(tc, ", int fld%d", j);
- fprintf(tc, ")\n");
- ntimes(tc, 0, 1, Addq11);
- for (q = qtab; q; q = q->nxt)
- { sprintf(buf0, "((Q%d *)z)->", q->qid);
- fprintf(tc, "\tcase %d:%s\n", q->qid,
- (q->nslots)?"":" /* =rv= */");
- if (q->nslots == 0) /* reset handshake point */
- fprintf(tc, "\t\t(trpt+2)->o_m = 0;\n");
- if (has_sorted)
- { fprintf(tc, "\t\tif (!sorted) goto append%d;\n", q->qid);
- fprintf(tc, "\t\tfor (j = 0; j < %sQlen; j++)\n", buf0);
- fprintf(tc, "\t\t{\t/* find insertion point */\n");
- sprintf(buf0, "((Q%d *)z)->contents[j].fld", q->qid);
- for (j = 0; j < q->nflds; j++)
- { fprintf(tc, "\t\t\tif (fld%d > %s%d) continue;\n",
- j, buf0, j);
- fprintf(tc, "\t\t\tif (fld%d < %s%d) ", j, buf0, j);
- fprintf(tc, "goto found%d;\n\n", q->qid);
- }
- fprintf(tc, "\t\t}\n");
- fprintf(tc, "\tfound%d:\n", q->qid);
- sprintf(buf0, "((Q%d *)z)->", q->qid);
- fprintf(tc, "\t\tfor (k = %sQlen - 1; k >= j; k--)\n", buf0);
- fprintf(tc, "\t\t{\t/* shift up */\n");
- for (j = 0; j < q->nflds; j++)
- { fprintf(tc, "\t\t\t%scontents[k+1].fld%d = ",
- buf0, j);
- fprintf(tc, "%scontents[k].fld%d;\n",
- buf0, j);
- }
- fprintf(tc, "\t\t}\n");
- fprintf(tc, "\tappend%d:\t/* insert in slot j */\n", q->qid);
- }
- fprintf(tc, "#ifdef HAS_SORTED\n");
- fprintf(tc, "\t\t(trpt+1)->ipt = j;\n"); /* ipt was bup.oval */
- fprintf(tc, "#endif\n");
- fprintf(tc, "\t\t%sQlen = %sQlen + 1;\n", buf0, buf0);
- sprintf(buf0, "((Q%d *)z)->contents[j].fld", q->qid);
- for (j = 0; j < q->nflds; j++)
- fprintf(tc, "\t\t%s%d = fld%d;\n", buf0, j, j);
- fprintf(tc, "\t\tbreak;\n");
- }
- ntimes(tc, 0, 1, Addq2);
- for (q = qtab; q; q = q->nxt)
- fprintf(tc, "\tcase %d: return %d;\n", q->qid, (!q->nslots));
- ntimes(tc, 0, 1, Addq3);
- for (q = qtab; q; q = q->nxt)
- fprintf(tc, "\tcase %d: return (q_sz(from) == %d);\n",
- q->qid, max(1, q->nslots));
- ntimes(tc, 0, 1, Addq4);
- for (q = qtab; q; q = q->nxt)
- { sprintf(buf0, "((Q%d *)z)->", q->qid);
- fprintf(tc, " case %d:%s\n\t\t",
- q->qid, (q->nslots)?"":" /* =rv= */");
- if (q->nflds == 1)
- { fprintf(tc, "if (fld == 0) r = %s", buf0);
- fprintf(tc, "contents[slot].fld0;\n");
- } else
- { fprintf(tc, "switch (fld) {\n");
- ncases(tc, q->qid, 0, q->nflds, R12);
- fprintf(tc, "\t\tdefault: Uerror");
- fprintf(tc, "(\"too many fields in recv\");\n");
- fprintf(tc, "\t\t}\n");
- }
- fprintf(tc, "\t\tif (done)\n");
- if (q->nslots == 0)
- { fprintf(tc, "\t\t{ j = %sQlen - 1;\n", buf0);
- fprintf(tc, "\t\t %sQlen = 0;\n", buf0);
- sprintf(buf0, "\t\t\t((Q%d *)z)->contents", q->qid);
- } else
- { fprintf(tc, "\t\t{ j = %sQlen;\n", buf0);
- fprintf(tc, "\t\t %sQlen = --j;\n", buf0);
- fprintf(tc, "\t\t for (k=slot; k<j; k++)\n");
- fprintf(tc, "\t\t {\n");
- sprintf(buf0, "\t\t\t((Q%d *)z)->contents", q->qid);
- for (j = 0; j < q->nflds; j++)
- { fprintf(tc, "\t%s[k].fld%d = \n", buf0, j);
- fprintf(tc, "\t\t%s[k+1].fld%d;\n", buf0, j);
- }
- fprintf(tc, "\t\t }\n");
- }
- for (j = 0; j < q->nflds; j++)
- fprintf(tc, "%s[j].fld%d = 0;\n", buf0, j);
- fprintf(tc, "\t\t\tif (fld+1 != %d)\n\t\t\t", q->nflds);
- fprintf(tc, "\tuerror(\"missing pars in receive\");\n");
- /* incompletely received msgs cannot be unrecv'ed */
- fprintf(tc, "\t\t}\n");
- fprintf(tc, "\t\tbreak;\n");
- }
- ntimes(tc, 0, 1, Addq5);
- for (q = qtab; q; q = q->nxt)
- fprintf(tc, " case %d: j = sizeof(Q%d); break;\n",
- q->qid, q->qid);
- ntimes(tc, 0, 1, R8b);
- ntimes(th, 0, 1, Proto); /* tag on function prototypes */
- fprintf(th, "void qsend(int, int");
- for (j = 0; j < Mpars; j++)
- fprintf(th, ", int");
- fprintf(th, ");\n");
- fprintf(th, "#define Addproc(x) addproc(x");
- for (j = 0; j < Npars; j++)
- fprintf(th, ", 0");
- fprintf(th, ")\n");
- }
|