+++ /dev/null
-#include "depend.h"
-#include "genint.h"
-#include "int.h"
-#include "process.h"
-#include "intproto.h"
-
-#if DLINK
-# include "dlink.h"
-#elif TCPIP
-# include "tcpip.h"
-#endif
-
-#include <assert.h>
-
-
-/* Process management */
-
-procdescr process[ MAXPROCESS ]; /* process descriptor table */
-procdescr *thisp; /* pointer to current process descr */
-word thispix; /* current process index */
-queue ready; /* Round-Robin queue */
-bool network; /* TRUE if operating in network */
-message globmsgqueue[ MAXMSGQUEUE ]; /* queue of waiting messages */
-int msgready = 0; /* number of waiting messages */
-int msghead = 0, msgtail = 0; /* pointers to message queue */
-word ournode; /* this machine node number */
-word console; /* console node number */
-bool remote = FALSE; /* TRUE if remote node */
-bool reschedule = TRUE; /* TRUE if must re-schedule */
-
-
-
-#ifndef NO_PROTOTYPES
-static void ansprot(message *);
-static void localkill(message *);
-void transfer(word);
-static void backcreate(message *);
-static void createprocess(message *);
-static void localerror(message *);
-static void killprocess(word);
-static void mkglobal(word);
-word pix, ref;
-#else
-static void ansprot();
-static void localkill();
-void transfer();
-static void backcreate();
-static void createprocess();
-static void localerror();
-static void killprocess();
-static void mkglobal();
-#endif
-
-
-
-#if OS2
-PGINFOSEG ginf; /* pointer to Global Info Segment */
-#endif
-
-
-#if USE_ALARM
-# include <signal.h>
-# ifndef NO_PROTOTYPES
- static void signal_catch( void );
-# else
- static void signal_catch();
-# endif
- static void signal_catch(){ reschedule=TRUE; }
-#endif
-
-
-void init_scheduler(){
-#if USE_ALARM
- signal(SIGALRM,signal_catch);
- alarm(1);
-#endif
-}
-
-void schedule() /* Choose next ready process to exec */
-{
- trapmsg(); /* STRONGLY machine dependent */
-#if USE_ALARM
- if(reschedule){
- alarm(0);
- signal(SIGALRM,signal_catch);
- alarm(1);
-#elif USE_CLOCK
- static char last;
- char c;
- c = clock() >> 5; /* the most expensive method */
- if (reschedule || c != last) /* context switch is needed */
- {
- last = c;
-#elif MSDOS && ( WORD_16BIT || DWORD_16BIT ) /* DOS real memory model */
- static char last;
- char c;
- static char *clk = (char *) 0x0040006CL;
- c = *clk >> 1;
- if (reschedule || c != last) /* context switch is needed */
- {
- last = c;
-#elif OS2
- static char last;
- char c;
- c = ginf->hundredths >> 3;
- if (reschedule || c != last) /* context switch is needed */
- {
- last = c;
-#else
-#error Scheduler time counting method not implemented !
-#endif
-
- if (!(qempty(ready))) /* wait for event if no processes */
- {
- ready = qrotate(ready); /* find another ready process */
- transfer(pfront(ready)); /* transfer control to it */
- reschedule = FALSE;
- }
- }
-}
-
-
-void transfer(pix) /* Context switch to another process */
-word pix;
-{
- word apt;
- if (pix == thispix) return; /* optimized for case of one process */
-
- if( thisp != NULL ) /* previous process is alive */
- {
- thisp->ic = ic; /* store previous context */
- thisp->c1 = c1;
- thisp->c2 = c2;
- }
- thispix = pix; /* and load new context */
- thisp = &process[ thispix ];
- ic = thisp->ic;
- c1 = thisp->c1;
- c2 = thisp->c2;
- M = thisp->M;
- param = thisp->param;
- apt = thisp->prochead+M[ thisp->prochead ];
- display = apt+dispoff;
- display2 = apt+disp2off;
-}
-
-
-void activate(pix) /* Resume process on this node */
-word pix;
-{
- process[ pix ].status = EXECUTING; /* flag process as ready to execute */
- ready = pinsert(ready, pix); /* insert into ready queue */
- reschedule = TRUE; /* force context switch */
-# ifdef RPCDBG
- fprintf(stderr,"activate process %d\n",pix);
-# endif
-}
-
-
-void passivate(newstatus) /* Passivate process */
-int newstatus;
-{
-
- thisp->status = newstatus; /* change to some wait status */
- ready = qremove(ready); /* remove from ready queue */
- reschedule = TRUE; /* force context switch */
-# ifdef RPCDBG
- fprintf(stderr,"passivate process %d to state %d\n",thispix,newstatus);
-# endif
-}
-
-
-/* Copy parameters from object to message or vice versa. */
-
-
-void moveparams(pix, am, msg, par1, dir)
- word pix, am;
- message *msg;
- int par1, dir;
-{
- protdescr *ptr;
- procdescr *p;
- word i, tpd, ap, pd, prim, offset;
- char *cp;
- bool cflag, convert;
-
- p = &process[ pix ];
- ptr = prototype[ p->M[ am+PROTNUM ] ];
- cp = (char *) msg->params;
-
- for (i = 0; i < ptr->lthparlist; i++) /* loop through parameters */
- {
-
- offset = M[ ptr->parlist+i ];
- tpd = M[ ptr->pfdescr+i ]; /* type description of param */
- pd = M[ tpd ];
-
- if (par1 == PARIN)
- cflag = ( pd==PARIN || pd==PARINOUT || pd==FORMFUNC || pd==FORMPROC );
- else
- cflag = ( pd==PAROUT || pd==PARINOUT );
-
- if (cflag)
- {
- if (pd == FORMFUNC || pd == FORMPROC)
- {
- ap = APFMPROC;
- convert = TRUE;
- }
- else
- if (M[ M[ tpd+2 ] ] == CLASSTYPE)
- {
- ap = APREF;
- convert = TRUE;
- }
- else
- {
- prim = M[ tpd+2 ]-ipradr;
- ap = primapet[ prim ];
- convert = (prim == 4 || prim == 5); /* process or coroutine */
- }
-
- ap *= sizeof(word); /* param appetite in bytes */
-
- switch (dir) /* copy parameter in right direction */
- {
-
- case LOADPAR :
-
- /* we always load parameters from OUR process */
- assert(pix==thispix);
-
- if (convert){
- procaddr pa;
- {
- word ah=M[am+offset];
- if( !isprocess((virtaddr*)(M+am+offset)) &&
- M[ ah+1 ] == M[ am+offset+1 ]
- )
- if (prototype[ M[ M[ ah ]+PROTNUM ] ]->kind == PROCESS)
- {
- pa.node = ournode;
- pa.pix = pix;
- pa.mark = thisp->mark;
- }
- else
- /*pat errsignal(RTENONGL); */ /* only process may be global */
- /*pat*/ obj2mess(p->M,(virtaddr*)(p->M+am+offset),&pa);
- else
- obj2mess(M,(virtaddr*)(M+am+offset),&pa);
- }
-/*
- mkglobal(am+offset);
- obj2mess(p->M,(virtaddr*)(p->M+am+offset),&pa);
-*/
- moveblock((char *)&pa, cp, ap=sizeof(procaddr));
- }else
- moveblock((char *) &p->M[ am+offset ], cp, ap);
- break;
-
-
- case SAVEPAR :
-
- if (convert){
- procaddr pa;
- ap=sizeof(procaddr);
- moveblock(cp,(char *)&pa, ap);
- mess2obj(p,&pa,(virtaddr*)(p->M+am+offset));
- }else
- moveblock(cp, (char *) &p->M[ am+offset ], ap);
- break;
-
- }
-
- cp += ap;
- assert(cp-msg->params <= sizeof(msg->params));
- }
- }
-}
-
-
-word getnode(am) /* Determine node number for process */
-word am;
-{
- protdescr *ptr;
- word p;
- int i;
-
- p = prototype[ M[ am+PROTNUM ] ]->preflist;
- while (prototype[ M[ p ] ]->kind != PROCESS) p++;
- ptr = prototype[ M[ p ] ];
- if (ptr->lthpreflist == 1) i = 0;
- else i = prototype[ M[ p-1 ] ]->lthparlist;
- return (M[ am+M[ ptr->parlist+i ] ]);
-}
-
-
-void resume(virt) /* Perform RESUME instruction */
-virtaddr *virt;
-{
- message msg;
-
- if (isprocess(virt)) /* is it process realy ? */
- {
- msg.control.type = RESUME;
- obj2mess( M, virt, &msg.control.receiver );
- sendmsg1( &msg); /* request remote resume */
- }
- else errsignal(RTEILLRS); /* illegal RESUME */
-}
-
-
-static void createprocess(msg) /* Create new process */
-message *msg;
-{
- word i, prot;
- for (i = 0; i < MAXPROCESS; i++) /* find unused process descr. */
- if (!process[ i ].used && process[ i ].mark != -MAXMARKER) break;
- if (i == MAXPROCESS) senderr(RTETMPRC, &(msg->control.sender) );
- if (process[ i ].M == NULL) /* memory not allocated yet */
- {
- process[ i ].M = mallocate(memorysize+1);
- if (process[ i ].M == NULL) senderr(RTEMEMOV, &msg->control.sender);
- moveblock((char *) process[ 0 ].M, (char *) process[ i ].M,
- freem * sizeof(word));
- }
- prot = msg->control.par; /* process prototype number */
- initprocess(i, prot, &msg->control.sender);
- moveparams(i, process[ i ].prochead, msg, PARIN, SAVEPAR);
- process[ i ].status = GENERATING; /* execute process until RETURN */
- ready = pinsert(ready, i);
- reschedule = TRUE;
- if ((remote) && (i==0)) { thispix=1;thisp=NULL;transfer(i); }
-}
-
-
-static void killprocess(pix) /* Release process descriptor */
-word pix;
-{
- qfree(process[ pix ].msgqueue);
- qfree(process[ pix ].rpcwait);
- sfree(process[ pix ].rpcmask);
-
- process[ pix ].used = FALSE; /* mark descriptor as unused */
- process[ pix ].mark--; /* decrement marker */
-
- if( pix == thispix )
- {
- thispix = -1;
- thisp = NULL;
- }
-}
-
-
-static void localkill(msg)
-message *msg;
-{
- word pix;
-
- pix = msg->control.receiver.pix;
-
-# if RPCDBG
- fprintf( stderr, "kill process %d\n", pix );
-# endif
-
- if (process[ pix ].mark == msg->control.receiver.mark) /* not none */
- {
- if (process[ pix ].status != STOPPED) /* is process suspended ? */
- senderr(RTEILLKL, &msg->control.sender);
- killprocess(pix);
- }
-}
-
-
-void endprocess(status) /* Terminate current process */
-int status;
-{
- int i;
-
- passivate(STOPPED);
-# if RPCDBG
- fprintf( stderr, "terminate process %d\n", thispix );
-# endif
- killprocess(thispix);
- if (remote) longjmp(contenv, 1);
- for (i = 0; i < MAXPROCESS; i++)
- if (process[ i ].used) longjmp(contenv, 1);
- endrun(status);
-}
-
-
-static void backcreate(msg)
-message *msg;
-{
- word pix, am;
- procdescr *p;
-
- pix = msg->control.receiver.pix;
- p = &process[ pix ];
-
- am = p->M[ p->template.addr ]; /* template physical address */
- p->M[ temporary ] = am;
- moveparams(pix, am, msg, PAROUT, SAVEPAR);
-
- /*store new process address */
- mess2obj(p,&(msg->control.sender),&(p->backobj));
- activate(pix); /* end of waiting for NEW */
-}
-
-
-void senderr(exception, virt)
-int exception;
-procaddr *virt;
-{
- message msg;
-
- msg.control.type = ERRSIG;
- msg.control.receiver=*virt;
- msg.control.par = exception;
- sendmsg1(&msg); /* send error message */
- longjmp(contenv, 1); /* continue from next instruction */
-}
-
-
-static void localerror(msg)
-message *msg;
-{
- word pix;
- int s;
-
- pix = msg->control.receiver.pix;
- s = process[ pix ].status;
- if (process[ pix ].mark == msg->control.receiver.mark && s != STOPPED)
- {
- if (s == WAITFORNEW || s == WAITFORRPC) activate(pix);
- while (pfront(ready) != pix)
- ready = qrotate(ready);
- transfer(pfront(ready));
- errsignal(msg->control.par);
- }
-}
-
-
-void askprot(virt) /* Ask for prototype of object */
-virtaddr *virt;
-{
- word am;
- message msg;
-
- if (isprocess(virt)) /* send question to remote process */
- {
- obj2mess( M, virt, &msg.control.receiver );
- msg.control.type = ASKPRO;
- sendmsg1( &msg );
- passivate(WAITASKPRO);
- }
- else
- {
- if (member(virt, &am))
- M[ temporary ] = M[ am+PROTNUM ];
- else errsignal(RTEREFTN);
- }
-}
-
-
-static void ansprot(msg) /* Answer with prototype of process */
-message *msg;
-{
- message msg1;
- word pix;
-
- pix = msg->control.receiver.pix;
- if (process[ pix ].mark == msg->control.receiver.mark) /* not none */
- {
- msg1.control.receiver = msg->control.sender;
- msg1.control.type = PROACK;
- msg1.control.par = process[ pix ].prot;
- sendmsg1( &msg1 );
- }
- else senderr(RTEREFTN, &msg->control.sender);
-}
-
-
-/* Message send/receive handling : */
-
-void msginterrupt(msg) /* Receive message interrupt handler */
- message *msg;
-{
- moveblock((char *)msg, (char *)&globmsgqueue[ msgtail ],
- (word) sizeof(message));
- msgtail = (msgtail+1) % MAXMSGQUEUE;
- msgready++;
-
-}
-
-
-void sendmsg1(msg) /* Send message via net */
-message *msg;
-{
- MESSAGE m;
- int result=1;
-
- msg->control.sender.node = ournode;
- msg->control.sender.pix = thispix;
- msg->control.sender.mark = thisp->mark;
- if(
- msg->control.receiver.node == ournode
- ||
- msg->control.receiver.node == 0
- )
- /* simulate receive message interrupt */
- {
-
- msg->control.receiver.node == ournode;
- msginterrupt(msg); /* call directly interrupt handler */
- }
- else /* send message to kernel and then to NET module */
- {
- m.msg_type = MSG_NET;
- m.param.pword[0] = NET_PROPAGATE;
- m.param.pword[1] = MSG_INT;
- m.param.pword[2] = my_ctx.node;
- m.param.pword[3] = my_ctx.program_id;
- memcpy(&m.int_msg,msg,sizeof(message));
- result = send_to_net(&m);
- if (result == 0) {
- /* 2010 local allocation */
- msg->control.receiver.node == ournode;
- msginterrupt(msg); /* call directly interrupt handler */
- }
- }
-}
-
-
-void trapmsg() /* Check for waiting message */
-{
- message *msg;
- procdescr *p;
- word pix;
-
- if (msgready > 0) /* at least one message is waiting */
- {
- msg = &globmsgqueue[ msghead ]; /* get first message from queue */
- msghead = (msghead+1) % MAXMSGQUEUE;
-
- switch(msg->control.type)
- {
- case ERRSIG :
- localerror(msg);
- break;
-
- case RESUME :
- pix = msg->control.receiver.pix;
- if (process[ pix ].mark != msg->control.receiver.mark)
- senderr(RTEREFTN, &msg->control.sender);
- if (process[ pix ].status != STOPPED)
- senderr(RTEILLRS, &msg->control.sender);
- activate(pix);
- break;
-
- case CREATE :
- createprocess(msg);
- break;
-
- case CREACK :
- backcreate(msg);
- break;
-
- case KILLPR :
- localkill(msg);
- break;
-
- case RPCALL :
- rpc1(msg);
- break;
-
- case RPCACK :
- rpcend(msg);
- break;
-
- case ASKPRO :
- ansprot(msg);
- break;
-
- case PROACK :
- pix = msg->control.receiver.pix;
- p = &process[ pix ];
- p->M[ temporary ] = msg->control.par;
- activate(pix);
- break;
-
- default :
- fprintf( stderr, " Invalid message\n" );
- senderr(RTESYSER, &msg->control.sender);
- }
- msgready--;
-
- }
-}
-
-
-static void mkglobal(ref) /* Make global a process reference */
- word ref;
-{
- word ah;
- ah = M[ ref ];
- if (!isprocess((virtaddr*)(M+ref)) && M[ ah+1 ] == M[ ref+1 ])
- if (prototype[ M[ M[ ah ]+PROTNUM ] ]->kind == PROCESS)
- {
- virtaddr va;
- procaddr pa;
- pa.node = ournode;
- pa.pix = pix;
- pa.mark = thisp->mark;
- mess2obj(thisp,&pa,&va);
- M[ ref ] = va.addr;
- M[ ref+1 ] = va.mark;
-#ifdef RPCDBG
-fprintf(stderr,"mkglobal REAL (thisp=%d) isprocess:node=%d pix=%d mark=%d\n",thispix,pa.node,pa.pix,pa.mark);fflush(stderr);
-#endif
- }
- else errsignal(RTENONGL); /* only process may be global */
-}
-
-
-
-/*
-void show_m( char *s, message *msg ){
- char *n;
- switch(msg->control.type)
- {
- case ERRSIG : n = "ERRSIG"; break;
- case RESUME : n = "RESUME"; break;
- case CREATE : n = "CREATE"; break;
- case CREACK : n = "CREACK"; break;
- case KILLPR : n = "KILLPR"; break;
- case RPCALL : n = "RPCALL"; break;
- case RPCACK : n = "RPCACK"; break;
- case ASKPRO : n = "ASKPRO"; break;
- case PROACK : n = "PROACK"; break;
- default : n = "??????"; break;
- }
-#ifdef RPCDBG
- printf( "message %s type %s from %d:%d:%d to %d:%d:%d\n",
- s, n,
- msg->control.sender.node,
- msg->control.sender.pix,
- msg->control.sender.mark,
- msg->control.receiver.node,
- msg->control.receiver.pix,
- msg->control.receiver.mark
- );
- fflush( stdout );
-#endif
-}
-*/
-
projects / vlp.git / blobdiff