Michal Schmidt d962ba
From 6aa136216f2f78a840215e53ababeea7b65fc061 Mon Sep 17 00:00:00 2001
Michal Schmidt d962ba
From: Miroslav Lichvar <mlichvar@redhat.com>
Michal Schmidt d962ba
Date: Wed, 27 Aug 2014 16:47:24 +0200
Michal Schmidt d962ba
Subject: [PATCH 07/12] timesyncd: wait before reconnecting to first server
Michal Schmidt d962ba
Michal Schmidt d962ba
When all servers are exhausted, wait for one poll interval before trying
Michal Schmidt d962ba
to connect again to the first server in the list. Also, keep increasing
Michal Schmidt d962ba
the polling interval to make sure a client not getting any valid replies
Michal Schmidt d962ba
will not send requests to any server more frequently than is allowed by
Michal Schmidt d962ba
the maximum polling interval.
Michal Schmidt d962ba
Michal Schmidt d962ba
(cherry picked from commit 63463bf091949e0178b749016828ec400c106582)
Michal Schmidt d962ba
---
Michal Schmidt d962ba
 src/timesync/timesyncd-manager.c | 24 +++++++++++++++++++++++-
Michal Schmidt d962ba
 src/timesync/timesyncd-manager.h |  1 +
Michal Schmidt d962ba
 2 files changed, 24 insertions(+), 1 deletion(-)
Michal Schmidt d962ba
Michal Schmidt d962ba
diff --git a/src/timesync/timesyncd-manager.c b/src/timesync/timesyncd-manager.c
Michal Schmidt d962ba
index 696dd10..b7b39ef 100644
Michal Schmidt d962ba
--- a/src/timesync/timesyncd-manager.c
Michal Schmidt d962ba
+++ b/src/timesync/timesyncd-manager.c
Michal Schmidt d962ba
@@ -875,6 +875,7 @@ int manager_connect(Manager *m) {
Michal Schmidt d962ba
                         manager_set_server_name(m, m->current_server_name->names_next);
Michal Schmidt d962ba
                 else {
Michal Schmidt d962ba
                         ServerName *f;
Michal Schmidt d962ba
+                        bool restart = true;
Michal Schmidt d962ba
 
Michal Schmidt d962ba
                         /* Our current server name list is exhausted,
Michal Schmidt d962ba
                          * let's find the next one to iterate. First
Michal Schmidt d962ba
@@ -891,6 +892,8 @@ int manager_connect(Manager *m) {
Michal Schmidt d962ba
                                 f = m->link_servers;
Michal Schmidt d962ba
                                 if (!f)
Michal Schmidt d962ba
                                         f = m->system_servers;
Michal Schmidt d962ba
+                                else
Michal Schmidt d962ba
+                                        restart = false;
Michal Schmidt d962ba
                         }
Michal Schmidt d962ba
 
Michal Schmidt d962ba
                         if (!f)
Michal Schmidt d962ba
@@ -902,6 +905,25 @@ int manager_connect(Manager *m) {
Michal Schmidt d962ba
                                 return 0;
Michal Schmidt d962ba
                         }
Michal Schmidt d962ba
 
Michal Schmidt d962ba
+                        if (restart && !m->exhausted_servers && m->poll_interval_usec) {
Michal Schmidt d962ba
+                                log_debug("Waiting after exhausting servers.");
Michal Schmidt d962ba
+                                r = sd_event_add_time(m->event, &m->event_retry, clock_boottime_or_monotonic(), now(clock_boottime_or_monotonic()) + m->poll_interval_usec, 0, manager_retry_connect, m);
Michal Schmidt d962ba
+                                if (r < 0) {
Michal Schmidt d962ba
+                                        log_error("Failed to create retry timer: %s", strerror(-r));
Michal Schmidt d962ba
+                                        return r;
Michal Schmidt d962ba
+                                }
Michal Schmidt d962ba
+
Michal Schmidt d962ba
+                                m->exhausted_servers = true;
Michal Schmidt d962ba
+
Michal Schmidt d962ba
+                                /* Increase the polling interval */
Michal Schmidt d962ba
+                                if (m->poll_interval_usec < NTP_POLL_INTERVAL_MAX_SEC * USEC_PER_SEC)
Michal Schmidt d962ba
+                                        m->poll_interval_usec *= 2;
Michal Schmidt d962ba
+
Michal Schmidt d962ba
+                                return 0;
Michal Schmidt d962ba
+                        }
Michal Schmidt d962ba
+
Michal Schmidt d962ba
+                        m->exhausted_servers = false;
Michal Schmidt d962ba
+
Michal Schmidt d962ba
                         manager_set_server_name(m, f);
Michal Schmidt d962ba
                 }
Michal Schmidt d962ba
 
Michal Schmidt d962ba
@@ -1042,7 +1064,7 @@ static int manager_network_event_handler(sd_event_source *s, int fd, uint32_t re
Michal Schmidt d962ba
         online = network_is_online();
Michal Schmidt d962ba
 
Michal Schmidt d962ba
         /* check if the client is currently connected */
Michal Schmidt d962ba
-        connected = m->server_socket >= 0 || m->resolve_query;
Michal Schmidt d962ba
+        connected = m->server_socket >= 0 || m->resolve_query || m->exhausted_servers;
Michal Schmidt d962ba
 
Michal Schmidt d962ba
         if (connected && !online) {
Michal Schmidt d962ba
                 log_info("No network connectivity, watching for changes.");
Michal Schmidt d962ba
diff --git a/src/timesync/timesyncd-manager.h b/src/timesync/timesyncd-manager.h
Michal Schmidt d962ba
index 2345bf8..bb3e509 100644
Michal Schmidt d962ba
--- a/src/timesync/timesyncd-manager.h
Michal Schmidt d962ba
+++ b/src/timesync/timesyncd-manager.h
Michal Schmidt d962ba
@@ -41,6 +41,7 @@ struct Manager {
Michal Schmidt d962ba
         LIST_HEAD(ServerName, fallback_servers);
Michal Schmidt d962ba
 
Michal Schmidt d962ba
         RateLimit ratelimit;
Michal Schmidt d962ba
+        bool exhausted_servers;
Michal Schmidt d962ba
 
Michal Schmidt d962ba
         /* network */
Michal Schmidt d962ba
         sd_event_source *network_event_source;
Michal Schmidt d962ba
-- 
Michal Schmidt d962ba
2.1.0
Michal Schmidt d962ba