sulogin: use bb_error_msg instead of bb_info_msg; better message

[oweals/busybox.git] / networking / ntpd.c

diff --git a/networking/ntpd.c b/networking/ntpd.c
index 2a96ddbd0675c374a84e444f486d9bcc44264f28..410318979008a101ebcdfa7e6003ad52bb215c02 100644 (file)
--- a/networking/ntpd.c
+++ b/networking/ntpd.c
@@ -267,6 +267,7 @@ typedef struct {
 
 typedef struct {
        len_and_sockaddr *p_lsa;
+       char             *p_hostname;
        char             *p_dotted;
        int              p_fd;
        int              datapoint_idx;
@@ -727,7 +728,7 @@ reset_peer_stats(peer_t *p, double offset)
 
        /* Used to set p->filter_datapoint[i].d_dispersion = MAXDISP
         * and clear reachable bits, but this proved to be too agressive:
-        * after step (tested with suspinding laptop for ~30 secs),
+        * after step (tested with suspending laptop for ~30 secs),
         * this caused all previous data to be considered invalid,
         * making us needing to collect full ~8 datapoins per peer
         * after step in order to start trusting them.
@@ -766,11 +767,29 @@ reset_peer_stats(peer_t *p, double offset)
 static void
 add_peers(const char *s)
 {
+       llist_t *item;
        peer_t *p;
 
        p = xzalloc(sizeof(*p));
        p->p_lsa = xhost2sockaddr(s, 123);
        p->p_dotted = xmalloc_sockaddr2dotted_noport(&p->p_lsa->u.sa);
+
+       /* Names like N.<country2chars>.pool.ntp.org are randomly resolved
+        * to a pool of machines. Sometimes different N's resolve to the same IP.
+        * It is not useful to have two peers with same IP. We skip duplicates.
+        */
+       for (item = G.ntp_peers; item != NULL; item = item->link) {
+               peer_t *pp = (peer_t *) item->data;
+               if (strcmp(p->p_dotted, pp->p_dotted) == 0) {
+                       bb_error_msg("duplicate peer %s (%s)", s, p->p_dotted);
+                       free(p->p_lsa);
+                       free(p->p_dotted);
+                       free(p);
+                       return;
+               }
+       }
+
+       p->p_hostname = xstrdup(s);
        p->p_fd = -1;
        p->p_xmt_msg.m_status = MODE_CLIENT | (NTP_VERSION << 3);
        p->next_action_time = G.cur_time; /* = set_next(p, 0); */
@@ -1953,8 +1972,8 @@ recv_and_process_peer_pkt(peer_t *p)
                        adjust_poll(MINPOLL);
                } else {
                        VERB3 if (rc > 0)
-                               bb_error_msg("want smaller poll interval: offset/jitter > %u",
-                                       POLLADJ_GATE);
+                               bb_error_msg("want smaller interval: offset/jitter = %u",
+                                       G.offset_to_jitter_ratio);
                        adjust_poll(-G.poll_exp * 2);
                }
        }
@@ -2317,6 +2336,21 @@ int ntpd_main(int argc UNUSED_PARAM, char **argv)
                                        timeout = poll_interval(NOREPLY_INTERVAL);
                                        bb_error_msg("timed out waiting for %s, reach 0x%02x, next query in %us",
                                                        p->p_dotted, p->reachable_bits, timeout);
+
+                                       /* What if don't see it because it changed its IP? */
+                                       if (p->reachable_bits == 0) {
+                                               len_and_sockaddr *lsa = host2sockaddr(p->p_hostname, 123);
+                                               if (lsa) {
+                                                       char *dotted = xmalloc_sockaddr2dotted_noport(&lsa->u.sa);
+                                                       //if (strcmp(dotted, p->p_dotted) != 0)
+                                                       //      bb_error_msg("peer IP changed");
+                                                       free(p->p_lsa);
+                                                       free(p->p_dotted);
+                                                       p->p_lsa = lsa;
+                                                       p->p_dotted = dotted;
+                                               }
+                                       }
+
                                        set_next(p, timeout);
                                }
                        }