File:  [ELWIX - Embedded LightWeight unIX -] / embedaddon / quagga / bgpd / bgp_main.c
Revision 1.1.1.4 (vendor branch): download - view: text, annotated - select for diffs - revision graph
Wed Nov 2 10:09:10 2016 UTC (8 years ago) by misho
Branches: quagga, MAIN
CVS tags: v1_0_20160315, HEAD
quagga 1.0.20160315

    1: /* Main routine of bgpd.
    2:    Copyright (C) 1996, 97, 98, 1999 Kunihiro Ishiguro
    3: 
    4: This file is part of GNU Zebra.
    5: 
    6: GNU Zebra is free software; you can redistribute it and/or modify it
    7: under the terms of the GNU General Public License as published by the
    8: Free Software Foundation; either version 2, or (at your option) any
    9: later version.
   10: 
   11: GNU Zebra 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 GNU Zebra; see the file COPYING.  If not, write to the Free
   18: Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
   19: 02111-1307, USA.  */
   20: 
   21: #include <zebra.h>
   22: 
   23: #include "vector.h"
   24: #include "vty.h"
   25: #include "command.h"
   26: #include "getopt.h"
   27: #include "thread.h"
   28: #include <lib/version.h>
   29: #include "memory.h"
   30: #include "prefix.h"
   31: #include "log.h"
   32: #include "privs.h"
   33: #include "sigevent.h"
   34: #include "zclient.h"
   35: #include "routemap.h"
   36: #include "filter.h"
   37: #include "plist.h"
   38: #include "stream.h"
   39: #include "vrf.h"
   40: #include "workqueue.h"
   41: 
   42: #include "bgpd/bgpd.h"
   43: #include "bgpd/bgp_attr.h"
   44: #include "bgpd/bgp_mplsvpn.h"
   45: #include "bgpd/bgp_aspath.h"
   46: #include "bgpd/bgp_dump.h"
   47: #include "bgpd/bgp_route.h"
   48: #include "bgpd/bgp_nexthop.h"
   49: #include "bgpd/bgp_regex.h"
   50: #include "bgpd/bgp_clist.h"
   51: #include "bgpd/bgp_debug.h"
   52: #include "bgpd/bgp_filter.h"
   53: #include "bgpd/bgp_zebra.h"
   54: 
   55: /* bgpd options, we use GNU getopt library. */
   56: static const struct option longopts[] = 
   57: {
   58:   { "daemon",      no_argument,       NULL, 'd'},
   59:   { "config_file", required_argument, NULL, 'f'},
   60:   { "pid_file",    required_argument, NULL, 'i'},
   61:   { "socket",      required_argument, NULL, 'z'},
   62:   { "bgp_port",    required_argument, NULL, 'p'},
   63:   { "listenon",    required_argument, NULL, 'l'},
   64:   { "vty_addr",    required_argument, NULL, 'A'},
   65:   { "vty_port",    required_argument, NULL, 'P'},
   66:   { "retain",      no_argument,       NULL, 'r'},
   67:   { "no_kernel",   no_argument,       NULL, 'n'},
   68:   { "user",        required_argument, NULL, 'u'},
   69:   { "group",       required_argument, NULL, 'g'},
   70:   { "version",     no_argument,       NULL, 'v'},
   71:   { "dryrun",      no_argument,       NULL, 'C'},
   72:   { "help",        no_argument,       NULL, 'h'},
   73:   { 0 }
   74: };
   75: 
   76: /* signal definitions */
   77: void sighup (void);
   78: void sigint (void);
   79: void sigusr1 (void);
   80: 
   81: static void bgp_exit (int);
   82: 
   83: static struct quagga_signal_t bgp_signals[] = 
   84: {
   85:   { 
   86:     .signal = SIGHUP, 
   87:     .handler = &sighup,
   88:   },
   89:   {
   90:     .signal = SIGUSR1,
   91:     .handler = &sigusr1,
   92:   },
   93:   {
   94:     .signal = SIGINT,
   95:     .handler = &sigint,
   96:   },
   97:   {
   98:     .signal = SIGTERM,
   99:     .handler = &sigint,
  100:   },
  101: };
  102: 
  103: /* Configuration file and directory. */
  104: char config_default[] = SYSCONFDIR BGP_DEFAULT_CONFIG;
  105: 
  106: /* Route retain mode flag. */
  107: static int retain_mode = 0;
  108: 
  109: /* Manually specified configuration file name.  */
  110: char *config_file = NULL;
  111: 
  112: /* Process ID saved for use by init system */
  113: static const char *pid_file = PATH_BGPD_PID;
  114: 
  115: /* VTY port number and address.  */
  116: int vty_port = BGP_VTY_PORT;
  117: char *vty_addr = NULL;
  118: 
  119: /* privileges */
  120: static zebra_capabilities_t _caps_p [] =  
  121: {
  122:     ZCAP_BIND, 
  123:     ZCAP_NET_RAW,
  124:     ZCAP_NET_ADMIN,
  125: };
  126: 
  127: struct zebra_privs_t bgpd_privs =
  128: {
  129: #if defined(QUAGGA_USER) && defined(QUAGGA_GROUP)
  130:   .user = QUAGGA_USER,
  131:   .group = QUAGGA_GROUP,
  132: #endif
  133: #ifdef VTY_GROUP
  134:   .vty_group = VTY_GROUP,
  135: #endif
  136:   .caps_p = _caps_p,
  137:   .cap_num_p = array_size(_caps_p),
  138:   .cap_num_i = 0,
  139: };
  140: 
  141: /* Help information display. */
  142: static void
  143: usage (char *progname, int status)
  144: {
  145:   if (status != 0)
  146:     fprintf (stderr, "Try `%s --help' for more information.\n", progname);
  147:   else
  148:     {    
  149:       printf ("Usage : %s [OPTION...]\n\n\
  150: Daemon which manages kernel routing table management and \
  151: redistribution between different routing protocols.\n\n\
  152: -d, --daemon       Runs in daemon mode\n\
  153: -f, --config_file  Set configuration file name\n\
  154: -i, --pid_file     Set process identifier file name\n\
  155: -z, --socket       Set path of zebra socket\n\
  156: -p, --bgp_port     Set bgp protocol's port number\n\
  157: -l, --listenon     Listen on specified address (implies -n)\n\
  158: -A, --vty_addr     Set vty's bind address\n\
  159: -P, --vty_port     Set vty's port number\n\
  160: -r, --retain       When program terminates, retain added route by bgpd.\n\
  161: -n, --no_kernel    Do not install route to kernel.\n\
  162: -u, --user         User to run as\n\
  163: -g, --group        Group to run as\n\
  164: -v, --version      Print program version\n\
  165: -C, --dryrun       Check configuration for validity and exit\n\
  166: -h, --help         Display this help and exit\n\
  167: \n\
  168: Report bugs to %s\n", progname, ZEBRA_BUG_ADDRESS);
  169:     }
  170: 
  171:   exit (status);
  172: }
  173: 
  174: /* SIGHUP handler. */
  175: void 
  176: sighup (void)
  177: {
  178:   zlog (NULL, LOG_INFO, "SIGHUP received");
  179: 
  180:   /* Terminate all thread. */
  181:   bgp_terminate ();
  182:   bgp_reset ();
  183:   zlog_info ("bgpd restarting!");
  184: 
  185:   /* Reload config file. */
  186:   vty_read_config (config_file, config_default);
  187: 
  188:   /* Create VTY's socket */
  189:   vty_serv_sock (vty_addr, vty_port, BGP_VTYSH_PATH);
  190: 
  191:   /* Try to return to normal operation. */
  192: }
  193: 
  194: /* SIGINT handler. */
  195: void
  196: sigint (void)
  197: {
  198:   zlog_notice ("Terminating on signal");
  199: 
  200:   if (! retain_mode) 
  201:     {
  202:       bgp_terminate ();
  203:       zprivs_terminate (&bgpd_privs);
  204:     }
  205: 
  206:   bgp_exit (0);
  207: }
  208: 
  209: /* SIGUSR1 handler. */
  210: void
  211: sigusr1 (void)
  212: {
  213:   zlog_rotate (NULL);
  214: }
  215: 
  216: /*
  217:   Try to free up allocations we know about so that diagnostic tools such as
  218:   valgrind are able to better illuminate leaks.
  219: 
  220:   Zebra route removal and protocol teardown are not meant to be done here.
  221:   For example, "retain_mode" may be set.
  222: */
  223: static void
  224: bgp_exit (int status)
  225: {
  226:   struct bgp *bgp;
  227:   struct listnode *node, *nnode;
  228:   int *socket;
  229:   struct interface *ifp;
  230:   extern struct zclient *zlookup;
  231: 
  232:   /* it only makes sense for this to be called on a clean exit */
  233:   assert (status == 0);
  234: 
  235:   /* reverse bgp_master_init */
  236:   for (ALL_LIST_ELEMENTS (bm->bgp, node, nnode, bgp))
  237:     bgp_delete (bgp);
  238:   list_free (bm->bgp);
  239:   bm->bgp = NULL;
  240:   
  241:   /*
  242:    * bgp_delete can re-allocate the process queues after they were
  243:    * deleted in bgp_terminate. delete them again.
  244:    *
  245:    * It might be better to ensure the RIBs (including static routes)
  246:    * are cleared by bgp_terminate() during its call to bgp_cleanup_routes(),
  247:    * which currently only deletes the kernel routes.
  248:    */
  249:   if (bm->process_main_queue)
  250:     {
  251:      work_queue_free (bm->process_main_queue);
  252:      bm->process_main_queue = NULL;
  253:     }
  254:   if (bm->process_rsclient_queue)
  255:     {
  256:       work_queue_free (bm->process_rsclient_queue);
  257:       bm->process_rsclient_queue = NULL;
  258:     }
  259:   
  260:   /* reverse bgp_master_init */
  261:   for (ALL_LIST_ELEMENTS_RO(bm->listen_sockets, node, socket))
  262:     {
  263:       if (close ((int)(long)socket) == -1)
  264:         zlog_err ("close (%d): %s", (int)(long)socket, safe_strerror (errno));
  265:     }
  266:   list_delete (bm->listen_sockets);
  267: 
  268:   /* reverse bgp_zebra_init/if_init */
  269:   if (retain_mode)
  270:     if_add_hook (IF_DELETE_HOOK, NULL);
  271:   for (ALL_LIST_ELEMENTS_RO (iflist, node, ifp))
  272:     {
  273:       struct listnode *c_node, *c_nnode;
  274:       struct connected *c;
  275: 
  276:       for (ALL_LIST_ELEMENTS (ifp->connected, c_node, c_nnode, c))
  277:         bgp_connected_delete (c);
  278:     }
  279: 
  280:   /* reverse bgp_attr_init */
  281:   bgp_attr_finish ();
  282: 
  283:   /* reverse bgp_dump_init */
  284:   bgp_dump_finish ();
  285: 
  286:   /* reverse bgp_route_init */
  287:   bgp_route_finish ();
  288: 
  289:   /* reverse bgp_route_map_init/route_map_init */
  290:   route_map_finish ();
  291: 
  292:   /* reverse bgp_scan_init */
  293:   bgp_scan_finish ();
  294: 
  295:   /* reverse access_list_init */
  296:   access_list_add_hook (NULL);
  297:   access_list_delete_hook (NULL);
  298:   access_list_reset ();
  299: 
  300:   /* reverse bgp_filter_init */
  301:   as_list_add_hook (NULL);
  302:   as_list_delete_hook (NULL);
  303:   bgp_filter_reset ();
  304: 
  305:   /* reverse prefix_list_init */
  306:   prefix_list_add_hook (NULL);
  307:   prefix_list_delete_hook (NULL);
  308:   prefix_list_reset ();
  309: 
  310:   /* reverse community_list_init */
  311:   community_list_terminate (bgp_clist);
  312: 
  313:   vrf_terminate ();
  314:   cmd_terminate ();
  315:   vty_terminate ();
  316:   bgp_address_destroy();
  317:   bgp_scan_destroy();
  318:   bgp_zebra_destroy();
  319:   if (zlookup)
  320:     zclient_free (zlookup);
  321:   if (bgp_nexthop_buf)
  322:     stream_free (bgp_nexthop_buf);
  323: 
  324:   /* reverse bgp_master_init */
  325:   if (bm->master)
  326:     thread_master_free (bm->master);
  327: 
  328:   if (zlog_default)
  329:     closezlog (zlog_default);
  330: 
  331:   if (CONF_BGP_DEBUG (normal, NORMAL))
  332:     log_memstats_stderr ("bgpd");
  333: 
  334:   exit (status);
  335: }
  336: 
  337: /* Main routine of bgpd. Treatment of argument and start bgp finite
  338:    state machine is handled at here. */
  339: int
  340: main (int argc, char **argv)
  341: {
  342:   char *p;
  343:   int opt;
  344:   int daemon_mode = 0;
  345:   int dryrun = 0;
  346:   char *progname;
  347:   struct thread thread;
  348:   int tmp_port;
  349: 
  350:   /* Set umask before anything for security */
  351:   umask (0027);
  352: 
  353:   /* Preserve name of myself. */
  354:   progname = ((p = strrchr (argv[0], '/')) ? ++p : argv[0]);
  355: 
  356:   zlog_default = openzlog (progname, ZLOG_BGP,
  357: 			   LOG_CONS|LOG_NDELAY|LOG_PID, LOG_DAEMON);
  358: 
  359:   /* BGP master init. */
  360:   bgp_master_init ();
  361: 
  362:   /* Command line argument treatment. */
  363:   while (1) 
  364:     {
  365:       opt = getopt_long (argc, argv, "df:i:z:hp:l:A:P:rnu:g:vC", longopts, 0);
  366:     
  367:       if (opt == EOF)
  368: 	break;
  369: 
  370:       switch (opt) 
  371: 	{
  372: 	case 0:
  373: 	  break;
  374: 	case 'd':
  375: 	  daemon_mode = 1;
  376: 	  break;
  377: 	case 'f':
  378: 	  config_file = optarg;
  379: 	  break;
  380:         case 'i':
  381:           pid_file = optarg;
  382:           break;
  383: 	case 'z':
  384: 	  zclient_serv_path_set (optarg);
  385: 	  break;
  386: 	case 'p':
  387: 	  tmp_port = atoi (optarg);
  388: 	  if (tmp_port <= 0 || tmp_port > 0xffff)
  389: 	    bm->port = BGP_PORT_DEFAULT;
  390: 	  else
  391: 	    bm->port = tmp_port;
  392: 	  break;
  393: 	case 'A':
  394: 	  vty_addr = optarg;
  395: 	  break;
  396: 	case 'P':
  397:           /* Deal with atoi() returning 0 on failure, and bgpd not
  398:              listening on bgp port... */
  399:           if (strcmp(optarg, "0") == 0) 
  400:             {
  401:               vty_port = 0;
  402:               break;
  403:             } 
  404:           vty_port = atoi (optarg);
  405: 	  if (vty_port <= 0 || vty_port > 0xffff)
  406: 	    vty_port = BGP_VTY_PORT;
  407: 	  break;
  408: 	case 'r':
  409: 	  retain_mode = 1;
  410: 	  break;
  411: 	case 'l':
  412: 	  bm->address = optarg;
  413: 	  /* listenon implies -n */
  414: 	case 'n':
  415: 	  bgp_option_set (BGP_OPT_NO_FIB);
  416: 	  break;
  417: 	case 'u':
  418: 	  bgpd_privs.user = optarg;
  419: 	  break;
  420: 	case 'g':
  421: 	  bgpd_privs.group = optarg;
  422: 	  break;
  423: 	case 'v':
  424: 	  print_version (progname);
  425: 	  exit (0);
  426: 	  break;
  427: 	case 'C':
  428: 	  dryrun = 1;
  429: 	  break;
  430: 	case 'h':
  431: 	  usage (progname, 0);
  432: 	  break;
  433: 	default:
  434: 	  usage (progname, 1);
  435: 	  break;
  436: 	}
  437:     }
  438: 
  439:   /* Initializations. */
  440:   srandom (time (NULL));
  441:   signal_init (bm->master, array_size(bgp_signals), bgp_signals);
  442:   zprivs_init (&bgpd_privs);
  443:   cmd_init (1);
  444:   vty_init (bm->master);
  445:   memory_init ();
  446:   vrf_init ();
  447: 
  448:   /* BGP related initialization.  */
  449:   bgp_init ();
  450: 
  451:   /* Parse config file. */
  452:   vty_read_config (config_file, config_default);
  453: 
  454:   /* Start execution only if not in dry-run mode */
  455:   if(dryrun)
  456:     return(0);
  457:   
  458:   /* Turn into daemon if daemon_mode is set. */
  459:   if (daemon_mode && daemon (0, 0) < 0)
  460:     {
  461:       zlog_err("BGPd daemon failed: %s", strerror(errno));
  462:       return (1);
  463:     }
  464: 
  465: 
  466:   /* Process ID file creation. */
  467:   pid_output (pid_file);
  468: 
  469:   /* Make bgp vty socket. */
  470:   vty_serv_sock (vty_addr, vty_port, BGP_VTYSH_PATH);
  471: 
  472:   /* Print banner. */
  473:   zlog_notice ("BGPd %s starting: vty@%d, bgp@%s:%d pid %d", QUAGGA_VERSION,
  474: 	       vty_port, 
  475: 	       (bm->address ? bm->address : "<all>"),
  476: 	       bm->port,
  477: 	       getpid ());
  478: 
  479:   /* Start finite state machine, here we go! */
  480:   while (thread_fetch (bm->master, &thread))
  481:     thread_call (&thread);
  482: 
  483:   /* Not reached. */
  484:   return (0);
  485: }

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>