diff options
Diffstat (limited to 'sysdep/unix')
| -rw-r--r-- | sysdep/unix/io.c | 35 | ||||
| -rw-r--r-- | sysdep/unix/timer.h | 1 | ||||
| -rw-r--r-- | sysdep/unix/unix.h | 8 |
3 files changed, 36 insertions, 8 deletions
diff --git a/sysdep/unix/io.c b/sysdep/unix/io.c index fa6b5b2..45ba0f8 100644 --- a/sysdep/unix/io.c +++ b/sysdep/unix/io.c @@ -59,6 +59,10 @@ tm_dump(resource *r) timer *t = (timer *) r; debug("(code %p, data %p, "); + if (t->randomize) + debug("rand %d, ", t->randomize); + if (t->recurrent) + debug("recur %d, ", t->recurrent); if (t->expires) debug("expires in %d sec)\n", t->expires - now); else @@ -99,7 +103,7 @@ tm_start(timer *t, unsigned after) bird_clock_t when; if (t->randomize) - after += random() % t->randomize; + after += random() % (t->randomize + 1); when = now + after; if (t->expires == when) return; @@ -189,11 +193,20 @@ tm_shot(void) } while ((n = HEAD(near_timers)) -> next) { + int delay; t = SKIP_BACK(timer, n, n); if (t->expires > now) break; rem_node(n); + delay = t->expires - now; t->expires = 0; + if (t->recurrent) + { + int i = t->recurrent - delay; + if (i < 0) + i = 0; + tm_start(t, i); + } t->hook(t); } } @@ -276,10 +289,13 @@ fill_in_sockaddr(struct sockaddr_in *sa, ip_addr a, unsigned port) set_inaddr(&sa->sin_addr, a); } -static void +void get_sockaddr(struct sockaddr_in *sa, ip_addr *a, unsigned *port) { - *port = ntohs(sa->sin_port); + if (sa->sin_family != AF_INET) + die("get_sockaddr called for wrong address family"); + if (port) + *port = ntohs(sa->sin_port); memcpy(a, &sa->sin_addr.s_addr, sizeof(*a)); *a = ipa_ntoh(*a); } @@ -384,19 +400,22 @@ sk_open(sock *s) { #ifdef HAVE_IP_MREQN struct ip_mreqn mreq; +#define mreq_add mreq mreq.imr_ifindex = s->iface->index; if (has_src) set_inaddr(&mreq.imr_address, s->saddr); else set_inaddr(&mreq.imr_address, s->iface->ifa->ip); #else - struct ip_mreq mreq; + struct in_addr mreq; + struct ip_mreq mreq_add; if (has_src) - set_inaddr(&mreq.imr_interface, s->saddr); + set_inaddr(&mreq, s->saddr); else - set_inaddr(&mreq.imr_interface, s->iface->ifa->ip); + set_inaddr(&mreq, s->iface->ifa->ip); + memcpy(&mreq_add.imr_interface, &mreq, sizeof(struct in_addr)); #endif - set_inaddr(&mreq.imr_multiaddr, s->daddr); + set_inaddr(&mreq_add.imr_multiaddr, s->daddr); if (has_dest) { if ( @@ -414,7 +433,7 @@ sk_open(sock *s) if (setsockopt(fd, SOL_IP, IP_MULTICAST_IF, &mreq, sizeof(mreq)) < 0) ERR("IP_MULTICAST_IF"); } - if (has_src && setsockopt(fd, SOL_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq)) < 0) + if (has_src && setsockopt(fd, SOL_IP, IP_ADD_MEMBERSHIP, &mreq_add, sizeof(mreq_add)) < 0) ERR("IP_ADD_MEMBERSHIP"); break; } diff --git a/sysdep/unix/timer.h b/sysdep/unix/timer.h index 0589ec0..00307f7 100644 --- a/sysdep/unix/timer.h +++ b/sysdep/unix/timer.h @@ -20,6 +20,7 @@ typedef struct timer { void (*hook)(struct timer *); void *data; unsigned randomize; /* Amount of randomization */ + unsigned recurrent; /* Timer recurrence */ node n; /* Internal link */ clock_t expires; /* 0=inactive */ } timer; diff --git a/sysdep/unix/unix.h b/sysdep/unix/unix.h index 2f98fcf..127101e 100644 --- a/sysdep/unix/unix.h +++ b/sysdep/unix/unix.h @@ -13,5 +13,13 @@ void io_init(void); void io_loop(void); +void get_sockaddr(struct sockaddr_in *sa, ip_addr *a, unsigned *port); + +/* sync-if.c */ + +extern int if_scan_sock; +extern int if_scan_period; + +void scan_if_init(void); #endif |