TheNetNode-CB/os/go32/go32.c

765 lines
23 KiB
C
Executable File

/************************************************************************/
/* */
/* ***** ***** */
/* ***** ***** */
/* ***** ***** */
/* ***** ***** */
/* *************** *************** */
/* ***************** ***************** */
/* *************** *************** */
/* ***** ***** TheNetNode */
/* ***** ***** Portable */
/* ***** ***** Network */
/* ***** ***** Software */
/* */
/* File os/go32/go32.c (maintained by: ???) */
/* */
/* This file is part of "TheNetNode" - Software Package */
/* */
/* Copyright (C) 1998 - 2008 NORD><LINK e.V. Braunschweig */
/* */
/* This program is free software; you can redistribute it and/or modify */
/* it under the terms of the NORD><LINK ALAS (Allgemeine Lizenz fuer */
/* Amateurfunk Software) as published by Hans Georg Giese (DF2AU) */
/* on 13/Oct/1992; either version 1, or (at your option) any later */
/* version. */
/* */
/* This program is distributed WITHOUT ANY WARRANTY only for further */
/* development and learning purposes. See the ALAS (Allgemeine Lizenz */
/* fuer Amateurfunk Software). */
/* */
/* You should have received a copy of the NORD><LINK ALAS (Allgemeine */
/* Lizenz fuer Amateurfunk Software) along with this program; if not, */
/* write to NORD><LINK e.V., Hinter dem Berge 5, D-38108 Braunschweig */
/* */
/* Dieses Programm ist PUBLIC DOMAIN, mit den Einschraenkungen durch */
/* die ALAS (Allgemeine Lizenz fuer Amateurfunk Software), entweder */
/* Version 1, veroeffentlicht von Hans Georg Giese (DF2AU), */
/* am 13.Oct.1992, oder (wenn gewuenscht) jede spaetere Version. */
/* */
/* Dieses Programm wird unter Haftungsausschluss vertrieben, aus- */
/* schliesslich fuer Weiterentwicklungs- und Lehrzwecke. Naeheres */
/* koennen Sie der ALAS (Allgemeine Lizenz fuer Amateurfunk Software) */
/* entnehmen. */
/* */
/* Sollte dieser Software keine ALAS (Allgemeine Lizenz fuer Amateur- */
/* funk Software) beigelegen haben, wenden Sie sich bitte an */
/* NORD><LINK e.V., Hinter dem Berge 5, D-38108 Braunschweig */
/* */
/************************************************************************/
#include "tnn.h"
#include "pc.h"
#include <crt0.h>
#include <sys/farptr.h>
#include <sys/movedata.h>
#include <pc.h>
#define WATCH_TIME 6000 /* ca.5 Minuten Timeout */
#define PIC 0x20 /* Interrupt-Controller */
#define PIT 0x40 /* Timer Port 0 */
int _crt0_startup_flags = _CRT0_FLAG_LOCK_MEMORY;
unsigned int_level = 0;
int GNU32BUFFERS = 5000;
char *dbg_module = "";
int tim_factor;
int conscom = -1; /* Schnittstellen-Handle fuer Console */
int portadress = 0;
static int oldtimer = 0;
FILE *aus; /* Fuer den Wachhund */
char debugfile[MAXPATH];
WORD watchdog; /* wurde schon mal extern deklariert */
static BOOLEAN flag = TRUE;
struct tm *zeit;
/**************************************************************************/
/* vsnprintf fuer DOSe DG8BR */
/*------------------------------------------------------------------------*/
int vsnprintf(char *str, int NOTIFYVSNPFBUFF, const char *format, va_list arg_ptr)
{
char str2[4096];
int n = 0;
if (vsprintf(str2, format, arg_ptr) == EOF)
return(EOF);
if ((n = strlen(str2)) > NOTIFYVSNPFBUFF)
return(n);
strncpy(str, str2, NOTIFYVSNPFBUFF);
return(n);
}
/**************************************************************************/
/* */
/*------------------------------------------------------------------------*/
void randomize(void)
{
}
/**************************************************************************/
/* */
/*------------------------------------------------------------------------*/
unsigned long coreleft(void)
{
return(_go32_dpmi_remaining_physical_memory());
}
/**************************************************************************/
/* */
/*------------------------------------------------------------------------*/
BOOLEAN ishput(void)
{
return(conscom == -1 ? FALSE : rs232_out_status(conscom));
}
/**************************************************************************/
/* */
/*------------------------------------------------------------------------*/
BOOLEAN ishget()
{
if (kbhit())
{
if (ishmod)
hgetc(); /* im Hostmode Console ignorieren */
else
return(TRUE); /* im Terminalmode melden, dass was da ist */
}
if (conscom != -1)
return(rs232_in_status(conscom));
return(FALSE); /* keine Umleitung, also auch nix da */
}
/**************************************************************************/
/* */
/*------------------------------------------------------------------------*/
char hgetc(void)
{
#define Prefix 0
#define ALT_X '-'
char retval;
if (kbhit()) {
if ((retval = getch()) == Prefix)
if (getch() == ALT_X)
quit_program(0);
return(retval);
}
if (conscom != -1)
if (rs232_in_status(conscom))
return(rs232_in(conscom));
return(0);
}
/**************************************************************************/
/* */
/* Zeichen an die Console ausgeben. Wenn eine Umleitung besteht, das */
/* Zeichen zusaetzlich noch dort ausgeben. Auf die PC-Console wird im */
/* Hostmode nichts geschrieben. */
/* */
/*------------------------------------------------------------------------*/
void hputc(char c)
{
if (!ishmod) { /* keine Ausgaben im Hostmode */
if (c == CR) /* nur fuer PC/Console notwenig! */
putchar('\n');
else
putchar(c);
}
if (conscom != -1)
rs232_out(conscom, c);
}
/**************************************************************************/
/* */
/*------------------------------------------------------------------------*/
BOOLEAN init_hardware(int argc, char *argv[])
{
char *tz_string;
int baseadress[3];
int lpt = 0;
#define MEMORY_NEEDED (GNU32BUFFERS*sizeof(MAX_BUFFER))
randomize();
if (getenv("TNN32BUFFERS") != NULL)
sscanf(getenv("TNN32BUFFERS"), "%u", &GNU32BUFFERS);
if (getenv("TOGGLEPORT") != NULL)
{
sscanf(getenv("TOGGLEPORT"), "%u", &lpt);
baseadress[0] = _farpeekw(_dos_ds,0x0040*16 + 0x08); /* LPT 1 */
baseadress[1] = _farpeekw(_dos_ds,0x0040*16 + 0x0a); /* LPT 2 */
baseadress[2] = _farpeekw(_dos_ds,0x0040*16 + 0x0c); /* LPT 3 */
portadress = baseadress[lpt -1];
printf("\nfound LPT at $%x.\n",portadress);
portadress = portadress + 2; /* getoggelt wird 2 hoeher */
toggle_lpt(); /* schon mal schalten, sonst werden es 2 Minuten */
}
if ((RAMBOT = (char *) calloc(1,MEMORY_NEEDED)) == NULL)
{
printf("\n\007\n*** WARNING: Not enough memory !\n\n");
exit(-1);
}
RAMTOP = RAMBOT + MEMORY_NEEDED;
/**********************************************************************/
/* Komandozeile auswerten */
/**********************************************************************/
if (argc > 1) hputs("*** WARNING: Parameters ignored");
/**********************************************************************/
/* Systemzeit und Zeitberechung initialisieren */
/**********************************************************************/
tz_string = getenv("TZ"); /* Feststellen, ob TimeZone */
if (tz_string == NULL) { /* gesetzt ist, sonst */
putenv("TZ=UTC0"); /* mit UTC0 vorbelegen */
puts("*** WARNING: Timezone set to UTC");
}
tzset(); /* Zeitzone auswerten */
consfile = stdout;
return(FALSE);
}
/**************************************************************************/
/* */
/*------------------------------------------------------------------------*/
void init_console(void)
{
int dev,adr,irq,bd;
read_envcom("CONSOLE", &dev, &adr, &irq);
if (dev != -1) {
conscom = open_rs232(dev,adr,irq,512,512);
bd = setbaud(conscom, 192);
xprintf(" setting to %u00 8N1.\n", bd);
xprintf("--- CONSOLE attached to /dev/COM%u\n", dev+1);
}
}
/**************************************************************************/
/* */
/*------------------------------------------------------------------------*/
void exit_console(void)
{
if (conscom != -1)
close_rs232(conscom);
}
/**************************************************************************/
/* Uebergabe von Daten an die Shell (nur Linux) */
/*------------------------------------------------------------------------*/
BOOLEAN l7tosh(MBHEAD *mbp)
{
return(FALSE);
}
/**************************************************************************/
/* Shell-Server (nur Linux) */
/*------------------------------------------------------------------------*/
void shellsrv(void)
{
}
/**************************************************************************/
/* Ausfuehren einer neuen Software */
/*------------------------------------------------------------------------*/
void tnnexec(char *file)
{
char filename[MAXPATH+1];
strncpy(filename, file, MAXPATH);
filename[MAXPATH] = 0;
if (xaccess(filename,0)==0) {
l1exit();
/* bei DOS16 -> done_umb() */
exit_timer();
exit_hardware();
execl(filename, filename, NULL);
perror("EXEC");
HALT("tnnexec");
}
}
/**************************************************************************/
/* Ausfuehren eines Befehls */
/*------------------------------------------------------------------------*/
BOOLEAN tnnshell(char *cmdline)
{
char cmd[MAXPATH+MAXPATH+2], *name;
strncpy(cmd, cmdline, MAXPATH);
cmd[MAXPATH] = 0;
name = tempnam(textpath, "sh");
if (name) {
strcat(cmd, " > ");
strcat(cmd, name);
system(cmd);
strcpy(cmdline, normfname(name));
free(name);
} else cmdline[0] = 0;
return(FALSE);
}
/**************************************************************************/
/* Hardware deinitialisieren */
/*------------------------------------------------------------------------*/
void exit_hardware()
{
free((void *) RAMBOT);
}
/**************************************************************************/
/* System neu starten (GNU32 -> Beenden und Rechner neu starten) */
/*------------------------------------------------------------------------*/
void reboot_system()
{
__dpmi_regs r;
l1exit();
r.x.ax = 47; /* Pointer setzen */
r.x.cs = 0xffff; /* Segment im DOS */
r.x.ip = 0x0000; /* Offset im DOS */
r.x.ss = r.x.sp = 0; /* Sollen laut DPMI auf 0 stehen */
__dpmi_simulate_real_mode_procedure_retf(&r); /* Kaltstartroutine */
}
/**************************************************************************/
/* An LPT1 den Pin 16(RESET) toggeln. Hardware-Watchdog */
/**************************************************************************/
void
toggle_lpt (void)
{
if (portadress != 0)
{
if (flag)
{
writebit(portadress, 0x04, 1); /* Pin 16 einschalten */
flag = FALSE;
}
else
{
writebit(portadress, 0x04, 0); /* Pin 16 ausschalten */
flag = TRUE;
}
}
}
/**************************************************************************/
/* Wenn moeglich Interrupts wieder freigeben */
/*------------------------------------------------------------------------*/
void decEI(void)
{
if (--int_level == 0)
enable();
}
/**************************************************************************/
/* Interrupts sperren in kritischen Bereichen. */
/*------------------------------------------------------------------------*/
void DIinc(void)
{
int_level++;
disable();
}
/* Disable hardware interrupt */
int
maskoff(unsigned irq)
{
if (irq < 8)
{
setbit(0x21, (char)(1 << irq));
}
else
if (irq < 16)
{
irq -= 8;
setbit(0xa1, (char)(1 << irq));
}
else
{
return(-1);
}
return(0);
}
/* Enable hardware interrupt */
int
maskon(unsigned irq)
{
if (irq < 8)
{
clrbit(0x21, 1 << irq);
}
else
if (irq < 16)
{
irq -= 8;
clrbit(0xa1, 1 << irq);
}
else
{
return(-1);
}
return(0);
}
/* Return 1 if specified interrupt is enabled, 0 if not, -1 if invalid */
int
getmask(unsigned irq)
{
if (irq < 8)
return((inportb(0x21) & (1 << irq)) ? 0 : 1);
else
if (irq < 16)
{
irq -= 8;
return((inportb(0xa1) & (1 << irq)) ? 0 : 1);
}
else
return(-1);
}
/* Set bit(s) in I/O port */
void
setbit(unsigned port, unsigned char bits)
{
outportb(port, inportb(port) | bits);
}
/* Clear bit(s) in I/O port */
void
clrbit(unsigned port, unsigned char bits)
{
outportb(port, inportb(port) & ~bits);
}
/* Set or clear selected bits(s) in I/O port */
void
writebit(unsigned port, unsigned char mask, int val)
{
unsigned char x;
x = inportb(port);
if (val)
x |= mask;
else
x &= ~mask;
outportb(port, x);
}
struct int_tab
{
__dpmi_paddr old; /* Previous handler at this vector */
_go32_dpmi_seginfo new; /* Current handler, with wrapper info */
void (*func)(int); /* Function to call on interrupt */
int arg; /* Arg to pass to interrupt function */
int chain; /* Is interrupt chained to old handler? */
} Int_tab[16];
/* What a crock. All this inelegance should be replaced with something
* that figures out what interrupt is being serviced by reading the 8259.
*/
static void
irq0(void)
{
eoi();
(*Int_tab[0].func)(Int_tab[0].arg);
}
static void
irq1(void)
{
eoi();
(*Int_tab[1].func)(Int_tab[1].arg);
}
static void
irq2(void)
{
eoi();
(*Int_tab[2].func)(Int_tab[2].arg);
}
static void
irq3(void)
{
eoi();
(*Int_tab[3].func)(Int_tab[3].arg);
}
static void
irq4(void)
{
eoi();
(*Int_tab[4].func)(Int_tab[4].arg);
}
static void
irq5(void)
{
eoi();
(*Int_tab[5].func)(Int_tab[5].arg);
}
static void
irq6(void)
{
eoi();
(*Int_tab[6].func)(Int_tab[6].arg);
}
static void
irq7(void)
{
eoi();
(*Int_tab[7].func)(Int_tab[7].arg);
}
static void
irq8(void)
{
eoi();
(*Int_tab[8].func)(Int_tab[8].arg);
}
static void
irq9(void)
{
eoi();
(*Int_tab[9].func)(Int_tab[9].arg);
}
static void
irq10(void)
{
eoi();
(*Int_tab[10].func)(Int_tab[10].arg);
}
static void
irq11(void)
{
eoi();
(*Int_tab[11].func)(Int_tab[11].arg);
}
static void
irq12(void)
{
eoi();
(*Int_tab[12].func)(Int_tab[12].arg);
}
static void
irq13(void)
{
eoi();
(*Int_tab[13].func)(Int_tab[13].arg);
}
static void
irq14(void)
{
eoi();
(*Int_tab[14].func)(Int_tab[14].arg);
}
static void
irq15(void)
{
eoi();
(*Int_tab[15].func)(Int_tab[15].arg);
}
static void (*Vectab[16])(void) =
{
irq0, irq1, irq2, irq3, irq4, irq5, irq6, irq7,
irq8, irq9, irq10, irq11, irq12, irq13, irq14, irq15
};
int
allocirq(unsigned irq, int chain, void (*func)(int), int arg)
{
struct int_tab *ip;
unsigned char intno;
int i;
if (irq > 15)
return(-1); /* IRQ out of legal range */
ip = &Int_tab[irq];
if (ip->func != NULL)
return(-1); /* Already in use */
/* Convert irq to actual CPU interrupt vector */
intno = (irq < 8) ? irq + 8 : 0x70 + irq - 8;
__dpmi_get_protected_mode_interrupt_vector(intno, &ip->old);
ip->func = func;
ip->arg = arg;
ip->new.pm_offset = (int)Vectab[irq];
ip->new.pm_selector = _go32_my_cs();
ip->chain = chain;
if (chain)
return(_go32_dpmi_chain_protected_mode_interrupt_vector(intno, &ip->new));
if ((i = _go32_dpmi_allocate_iret_wrapper(&ip->new)) != 0)
return(i);
return(_go32_dpmi_set_protected_mode_interrupt_vector(intno, &ip->new));
}
int
freeirq(unsigned irq)
{
struct int_tab *ip;
int i;
if (irq > 15)
return(-1); /* IRQ out of legal range */
ip = &Int_tab[irq];
ip->func = NULL;
/* Convert irq to actual CPU interrupt vector */
irq = (irq < 8) ? irq + 8 : 0x70 + irq - 8;
if (ip->chain)
return(_go32_dpmi_unchain_protected_mode_interrupt_vector(irq, &ip->new));
if((i = __dpmi_set_protected_mode_interrupt_vector(irq, &ip->old)) != 0)
return(i);
return(_go32_dpmi_free_iret_wrapper(&ip->new));
}
void
init_timer(void)
{
unsigned long t1, t2, tx;
tx = time(NULL); /* Korrekturfaktor fuer kaputte Boards */
while (tx == time(NULL));
t1 = uclock();
while (tx + 1 == time(NULL));
t2 = uclock();
if (t2 - t1 > 2000000)
{
xprintf("*** WARNING: Timer XTAL is 2.38Mhz\n");
tim_factor = 2;
}
else
tim_factor = 1;
watchdog = 0; /* erstmal auf 0 stellen */
disable(); /* einen Soft-Wachhund installieren */
allocirq(0, 1, watch_dog_reset, 0); /* wir haengen uns in IRQ 0 */
oldtimer = getmask(0); /* alten IRQ-Vektor merken */
maskon(0);
enable();
}
void
exit_timer(void)
{
disable();
if (!oldtimer)
maskoff(0); /* alten IRQ-Vektor wieder herstellen */
freeirq(0); /* einmal mit neuer Maske freigeben ?! */
enable();
}
void
update_timer(void)
{
static uclock_t last_uclock = 0L;
static uclock_t uclock_sum = 0L;
uclock_t now, diff;
watchdog = 0; /* watchdog zuruecksetzen */
now = uclock(); /* aktuelle Uhrzeit merken */
diff = (now - last_uclock) /* Zeit seit letzer Runde */
* tim_factor; /* Korrekturfaktor */
last_uclock = now; /* den neuen Wert merken */
uclock_sum += diff; /* aktueller Zaehlerstand */
/* jetzt die vergangenen Tenticks aufaddieren und vom Zaehlerstand */
/* wegstreichen, Ungenauigkeit etwa 1.2ms in 10 Sekunden. Da es */
/* sich hier nur um einen Timer fuer LAPB (AX.25) handelt, ist das */
/* zu verkraften. */
tic10 += (unsigned) (uclock_sum / (UCLOCKS_PER_SEC / 100));
uclock_sum %= (UCLOCKS_PER_SEC / 100);
fflush(stdout);
}
void
watch_dog_reset(int nix)
{
nix = 1; /* Dummy-Variable. Ist beim IRQ-Aufruf so definiert!! */
if (++watchdog > WATCH_TIME)
{
sprintf(debugfile, "%s\\debug.txt", textcmdpath);
aus = fopen(debugfile, "at");
fprintf(aus, "Der Wachhund hat zugebissen!!\n");
fprintf(aus, "Letzter Befehl war : %s\n", clilin);
zeit = localtime(&sys_time);
fprintf(aus, "%02d.%02d.%02d %02d:%02d\n\n", zeit->tm_mday,
zeit->tm_mon+1,
zeit->tm_year%100,
zeit->tm_hour,
zeit->tm_min);
fclose(aus);
reboot_system(); /* und Schulz is */
}
}
/* Written to extend gopint.c in djgpp library */
int _go32_dpmi_unchain_protected_mode_interrupt_vector(unsigned irq,_go32_dpmi_seginfo *info)
{
__dpmi_paddr v;
char *stack;
char *wrapper;
__dpmi_get_protected_mode_interrupt_vector(irq,&v);
/* Sanity check: does the vector point into our program? A bug in gdb
* keeps us from hooking the keyboard interrupt when we run under its
* control. This test catches it.
*/
if (v.selector != _go32_my_cs())
return(-1);
wrapper = (char *)v.offset32;
/* Extract previous vector from the wrapper chainback area */
v.offset32 = *(long *)(wrapper + 0x5b);
v.selector = *(short *)(wrapper + 0x5f);
/* Extract stack base from address of _call_count variable in wrapper */
stack = (char *)(*(long *)(wrapper+0x0F) - 8);
#define STACK_WAS_MALLOCED (1 << 0)
if (*(long *) stack & STACK_WAS_MALLOCED)
free(stack);
free(wrapper);
__dpmi_set_protected_mode_interrupt_vector(irq, &v);
return(0);
}
/* Re-arm 8259 interrupt controller(s)
* Should be called just after taking an interrupt, instead of just
* before returning. This is because the 8259 inputs are edge triggered, and
* new interrupts arriving during an interrupt service routine might be missed.
*/
void eoi(void)
{
/* read in-service register from secondary 8259 */
outportb(0xa0, 0x0b);
if(inportb(0xa0))
outportb(0xa0, 0x20); /* Send EOI to secondary 8259 */
outportb(0x20, 0x20); /* Send EOI to primary 8259 */
}
/* End of os/go32/go32.c */