workbench/network/stacks/AROSTCP/bsdsocket/kern/amiga_main.c

   1 /*
   2  * Copyright (C) 1993 AmiTCP/IP Group, <amitcp-group@hut.fi>
   3  *                    Helsinki University of Technology, Finland.
   4  *                    All rights reserved.
   5  * Copyright (C) 2005 - 2010 The AROS Dev Team
   6  *
   7  * This program is free software; you can redistribute it and/or modify
   8  * it under the terms of the GNU General Public License version 2 as
   9  * published by the Free Software Foundation.
  10  *
  11  * This program is distributed in the hope that it will be useful, but
  12  * WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  14  * General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU General Public License
  17  * along with this program; if not, write to the Free Software
  18  * Foundation, Inc., 59 Temple Place - Suite 330, Boston,
  19  * MA 02111-1307, USA.
  20  *
  21  */
  22
  23 #include <conf.h>
  24
  25 #include <sys/param.h>
  26 #include <sys/systm.h>
  27 #include <sys/synch.h>
  28 #include <sys/malloc.h>
  29 #include <sys/mbuf.h>
  30 #include <sys/syslog.h>
  31 #include <sys/socket.h>
  32 #include <sys/socketvar.h>
  33
  34 #include <stdio.h>
  35 #include <version.h>
  36 /*#include <string.h>*/
  37
  38 #include <signal.h>             /* from the C compiler's includes */
  39
  40 #include <kern/amiga_includes.h>
  41 #include <libraries/miamipanel.h>
  42
  43 #include <proto/dos.h>
  44 //#include <proto/miamipanel.h>
  45
  46 #include <kern/amiga_time.h>
  47 #include <kern/amiga_log.h>
  48
  49 ULONG sana_init(void);
  50 void sana_deinit(void);
  51 BOOL sana_poll(void);
  52
  53 #include <kern/amiga_main_protos.h>
  54 #include <kern/amiga_config.h>
  55 #include <kern/amiga_gui.h>
  56 #include <kern/amiga_netdb.h>
  57 #include <kern/amiga_rc.h>
  58 #include <kern/amiga_log.h>
  59 #include <kern/kern_malloc_protos.h>
  60 #include <api/amiga_api.h>
  61
  62 /*
  63  * include prototypes for initialization functions
  64  */
  65 #include <kern/uipc_domain_protos.h>    /* domaininit() */
  66
  67 /*
  68  * The main module of the AMITCP/IP.
  69  */
  70
  71 /*
  72  * Global variable so AMITCP/IP task information can be utilized.
  73  */
  74 struct Task * AROSTCP_Task;
  75
  76 extern struct ExecBase * SysBase;
  77 extern struct Library * MasterSocketBase;
  78 extern WORD nthLibrary;
  79
  80 static ULONG sanamask = 0,
  81   sig = 0, signalmask = 0, timermask = 0,
  82   breakmask = 0;
  83
  84 UBYTE *taskname = NULL;
  85 /*BPTR db_lock = NULL;*/
  86 ULONG EnableDebug = 0;
  87 BOOL  initialized = FALSE;
  88
  89 TEXT interfaces_path[FILENAME_MAX];
  90 TEXT netdb_path[FILENAME_MAX];
  91 TEXT db_path[FILENAME_MAX];
  92 TEXT config_path[FILENAME_MAX];
  93 UBYTE logfiledefname[FILENAME_MAX];
  94 UBYTE dhclient_path[FILENAME_MAX];
  95
  96 /*
  97 TEXT hequiv_path[FILENAME_MAX];
  98 TEXT inetdconf_path[FILENAME_MAX];
  99 */
 100 STRPTR version = "$VER: " STACK_RELEASE;
 101
 102 int
 103 main(int argc, char *argv[])
 104 {
 105   BYTE oldpri;
 106   STRPTR oldname;
 107   int retval;
 108   struct Library *TestSocketBase;
 109
 110 #ifndef __AROS__
 111   SysBase = *(struct ExecBase **)4;
 112 #else
 113 D(bug("[AROSTCP](amiga_main.c) main()\n"));
 114 #endif
 115
 116   TestSocketBase = OpenLibrary("bsdsocket.library",0);
 117   if (TestSocketBase) {
 118         CloseLibrary(TestSocketBase);
 119         error_request("Another TCP/IP stack is running, please quit it first.");
 120         return 21;
 121   }
 122
 123 #if defined(__AROS__)
 124 D(bug("[AROSTCP](amiga_main.c) main: Kernel launching ...\n"));
 125 #else
 126   D(Printf(STACK_NAME " kernel started\n");)
 127 #endif
 128
 129   /*
 130    * Disable CTRL-C(D) Break signal.
 131    */
 132   signal(SIGINT, SIG_IGN);
 133
 134   /*
 135    * Initialize AROSTCP_Task to point the Task structure of this task.
 136    */
 137   AROSTCP_Task = FindTask(NULL);
 138 #if defined(__AROS__)
 139 D(bug("[AROSTCP](amiga_main.c) main: AROSTCP_Task @ 0x%p\n",AROSTCP_Task));
 140 #endif
 141   D(Printf("AROSTCP_Task @ 0x%p\n",AROSTCP_Task);)
 142
 143   /*
 144    * Get a lock on the 'db' directory so we don't need an assign.
 145    */
 146    BPTR  db_path_lock = BNULL;
 147
 148    char tmpconfigpath[1024];
 149
 150 #if defined(__AROS__)
 151 D(bug("[AROSTCP](amiga_main.c) main: Setting environment default Paths ... \n"));
 152 #endif
 153
 154    db_path_lock = GetProgramDir();
 155 #if defined(__AROS__)
 156    db_path_lock = ParentDir(db_path_lock);
 157 #endif
 158
 159   NameFromLock(db_path_lock, interfaces_path, FILENAME_MAX);
 160
 161 #if defined(__AROS__)
 162 D(bug("[AROSTCP](amiga_main.c) main: Directory tree root: %s\n", interfaces_path));
 163 #endif
 164   D(Printf("Directory tree root: %s\n", interfaces_path);)
 165   strcpy(netdb_path, interfaces_path);
 166   strcpy(db_path, interfaces_path);
 167   strcpy(config_path, interfaces_path);
 168   strcpy(logfiledefname, "T:");             /* NicJA: Default to storing logs in Temp for launching
 169                                                from read only media                          */
 170   strcpy(dhclient_path, interfaces_path);
 171 /*strcpy(hequiv_path, interfaces_path);
 172   strcpy(inetdconf_path, interfaces_path);*/
 173   AddPart(interfaces_path, _PATH_DB, FILENAME_MAX);
 174   AddPart(netdb_path, _PATH_DB, FILENAME_MAX);
 175   AddPart(db_path, _PATH_DB, FILENAME_MAX);
 176   AddPart(config_path, _PATH_DB, FILENAME_MAX);
 177   AddPart(logfiledefname, _PATH_SYSLOG, FILENAME_MAX);
 178   AddPart(dhclient_path, _PATH_DHCLIENT, FILENAME_MAX);
 179 /*AddPart(hequiv_path, _PATH_HEQUIV, FILENAME_MAX);
 180   AddPart(inetdconf_path, _PATH_INETDCONF, FILENAME_MAX);*/
 181
 182 /* NicJA : Allow user specified config location (from Env: variable) */
 183         if (GetVar("AROSTCP/Config", tmpconfigpath, 1024, GVF_GLOBAL_ONLY) != -1)
 184         {
 185         db_path_lock = BNULL;
 186 #if defined(__AROS__)
 187 D(bug("[AROSTCP](amiga_main.c) main: Env: Var AROSTCP/Config set.\n"));
 188 D(bug("[AROSTCP](amiga_main.c) main: Attempting to use '%s' for config location..\n", tmpconfigpath));
 189 #endif
 190           if (db_path_lock = Lock(tmpconfigpath, ACCESS_READ))
 191           {
 192 #if defined(__AROS__)
 193 D(bug("[AROSTCP](amiga_main.c) main: successfully locked config dir '%s'\n", tmpconfigpath));
 194 #endif
 195         strcpy(interfaces_path, tmpconfigpath);
 196         strcpy(netdb_path, tmpconfigpath);
 197         strcpy(db_path, tmpconfigpath);
 198         strcpy(config_path, tmpconfigpath);
 199           //UnLock(db_path_lock);
 200       }
 201 /* TODO: NicJA - Attempt to create chosen config location */
 202 /* TODO: NicJA - and copy defaults if it doesnt currently exist and is possible? */
 203         }
 204
 205   AddPart(interfaces_path, _FILE_SANA2CONFIG, FILENAME_MAX);
 206   AddPart(netdb_path, _FILE_NETDB, FILENAME_MAX);
 207   AddPart(config_path, _FILE_CONFIG, FILENAME_MAX);
 208
 209 #if defined(__AROS__)
 210 D(bug("[AROSTCP](amiga_main.c) main: Log file defaulting to '%s'\n", logfiledefname));
 211 #endif
 212
 213   /* Save pointer to this tasks old name */
 214   oldname = AROSTCP_Task->tc_Node.ln_Name;
 215
 216   if (init_all()) {
 217 #if defined(__AROS__)
 218 D(bug("[AROSTCP](amiga_main.c) main: preparing AROSTCP_Task\n"));
 219 #endif
 220     /* Set our priority */
 221     oldpri = SetTaskPri(AROSTCP_Task, 5);
 222
 223     /* Set our Task name */
 224     if (!taskname) {
 225 #ifdef DEBUG
 226       if (nthLibrary) {
 227         if (taskname = bsd_malloc(16, M_CFGVAR, M_WAITOK)) {
 228           strcpy(taskname, "bsdsocket.library");
 229           taskname[6] = '.'; taskname[7] = '0' + nthLibrary;
 230         }
 231       } else {
 232 #endif
 233         taskname = "bsdsocket.library";
 234 #ifdef DEBUG
 235       }
 236 #endif
 237     }
 238     if (taskname) AROSTCP_Task->tc_Node.ln_Name = taskname;
 239
 240     initialized = TRUE;           /* Global initialization flag */
 241
 242 #ifdef DEBUG
 243     /* Show our task address */
 244     printf("%s Task address : %lx\n", taskname, (long) AROSTCP_Task);
 245 #endif
 246
 247     /* Initialize signal mask for the wait */
 248     breakmask = SIGBREAKF_CTRL_C | SIGBREAKF_CTRL_F;
 249     signalmask = timermask | breakmask | sanamask;
 250
 251     /*
 252      * Now when everything else is successfully initialized,
 253      * let the timeouts roll!
 254      */
 255     timer_send();
 256
 257     for(;;) {
 258       sig = Wait(signalmask);     /* Sleep until we are signalled. */
 259
 260       do {
 261         if (sig & sanamask) {
 262           if (!sana_poll()) sig &= ~sanamask;
 263              }
 264
 265         if (sig & timermask) {
 266                if (!timer_poll()) sig &= ~timermask;
 267              }
 268
 269              sig |= SetSignal(0L, signalmask) & signalmask;
 270       } while (sig & (~breakmask));
 271
 272       if (sig & breakmask) {
 273              int i;
 274
 275 #if defined(__AROS__)
 276 D(bug("[AROSTCP](amiga_main.c) main: Task received CTRL-C\n"));
 277 #endif
 278             /* We received CTRL-C
 279              * NETTRACE task keeps one base open, it is not counted. */
 280         api_hide();                       /* hides the API from users */
 281
 282         api_sendbreaktotasks(); /* send brk to all tasks w/ SBase open */
 283
 284         /* Try three times with a short delay */
 285         for (i = 0; i < 3 && MasterSocketBase->lib_OpenCnt > 1; i++) {
 286           Delay(50);                      /* give tasks time to close socket base */
 287         }
 288
 289         if (MasterSocketBase->lib_OpenCnt > 1) {
 290 #if defined(__AROS__)
 291 D(bug("[AROSTCP](amiga_main.c) main: Got CTRL-C while %ld %s still open.\n",
 292           MasterSocketBase->lib_OpenCnt - 1,
 293                      (MasterSocketBase->lib_OpenCnt == 2) ? "library" : "libraries"));
 294 #endif
 295
 296           __log(LOG_ERR, "Got CTRL-C while %ld %s still open.\n",
 297                MasterSocketBase->lib_OpenCnt - 1,
 298                      (MasterSocketBase->lib_OpenCnt == 2) ? "library" : "libraries");
 299
 300           api_show(); /* stopping not successful, show API to users */
 301         } else {
 302           break;
 303         }
 304       }
 305     }
 306     retval = 0;
 307   } else
 308     retval = 20;
 309
 310   /* free all resources */
 311   deinit_all();
 312   initialized = FALSE;
 313
 314   SetTaskPri(AROSTCP_Task, oldpri);
 315   AROSTCP_Task->tc_Node.ln_Name = oldname;
 316
 317   return retval;
 318 }
 319
 320 /*
 321  * Do all initializations
 322  */
 323 BOOL
 324 init_all(void)
 325 {
 326 #if defined(__AROS__)
 327 D(bug("[AROSTCP](amiga_main.c) init_all()\n"));
 328 #endif
 329   /*
 330    * Initialize malloc semaphore
 331    */
 332   malloc_init();
 333   D(Printf("malloc_init() complete\n");)
 334
 335   /*
 336    * initialize concurrency control subsystem
 337    */
 338   spl_init();
 339   D(Printf("spl_init() complete\n");)
 340
 341   /*
 342    * initialize sleep queues
 343    */
 344   sleep_init();
 345   D(Printf("sleep_init() complete\n");)
 346
 347   /*
 348    * Read command line arguments and configuration file
 349    */
 350   if (!readconfig())
 351     return FALSE;
 352   D(Printf("readconfig() complete\n");)
 353
 354   /*
 355    * initialize logging system
 356    */
 357   if (!log_init())
 358     return FALSE;
 359   D(Printf("log_init() complete\n");)
 360
 361   /*
 362    * initialize the mbuf subsystem
 363    */
 364   if (!mbinit())
 365     return FALSE;
 366   D(Printf("mbinit() complete\n");)
 367
 368   /*
 369    * initialize timer
 370    */
 371   if ((timermask = timer_init()) == 0L)
 372     return FALSE;
 373   D(Printf("timer_init() complete\n");)
 374
 375   /*
 376    * initialize API
 377    */
 378   if (!api_init())
 379     return FALSE;
 380   D(Printf("api_init() complete\n");)
 381
 382   /*
 383    * initialize SANA-II subsystem
 384    */
 385   if ((sanamask = sana_init()) == 0L)
 386     return FALSE;
 387   D(Printf("sana_init() complete\n");)
 388
 389   /*
 390    * initialize domains (initializes all protocols)
 391    */
 392   domaininit();
 393   D(Printf("domaininit() complete\n");)
 394
 395   pfil_init();
 396   D(Printf("pfil_init() complete\n");)
 397
 398   loconfig();
 399   D(Printf("loconfig() complete\n");)
 400
 401   /*
 402    * Initialize NetDataBase
 403    */
 404   if (init_netdb() != 0)
 405     return FALSE;
 406   D(Printf("init_netdb() complete\n");)
 407
 408   /*
 409    * Make API visible
 410    */
 411   if (api_show() == FALSE)
 412     return FALSE;
 413   D(Printf("api_show() complete\n");)
 414
 415   if (Nettrace_Task) {
 416     D(Printf("Initialization complete, signalling NETTRACE\n");)
 417     Signal(Nettrace_Task, SIGBREAKF_CTRL_F);
 418   } else
 419     return FALSE;
 420
 421   rc_start();
 422   D(Printf("rc_start() complete, initialization finished\n");)
 423
 424 #if defined(__AROS__)
 425 D(bug("[AROSTCP](amiga_main.c) init_all: Initialisation successful.\n"));
 426 #endif
 427
 428   return TRUE;
 429 }
 430
 431 /*
 432  * clean up everything
 433  */
 434 void
 435 deinit_all(void)
 436 {
 437 #if defined(__AROS__)
 438 D(bug("[AROSTCP](amiga_main.c) deinit_all()\n"));
 439 #endif
 440   /*
 441    * make sure we are out of critical section
 442    */
 443   spl0();
 444   D(Printf("spl0() completed\n");)
 445
 446   api_hide();                   /* hides the API from users */
 447   D(Printf("api_hide() completed\n");)
 448
 449   /*
 450    * Deinitialize network database.
 451    */
 452   netdb_deinit();
 453
 454   /*
 455    * Deinitialize network interfaces
 456    */
 457   sana_deinit();
 458
 459   /*
 460    * Deinitialize timers
 461    */
 462   timer_deinit();
 463
 464   /*
 465    * Free all resources allocated by mbufs.
 466    */
 467   mbdeinit();
 468   D(Printf("mbdeinit() completed\n");)
 469
 470   log_deinit();
 471   D(Printf("log_deinit() completed\n");)
 472
 473   /*
 474    * Free memory pool.
 475    */
 476   malloc_deinit();
 477   D(Printf("malloc_deinit() completed\n");)
 478
 479   /*
 480    * Check that there are no libraries open (to our API). We can continue only
 481    * if all bases are closed.
 482    */
 483   api_deinit();  /* NOTICE: this waits until every api user has exited */
 484 }
 485
 486 /*
 487  * Notification function for taskname
 488  */
 489 int taskname_changed(void *p, IPTR new)
 490 {
 491   UBYTE *newname = (UBYTE *)new;
 492
 493 #if defined(__AROS__)
 494 D(bug("[AROSTCP](amiga_main.c) taskname_changed()\n"));
 495 #endif
 496
 497   AROSTCP_Task->tc_Node.ln_Name = newname;
 498   if (initialized)
 499     printf("New task name %s\n", newname);
 500
 501   return TRUE;
 502 }