usr.sbin/rrenumd/rrenumd.c

   1 /*      $KAME: rrenumd.c,v 1.20 2000/11/08 02:40:53 itojun Exp $        */
   2
   3 /*
   4  * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
   5  * All rights reserved.
   6  *
   7  * Redistribution and use in source and binary forms, with or without
   8  * modification, are permitted provided that the following conditions
   9  * are met:
  10  * 1. Redistributions of source code must retain the above copyright
  11  *    notice, this list of conditions and the following disclaimer.
  12  * 2. Redistributions in binary form must reproduce the above copyright
  13  *    notice, this list of conditions and the following disclaimer in the
  14  *    documentation and/or other materials provided with the distribution.
  15  * 3. Neither the name of the project nor the names of its contributors
  16  *    may be used to endorse or promote products derived from this software
  17  *    without specific prior written permission.
  18  *
  19  * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
  20  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  21  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  22  * ARE DISCLAIMED.  IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
  23  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  24  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  25  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  26  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  27  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  28  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  29  * SUCH DAMAGE.
  30  *
  31  * $FreeBSD: src/usr.sbin/rrenumd/rrenumd.c,v 1.1.2.4 2001/07/09 09:49:49 ume Exp $
  32  * $DragonFly: src/usr.sbin/rrenumd/rrenumd.c,v 1.6 2005/12/05 03:40:28 swildner Exp $
  33  */
  34
  35 #include <sys/param.h>
  36 #include <sys/socket.h>
  37 #include <sys/uio.h>
  38 #include <sys/time.h>
  39
  40 #include <string.h>
  41
  42 #include <net/route.h>
  43
  44 #include <netinet/in_systm.h>
  45 #include <netinet/in.h>
  46 #include <netinet/ip.h>
  47 #include <netinet/ip6.h>
  48 #include <netinet/icmp6.h>
  49
  50 #include <arpa/inet.h>
  51
  52 #ifdef IPSEC
  53 #include <netinet6/ipsec.h>
  54 #endif
  55
  56 #include <stdio.h>
  57 #include <err.h>
  58 #include <errno.h>
  59 #include <stdlib.h>
  60 #include <unistd.h>
  61 #include <syslog.h>
  62
  63 #include "rrenumd.h"
  64
  65 #define LL_ALLROUTERS "ff02::2"
  66 #define SL_ALLROUTERS "ff05::2"
  67
  68 #define RR_MCHLIM_DEFAULT 64
  69
  70 #ifndef IN6_IS_SCOPE_LINKLOCAL
  71 #define IN6_IS_SCOPE_LINKLOCAL(a)       \
  72         ((IN6_IS_ADDR_LINKLOCAL(a)) ||  \
  73          (IN6_IS_ADDR_MC_LINKLOCAL(a)))
  74 #endif /* IN6_IS_SCOPE_LINKLOCAL */
  75
  76 struct flags {
  77         u_long debug : 1;
  78         u_long fg : 1;
  79 #ifdef IPSEC
  80 #ifdef IPSEC_POLICY_IPSEC
  81         u_long policy : 1;
  82 #else /* IPSEC_POLICY_IPSEC */
  83         u_long auth : 1;
  84         u_long encrypt : 1;
  85 #endif /* IPSEC_POLICY_IPSEC */
  86 #endif /*IPSEC*/
  87 };
  88
  89 struct msghdr sndmhdr;
  90 struct msghdr rcvmhdr;
  91 struct sockaddr_in6 from;
  92 struct sockaddr_in6 sin6_ll_allrouters;
  93
  94 int s4, s6;
  95 int with_v4dest, with_v6dest;
  96 struct in6_addr prefix; /* ADHOC */
  97 int prefixlen = 64; /* ADHOC */
  98
  99 extern int parse(FILE **);
 100
 101 static void show_usage(void);
 102 static void init_sin6(struct sockaddr_in6 *, const char *);
 103 #if 0
 104 static void join_multi(const char *);
 105 #endif
 106 static void init_globals(void);
 107 static void config(FILE **);
 108 #ifdef IPSEC_POLICY_IPSEC
 109 static void sock6_open(struct flags *, char *);
 110 static void sock4_open(struct flags *, char *);
 111 #else
 112 static void sock6_open(struct flags *);
 113 static void sock4_open(struct flags *);
 114 #endif
 115 static void rrenum_output(struct payload_list *, struct dst_list *);
 116 static void rrenum_snd_eachdst(struct payload_list *);
 117 #if 0
 118 static void rrenum_snd_fullsequence(void);
 119 #endif
 120 static void rrenum_input(int);
 121 int main(int, char *[]);
 122
 123
 124 /* Print usage. Don't call this after daemonized. */
 125 static void
 126 show_usage(void)
 127 {
 128         fprintf(stderr, "usage: rrenumd [-c conf_file|-s] [-df"
 129 #ifdef IPSEC
 130 #ifdef IPSEC_POLICY_IPSEC
 131                 "] [-P policy"
 132 #else /* IPSEC_POLICY_IPSEC */
 133                 "AE"
 134 #endif /* IPSEC_POLICY_IPSEC */
 135 #endif /* IPSEC */
 136                 "]\n");
 137         exit(1);
 138 }
 139
 140 static void
 141 init_sin6(struct sockaddr_in6 *sin6, const char *addr_ascii)
 142 {
 143         memset(sin6, 0, sizeof(*sin6));
 144         sin6->sin6_len = sizeof(*sin6);
 145         sin6->sin6_family = AF_INET6;
 146         if (inet_pton(AF_INET6, addr_ascii, &sin6->sin6_addr) != 1)
 147                 ; /* XXX do something */
 148 }
 149
 150 #if 0  /* XXX: not necessary ?? */
 151 static void
 152 join_multi(const char *addrname)
 153 {
 154         struct ipv6_mreq mreq;
 155
 156         if (inet_pton(AF_INET6, addrname, &mreq.ipv6mr_multiaddr.s6_addr)
 157             != 1) {
 158                 syslog(LOG_ERR, "<%s> inet_pton failed(library bug?)",
 159                        __func__);
 160                 exit(1);
 161         }
 162         /* ADHOC: currently join only one */
 163         {
 164                 if ((mreq.ipv6mr_interface = if_nametoindex(ifname)) == 0) {
 165                         syslog(LOG_ERR, "<%s> ifname %s should be invalid: %s",
 166                                __func__, ifname, strerror(errno));
 167                         exit(1);
 168                 }
 169                 if (setsockopt(s, IPPROTO_IPV6, IPV6_JOIN_GROUP,
 170                                &mreq,
 171                                sizeof(mreq)) < 0) {
 172                         syslog(LOG_ERR, "<%s> IPV6_JOIN_GROUP on %s: %s",
 173                                __func__, ifname, strerror(errno));
 174                         exit(1);
 175                 }
 176         }
 177 }
 178 #endif
 179
 180 static void
 181 init_globals(void)
 182 {
 183         static struct iovec rcviov;
 184         static u_char rprdata[4500]; /* maximal MTU of connected links */
 185         static u_char *rcvcmsgbuf = NULL;
 186         static u_char *sndcmsgbuf = NULL;
 187         int sndcmsglen, rcvcmsglen;
 188
 189         /* init ll_allrouters */
 190         init_sin6(&sin6_ll_allrouters, LL_ALLROUTERS);
 191
 192         /* initialize msghdr for receiving packets */
 193         rcviov.iov_base = (caddr_t)rprdata;
 194         rcviov.iov_len = sizeof(rprdata);
 195         rcvmhdr.msg_namelen = sizeof(struct sockaddr_in6);
 196         rcvmhdr.msg_iov = &rcviov;
 197         rcvmhdr.msg_iovlen = 1;
 198         rcvcmsglen = CMSG_SPACE(sizeof(struct in6_pktinfo)) +
 199                 CMSG_SPACE(sizeof(int));
 200         if (rcvcmsgbuf == NULL &&
 201             (rcvcmsgbuf = (u_char *)malloc(rcvcmsglen)) == NULL) {
 202                 syslog(LOG_ERR, "<%s>: malloc failed", __func__);
 203                 exit(1);
 204         }
 205         rcvmhdr.msg_control = (caddr_t)rcvcmsgbuf;
 206         rcvmhdr.msg_controllen = rcvcmsglen;
 207
 208         /* initialize msghdr for sending packets */
 209         sndmhdr.msg_namelen = sizeof(struct sockaddr_in6);
 210         sndmhdr.msg_iovlen = 1;
 211         sndcmsglen = CMSG_SPACE(sizeof(struct in6_pktinfo)) +
 212                 CMSG_SPACE(sizeof(int));
 213         if (sndcmsgbuf == NULL &&
 214             (sndcmsgbuf = (u_char *)malloc(sndcmsglen)) == NULL) {
 215                 syslog(LOG_ERR, "<%s>: malloc failed", __func__);
 216                 exit(1);
 217         }
 218         sndmhdr.msg_control = (caddr_t)sndcmsgbuf;
 219         sndmhdr.msg_controllen = sndcmsglen;
 220 }
 221
 222 static void
 223 config(FILE **fpp)
 224 {
 225         struct payload_list *pl;
 226         struct iovec *iov;
 227         struct icmp6_router_renum *irr;
 228         struct rr_pco_match *rpm;
 229
 230         if (parse(fpp) < 0) {
 231                 syslog(LOG_ERR, "<%s> parse failed", __func__);
 232                 exit(1);
 233         }
 234
 235         /* initialize fields not configured by parser */
 236         for (pl = pl_head; pl; pl = pl->pl_next) {
 237                 iov = (struct iovec *)&pl->pl_sndiov;
 238                 irr = (struct icmp6_router_renum *)&pl->pl_irr;
 239                 rpm = (struct rr_pco_match *)&pl->pl_rpm;
 240
 241                 irr->rr_type = ICMP6_ROUTER_RENUMBERING;
 242                 irr->rr_code = 0;
 243                 /*
 244                  * now we don't support multiple PCOs in a rr message.
 245                  * so segment number is not supported.
 246                  */
 247                 /* TODO: rr flags config in parser */
 248                 irr->rr_flags |= ICMP6_RR_FLAGS_SPECSITE;
 249                 /* TODO: max delay config in parser */
 250
 251                 /*
 252                  * means only 1 use_prefix is contained as router-renum-05.txt.
 253                  * now we don't support multiple PCOs in a rr message,
 254                  * nor multiple use_prefix in one PCO.
 255                  */
 256                 rpm->rpm_len = 4*1 +3;
 257                 rpm->rpm_ordinal = 0;
 258                 iov->iov_base = (caddr_t)irr;
 259                 iov->iov_len =  sizeof(struct icmp6_router_renum)
 260                         + sizeof(struct rr_pco_match)
 261                         + sizeof(struct rr_pco_use);
 262         }
 263 }
 264
 265 static void
 266 sock6_open(struct flags *flags
 267 #ifdef IPSEC_POLICY_IPSEC
 268            , char *policy
 269 #endif /* IPSEC_POLICY_IPSEC */
 270            )
 271 {
 272         struct icmp6_filter filt;
 273         int on;
 274 #ifdef IPSEC
 275 #ifndef IPSEC_POLICY_IPSEC
 276         int optval;
 277 #endif
 278 #endif
 279
 280         if (with_v6dest == 0)
 281                 return;
 282         if (with_v6dest &&
 283             (s6 = socket(AF_INET6, SOCK_RAW, IPPROTO_ICMPV6)) < 0) {
 284                 syslog(LOG_ERR, "<%s> socket(v6): %s", __func__,
 285                        strerror(errno));
 286                 exit(1);
 287         }
 288
 289         /*
 290          * join all routers multicast addresses.
 291          */
 292 #if 0 /* XXX: not necessary ?? */
 293         join_multi(LL_ALLROUTERS);
 294         join_multi(SL_ALLROUTERS);
 295 #endif
 296
 297         /* set icmpv6 filter */
 298         ICMP6_FILTER_SETBLOCKALL(&filt);
 299         ICMP6_FILTER_SETPASS(ICMP6_ROUTER_RENUMBERING, &filt);
 300         if (setsockopt(s6, IPPROTO_ICMPV6, ICMP6_FILTER, &filt,
 301                        sizeof(filt)) < 0) {
 302                 syslog(LOG_ERR, "<%s> IICMP6_FILTER: %s",
 303                        __func__, strerror(errno));
 304                 exit(1);
 305         }
 306
 307         /* specify to tell receiving interface */
 308         on = 1;
 309         if (setsockopt(s6, IPPROTO_IPV6, IPV6_PKTINFO, &on,
 310                        sizeof(on)) < 0) {
 311                 syslog(LOG_ERR, "<%s> IPV6_PKTINFO: %s",
 312                        __func__, strerror(errno));
 313                 exit(1);
 314         }
 315
 316 #ifdef IPSEC
 317 #ifdef IPSEC_POLICY_IPSEC
 318         if (flags->policy) {
 319                 char *buf;
 320                 buf = ipsec_set_policy(policy, strlen(policy));
 321                 if (buf == NULL)
 322                         errx(1, "%s", ipsec_strerror());
 323                 /* XXX should handle in/out bound policy. */
 324                 if (setsockopt(s6, IPPROTO_IPV6, IPV6_IPSEC_POLICY,
 325                                 buf, ipsec_get_policylen(buf)) < 0)
 326                         err(1, "setsockopt(IPV6_IPSEC_POLICY)");
 327                 free(buf);
 328         }
 329 #else /* IPSEC_POLICY_IPSEC */
 330         if (flags->auth) {
 331                 optval = IPSEC_LEVEL_REQUIRE;
 332                 if (setsockopt(s6, IPPROTO_IPV6, IPV6_AUTH_TRANS_LEVEL,
 333                                &optval, sizeof(optval)) == -1) {
 334                         syslog(LOG_ERR, "<%s> IPV6_AUTH_TRANS_LEVEL: %s",
 335                                __func__, strerror(errno));
 336                         exit(1);
 337                 }
 338         }
 339         if (flags->encrypt) {
 340                 optval = IPSEC_LEVEL_REQUIRE;
 341                 if (setsockopt(s6, IPPROTO_IPV6, IPV6_ESP_TRANS_LEVEL,
 342                                 &optval, sizeof(optval)) == -1) {
 343                         syslog(LOG_ERR, "<%s> IPV6_ESP_TRANS_LEVEL: %s",
 344                                __func__, strerror(errno));
 345                         exit(1);
 346                 }
 347         }
 348 #endif /* IPSEC_POLICY_IPSEC */
 349 #endif /* IPSEC */
 350
 351         return;
 352 }
 353
 354 static void
 355 sock4_open(struct flags *flags
 356 #ifdef IPSEC_POLICY_IPSEC
 357            , char *policy
 358 #endif /* IPSEC_POLICY_IPSEC */
 359            )
 360 {
 361 #ifdef IPSEC
 362 #ifndef IPSEC_POLICY_IPSEC
 363         int optval;
 364 #endif
 365 #endif
 366
 367         if (with_v4dest == 0)
 368                 return;
 369         if ((s4 = socket(AF_INET, SOCK_RAW, IPPROTO_ICMPV6)) < 0) {
 370                 syslog(LOG_ERR, "<%s> socket(v4): %s", __func__,
 371                        strerror(errno));
 372                 exit(1);
 373         }
 374
 375 #if 0 /* XXX: not necessary ?? */
 376         /*
 377          * join all routers multicast addresses.
 378          */
 379         some_join_function();
 380 #endif
 381
 382 #ifdef IPSEC
 383 #ifdef IPSEC_POLICY_IPSEC
 384         if (flags->policy) {
 385                 char *buf;
 386                 buf = ipsec_set_policy(policy, strlen(policy));
 387                 if (buf == NULL)
 388                         errx(1, "%s", ipsec_strerror());
 389                 /* XXX should handle in/out bound policy. */
 390                 if (setsockopt(s4, IPPROTO_IP, IP_IPSEC_POLICY,
 391                                 buf, ipsec_get_policylen(buf)) < 0)
 392                         err(1, "setsockopt(IP_IPSEC_POLICY)");
 393                 free(buf);
 394         }
 395 #else /* IPSEC_POLICY_IPSEC */
 396         if (flags->auth) {
 397                 optval = IPSEC_LEVEL_REQUIRE;
 398                 if (setsockopt(s4, IPPROTO_IP, IP_AUTH_TRANS_LEVEL,
 399                                &optval, sizeof(optval)) == -1) {
 400                         syslog(LOG_ERR, "<%s> IP_AUTH_TRANS_LEVEL: %s",
 401                                __func__, strerror(errno));
 402                         exit(1);
 403                 }
 404         }
 405         if (flags->encrypt) {
 406                 optval = IPSEC_LEVEL_REQUIRE;
 407                 if (setsockopt(s4, IPPROTO_IP, IP_ESP_TRANS_LEVEL,
 408                                 &optval, sizeof(optval)) == -1) {
 409                         syslog(LOG_ERR, "<%s> IP_ESP_TRANS_LEVEL: %s",
 410                                __func__, strerror(errno));
 411                         exit(1);
 412                 }
 413         }
 414 #endif /* IPSEC_POLICY_IPSEC */
 415 #endif /* IPSEC */
 416
 417         return;
 418 }
 419
 420 static void
 421 rrenum_output(struct payload_list *pl, struct dst_list *dl)
 422 {
 423         int i, msglen = 0;
 424         struct cmsghdr *cm;
 425         struct in6_pktinfo *pi;
 426         struct sockaddr_in6 *sin6 = NULL;
 427
 428         sndmhdr.msg_name = (caddr_t)dl->dl_dst;
 429         if (dl->dl_dst->sa_family == AF_INET6)
 430                 sin6 = (struct sockaddr_in6 *)dl->dl_dst;
 431
 432         if (sin6 != NULL &&
 433             IN6_IS_ADDR_MULTICAST(&sin6->sin6_addr)) {
 434                 int hoplimit = RR_MCHLIM_DEFAULT;
 435
 436                 cm = CMSG_FIRSTHDR(&sndmhdr);
 437                 /* specify the outgoing interface */
 438                 cm->cmsg_level = IPPROTO_IPV6;
 439                 cm->cmsg_type = IPV6_PKTINFO;
 440                 cm->cmsg_len = CMSG_LEN(sizeof(struct in6_pktinfo));
 441                 pi = (struct in6_pktinfo *)CMSG_DATA(cm);
 442                 memset(&pi->ipi6_addr, 0, sizeof(pi->ipi6_addr));       /*XXX*/
 443                 pi->ipi6_ifindex = sin6->sin6_scope_id;
 444                 msglen += CMSG_LEN(sizeof(struct in6_pktinfo));
 445
 446                 /* specify the hop limit of the packet if dest is link local */
 447                 /* not defined by router-renum-05.txt, but maybe its OK */
 448                 cm = CMSG_NXTHDR(&sndmhdr, cm);
 449                 cm->cmsg_level = IPPROTO_IPV6;
 450                 cm->cmsg_type = IPV6_HOPLIMIT;
 451                 cm->cmsg_len = CMSG_LEN(sizeof(int));
 452                 memcpy(CMSG_DATA(cm), &hoplimit, sizeof(int));
 453                 msglen += CMSG_LEN(sizeof(int));
 454         }
 455         sndmhdr.msg_controllen = msglen;
 456         if (sndmhdr.msg_controllen == 0)
 457                 sndmhdr.msg_control = 0;
 458
 459         sndmhdr.msg_iov = &pl->pl_sndiov;
 460         i = sendmsg(dl->dl_dst->sa_family == AF_INET ? s4 : s6, &sndmhdr, 0);
 461
 462         if (i < 0 || i != sndmhdr.msg_iov->iov_len)
 463                 syslog(LOG_ERR, "<%s> sendmsg: %s", __func__,
 464                        strerror(errno));
 465 }
 466
 467 static void
 468 rrenum_snd_eachdst(struct payload_list *pl)
 469 {
 470         struct dst_list *dl;
 471
 472         for (dl = dl_head; dl; dl = dl->dl_next) {
 473                 rrenum_output(pl, dl);
 474         }
 475 }
 476
 477 #if 0
 478 static void
 479 rrenum_snd_fullsequence(void)
 480 {
 481         struct payload_list *pl;
 482
 483         for (pl = pl_head; pl; pl = pl->pl_next) {
 484                 rrenum_snd_eachdst(pl);
 485         }
 486 }
 487 #endif
 488
 489 static void
 490 rrenum_input(int s)
 491 {
 492         int i;
 493         struct icmp6_router_renum *rr;
 494
 495         /* get message */
 496         if ((i = recvmsg(s, &rcvmhdr, 0)) < 0) {
 497                 syslog(LOG_ERR, "<%s> recvmsg: %s", __func__,
 498                        strerror(errno));
 499                 return;
 500         }
 501         if (s == s4)
 502                 i -= sizeof(struct ip);
 503         if (i < sizeof(struct icmp6_router_renum)) {
 504                 syslog(LOG_ERR, "<%s> packet size(%d) is too short",
 505                        __func__, i);
 506                 return;
 507         }
 508         if (s == s4) {
 509                 struct ip *ip = (struct ip *)rcvmhdr.msg_iov->iov_base;
 510
 511                 rr = (struct icmp6_router_renum *)(ip + 1);
 512         } else /* s == s6 */
 513                 rr = (struct icmp6_router_renum *)rcvmhdr.msg_iov->iov_base;
 514
 515         switch(rr->rr_code) {
 516         case ICMP6_ROUTER_RENUMBERING_COMMAND:
 517                 /* COMMAND will be processed by rtadvd */
 518                 break;
 519         case ICMP6_ROUTER_RENUMBERING_RESULT:
 520                 /* TODO: receiving result message */
 521                 break;
 522         default:
 523                 syslog(LOG_ERR, "<%s> received unknown code %d",
 524                        __func__, rr->rr_code);
 525                 break;
 526         }
 527 }
 528
 529 int
 530 main(int argc, char *argv[])
 531 {
 532         FILE *fp = stdin;
 533         fd_set fdset;
 534         struct timeval timeout;
 535         int ch, i, maxfd = 0, send_counter = 0;
 536         struct flags flags;
 537         struct payload_list *pl;
 538 #ifdef IPSEC_POLICY_IPSEC
 539         char *policy = NULL;
 540 #endif
 541
 542         memset(&flags, 0, sizeof(flags));
 543         openlog("rrenumd", LOG_PID, LOG_DAEMON);
 544
 545         /* get options */
 546         while ((ch = getopt(argc, argv, "c:sdf"
 547 #ifdef IPSEC
 548 #ifdef IPSEC_POLICY_IPSEC
 549                             "P:"
 550 #else /* IPSEC_POLICY_IPSEC */
 551                             "AE"
 552 #endif /* IPSEC_POLICY_IPSEC */
 553 #endif /* IPSEC */
 554                             )) != -1){
 555                 switch (ch) {
 556                 case 'c':
 557                         if((fp = fopen(optarg, "r")) == NULL) {
 558                                 syslog(LOG_ERR,
 559                                        "<%s> config file %s open failed",
 560                                        __func__, optarg);
 561                                 exit(1);
 562                         }
 563                         break;
 564                 case 's':
 565                         fp = stdin;
 566                         break;
 567                 case 'd':
 568                         flags.debug = 1;
 569                         break;
 570                 case 'f':
 571                         flags.fg = 1;
 572                         break;
 573 #ifdef IPSEC
 574 #ifdef IPSEC_POLICY_IPSEC
 575                 case 'P':
 576                         flags.policy = 1;
 577                         policy = strdup(optarg);
 578                         break;
 579 #else /* IPSEC_POLICY_IPSEC */
 580                 case 'A':
 581                         flags.auth = 1;
 582                         break;
 583                 case 'E':
 584                         flags.encrypt = 1;
 585                         break;
 586 #endif /* IPSEC_POLICY_IPSEC */
 587 #endif /*IPSEC*/
 588                 default:
 589                         show_usage();
 590                 }
 591         }
 592         argc -= optind;
 593         argv += optind;
 594
 595         /* set log level */
 596         if (flags.debug == 0)
 597                 setlogmask(LOG_UPTO(LOG_ERR));
 598         if (flags.debug == 1)
 599                 setlogmask(LOG_UPTO(LOG_INFO));
 600
 601         /* init global variables */
 602         init_globals();
 603
 604         config(&fp);
 605
 606         sock6_open(&flags
 607 #ifdef IPSEC_POLICY_IPSEC
 608                    , policy
 609 #endif /* IPSEC_POLICY_IPSEC */
 610                    );
 611         sock4_open(&flags
 612 #ifdef IPSEC_POLICY_IPSEC
 613                    , policy
 614 #endif /* IPSEC_POLICY_IPSEC */
 615                    );
 616
 617         if (!flags.fg)
 618                 daemon(0, 0);
 619
 620         FD_ZERO(&fdset);
 621         if (with_v6dest) {
 622                 FD_SET(s6, &fdset);
 623                 if (s6 > maxfd)
 624                         maxfd = s6;
 625         }
 626         if (with_v4dest) {
 627                 FD_SET(s4, &fdset);
 628                 if (s4 > maxfd)
 629                         maxfd = s4;
 630         }
 631
 632         /* ADHOC: timeout each 30seconds */
 633         memset(&timeout, 0, sizeof(timeout));
 634
 635         /* init temporary payload_list and send_counter*/
 636         pl = pl_head;
 637         send_counter = retry + 1;
 638         while (1) {
 639                 struct fd_set select_fd = fdset; /* reinitialize */
 640
 641                 if ((i = select(maxfd + 1, &select_fd, NULL, NULL,
 642                                 &timeout)) < 0){
 643                         syslog(LOG_ERR, "<%s> select: %s",
 644                                __func__, strerror(errno));
 645                         continue;
 646                 }
 647                 if (i == 0) {   /* timeout */
 648                         if (pl == NULL)
 649                                 exit(0);
 650                         rrenum_snd_eachdst(pl);
 651                         send_counter--;
 652                         timeout.tv_sec = 30;
 653                         if (send_counter == 0) {
 654                                 timeout.tv_sec = 0;
 655                                 pl = pl->pl_next;
 656                                 send_counter = retry + 1;
 657                         }
 658                 }
 659                 if (FD_ISSET(s4, &select_fd))
 660                         rrenum_input(s4);
 661                 if (FD_ISSET(s6, &select_fd))
 662                         rrenum_input(s6);
 663         }
 664 }