9:44 a.m.
From: Aleksandar Mitev <shondll(a)yahoo.com>
Hi Daniel,
Following your advice on every commit, I resubmit the patches again. I hope
I've got everything sorted out.
I agree with the name change, indeed "perpetual" sounds more epic but does
not have the necessary semantics.
The state diagram in the doc section is updated as well.
Best,
Aleksandar
Aleksandar Mitev (4):
gweb: added timeout to socket connections
service: perform continuous online checks
service: Added a compile config for online check
doc: updated state diagram for services
README | 10 ++++++
configure.ac | 6 ++++
doc/overview-api.txt | 25 +++++++++-----
gweb/gweb.c | 27 +++++++++++++++
src/service.c | 78 +++++++++++++++++++++++++++++++++++++++++---
5 files changed, 133 insertions(+), 13 deletions(-)
--
2.17.1
9:44 a.m.
New subject: [PATCH 1/4] gweb: added timeout to socket connections
From: Aleksandar Mitev <shondll(a)yahoo.com>
By default, sockets timeout after the system defined time which is
too much all the timers in connman.
This patch helps make online checks in a deterministic fashion.
SOCKET_TIMEOUT controls the amount of time spent in waiting for
the request to complete.
---
gweb/gweb.c | 27 +++++++++++++++++++++++++++
1 file changed, 27 insertions(+)
diff --git a/gweb/gweb.c b/gweb/gweb.c
index 393afe0a..ea820bd7 100644
--- a/gweb/gweb.c
+++ b/gweb/gweb.c
@@ -44,6 +44,7 @@
#include "gweb.h"
#define DEFAULT_BUFFER_SIZE 2048
+#define SOCKET_TIMEOUT 20 /* in seconds */
#define SESSION_FLAG_USE_TLS (1 << 0)
@@ -77,6 +78,7 @@ struct web_session {
GIOChannel *transport_channel;
guint transport_watch;
guint send_watch;
+ guint timeout_timer;
guint resolv_action;
guint address_action;
@@ -164,6 +166,8 @@ static void free_session(struct web_session *session)
web = session->web;
+ debug(web, "freeing session %p", session);
+
if (session->address_action > 0)
g_source_remove(session->address_action);
@@ -176,6 +180,9 @@ static void free_session(struct web_session *session)
if (session->send_watch > 0)
g_source_remove(session->send_watch);
+ if (session->timeout_timer > 0)
+ g_source_remove(session->timeout_timer);
+
if (session->transport_channel)
g_io_channel_unref(session->transport_channel);
@@ -1032,6 +1039,22 @@ static inline int bind_socket(int sk, int index, int family)
return err;
}
+static gboolean socket_timeout_handler(gpointer user_data)
+{
+ struct web_session *session = user_data;
+ int fd;
+
+ if (session->transport_channel) {
+ debug(session->web, "No response, closing the socket");
+ fd = g_io_channel_unix_get_fd(session->transport_channel);
+ g_io_channel_shutdown(session->transport_channel, TRUE, NULL);
+ close(fd);
+ }
+
+ session->timeout_timer = 0;
+ return FALSE;
+}
+
static int connect_session_transport(struct web_session *session)
{
GIOFlags flags;
@@ -1090,6 +1113,10 @@ static int connect_session_transport(struct web_session *session)
G_IO_OUT | G_IO_HUP | G_IO_NVAL | G_IO_ERR,
send_data, session);
+ debug(session->web, "Setting timeout to the socket to %ds",
SOCKET_TIMEOUT);
+ session->timeout_timer = g_timeout_add_seconds(
+ SOCKET_TIMEOUT, socket_timeout_handler, session);
+
return 0;
}
--
2.17.1
9:44 a.m.
New subject: [PATCH 2/4] service: perform continuous online checks
From: Aleksandar Mitev <shondll(a)yahoo.com>
The feature activates when online state is reached and performs
regular checks whether online state is still maintained by the
services (default every 5 minutes). In the case then the
online check fails the serice state is downgrated to READY
to give the chance for a switchover to another service.
---
src/service.c | 74 +++++++++++++++++++++++++++++++++++++++++++++++----
1 file changed, 69 insertions(+), 5 deletions(-)
diff --git a/src/service.c b/src/service.c
index 3202f26c..36a1911b 100644
--- a/src/service.c
+++ b/src/service.c
@@ -38,6 +38,7 @@
#include "connman.h"
#define CONNECT_TIMEOUT 120
+#define ONLINE_CHECK_REGULAR_INTERVAL 300 /* in seconds */
static DBusConnection *connection = NULL;
@@ -3440,17 +3441,23 @@ int __connman_service_reset_ipconfig(struct connman_service
*service,
#define ONLINE_CHECK_INITIAL_INTERVAL 1
#define ONLINE_CHECK_MAX_INTERVAL 12
-void __connman_service_wispr_start(struct connman_service *service,
+static void reset_online_recheck_interval(struct connman_service *service,
enum connman_ipconfig_type type)
{
- DBG("service %p type %s", service, __connman_ipconfig_type2string(type));
-
if (type == CONNMAN_IPCONFIG_TYPE_IPV4)
service->online_check_interval_ipv4 =
ONLINE_CHECK_INITIAL_INTERVAL;
else
service->online_check_interval_ipv6 =
ONLINE_CHECK_INITIAL_INTERVAL;
+}
+
+void __connman_service_wispr_start(struct connman_service *service,
+ enum connman_ipconfig_type type)
+{
+ DBG("service %p type %s", service, __connman_ipconfig_type2string(type));
+
+ reset_online_recheck_interval(service, type);
__connman_wispr_start(service, type);
}
@@ -6039,18 +6046,58 @@ static gboolean redo_wispr_ipv6(gpointer user_data)
return FALSE;
}
+static int start_periodic_online_check(struct connman_service *service,
+ enum connman_ipconfig_type type)
+{
+ GSourceFunc redo_func;
+ guint retry_interval = ONLINE_CHECK_REGULAR_INTERVAL;
+
+ if (service->online_timeout != 0)
+ return 0;
+
+ if (type == CONNMAN_IPCONFIG_TYPE_IPV4) {
+ redo_func = redo_wispr_ipv4;
+ } else {
+ redo_func = redo_wispr_ipv6;
+ }
+ reset_online_recheck_interval(service, type);
+
+ DBG("service %p (%s) will be rechecked for internet connectivity in %ds",
+ service, service ? service->identifier : NULL, retry_interval);
+
+ service->online_timeout =
+ g_timeout_add_seconds(retry_interval, redo_func, connman_service_ref(service));
+
+ return 0;
+}
+
+static gboolean downgrade_state_handler(gpointer user_data)
+{
+ struct connman_service *service = user_data;
+
+ connman_warn("Downgrading service %s for online check did not pass",
+ service ? service->identifier : NULL);
+
+ downgrade_state(service);
+
+ return FALSE;
+}
+
int __connman_service_online_check_failed(struct connman_service *service,
enum connman_ipconfig_type type)
{
GSourceFunc redo_func;
int *interval;
+ enum connman_service_state curr_state;
if (type == CONNMAN_IPCONFIG_TYPE_IPV4) {
interval = &service->online_check_interval_ipv4;
redo_func = redo_wispr_ipv4;
+ curr_state = service->state_ipv4;
} else {
interval = &service->online_check_interval_ipv6;
redo_func = redo_wispr_ipv6;
+ curr_state = service->state_ipv6;
}
DBG("service %p type %s interval %d", service,
@@ -6059,11 +6106,18 @@ int __connman_service_online_check_failed(struct connman_service
*service,
service->online_timeout = g_timeout_add_seconds(*interval * *interval,
redo_func, connman_service_ref(service));
- /* Increment the interval for the next time, set a maximum timeout of
+ /*
+ * Increment the interval for the next time, set a maximum timeout of
* ONLINE_CHECK_MAX_INTERVAL * ONLINE_CHECK_MAX_INTERVAL seconds.
*/
if (*interval < ONLINE_CHECK_MAX_INTERVAL)
(*interval)++;
+ else {
+ if(curr_state == CONNMAN_SERVICE_STATE_ONLINE) {
+ g_idle_add(downgrade_state_handler, service);
+ return 0;
+ }
+ }
return EAGAIN;
}
@@ -6131,8 +6185,17 @@ int __connman_service_ipconfig_indicate_state(struct
connman_service *service,
}
/* Any change? */
- if (old_state == new_state)
+ if (old_state == new_state) {
+ /*
+ * continuous online check requires restart of the check
+ * at regular intervals
+ */
+ if (new_state == CONNMAN_SERVICE_STATE_ONLINE) {
+ start_periodic_online_check(service, type);
+ }
+
return -EALREADY;
+ }
DBG("service %p (%s) old state %d (%s) new state %d (%s) type %d (%s)",
service, service ? service->identifier : NULL,
@@ -6161,6 +6224,7 @@ int __connman_service_ipconfig_indicate_state(struct connman_service
*service,
set_mdns(service, service->mdns_config);
break;
case CONNMAN_SERVICE_STATE_ONLINE:
+ start_periodic_online_check(service, type);
break;
case CONNMAN_SERVICE_STATE_DISCONNECT:
if (service->state == CONNMAN_SERVICE_STATE_IDLE)
--
2.17.1
9:44 a.m.
New subject: [PATCH 3/4] service: Added a compile config for online check
From: Aleksandar Mitev <shondll(a)yahoo.com>
New flag is
--enable-continuous-online-check
and is disabled by default, leaving the original behaviour
in place. Even if enabled the continuous check relies on:
EnableOnlineCheck = true
Otherwise it will have no effect.
---
README | 10 ++++++++++
configure.ac | 6 ++++++
src/service.c | 4 ++++
3 files changed, 20 insertions(+)
diff --git a/README b/README
index f16b9ec0..34aef9ee 100644
--- a/README
+++ b/README
@@ -231,6 +231,16 @@ For a working system, certain configuration options need to be
enabled:
is selected, ConnMan configures systemd-resolved to do DNS
resolving. The default value is "internal".
+ --enable-continuous-online-check
+
+ Enable continuously checking for Internet connection.
+
+ If enabled, services will conduct online state check
+ regularly once Online state is reached. When in Online state,
+ but due to lack of internet connectivity, the service will be
+ downgraded to a Ready state giving the chance for other
+ configured services to take over.
+ This feature depends on EnableOnlineCheck = true.
Activating debugging
====================
diff --git a/configure.ac b/configure.ac
index ee49a22c..cb5be448 100644
--- a/configure.ac
+++ b/configure.ac
@@ -323,6 +323,12 @@ AC_ARG_ENABLE(selinux, AC_HELP_STRING([--enable-selinux],
[enable_selinux=${enableval}], [enable_selinux="no"])
AM_CONDITIONAL(SELINUX, test "${enable_selinux}" != "no")
+AC_ARG_ENABLE(continuous-online-check,
AC_HELP_STRING([--enable-continuous-online-check],
+ [enable continuous online check in the online state]),
+ [enable_cont_check="true"], [enable_cont_check="false"])
+AC_DEFINE_UNQUOTED([CONTIUOUS_ONLINE_CHECK_ENABLED], ${enable_cont_check},
+ [enable continuous online check during the online state])
+
AC_ARG_ENABLE(loopback, AC_HELP_STRING([--disable-loopback],
[disable loopback support]),
[enable_loopback=${enableval}])
diff --git a/src/service.c b/src/service.c
index 36a1911b..8e3758fd 100644
--- a/src/service.c
+++ b/src/service.c
@@ -6186,6 +6186,7 @@ int __connman_service_ipconfig_indicate_state(struct connman_service
*service,
/* Any change? */
if (old_state == new_state) {
+#if defined(CONTIUOUS_ONLINE_CHECK_ENABLED)
/*
* continuous online check requires restart of the check
* at regular intervals
@@ -6193,6 +6194,7 @@ int __connman_service_ipconfig_indicate_state(struct connman_service
*service,
if (new_state == CONNMAN_SERVICE_STATE_ONLINE) {
start_periodic_online_check(service, type);
}
+#endif
return -EALREADY;
}
@@ -6224,7 +6226,9 @@ int __connman_service_ipconfig_indicate_state(struct connman_service
*service,
set_mdns(service, service->mdns_config);
break;
case CONNMAN_SERVICE_STATE_ONLINE:
+#if defined(CONTIUOUS_ONLINE_CHECK_ENABLED)
start_periodic_online_check(service, type);
+#endif
break;
case CONNMAN_SERVICE_STATE_DISCONNECT:
if (service->state == CONNMAN_SERVICE_STATE_IDLE)
--
2.17.1
9:44 a.m.
New subject: [PATCH 4/4] doc: updated state diagram for services
From: Aleksandar Mitev <shondll(a)yahoo.com>
---
doc/overview-api.txt | 25 +++++++++++++++++--------
1 file changed, 17 insertions(+), 8 deletions(-)
diff --git a/doc/overview-api.txt b/doc/overview-api.txt
index fd51d706..c7c47a5b 100644
--- a/doc/overview-api.txt
+++ b/doc/overview-api.txt
@@ -257,6 +257,14 @@ to retrieve/configure IP settings.
The "ready" state signals a successful connected device. This doesn't mean
it has the default route, but basic IP operations will succeed.
+There is also the optional "online" state that is reached whenever
+an online check is perfomed and succeeds. This state is intended to point
+out that global IPs can be reached, i.e. there is Internet connectivity.
+More details on how the online check is performed can be found in README.
+Getting to this state is governed by config option "EnableOnlineCheck".
+Continuously checking for Internet connectivity is configured with
+"--enable-continuous-online-check" compile option.
+
With the "disconnect" state a service indicates that it is going to terminate
the current connection and will return to the "idle" state.
@@ -284,14 +292,15 @@ the "idle" state since the service is not connected.
| success |
V |
+---------------+ |
- | ready | |
- +---------------+ |
- | |
- | success |
- | |
- V |
- +---------------+ |
- | online |<----------------+ |
+ | ready |<----------------+ |
+ +---------------+ | |
+ | | |
+ | online check continuous online |
+ | success check fails |
+ V | |
+ +---------------+ | |
+ | online |-----------------+ |
+ | (optional) |<----------------+ |
+---------------+ | |
| | |
| service.Disconnect() | |
--
2.17.1
250
days inactive
250
days old
4 comments
1 participants
participants (1)
-
aleksandar＠analyticsfire.com