home *** CD-ROM | disk | FTP | other *** search
#define NET14MASTER #ifdef __TURBOC__ #include "turboc.h" #endif #include <stdio.h> #include <conio.h> #include <string.h> #include <stdlib.h> #include <malloc.h> #include <dos.h> #include <ctype.h> #include <process.h> #include <errno.h> #ifdef MSC #include <direct.h> #include <signal.h> #include <time.h> #endif #ifdef MEMORY_DEBUG #include "memdebug.h" #endif #include "netevent.h" #include "hostform.h" #include "whatami.h" #include "externs.h" /* #define DEBUG */ /* * Global variables */ static unsigned char path_name[_MAX_DRIVE+_MAX_DIR], /* character storage for the path name */ temp_str[100],temp_data[100]; /* temporary character storage */ #ifdef CHECKNULL unsigned char nullbuf[1024]; /* buffer to hold the lowest 1024 bytes */ #endif unsigned char buf[256]; static char *config; int debug = 0; /* enable with -D option */ #define SERIAL 0x14 #define NUM_COMM_PORTS 4 /* the number of comm. ports supported, remember to change this variable in int14.asm also */ extern volatile unsigned char *data_begin[NUM_COMM_PORTS]; /* pointers to the beginning of the data buffer for the comm.ports */ extern unsigned char *data_max[NUM_COMM_PORTS]; /* pointers to the maximum value for the data_end pointers */ extern volatile unsigned char *data_end[NUM_COMM_PORTS]; /* pointers to the end of the data buffer for the comm. ports */ extern unsigned char *data_start[NUM_COMM_PORTS]; /* pointers to the start of the data buffer for the comm. ports */ #define PORT_DATA_SIZE 2048 /* this is sort of a guess, might need larger */ unsigned char port_data[NUM_COMM_PORTS][PORT_DATA_SIZE]; /* data buffer for data read in from the comm. port */ int comm_port_index[NPORTS]; /* lookup table from a network port number to a comm port number */ unsigned char myipnum[4]; /* the ip number for this machine */ uint speedup=2; #ifdef OLD_WAY int bypass_passwd=0; /* whether to bypass the password check, not used */ struct machinfo *mp; extern struct config def; /* Default settings obtained from host file */ extern unsigned char initialized_flags; /* flags indicating whether a port has been initialized */ extern unsigned char connected_flags; /* flags indicating whether a port is connected yet */ extern unsigned char opening_flags; /* flags indicating whether a port is negotiating an open connection */ extern unsigned char port_buffer[NUM_COMM_PORTS][64]; /* four buffers to store the machine name to connect to */ extern unsigned char buffer_offset[NUM_COMM_PORTS]; /* the offset into the buffer currently */ extern int pnum[NUM_COMM_PORTS]; /* the port number we are connected to */ unsigned char parsedat[32]; /* character buffer to store network writes */ int telstate[NUM_COMM_PORTS]={STNORM,STNORM,STNORM,STNORM}; /* the telnet state for each comm. port */ int substate[NUM_COMM_PORTS]={0,0,0,0}; /* the telnet state for each comm. port */ int echo[NUM_COMM_PORTS]={1,1,1,1}; int igoahead[NUM_COMM_PORTS]={0,0,0,0}; int ugoahead[NUM_COMM_PORTS]={0,0,0,0}; int timing[NUM_COMM_PORTS]={0,0,0,0}; char c; #ifdef QAK int buffer_stat=0,max_buffer_stat=0; #endif #endif /* * main ( argc, argv ) * * Entry : * * parameter 1 : machine name * */ /* #define TSR #define PORT 1 */ int main(argc,argv) int argc; char *argv[]; { #ifdef TSR union REGS inregs; /* register set going into the interrupt */ union REGS outregs; /* register set going out of the interrupt */ unsigned int str_length; #endif int i, #ifdef TSR cnt,ev,what,dat, #endif exec_num; /* the argument number which is the name of the file to execute */ char file_name[_MAX_PATH], *str, spawn_str[_MAX_PATH]; /* file name oft he executable to spawn */ #ifdef QAK printf("stackavail=%u\n",stackavail()); #endif #ifdef __TURBOC__ fnsplit(argv[0],path_name,buf,temp_str,temp_data); #else _splitpath(argv[0],path_name,buf,temp_str,temp_data); /* split the full path name of net14.exe into it's components */ #endif strcat(path_name,buf); /* append the real path name to the drive specifier */ config = (getenv("CONFIG.TEL")); /* check for a config.tel in the environment */ if(config) /* set a different config.tel file */ Shostfile(config); #ifdef QAK puts("National Center for Supercomputing Applications"); /* put the banner on the screen */ puts("Interrupt 14h driver"); puts("January 1991\n"); #endif #ifndef TSR if(argc<2) { puts("Usage: net14 [-h hostfile] childname [child_param]\n"); exit(1); } /* end if */ #endif /* * work on parms */ for(i=1; i<argc; i++) { /* look at each parm */ if(*argv[i]=='-') { /* command line parameter */ switch(*(argv[i]+1)) { case 'h': Shostfile(argv[++i]); /* set new name for host file */ break; case 'D': /* turn on debugging */ debug=1; break; case '#': /* set the clock speedup */ speedup=atoi(argv[i]+2); /* get the speedup factor */ if(speedup!=1 && speedup!=2 && speedup!=4 && speedup!=8 && speedup!=16 && speedup!=32) /* only accept multiples of two between 1 and 32 for the speedup factor */ speedup=1; break; default: puts("Usage: net14 [-h hostfile] [-#<speedup>] filename [param]\n"); exit(1); } } else { /* must be the name of the file to execute */ exec_num=i; /* save the argument number of the name to execute */ break; /* break out of the loop (any further arguments must pertain to the program to execute) */ } /* end else */ } if(!int14init()) /* install the network stuff */ exit(1); for(i=0; i<NUM_COMM_PORTS; i++) { /* initialize the port buffers */ data_begin[i]=port_data[i]; /* start at the beginning of the buffer */ data_end[i]=port_data[i]; /* set the end of the buffer at the beginning currently */ data_start[i]=port_data[i]; /* set the start of each buffer */ data_max[i]=port_data[i]+PORT_DATA_SIZE; /* set the maximum value the buffer can use */ /* Special: grab at least one port to communicate TCP over */ makeport(); #ifdef DEBUG printf("%d: data_begin=%p, data_max=%p, data_end=%p\n",i,data_begin[i],data_max[i],data_end[i]); #endif } /* end for */ for(i=0; i<NPORTS; i++) /* initialize the comm port indices */ comm_port_index[i]=-1; #ifdef DEBUG printf("data_begin[2]=[%x][%x]\n",(unsigned)(*((unsigned *)&data_begin[2])),(unsigned)(*(((unsigned *)&data_begin[2])+1))); #endif int14inst(); /* install the int 14h handler */ #ifdef QAK printf("int14 =%p\n",_dos_getvect(0x14)); #endif /* #ifndef TSR */ timeinst(); /* install the timer interrupt handler */ /* #endif */ #ifdef QAK printf("int1C =%p\n",_dos_getvect(0x1C)); #endif #ifdef TSR inregs.h.ah=0; /* set to initialize the comm. port */ inregs.x.dx=PORT; /* use port two */ int86(SERIAL,&inregs,&outregs); /* call to initialize the interrupt */ inregs.h.ah=1; /* set to send a character */ inregs.h.al=2; /* send initialization character */ inregs.x.dx=PORT; /* use port two */ int86(SERIAL,&inregs,&outregs); /* call to initialize the interrupt */ str=argv[1]; str_length=strlen(str); for(i=0; i<(int)str_length; i++,str++) { inregs.h.ah=1; /* set to send a character */ inregs.h.al=*str; /* send name character */ inregs.x.dx=PORT; /* use port two */ int86(SERIAL,&inregs,&outregs); /* call to initialize the interrupt */ } /* end for */ inregs.h.ah=1; /* set to send a character */ inregs.h.al=3; /* send initialization character */ inregs.x.dx=PORT; /* use port two */ int86(SERIAL,&inregs,&outregs); /* call to initialize the interrupt */ #ifdef QAK if(!int14open(argv[1]),2) /* open session to the specified machine */ exit(1); #endif c = 0; do { if(kbhit()) { /* has key been pressed */ c=(char)getch(); if(c==16) break; if(c==14) #ifdef QAK printf("max_buffer_stat=%d\n",max_buffer_stat); #else printf("stackavail()=%u\n",stackavail()); #endif inregs.h.ah=1; /* set to send a character */ inregs.h.al=c; /* send character */ inregs.x.dx=PORT; /* use port two */ int86(SERIAL,&inregs,&outregs); /* call to initialize the interrupt */ } #ifdef QAK int14netsleep(); /* call this to maintain network */ #endif #ifdef QAK inregs.h.ah=3; /* set to check status */ inregs.x.dx=PORT; /* use port two */ int86(SERIAL,&inregs,&outregs); /* call to initialize the interrupt */ if(outregs.h.ah&0x01) { /* check for data being ready */ inregs.h.ah=2; /* set to receive a character */ inregs.x.dx=PORT; /* use port two */ int86(SERIAL,&inregs,&outregs); /* call to initialize the interrupt */ c=(int)outregs.h.al; /* get the return value */ putchar(c); } /* end if */ #else dat=int14check(); if(dat&0x0100) { /* chek for data begin ready */ c=int14receive(); putchar(c); } /* end if */ #endif } while(c!=16); /* Ctrl-P, arbitrary escape */ #ifdef QAK printf("max_buffer_stat=%d\n",max_buffer_stat); #endif timedeinst(); /* remove the timer interrupt handler */ int14deinst(); /* remove the int 14h handler */ netclose(pnum[PORT]); netshut(); #else #ifdef QAK go_tsr(); #else #ifdef QAK printf("sizeof(struct port)=%d\n",sizeof(struct port)); #endif #ifdef CHECKNULL memcpy(nullbuf,MK_FP(0x0,0x0),1024); #endif #ifdef OLD_WAY str=malloc(5000); /* malloc a large chunk of memory */ free(str); /* just to get it into the memory pool */ #endif strupr(argv[exec_num]); _searchenv(argv[exec_num],"PATH",file_name); /* get the pathname of the file to execute */ if(file_name[0]=='\0') { /* couldn't find the executable in the path, is must be in the current directory */ strcpy(spawn_str,argv[exec_num]); strcat(spawn_str,".COM"); _searchenv(spawn_str,"PATH",file_name); /* get the pathname of the file to execute */ if(file_name[0]=='\0') { /* couldn't find the executable in the path, is must be in the current directory */ strcpy(spawn_str,argv[exec_num]); strcat(spawn_str,".EXE"); _searchenv(spawn_str,"PATH",file_name); /* get the pathname of the file to execute */ if(file_name[0]=='\0') /* couldn't find the executable in the path, is must be in the current directory */ getcwd(file_name,_MAX_PATH); } /* end if */ } /* end if */ #ifdef CHECKNULL /* If we are running in NULL debugging mode, check that */ if(memcmp(nullbuf,MK_FP(0x0,0x0),1024)) { unsigned u; unsigned char *s; puts("NULL overwritten!"); s=MK_FP(0x0,0x0); for(u=0; u<1024; u++,s++) if(*s!=nullbuf[u]) printf("s=%p, u=%u, val=%u\n",s,u,(unsigned int)*s); getch(); } /* end if */ else { puts("NULL looks fine right before spawning a program"); getch(); } /* end else */ #endif i=spawnvp(P_WAIT,file_name,&argv[exec_num]); /* call the program which needs the re-direction */ puts("After spawn returns"); if(i==(-1)) { /* check for error spawning the process */ switch(errno) { /* find out what the problem was */ case E2BIG: /* argument list too long to child process */ puts("Error: bad argument list to child process\n"); break; case EINVAL: /* the execution mode was invalid */ puts("Error: invalid execution mode for child process\n"); break; case ENOENT: /* file not found to spawn */ puts("Error: child process not found\n"); break; case ENOEXEC: /* not an executable file */ puts("Error: child process is not an executable file\n"); break; case ENOMEM: /* not enough memory to spawn process */ puts("Error: not enough memory for child process\n"); break; } /* end switch() */ } /* end if */ timedeinst(); /* remove the timer interrupt handler */ int14deinst(); /* remove the int 14h handler */ puts("After removing the interrupt handlers"); netshut(); puts("After shutting down the network"); #endif #endif return(0); } #ifdef QAK /* * errhandle () * * Write error messages to the console window * */ void errhandle(void ) { char *errmsg; int i,j; while(ERR1==Sgetevent(ERRCLASS,&i,&j)) { errmsg=neterrstring(j); puts(errmsg); } } #endif 
