servers/inet/inet.c

   1 /*      this file contains the interface of the network software with rest of
   2         minix. Furthermore it contains the main loop of the network task.
   3
   4 Copyright 1995 Philip Homburg
   5
   6 The valid messages and their parameters are:
   7
   8 from FS:
   9  __________________________________________________________________
  10 |               |           |         |       |          |         |
  11 | m_type        |   DEVICE  | PROC_NR | COUNT | POSITION | ADDRESS |
  12 |_______________|___________|_________|_______|__________|_________|
  13 |               |           |         |       |          |         |
  14 | NW_OPEN       | minor dev | proc nr | mode  |          |         |
  15 |_______________|___________|_________|_______|__________|_________|
  16 |               |           |         |       |          |         |
  17 | NW_CLOSE      | minor dev | proc nr |       |          |         |
  18 |_______________|___________|_________|_______|__________|_________|
  19 |               |           |         |       |          |         |
  20 | NW_IOCTL      | minor dev | proc nr |       | NWIO..   | address |
  21 |_______________|___________|_________|_______|__________|_________|
  22 |               |           |         |       |          |         |
  23 | NW_READ       | minor dev | proc nr | count |          | address |
  24 |_______________|___________|_________|_______|__________|_________|
  25 |               |           |         |       |          |         |
  26 | NW_WRITE      | minor dev | proc nr | count |          | address |
  27 |_______________|___________|_________|_______|__________|_________|
  28 |               |           |         |       |          |         |
  29 | NW_CANCEL     | minor dev | proc nr |       |          |         |
  30 |_______________|___________|_________|_______|__________|_________|
  31
  32 from DL_ETH:
  33  _______________________________________________________________________
  34 |               |           |         |          |            |         |
  35 | m_type        |  DL_PORT  | DL_PROC | DL_COUNT |  DL_STAT   | DL_TIME |
  36 |_______________|___________|_________|__________|____________|_________|
  37 |               |           |         |          |            |         |
  38 | DL_CONF_REPLY | minor dev | proc nr | rd_count |  0  | stat |  time   |
  39 |_______________|___________|_________|__________|____________|_________|
  40 |               |           |         |          |            |         |
  41 | DL_TASK_REPLY | minor dev | proc nr | rd_count | err | stat |  time   |
  42 |_______________|___________|_________|__________|____________|_________|
  43 */
  44
  45 #include "inet.h"
  46
  47 #define _MINIX_SOURCE 1
  48
  49 #include <fcntl.h>
  50 #include <unistd.h>
  51 #include <sys/svrctl.h>
  52 #include <minix/ds.h>
  53 #include <minix/endpoint.h>
  54
  55 #include "mq.h"
  56 #include "qp.h"
  57 #include "proto.h"
  58 #include "generic/type.h"
  59
  60 #include "generic/arp.h"
  61 #include "generic/assert.h"
  62 #include "generic/buf.h"
  63 #include "generic/clock.h"
  64 #include "generic/eth.h"
  65 #include "generic/event.h"
  66 #include "generic/ip.h"
  67 #include "generic/psip.h"
  68 #include "generic/rand256.h"
  69 #include "generic/sr.h"
  70 #include "generic/tcp.h"
  71 #include "generic/udp.h"
  72
  73 THIS_FILE
  74
  75 #define RANDOM_DEV_NAME "/dev/random"
  76
  77 int this_proc;          /* Process number of this server. */
  78
  79 /* Killing Solaris */
  80 int killer_inet= 0;
  81
  82 #ifdef BUF_CONSISTENCY_CHECK
  83 extern int inet_buf_debug;
  84 #endif
  85
  86 #if HZ_DYNAMIC
  87 u32_t system_hz;
  88 #endif
  89
  90 _PROTOTYPE( void main, (void) );
  91
  92 FORWARD _PROTOTYPE( void nw_conf, (void) );
  93 FORWARD _PROTOTYPE( void nw_init, (void) );
  94
  95 /* SEF functions and variables. */
  96 FORWARD _PROTOTYPE( void sef_local_startup, (void) );
  97 FORWARD _PROTOTYPE( int sef_cb_init_fresh, (int type, sef_init_info_t *info) );
  98
  99 PUBLIC void main()
 100 {
 101         mq_t *mq;
 102         int r;
 103         int source, m_type;
 104
 105         /* SEF local startup. */
 106         sef_local_startup();
 107
 108         while (TRUE)
 109         {
 110 #ifdef BUF_CONSISTENCY_CHECK
 111                 if (inet_buf_debug)
 112                 {
 113                         static int buf_debug_count= 0;
 114
 115                         if (++buf_debug_count >= inet_buf_debug)
 116                         {
 117                                 buf_debug_count= 0;
 118                                 if (!bf_consistency_check())
 119                                         break;
 120                         }
 121                 }
 122 #endif
 123                 if (ev_head)
 124                 {
 125                         ev_process();
 126                         continue;
 127                 }
 128                 if (clck_call_expire)
 129                 {
 130                         clck_expire_timers();
 131                         continue;
 132                 }
 133                 mq= mq_get();
 134                 if (!mq)
 135                         ip_panic(("out of messages"));
 136
 137                 r= sef_receive(ANY, &mq->mq_mess);
 138                 if (r<0)
 139                 {
 140                         ip_panic(("unable to receive: %d", r));
 141                 }
 142                 reset_time();
 143                 source= mq->mq_mess.m_source;
 144                 m_type= mq->mq_mess.m_type;
 145                 if (source == FS_PROC_NR)
 146                 {
 147                         sr_rec(mq);
 148                 }
 149                 else if (is_notify(m_type))
 150                 {
 151                         if (_ENDPOINT_P(source) == CLOCK)
 152                         {
 153                                 clck_tick(&mq->mq_mess);
 154                                 mq_free(mq);
 155                         }
 156                         else if (_ENDPOINT_P(source) == PM_PROC_NR)
 157                         {
 158                                 /* signaled */
 159                                 /* probably SIGTERM */
 160                                 mq_free(mq);
 161                         }
 162                         else
 163                         {
 164                                 /* A driver is (re)started. */
 165                                 eth_check_drivers(&mq->mq_mess);
 166                                 mq_free(mq);
 167                         }
 168                 }
 169                 else if (m_type == DL_CONF_REPLY || m_type == DL_TASK_REPLY ||
 170                         m_type == DL_NAME_REPLY || m_type == DL_STAT_REPLY)
 171                 {
 172                         eth_rec(&mq->mq_mess);
 173                         mq_free(mq);
 174                 }
 175                 else
 176                 {
 177                         printf("inet: got bad message type 0x%x from %d\n",
 178                                 mq->mq_mess.m_type, mq->mq_mess.m_source);
 179                         mq_free(mq);
 180                 }
 181         }
 182         ip_panic(("task is not allowed to terminate"));
 183 }
 184
 185 /*===========================================================================*
 186  *                             sef_local_startup                             *
 187  *===========================================================================*/
 188 PRIVATE void sef_local_startup()
 189 {
 190   /* Register init callbacks. */
 191   sef_setcb_init_fresh(sef_cb_init_fresh);
 192   sef_setcb_init_restart(sef_cb_init_restart_fail);
 193
 194   /* No live update support for now. */
 195
 196   /* Let SEF perform startup. */
 197   sef_startup();
 198 }
 199
 200 /*===========================================================================*
 201  *                          sef_cb_init_fresh                                *
 202  *===========================================================================*/
 203 PRIVATE int sef_cb_init_fresh(int type, sef_init_info_t *info)
 204 {
 205 /* Initialize the inet server. */
 206         int r;
 207         int timerand, fd;
 208         u32_t tasknr;
 209         struct fssignon device;
 210         u8_t randbits[32];
 211         struct timeval tv;
 212
 213 #if DEBUG
 214         printf("Starting inet...\n");
 215         printf("%s\n", version);
 216 #endif
 217
 218 #if HZ_DYNAMIC
 219         system_hz = sys_hz();
 220 #endif
 221
 222         /* Read configuration. */
 223         nw_conf();
 224
 225         /* Get a random number */
 226         timerand= 1;
 227         fd= open(RANDOM_DEV_NAME, O_RDONLY | O_NONBLOCK);
 228         if (fd != -1)
 229         {
 230                 r= read(fd, randbits, sizeof(randbits));
 231                 if (r == sizeof(randbits))
 232                         timerand= 0;
 233                 else
 234                 {
 235                         printf("inet: unable to read random data from %s: %s\n",
 236                                 RANDOM_DEV_NAME, r == -1 ? strerror(errno) :
 237                                 r == 0 ? "EOF" : "not enough data");
 238                 }
 239                 close(fd);
 240         }
 241         else
 242         {
 243                 printf("inet: unable to open random device %s: %s\n",
 244                         RANDOM_DEV_NAME, strerror(errno));
 245         }
 246         if (timerand)
 247         {
 248                 printf("inet: using current time for random-number seed\n");
 249                 r= gettimeofday(&tv, NULL);
 250                 if (r == -1)
 251                 {
 252                         printf("sysutime failed: %s\n", strerror(errno));
 253                         exit(1);
 254                 }
 255                 memcpy(randbits, &tv, sizeof(tv));
 256         }
 257         init_rand256(randbits);
 258
 259         /* Our new identity as a server. */
 260         r= ds_retrieve_label_num("inet", &tasknr);
 261         if (r != OK)
 262                 ip_panic(("inet: ds_retrieve_label_num failed for 'inet': %d", r));
 263         this_proc= tasknr;
 264
 265         /* Register the device group. */
 266         device.dev= ip_dev;
 267         device.style= STYLE_CLONE;
 268         if (svrctl(FSSIGNON, (void *) &device) == -1) {
 269                 printf("inet: error %d on registering ethernet devices\n",
 270                         errno);
 271                 pause();
 272         }
 273
 274 #ifdef BUF_CONSISTENCY_CHECK
 275         inet_buf_debug= (getenv("inetbufdebug") &&
 276                 (strcmp(getenv("inetbufdebug"), "on") == 0));
 277         inet_buf_debug= 100;
 278         if (inet_buf_debug)
 279         {
 280                 ip_warning(( "buffer consistency check enabled" ));
 281         }
 282 #endif
 283
 284         if (getenv("killerinet"))
 285         {
 286                 ip_warning(( "killer inet active" ));
 287                 killer_inet= 1;
 288         }
 289
 290         nw_init();
 291
 292         return(OK);
 293 }
 294
 295 PRIVATE void nw_conf()
 296 {
 297         read_conf();
 298         eth_prep();
 299         arp_prep();
 300         psip_prep();
 301         ip_prep();
 302         tcp_prep();
 303         udp_prep();
 304 }
 305
 306 PRIVATE void nw_init()
 307 {
 308         mq_init();
 309         bf_init();
 310         clck_init();
 311         sr_init();
 312         qp_init();
 313         eth_init();
 314         arp_init();
 315         psip_init();
 316         ip_init();
 317         tcp_init();
 318         udp_init();
 319 }
 320
 321 PUBLIC void panic0(file, line)
 322 char *file;
 323 int line;
 324 {
 325         printf("panic at %s, %d: ", file, line);
 326 }
 327
 328 PUBLIC void inet_panic()
 329 {
 330         printf("\ninet stacktrace: ");
 331         util_stacktrace();
 332         (panic)("INET","aborted due to a panic",NO_NUM);
 333         for(;;);
 334 }
 335
 336 #if !NDEBUG
 337 PUBLIC void bad_assertion(file, line, what)
 338 char *file;
 339 int line;
 340 char *what;
 341 {
 342         panic0(file, line);
 343         printf("assertion \"%s\" failed", what);
 344         panic();
 345 }
 346
 347
 348 PUBLIC void bad_compare(file, line, lhs, what, rhs)
 349 char *file;
 350 int line;
 351 int lhs;
 352 char *what;
 353 int rhs;
 354 {
 355         panic0(file, line);
 356         printf("compare (%d) %s (%d) failed", lhs, what, rhs);
 357         panic();
 358 }
 359 #endif /* !NDEBUG */
 360
 361 /*
 362  * $PchId: inet.c,v 1.23 2005/06/28 14:27:22 philip Exp $
 363  */