version 1.1.1.2, 2014/06/15 16:31:38
|
version 1.1.1.3, 2016/11/02 09:57:01
|
Line 1
|
Line 1
|
/* dnsmasq is Copyright (c) 2000-2014 Simon Kelley | /* dnsmasq is Copyright (c) 2000-2016 Simon Kelley |
|
|
This program is free software; you can redistribute it and/or modify |
This program is free software; you can redistribute it and/or modify |
it under the terms of the GNU General Public License as published by |
it under the terms of the GNU General Public License as published by |
Line 24 struct daemon *daemon;
|
Line 24 struct daemon *daemon;
|
static volatile pid_t pid = 0; |
static volatile pid_t pid = 0; |
static volatile int pipewrite; |
static volatile int pipewrite; |
|
|
static int set_dns_listeners(time_t now, fd_set *set, int *maxfdp); | static int set_dns_listeners(time_t now); |
static void check_dns_listeners(fd_set *set, time_t now); | static void check_dns_listeners(time_t now); |
static void sig_handler(int sig); |
static void sig_handler(int sig); |
static void async_event(int pipe, time_t now); |
static void async_event(int pipe, time_t now); |
static void fatal_event(struct event_desc *ev, char *msg); |
static void fatal_event(struct event_desc *ev, char *msg); |
static int read_event(int fd, struct event_desc *evp, char **msg); |
static int read_event(int fd, struct event_desc *evp, char **msg); |
|
static void poll_resolv(int force, int do_reload, time_t now); |
|
|
int main (int argc, char **argv) |
int main (int argc, char **argv) |
{ |
{ |
Line 57 int main (int argc, char **argv)
|
Line 58 int main (int argc, char **argv)
|
struct dhcp_context *context; |
struct dhcp_context *context; |
struct dhcp_relay *relay; |
struct dhcp_relay *relay; |
#endif |
#endif |
|
#ifdef HAVE_TFTP |
|
int tftp_prefix_missing = 0; |
|
#endif |
|
|
#ifdef LOCALEDIR |
#ifdef LOCALEDIR |
setlocale(LC_ALL, ""); |
setlocale(LC_ALL, ""); |
Line 79 int main (int argc, char **argv)
|
Line 83 int main (int argc, char **argv)
|
sigaction(SIGPIPE, &sigact, NULL); |
sigaction(SIGPIPE, &sigact, NULL); |
|
|
umask(022); /* known umask, create leases and pid files as 0644 */ |
umask(022); /* known umask, create leases and pid files as 0644 */ |
| |
| rand_init(); /* Must precede read_opts() */ |
| |
read_opts(argc, argv, compile_opts); |
read_opts(argc, argv, compile_opts); |
|
|
if (daemon->edns_pktsz < PACKETSZ) |
if (daemon->edns_pktsz < PACKETSZ) |
daemon->edns_pktsz = PACKETSZ; |
daemon->edns_pktsz = PACKETSZ; |
#ifdef HAVE_DNSSEC |
|
/* Enforce min packet big enough for DNSSEC */ |
|
if (option_bool(OPT_DNSSEC_VALID) && daemon->edns_pktsz < EDNS_PKTSZ) |
|
daemon->edns_pktsz = EDNS_PKTSZ; |
|
#endif |
|
|
|
daemon->packet_buff_sz = daemon->edns_pktsz > DNSMASQ_PACKETSZ ? | /* Min buffer size: we check after adding each record, so there must be |
daemon->edns_pktsz : DNSMASQ_PACKETSZ; | memory for the largest packet, and the largest record so the |
| min for DNS is PACKETSZ+MAXDNAME+RRFIXEDSZ which is < 1000. |
| This might be increased is EDNS packet size if greater than the minimum. */ |
| daemon->packet_buff_sz = daemon->edns_pktsz + MAXDNAME + RRFIXEDSZ; |
daemon->packet = safe_malloc(daemon->packet_buff_sz); |
daemon->packet = safe_malloc(daemon->packet_buff_sz); |
|
|
daemon->addrbuff = safe_malloc(ADDRSTRLEN); |
daemon->addrbuff = safe_malloc(ADDRSTRLEN); |
|
if (option_bool(OPT_EXTRALOG)) |
|
daemon->addrbuff2 = safe_malloc(ADDRSTRLEN); |
|
|
#ifdef HAVE_DNSSEC |
#ifdef HAVE_DNSSEC |
if (option_bool(OPT_DNSSEC_VALID)) |
if (option_bool(OPT_DNSSEC_VALID)) |
{ |
{ |
daemon->keyname = safe_malloc(MAXDNAME); | /* Note that both /000 and '.' are allowed within labels. These get |
daemon->workspacename = safe_malloc(MAXDNAME); | represented in presentation format using NAME_ESCAPE as an escape |
| character when in DNSSEC mode. |
| In theory, if all the characters in a name were /000 or |
| '.' or NAME_ESCAPE then all would have to be escaped, so the |
| presentation format would be twice as long as the spec. |
| |
| daemon->namebuff was previously allocated by the option-reading |
| code before we knew if we're in DNSSEC mode, so reallocate here. */ |
| free(daemon->namebuff); |
| daemon->namebuff = safe_malloc(MAXDNAME * 2); |
| daemon->keyname = safe_malloc(MAXDNAME * 2); |
| daemon->workspacename = safe_malloc(MAXDNAME * 2); |
} |
} |
#endif |
#endif |
|
|
Line 143 int main (int argc, char **argv)
|
Line 160 int main (int argc, char **argv)
|
reset_option_bool(OPT_CLEVERBIND); |
reset_option_bool(OPT_CLEVERBIND); |
} |
} |
#endif |
#endif |
|
|
|
#ifndef HAVE_INOTIFY |
|
if (daemon->dynamic_dirs) |
|
die(_("dhcp-hostsdir, dhcp-optsdir and hostsdir are not supported on this platform"), NULL, EC_BADCONF); |
|
#endif |
|
|
if (option_bool(OPT_DNSSEC_VALID)) |
if (option_bool(OPT_DNSSEC_VALID)) |
{ |
{ |
#ifdef HAVE_DNSSEC |
#ifdef HAVE_DNSSEC |
if (!daemon->ds) | struct ds_config *ds; |
die(_("No trust anchors provided for DNSSEC"), NULL, EC_BADCONF); | |
| /* Must have at least a root trust anchor, or the DNSSEC code |
| can loop forever. */ |
| for (ds = daemon->ds; ds; ds = ds->next) |
| if (ds->name[0] == 0) |
| break; |
| |
| if (!ds) |
| die(_("no root trust anchor provided for DNSSEC"), NULL, EC_BADCONF); |
|
|
if (daemon->cachesize < CACHESIZ) |
if (daemon->cachesize < CACHESIZ) |
die(_("Cannot reduce cache size from default when DNSSEC enabled"), NULL, EC_BADCONF); | die(_("cannot reduce cache size from default when DNSSEC enabled"), NULL, EC_BADCONF); |
#else |
#else |
die(_("DNSSEC not available: set HAVE_DNSSEC in src/config.h"), NULL, EC_BADCONF); |
die(_("DNSSEC not available: set HAVE_DNSSEC in src/config.h"), NULL, EC_BADCONF); |
#endif |
#endif |
Line 164 int main (int argc, char **argv)
|
Line 194 int main (int argc, char **argv)
|
|
|
#ifdef HAVE_CONNTRACK |
#ifdef HAVE_CONNTRACK |
if (option_bool(OPT_CONNTRACK) && (daemon->query_port != 0 || daemon->osport)) |
if (option_bool(OPT_CONNTRACK) && (daemon->query_port != 0 || daemon->osport)) |
die (_("Cannot use --conntrack AND --query-port"), NULL, EC_BADCONF); | die (_("cannot use --conntrack AND --query-port"), NULL, EC_BADCONF); |
#else |
#else |
if (option_bool(OPT_CONNTRACK)) |
if (option_bool(OPT_CONNTRACK)) |
die(_("Conntrack support not available: set HAVE_CONNTRACK in src/config.h"), NULL, EC_BADCONF); | die(_("conntrack support not available: set HAVE_CONNTRACK in src/config.h"), NULL, EC_BADCONF); |
#endif |
#endif |
|
|
#ifdef HAVE_SOLARIS_NETWORK |
#ifdef HAVE_SOLARIS_NETWORK |
Line 185 int main (int argc, char **argv)
|
Line 215 int main (int argc, char **argv)
|
die(_("authoritative DNS not available: set HAVE_AUTH in src/config.h"), NULL, EC_BADCONF); |
die(_("authoritative DNS not available: set HAVE_AUTH in src/config.h"), NULL, EC_BADCONF); |
#endif |
#endif |
|
|
rand_init(); | #ifndef HAVE_LOOP |
| if (option_bool(OPT_LOOP_DETECT)) |
| die(_("loop detection not available: set HAVE_LOOP in src/config.h"), NULL, EC_BADCONF); |
| #endif |
| |
| if (daemon->max_port != MAX_PORT && daemon->min_port == 0) |
| daemon->min_port = 1024u; |
| |
| if (daemon->max_port < daemon->min_port) |
| die(_("max_port cannot be smaller than min_port"), NULL, EC_BADCONF); |
| |
now = dnsmasq_time(); |
now = dnsmasq_time(); |
|
|
/* Create a serial at startup if not configured. */ |
/* Create a serial at startup if not configured. */ |
Line 220 int main (int argc, char **argv)
|
Line 259 int main (int argc, char **argv)
|
/* Note that order matters here, we must call lease_init before |
/* Note that order matters here, we must call lease_init before |
creating any file descriptors which shouldn't be leaked |
creating any file descriptors which shouldn't be leaked |
to the lease-script init process. We need to call common_init |
to the lease-script init process. We need to call common_init |
before lease_init to allocate buffers it uses.*/ | before lease_init to allocate buffers it uses. |
if (daemon->dhcp || daemon->doing_dhcp6 || daemon->relay4 || daemon->relay6) | The script subsystem relies on DHCP buffers, hence the last two |
| conditions below. */ |
| if (daemon->dhcp || daemon->doing_dhcp6 || daemon->relay4 || |
| daemon->relay6 || option_bool(OPT_TFTP) || option_bool(OPT_SCRIPT_ARP)) |
{ |
{ |
dhcp_common_init(); |
dhcp_common_init(); |
if (daemon->dhcp || daemon->doing_dhcp6) |
if (daemon->dhcp || daemon->doing_dhcp6) |
Line 309 int main (int argc, char **argv)
|
Line 351 int main (int argc, char **argv)
|
if (daemon->port != 0) |
if (daemon->port != 0) |
{ |
{ |
cache_init(); |
cache_init(); |
|
|
#ifdef HAVE_DNSSEC |
#ifdef HAVE_DNSSEC |
blockdata_init(); |
blockdata_init(); |
#endif |
#endif |
} |
} |
| |
| #ifdef HAVE_INOTIFY |
| if (daemon->port != 0 || daemon->dhcp || daemon->doing_dhcp6) |
| inotify_dnsmasq_init(); |
| else |
| daemon->inotifyfd = -1; |
| #endif |
| |
if (option_bool(OPT_DBUS)) |
if (option_bool(OPT_DBUS)) |
#ifdef HAVE_DBUS |
#ifdef HAVE_DBUS |
{ |
{ |
Line 326 int main (int argc, char **argv)
|
Line 376 int main (int argc, char **argv)
|
#else |
#else |
die(_("DBus not available: set HAVE_DBUS in src/config.h"), NULL, EC_BADCONF); |
die(_("DBus not available: set HAVE_DBUS in src/config.h"), NULL, EC_BADCONF); |
#endif |
#endif |
| |
if (daemon->port != 0) |
if (daemon->port != 0) |
pre_allocate_sfds(); |
pre_allocate_sfds(); |
|
|
Line 353 int main (int argc, char **argv)
|
Line 403 int main (int argc, char **argv)
|
|
|
if (baduser) |
if (baduser) |
die(_("unknown user or group: %s"), baduser, EC_BADCONF); |
die(_("unknown user or group: %s"), baduser, EC_BADCONF); |
| |
/* implement group defaults, "dip" if available, or group associated with uid */ |
/* implement group defaults, "dip" if available, or group associated with uid */ |
if (!daemon->group_set && !gp) |
if (!daemon->group_set && !gp) |
{ |
{ |
Line 428 int main (int argc, char **argv)
|
Line 478 int main (int argc, char **argv)
|
char *msg; |
char *msg; |
|
|
/* close our copy of write-end */ |
/* close our copy of write-end */ |
close(err_pipe[1]); | while (retry_send(close(err_pipe[1]))); |
|
|
/* check for errors after the fork */ |
/* check for errors after the fork */ |
if (read_event(err_pipe[0], &ev, &msg)) |
if (read_event(err_pipe[0], &ev, &msg)) |
Line 437 int main (int argc, char **argv)
|
Line 487 int main (int argc, char **argv)
|
_exit(EC_GOOD); |
_exit(EC_GOOD); |
} |
} |
|
|
close(err_pipe[0]); | while (retry_send(close(err_pipe[0]))); |
|
|
/* NO calls to die() from here on. */ |
/* NO calls to die() from here on. */ |
|
|
Line 489 int main (int argc, char **argv)
|
Line 539 int main (int argc, char **argv)
|
{ |
{ |
if (!read_write(fd, (unsigned char *)daemon->namebuff, strlen(daemon->namebuff), 0)) |
if (!read_write(fd, (unsigned char *)daemon->namebuff, strlen(daemon->namebuff), 0)) |
err = 1; |
err = 1; |
| else |
while (!err && close(fd) == -1) | { |
if (!retry_send()) | while (retry_send(close(fd))); |
err = 1; | if (errno != 0) |
| err = 1; |
| } |
} |
} |
|
|
if (err) |
if (err) |
Line 509 int main (int argc, char **argv)
|
Line 561 int main (int argc, char **argv)
|
{ |
{ |
/* open stdout etc to /dev/null */ |
/* open stdout etc to /dev/null */ |
int nullfd = open("/dev/null", O_RDWR); |
int nullfd = open("/dev/null", O_RDWR); |
dup2(nullfd, STDOUT_FILENO); | if (nullfd != -1) |
dup2(nullfd, STDERR_FILENO); | { |
dup2(nullfd, STDIN_FILENO); | dup2(nullfd, STDOUT_FILENO); |
close(nullfd); | dup2(nullfd, STDERR_FILENO); |
| dup2(nullfd, STDIN_FILENO); |
| close(nullfd); |
| } |
} |
} |
|
|
/* if we are to run scripts, we need to fork a helper before dropping root. */ |
/* if we are to run scripts, we need to fork a helper before dropping root. */ |
daemon->helperfd = -1; |
daemon->helperfd = -1; |
#ifdef HAVE_SCRIPT |
#ifdef HAVE_SCRIPT |
if ((daemon->dhcp || daemon->dhcp6) && (daemon->lease_change_command || daemon->luascript)) | if ((daemon->dhcp || daemon->dhcp6 || option_bool(OPT_TFTP) || option_bool(OPT_SCRIPT_ARP)) && |
daemon->helperfd = create_helper(pipewrite, err_pipe[1], script_uid, script_gid, max_fd); | (daemon->lease_change_command || daemon->luascript)) |
| daemon->helperfd = create_helper(pipewrite, err_pipe[1], script_uid, script_gid, max_fd); |
#endif |
#endif |
|
|
if (!option_bool(OPT_DEBUG) && getuid() == 0) |
if (!option_bool(OPT_DEBUG) && getuid() == 0) |
Line 611 int main (int argc, char **argv)
|
Line 667 int main (int argc, char **argv)
|
} |
} |
|
|
#ifdef HAVE_LINUX_NETWORK |
#ifdef HAVE_LINUX_NETWORK |
|
free(hdr); |
|
free(data); |
if (option_bool(OPT_DEBUG)) |
if (option_bool(OPT_DEBUG)) |
prctl(PR_SET_DUMPABLE, 1, 0, 0, 0); |
prctl(PR_SET_DUMPABLE, 1, 0, 0, 0); |
#endif |
#endif |
|
|
#ifdef HAVE_TFTP |
#ifdef HAVE_TFTP |
if (option_bool(OPT_TFTP)) | if (option_bool(OPT_TFTP)) |
{ |
{ |
DIR *dir; |
DIR *dir; |
struct tftp_prefix *p; |
struct tftp_prefix *p; |
Line 625 int main (int argc, char **argv)
|
Line 683 int main (int argc, char **argv)
|
{ |
{ |
if (!((dir = opendir(daemon->tftp_prefix)))) |
if (!((dir = opendir(daemon->tftp_prefix)))) |
{ |
{ |
send_event(err_pipe[1], EVENT_TFTP_ERR, errno, daemon->tftp_prefix); | tftp_prefix_missing = 1; |
_exit(0); | if (!option_bool(OPT_TFTP_NO_FAIL)) |
| { |
| send_event(err_pipe[1], EVENT_TFTP_ERR, errno, daemon->tftp_prefix); |
| _exit(0); |
| } |
} |
} |
closedir(dir); | else |
| closedir(dir); |
} |
} |
|
|
for (p = daemon->if_prefix; p; p = p->next) |
for (p = daemon->if_prefix; p; p = p->next) |
{ |
{ |
|
p->missing = 0; |
if (!((dir = opendir(p->prefix)))) |
if (!((dir = opendir(p->prefix)))) |
{ | { |
send_event(err_pipe[1], EVENT_TFTP_ERR, errno, p->prefix); | p->missing = 1; |
_exit(0); | if (!option_bool(OPT_TFTP_NO_FAIL)) |
} | { |
closedir(dir); | send_event(err_pipe[1], EVENT_TFTP_ERR, errno, p->prefix); |
| _exit(0); |
| } |
| } |
| else |
| closedir(dir); |
} |
} |
} |
} |
#endif |
#endif |
Line 668 int main (int argc, char **argv)
|
Line 737 int main (int argc, char **argv)
|
#ifdef HAVE_DNSSEC |
#ifdef HAVE_DNSSEC |
if (option_bool(OPT_DNSSEC_VALID)) |
if (option_bool(OPT_DNSSEC_VALID)) |
{ |
{ |
|
int rc; |
|
|
|
/* Delay creating the timestamp file until here, after we've changed user, so that |
|
it has the correct owner to allow updating the mtime later. |
|
This means we have to report fatal errors via the pipe. */ |
|
if ((rc = setup_timestamp()) == -1) |
|
{ |
|
send_event(err_pipe[1], EVENT_TIME_ERR, errno, daemon->timestamp_file); |
|
_exit(0); |
|
} |
|
|
my_syslog(LOG_INFO, _("DNSSEC validation enabled")); |
my_syslog(LOG_INFO, _("DNSSEC validation enabled")); |
|
|
if (option_bool(OPT_DNSSEC_TIME)) |
if (option_bool(OPT_DNSSEC_TIME)) |
my_syslog(LOG_INFO, _("DNSSEC signature timestamps not checked until first cache reload")); |
my_syslog(LOG_INFO, _("DNSSEC signature timestamps not checked until first cache reload")); |
|
|
|
if (rc == 1) |
|
my_syslog(LOG_INFO, _("DNSSEC signature timestamps not checked until system time valid")); |
} |
} |
#endif |
#endif |
|
|
Line 736 int main (int argc, char **argv)
|
Line 820 int main (int argc, char **argv)
|
#endif |
#endif |
|
|
#ifdef HAVE_TFTP |
#ifdef HAVE_TFTP |
if (option_bool(OPT_TFTP)) | if (option_bool(OPT_TFTP)) |
{ |
{ |
#ifdef FD_SETSIZE | struct tftp_prefix *p; |
if (FD_SETSIZE < (unsigned)max_fd) | |
max_fd = FD_SETSIZE; | |
#endif | |
|
|
my_syslog(MS_TFTP | LOG_INFO, "TFTP %s%s %s", |
my_syslog(MS_TFTP | LOG_INFO, "TFTP %s%s %s", |
daemon->tftp_prefix ? _("root is ") : _("enabled"), |
daemon->tftp_prefix ? _("root is ") : _("enabled"), |
daemon->tftp_prefix ? daemon->tftp_prefix: "", |
daemon->tftp_prefix ? daemon->tftp_prefix: "", |
option_bool(OPT_TFTP_SECURE) ? _("secure mode") : ""); |
option_bool(OPT_TFTP_SECURE) ? _("secure mode") : ""); |
| |
| if (tftp_prefix_missing) |
| my_syslog(MS_TFTP | LOG_WARNING, _("warning: %s inaccessible"), daemon->tftp_prefix); |
| |
| for (p = daemon->if_prefix; p; p = p->next) |
| if (p->missing) |
| my_syslog(MS_TFTP | LOG_WARNING, _("warning: TFTP directory %s inaccessible"), p->prefix); |
| |
/* This is a guess, it assumes that for small limits, |
/* This is a guess, it assumes that for small limits, |
disjoint files might be served, but for large limits, |
disjoint files might be served, but for large limits, |
a single file will be sent to may clients (the file only needs |
a single file will be sent to may clients (the file only needs |
Line 780 int main (int argc, char **argv)
|
Line 868 int main (int argc, char **argv)
|
|
|
/* finished start-up - release original process */ |
/* finished start-up - release original process */ |
if (err_pipe[1] != -1) |
if (err_pipe[1] != -1) |
close(err_pipe[1]); | while (retry_send(close(err_pipe[1]))); |
|
|
if (daemon->port != 0) |
if (daemon->port != 0) |
check_servers(); |
check_servers(); |
|
|
pid = getpid(); |
pid = getpid(); |
|
|
|
#ifdef HAVE_INOTIFY |
|
/* Using inotify, have to select a resolv file at startup */ |
|
poll_resolv(1, 0, now); |
|
#endif |
|
|
while (1) |
while (1) |
{ |
{ |
int maxfd = -1; | int t, timeout = -1; |
struct timeval t, *tp = NULL; | |
fd_set rset, wset, eset; | |
|
|
FD_ZERO(&rset); | poll_reset(); |
FD_ZERO(&wset); | |
FD_ZERO(&eset); | |
|
|
/* if we are out of resources, find how long we have to wait |
/* if we are out of resources, find how long we have to wait |
for some to come free, we'll loop around then and restart |
for some to come free, we'll loop around then and restart |
listening for queries */ |
listening for queries */ |
if ((t.tv_sec = set_dns_listeners(now, &rset, &maxfd)) != 0) | if ((t = set_dns_listeners(now)) != 0) |
{ | timeout = t * 1000; |
t.tv_usec = 0; | |
tp = &t; | |
} | |
|
|
/* Whilst polling for the dbus, or doing a tftp transfer, wake every quarter second */ |
/* Whilst polling for the dbus, or doing a tftp transfer, wake every quarter second */ |
if (daemon->tftp_trans || |
if (daemon->tftp_trans || |
(option_bool(OPT_DBUS) && !daemon->dbus)) |
(option_bool(OPT_DBUS) && !daemon->dbus)) |
{ | timeout = 250; |
t.tv_sec = 0; | |
t.tv_usec = 250000; | |
tp = &t; | |
} | |
/* Wake every second whilst waiting for DAD to complete */ |
/* Wake every second whilst waiting for DAD to complete */ |
else if (is_dad_listeners()) |
else if (is_dad_listeners()) |
{ | timeout = 1000; |
t.tv_sec = 1; | |
t.tv_usec = 0; | |
tp = &t; | |
} | |
|
|
#ifdef HAVE_DBUS |
#ifdef HAVE_DBUS |
set_dbus_listeners(&maxfd, &rset, &wset, &eset); | set_dbus_listeners(); |
#endif |
#endif |
|
|
#ifdef HAVE_DHCP |
#ifdef HAVE_DHCP |
if (daemon->dhcp || daemon->relay4) |
if (daemon->dhcp || daemon->relay4) |
{ |
{ |
FD_SET(daemon->dhcpfd, &rset); | poll_listen(daemon->dhcpfd, POLLIN); |
bump_maxfd(daemon->dhcpfd, &maxfd); | |
if (daemon->pxefd != -1) |
if (daemon->pxefd != -1) |
{ | poll_listen(daemon->pxefd, POLLIN); |
FD_SET(daemon->pxefd, &rset); | |
bump_maxfd(daemon->pxefd, &maxfd); | |
} | |
} |
} |
#endif |
#endif |
|
|
#ifdef HAVE_DHCP6 |
#ifdef HAVE_DHCP6 |
if (daemon->doing_dhcp6 || daemon->relay6) |
if (daemon->doing_dhcp6 || daemon->relay6) |
{ | poll_listen(daemon->dhcp6fd, POLLIN); |
FD_SET(daemon->dhcp6fd, &rset); | |
bump_maxfd(daemon->dhcp6fd, &maxfd); | |
} | |
| |
if (daemon->doing_ra) |
if (daemon->doing_ra) |
{ | poll_listen(daemon->icmp6fd, POLLIN); |
FD_SET(daemon->icmp6fd, &rset); | |
bump_maxfd(daemon->icmp6fd, &maxfd); | |
} | |
#endif |
#endif |
|
|
|
#ifdef HAVE_INOTIFY |
|
if (daemon->inotifyfd != -1) |
|
poll_listen(daemon->inotifyfd, POLLIN); |
|
#endif |
|
|
#if defined(HAVE_LINUX_NETWORK) |
#if defined(HAVE_LINUX_NETWORK) |
FD_SET(daemon->netlinkfd, &rset); | poll_listen(daemon->netlinkfd, POLLIN); |
bump_maxfd(daemon->netlinkfd, &maxfd); | |
#elif defined(HAVE_BSD_NETWORK) |
#elif defined(HAVE_BSD_NETWORK) |
FD_SET(daemon->routefd, &rset); | poll_listen(daemon->routefd, POLLIN); |
bump_maxfd(daemon->routefd, &maxfd); | |
#endif |
#endif |
|
|
|
poll_listen(piperead, POLLIN); |
|
|
FD_SET(piperead, &rset); | #ifdef HAVE_SCRIPT |
bump_maxfd(piperead, &maxfd); | # ifdef HAVE_DHCP |
| while (helper_buf_empty() && do_script_run(now)); |
| # endif |
|
|
#ifdef HAVE_DHCP | /* Refresh cache */ |
# ifdef HAVE_SCRIPT | if (option_bool(OPT_SCRIPT_ARP)) |
while (helper_buf_empty() && do_script_run(now)); | find_mac(NULL, NULL, 0, now); |
| while (helper_buf_empty() && do_arp_script_run()); |
|
|
# ifdef HAVE_TFTP |
# ifdef HAVE_TFTP |
while (helper_buf_empty() && do_tftp_script_run()); |
while (helper_buf_empty() && do_tftp_script_run()); |
# endif |
# endif |
|
|
if (!helper_buf_empty()) |
if (!helper_buf_empty()) |
{ | poll_listen(daemon->helperfd, POLLOUT); |
FD_SET(daemon->helperfd, &wset); | #else |
bump_maxfd(daemon->helperfd, &maxfd); | |
} | |
# else | |
/* need this for other side-effects */ |
/* need this for other side-effects */ |
|
# ifdef HAVE_DHCP |
while (do_script_run(now)); |
while (do_script_run(now)); |
|
# endif |
|
|
|
while (do_arp_script_run()); |
|
|
# ifdef HAVE_TFTP |
# ifdef HAVE_TFTP |
while (do_tftp_script_run()); |
while (do_tftp_script_run()); |
# endif |
# endif |
|
|
# endif |
|
#endif |
#endif |
|
|
|
|
/* must do this just before select(), when we know no |
/* must do this just before select(), when we know no |
more calls to my_syslog() can occur */ |
more calls to my_syslog() can occur */ |
set_log_writer(&wset, &maxfd); | set_log_writer(); |
|
|
if (select(maxfd+1, &rset, &wset, &eset, tp) < 0) | if (do_poll(timeout) < 0) |
{ | continue; |
/* otherwise undefined after error */ | |
FD_ZERO(&rset); FD_ZERO(&wset); FD_ZERO(&eset); | |
} | |
| |
now = dnsmasq_time(); |
now = dnsmasq_time(); |
|
|
check_log_writer(&wset); | check_log_writer(0); |
|
|
/* prime. */ |
/* prime. */ |
enumerate_interfaces(1); |
enumerate_interfaces(1); |
Line 916 int main (int argc, char **argv)
|
Line 991 int main (int argc, char **argv)
|
} |
} |
|
|
#if defined(HAVE_LINUX_NETWORK) |
#if defined(HAVE_LINUX_NETWORK) |
if (FD_ISSET(daemon->netlinkfd, &rset)) | if (poll_check(daemon->netlinkfd, POLLIN)) |
netlink_multicast(now); | netlink_multicast(); |
#elif defined(HAVE_BSD_NETWORK) |
#elif defined(HAVE_BSD_NETWORK) |
if (FD_ISSET(daemon->routefd, &rset)) | if (poll_check(daemon->routefd, POLLIN)) |
route_sock(now); | route_sock(); |
#endif |
#endif |
|
|
|
#ifdef HAVE_INOTIFY |
|
if (daemon->inotifyfd != -1 && poll_check(daemon->inotifyfd, POLLIN) && inotify_check(now)) |
|
{ |
|
if (daemon->port != 0 && !option_bool(OPT_NO_POLL)) |
|
poll_resolv(1, 1, now); |
|
} |
|
#else |
/* Check for changes to resolv files once per second max. */ |
/* Check for changes to resolv files once per second max. */ |
/* Don't go silent for long periods if the clock goes backwards. */ |
/* Don't go silent for long periods if the clock goes backwards. */ |
if (daemon->last_resolv == 0 || |
if (daemon->last_resolv == 0 || |
Line 935 int main (int argc, char **argv)
|
Line 1017 int main (int argc, char **argv)
|
poll_resolv(0, daemon->last_resolv != 0, now); |
poll_resolv(0, daemon->last_resolv != 0, now); |
daemon->last_resolv = now; |
daemon->last_resolv = now; |
} |
} |
| #endif |
if (FD_ISSET(piperead, &rset)) | |
| if (poll_check(piperead, POLLIN)) |
async_event(piperead, now); |
async_event(piperead, now); |
|
|
#ifdef HAVE_DBUS |
#ifdef HAVE_DBUS |
Line 949 int main (int argc, char **argv)
|
Line 1032 int main (int argc, char **argv)
|
if (daemon->dbus) |
if (daemon->dbus) |
my_syslog(LOG_INFO, _("connected to system DBus")); |
my_syslog(LOG_INFO, _("connected to system DBus")); |
} |
} |
check_dbus_listeners(&rset, &wset, &eset); | check_dbus_listeners(); |
#endif |
#endif |
|
|
check_dns_listeners(&rset, now); | check_dns_listeners(now); |
|
|
#ifdef HAVE_TFTP |
#ifdef HAVE_TFTP |
check_tftp_listeners(&rset, now); | check_tftp_listeners(now); |
#endif |
#endif |
|
|
#ifdef HAVE_DHCP |
#ifdef HAVE_DHCP |
if (daemon->dhcp || daemon->relay4) |
if (daemon->dhcp || daemon->relay4) |
{ |
{ |
if (FD_ISSET(daemon->dhcpfd, &rset)) | if (poll_check(daemon->dhcpfd, POLLIN)) |
dhcp_packet(now, 0); |
dhcp_packet(now, 0); |
if (daemon->pxefd != -1 && FD_ISSET(daemon->pxefd, &rset)) | if (daemon->pxefd != -1 && poll_check(daemon->pxefd, POLLIN)) |
dhcp_packet(now, 1); |
dhcp_packet(now, 1); |
} |
} |
|
|
#ifdef HAVE_DHCP6 |
#ifdef HAVE_DHCP6 |
if ((daemon->doing_dhcp6 || daemon->relay6) && FD_ISSET(daemon->dhcp6fd, &rset)) | if ((daemon->doing_dhcp6 || daemon->relay6) && poll_check(daemon->dhcp6fd, POLLIN)) |
dhcp6_packet(now); |
dhcp6_packet(now); |
|
|
if (daemon->doing_ra && FD_ISSET(daemon->icmp6fd, &rset)) | if (daemon->doing_ra && poll_check(daemon->icmp6fd, POLLIN)) |
icmp6_packet(now); |
icmp6_packet(now); |
#endif |
#endif |
|
|
# ifdef HAVE_SCRIPT |
# ifdef HAVE_SCRIPT |
if (daemon->helperfd != -1 && FD_ISSET(daemon->helperfd, &wset)) | if (daemon->helperfd != -1 && poll_check(daemon->helperfd, POLLOUT)) |
helper_write(); |
helper_write(); |
# endif |
# endif |
#endif |
#endif |
Line 1037 void send_alarm(time_t event, time_t now)
|
Line 1120 void send_alarm(time_t event, time_t now)
|
} |
} |
} |
} |
|
|
|
void queue_event(int event) |
|
{ |
|
send_event(pipewrite, event, 0, NULL); |
|
} |
|
|
void send_event(int fd, int event, int data, char *msg) |
void send_event(int fd, int event, int data, char *msg) |
{ |
{ |
struct event_desc ev; |
struct event_desc ev; |
Line 1117 static void fatal_event(struct event_desc *ev, char *m
|
Line 1205 static void fatal_event(struct event_desc *ev, char *m
|
|
|
case EVENT_TFTP_ERR: |
case EVENT_TFTP_ERR: |
die(_("TFTP directory %s inaccessible: %s"), msg, EC_FILE); |
die(_("TFTP directory %s inaccessible: %s"), msg, EC_FILE); |
|
|
|
case EVENT_TIME_ERR: |
|
die(_("cannot create timestamp file %s: %s" ), msg, EC_BADCONF); |
} |
} |
} |
} |
|
|
Line 1230 static void async_event(int pipe, time_t now)
|
Line 1321 static void async_event(int pipe, time_t now)
|
if (daemon->log_file != NULL) |
if (daemon->log_file != NULL) |
log_reopen(daemon->log_file); |
log_reopen(daemon->log_file); |
break; |
break; |
| |
| case EVENT_NEWADDR: |
| newaddress(now); |
| break; |
| |
| case EVENT_NEWROUTE: |
| resend_query(); |
| /* Force re-reading resolv file right now, for luck. */ |
| poll_resolv(0, 1, now); |
| break; |
| |
case EVENT_TERM: |
case EVENT_TERM: |
/* Knock all our children on the head. */ |
/* Knock all our children on the head. */ |
for (i = 0; i < MAX_PROCS; i++) |
for (i = 0; i < MAX_PROCS; i++) |
if (daemon->tcp_pids[i] != 0) |
if (daemon->tcp_pids[i] != 0) |
kill(daemon->tcp_pids[i], SIGALRM); |
kill(daemon->tcp_pids[i], SIGALRM); |
|
|
#if defined(HAVE_SCRIPT) | #if defined(HAVE_SCRIPT) && defined(HAVE_DHCP) |
/* handle pending lease transitions */ |
/* handle pending lease transitions */ |
if (daemon->helperfd != -1) |
if (daemon->helperfd != -1) |
{ |
{ |
Line 1247 static void async_event(int pipe, time_t now)
|
Line 1348 static void async_event(int pipe, time_t now)
|
do { |
do { |
helper_write(); |
helper_write(); |
} while (!helper_buf_empty() || do_script_run(now)); |
} while (!helper_buf_empty() || do_script_run(now)); |
close(daemon->helperfd); | while (retry_send(close(daemon->helperfd))); |
} |
} |
#endif |
#endif |
|
|
if (daemon->lease_stream) |
if (daemon->lease_stream) |
fclose(daemon->lease_stream); |
fclose(daemon->lease_stream); |
|
|
|
#ifdef HAVE_DNSSEC |
|
/* update timestamp file on TERM if time is considered valid */ |
|
if (daemon->back_to_the_future) |
|
{ |
|
if (utime(daemon->timestamp_file, NULL) == -1) |
|
my_syslog(LOG_ERR, _("failed to update mtime on %s: %s"), daemon->timestamp_file, strerror(errno)); |
|
} |
|
#endif |
|
|
if (daemon->runfile) |
if (daemon->runfile) |
unlink(daemon->runfile); |
unlink(daemon->runfile); |
|
|
Line 1263 static void async_event(int pipe, time_t now)
|
Line 1373 static void async_event(int pipe, time_t now)
|
} |
} |
} |
} |
|
|
void poll_resolv(int force, int do_reload, time_t now) | static void poll_resolv(int force, int do_reload, time_t now) |
{ |
{ |
struct resolvc *res, *latest; |
struct resolvc *res, *latest; |
struct stat statbuf; |
struct stat statbuf; |
Line 1346 void clear_cache_and_reload(time_t now)
|
Line 1456 void clear_cache_and_reload(time_t now)
|
if (option_bool(OPT_ETHERS)) |
if (option_bool(OPT_ETHERS)) |
dhcp_read_ethers(); |
dhcp_read_ethers(); |
reread_dhcp(); |
reread_dhcp(); |
|
#ifdef HAVE_INOTIFY |
|
set_dynamic_inotify(AH_DHCP_HST | AH_DHCP_OPT, 0, NULL, 0); |
|
#endif |
dhcp_update_configs(daemon->dhcp_conf); |
dhcp_update_configs(daemon->dhcp_conf); |
lease_update_from_configs(); |
lease_update_from_configs(); |
lease_update_file(now); |
lease_update_file(now); |
Line 1360 void clear_cache_and_reload(time_t now)
|
Line 1473 void clear_cache_and_reload(time_t now)
|
#endif |
#endif |
} |
} |
|
|
static int set_dns_listeners(time_t now, fd_set *set, int *maxfdp) | static int set_dns_listeners(time_t now) |
{ |
{ |
struct serverfd *serverfdp; |
struct serverfd *serverfdp; |
struct listener *listener; |
struct listener *listener; |
Line 1372 static int set_dns_listeners(time_t now, fd_set *set,
|
Line 1485 static int set_dns_listeners(time_t now, fd_set *set,
|
for (transfer = daemon->tftp_trans; transfer; transfer = transfer->next) |
for (transfer = daemon->tftp_trans; transfer; transfer = transfer->next) |
{ |
{ |
tftp++; |
tftp++; |
FD_SET(transfer->sockfd, set); | poll_listen(transfer->sockfd, POLLIN); |
bump_maxfd(transfer->sockfd, maxfdp); | |
} |
} |
#endif |
#endif |
|
|
Line 1382 static int set_dns_listeners(time_t now, fd_set *set,
|
Line 1494 static int set_dns_listeners(time_t now, fd_set *set,
|
get_new_frec(now, &wait, 0); |
get_new_frec(now, &wait, 0); |
|
|
for (serverfdp = daemon->sfds; serverfdp; serverfdp = serverfdp->next) |
for (serverfdp = daemon->sfds; serverfdp; serverfdp = serverfdp->next) |
{ | poll_listen(serverfdp->fd, POLLIN); |
FD_SET(serverfdp->fd, set); | |
bump_maxfd(serverfdp->fd, maxfdp); | |
} | |
| |
if (daemon->port != 0 && !daemon->osport) |
if (daemon->port != 0 && !daemon->osport) |
for (i = 0; i < RANDOM_SOCKS; i++) |
for (i = 0; i < RANDOM_SOCKS; i++) |
if (daemon->randomsocks[i].refcount != 0) |
if (daemon->randomsocks[i].refcount != 0) |
{ | poll_listen(daemon->randomsocks[i].fd, POLLIN); |
FD_SET(daemon->randomsocks[i].fd, set); | |
bump_maxfd(daemon->randomsocks[i].fd, maxfdp); | |
} | |
| |
for (listener = daemon->listeners; listener; listener = listener->next) |
for (listener = daemon->listeners; listener; listener = listener->next) |
{ |
{ |
/* only listen for queries if we have resources */ |
/* only listen for queries if we have resources */ |
if (listener->fd != -1 && wait == 0) |
if (listener->fd != -1 && wait == 0) |
{ | poll_listen(listener->fd, POLLIN); |
FD_SET(listener->fd, set); | |
bump_maxfd(listener->fd, maxfdp); | |
} | |
| |
/* death of a child goes through the select loop, so |
/* death of a child goes through the select loop, so |
we don't need to explicitly arrange to wake up here */ |
we don't need to explicitly arrange to wake up here */ |
if (listener->tcpfd != -1) |
if (listener->tcpfd != -1) |
for (i = 0; i < MAX_PROCS; i++) |
for (i = 0; i < MAX_PROCS; i++) |
if (daemon->tcp_pids[i] == 0) |
if (daemon->tcp_pids[i] == 0) |
{ |
{ |
FD_SET(listener->tcpfd, set); | poll_listen(listener->tcpfd, POLLIN); |
bump_maxfd(listener->tcpfd, maxfdp); | |
break; |
break; |
} |
} |
|
|
#ifdef HAVE_TFTP |
#ifdef HAVE_TFTP |
if (tftp <= daemon->tftp_max && listener->tftpfd != -1) |
if (tftp <= daemon->tftp_max && listener->tftpfd != -1) |
{ | poll_listen(listener->tftpfd, POLLIN); |
FD_SET(listener->tftpfd, set); | |
bump_maxfd(listener->tftpfd, maxfdp); | |
} | |
#endif |
#endif |
|
|
} |
} |
Line 1428 static int set_dns_listeners(time_t now, fd_set *set,
|
Line 1527 static int set_dns_listeners(time_t now, fd_set *set,
|
return wait; |
return wait; |
} |
} |
|
|
static void check_dns_listeners(fd_set *set, time_t now) | static void check_dns_listeners(time_t now) |
{ |
{ |
struct serverfd *serverfdp; |
struct serverfd *serverfdp; |
struct listener *listener; |
struct listener *listener; |
int i; |
int i; |
|
|
for (serverfdp = daemon->sfds; serverfdp; serverfdp = serverfdp->next) |
for (serverfdp = daemon->sfds; serverfdp; serverfdp = serverfdp->next) |
if (FD_ISSET(serverfdp->fd, set)) | if (poll_check(serverfdp->fd, POLLIN)) |
reply_query(serverfdp->fd, serverfdp->source_addr.sa.sa_family, now); |
reply_query(serverfdp->fd, serverfdp->source_addr.sa.sa_family, now); |
|
|
if (daemon->port != 0 && !daemon->osport) |
if (daemon->port != 0 && !daemon->osport) |
for (i = 0; i < RANDOM_SOCKS; i++) |
for (i = 0; i < RANDOM_SOCKS; i++) |
if (daemon->randomsocks[i].refcount != 0 && |
if (daemon->randomsocks[i].refcount != 0 && |
FD_ISSET(daemon->randomsocks[i].fd, set)) | poll_check(daemon->randomsocks[i].fd, POLLIN)) |
reply_query(daemon->randomsocks[i].fd, daemon->randomsocks[i].family, now); |
reply_query(daemon->randomsocks[i].fd, daemon->randomsocks[i].family, now); |
|
|
for (listener = daemon->listeners; listener; listener = listener->next) |
for (listener = daemon->listeners; listener; listener = listener->next) |
{ |
{ |
if (listener->fd != -1 && FD_ISSET(listener->fd, set)) | if (listener->fd != -1 && poll_check(listener->fd, POLLIN)) |
receive_query(listener, now); |
receive_query(listener, now); |
|
|
#ifdef HAVE_TFTP |
#ifdef HAVE_TFTP |
if (listener->tftpfd != -1 && FD_ISSET(listener->tftpfd, set)) | if (listener->tftpfd != -1 && poll_check(listener->tftpfd, POLLIN)) |
tftp_request(listener, now); |
tftp_request(listener, now); |
#endif |
#endif |
|
|
if (listener->tcpfd != -1 && FD_ISSET(listener->tcpfd, set)) | if (listener->tcpfd != -1 && poll_check(listener->tcpfd, POLLIN)) |
{ |
{ |
int confd, client_ok = 1; |
int confd, client_ok = 1; |
struct irec *iface = NULL; |
struct irec *iface = NULL; |
Line 1469 static void check_dns_listeners(fd_set *set, time_t no
|
Line 1568 static void check_dns_listeners(fd_set *set, time_t no
|
|
|
if (getsockname(confd, (struct sockaddr *)&tcp_addr, &tcp_len) == -1) |
if (getsockname(confd, (struct sockaddr *)&tcp_addr, &tcp_len) == -1) |
{ |
{ |
close(confd); | while (retry_send(close(confd))); |
continue; |
continue; |
} |
} |
|
|
Line 1534 static void check_dns_listeners(fd_set *set, time_t no
|
Line 1633 static void check_dns_listeners(fd_set *set, time_t no
|
if (!client_ok) |
if (!client_ok) |
{ |
{ |
shutdown(confd, SHUT_RDWR); |
shutdown(confd, SHUT_RDWR); |
close(confd); | while (retry_send(close(confd))); |
} |
} |
#ifndef NO_FORK |
#ifndef NO_FORK |
else if (!option_bool(OPT_DEBUG) && (p = fork()) != 0) |
else if (!option_bool(OPT_DEBUG) && (p = fork()) != 0) |
Line 1549 static void check_dns_listeners(fd_set *set, time_t no
|
Line 1648 static void check_dns_listeners(fd_set *set, time_t no
|
break; |
break; |
} |
} |
} |
} |
close(confd); | while (retry_send(close(confd))); |
| |
| /* The child can use up to TCP_MAX_QUERIES ids, so skip that many. */ |
| daemon->log_id += TCP_MAX_QUERIES; |
} |
} |
#endif |
#endif |
else |
else |
Line 1591 static void check_dns_listeners(fd_set *set, time_t no
|
Line 1693 static void check_dns_listeners(fd_set *set, time_t no
|
buff = tcp_request(confd, now, &tcp_addr, netmask, auth_dns); |
buff = tcp_request(confd, now, &tcp_addr, netmask, auth_dns); |
|
|
shutdown(confd, SHUT_RDWR); |
shutdown(confd, SHUT_RDWR); |
close(confd); | while (retry_send(close(confd))); |
|
|
if (buff) |
if (buff) |
free(buff); |
free(buff); |
Line 1600 static void check_dns_listeners(fd_set *set, time_t no
|
Line 1702 static void check_dns_listeners(fd_set *set, time_t no
|
if (s->tcpfd != -1) |
if (s->tcpfd != -1) |
{ |
{ |
shutdown(s->tcpfd, SHUT_RDWR); |
shutdown(s->tcpfd, SHUT_RDWR); |
close(s->tcpfd); | while (retry_send(close(s->tcpfd))); |
} |
} |
#ifndef NO_FORK |
#ifndef NO_FORK |
if (!option_bool(OPT_DEBUG)) |
if (!option_bool(OPT_DEBUG)) |
Line 1642 int icmp_ping(struct in_addr addr)
|
Line 1744 int icmp_ping(struct in_addr addr)
|
better not use any resources our caller has in use...) |
better not use any resources our caller has in use...) |
but we remain deaf to signals or further DHCP packets. */ |
but we remain deaf to signals or further DHCP packets. */ |
|
|
int fd; | /* There can be a problem using dnsmasq_time() to end the loop, since |
| it's not monotonic, and can go backwards if the system clock is |
| tweaked, leading to the code getting stuck in this loop and |
| ignoring DHCP requests. To fix this, we check to see if select returned |
| as a result of a timeout rather than a socket becoming available. We |
| only allow this to happen as many times as it takes to get to the wait time |
| in quarter-second chunks. This provides a fallback way to end loop. */ |
| |
| int fd, rc; |
struct sockaddr_in saddr; |
struct sockaddr_in saddr; |
struct { |
struct { |
struct ip ip; |
struct ip ip; |
struct icmp icmp; |
struct icmp icmp; |
} packet; |
} packet; |
unsigned short id = rand16(); |
unsigned short id = rand16(); |
unsigned int i, j; | unsigned int i, j, timeout_count; |
int gotreply = 0; |
int gotreply = 0; |
time_t start, now; |
time_t start, now; |
|
|
Line 1678 int icmp_ping(struct in_addr addr)
|
Line 1788 int icmp_ping(struct in_addr addr)
|
j = (j & 0xffff) + (j >> 16); |
j = (j & 0xffff) + (j >> 16); |
packet.icmp.icmp_cksum = (j == 0xffff) ? j : ~j; |
packet.icmp.icmp_cksum = (j == 0xffff) ? j : ~j; |
|
|
while (sendto(fd, (char *)&packet.icmp, sizeof(struct icmp), 0, | while (retry_send(sendto(fd, (char *)&packet.icmp, sizeof(struct icmp), 0, |
(struct sockaddr *)&saddr, sizeof(saddr)) == -1 && | (struct sockaddr *)&saddr, sizeof(saddr)))); |
retry_send()); | |
|
|
for (now = start = dnsmasq_time(); | for (now = start = dnsmasq_time(), timeout_count = 0; |
difftime(now, start) < (float)PING_WAIT;) | (difftime(now, start) < (float)PING_WAIT) && (timeout_count < PING_WAIT * 4);) |
{ |
{ |
struct timeval tv; |
|
fd_set rset, wset; |
|
struct sockaddr_in faddr; |
struct sockaddr_in faddr; |
int maxfd = fd; |
|
socklen_t len = sizeof(faddr); |
socklen_t len = sizeof(faddr); |
|
|
tv.tv_usec = 250000; | poll_reset(); |
tv.tv_sec = 0; | poll_listen(fd, POLLIN); |
| set_dns_listeners(now); |
| set_log_writer(); |
|
|
FD_ZERO(&rset); |
|
FD_ZERO(&wset); |
|
FD_SET(fd, &rset); |
|
set_dns_listeners(now, &rset, &maxfd); |
|
set_log_writer(&wset, &maxfd); |
|
|
|
#ifdef HAVE_DHCP6 |
#ifdef HAVE_DHCP6 |
if (daemon->doing_ra) |
if (daemon->doing_ra) |
{ | poll_listen(daemon->icmp6fd, POLLIN); |
FD_SET(daemon->icmp6fd, &rset); | |
bump_maxfd(daemon->icmp6fd, &maxfd); | |
} | |
#endif |
#endif |
|
|
if (select(maxfd+1, &rset, &wset, NULL, &tv) < 0) | rc = do_poll(250); |
{ | |
FD_ZERO(&rset); | if (rc < 0) |
FD_ZERO(&wset); | continue; |
} | else if (rc == 0) |
| timeout_count++; |
|
|
now = dnsmasq_time(); |
now = dnsmasq_time(); |
|
|
check_log_writer(&wset); | check_log_writer(0); |
check_dns_listeners(&rset, now); | check_dns_listeners(now); |
|
|
#ifdef HAVE_DHCP6 |
#ifdef HAVE_DHCP6 |
if (daemon->doing_ra && FD_ISSET(daemon->icmp6fd, &rset)) | if (daemon->doing_ra && poll_check(daemon->icmp6fd, POLLIN)) |
icmp6_packet(now); |
icmp6_packet(now); |
#endif |
#endif |
|
|
#ifdef HAVE_TFTP |
#ifdef HAVE_TFTP |
check_tftp_listeners(&rset, now); | check_tftp_listeners(now); |
#endif |
#endif |
|
|
if (FD_ISSET(fd, &rset) && | if (poll_check(fd, POLLIN) && |
recvfrom(fd, &packet, sizeof(packet), 0, |
recvfrom(fd, &packet, sizeof(packet), 0, |
(struct sockaddr *)&faddr, &len) == sizeof(packet) && |
(struct sockaddr *)&faddr, &len) == sizeof(packet) && |
saddr.sin_addr.s_addr == faddr.sin_addr.s_addr && |
saddr.sin_addr.s_addr == faddr.sin_addr.s_addr && |
Line 1742 int icmp_ping(struct in_addr addr)
|
Line 1842 int icmp_ping(struct in_addr addr)
|
} |
} |
|
|
#if defined(HAVE_LINUX_NETWORK) || defined(HAVE_SOLARIS_NETWORK) |
#if defined(HAVE_LINUX_NETWORK) || defined(HAVE_SOLARIS_NETWORK) |
close(fd); | while (retry_send(close(fd))); |
#else |
#else |
opt = 1; |
opt = 1; |
setsockopt(fd, SOL_SOCKET, SO_RCVBUF, &opt, sizeof(opt)); |
setsockopt(fd, SOL_SOCKET, SO_RCVBUF, &opt, sizeof(opt)); |