#include <errno.h>
#include <glib.h>
-#include <stdlib.h>
-#include <gweb/gresolv.h>
#include "connman.h"
static GSList *driver_list = NULL;
static GHashTable *server_hash = NULL;
-static char **system_timeservers = NULL;
-static char **timeservers = NULL;
-
-static GResolv *resolv = NULL;
-static int resolv_id = 0;
-static volatile int count;
-
-static void resolv_debug(const char *str, void *data)
-{
- connman_info("%s: %s\n", (const char *) data, str);
-}
-static void save_timeservers(char **servers)
-{
- GKeyFile *keyfile;
- int cnt;
-
- keyfile = __connman_storage_load_global();
- if (keyfile == NULL)
- keyfile = g_key_file_new();
-
- for (cnt = 0; servers != NULL && servers[cnt] != NULL; cnt++);
-
- g_key_file_set_string_list(keyfile, "global", "Timeservers",
- (const gchar **)servers, cnt);
-
- __connman_storage_save_global(keyfile);
-
- g_key_file_free(keyfile);
-
- return;
-}
-
-static char **load_timeservers()
-{
- GKeyFile *keyfile;
- GError *error = NULL;
- char **servers = NULL;
-
- keyfile = __connman_storage_load_global();
- if (keyfile == NULL)
- return NULL;
-
- servers = g_key_file_get_string_list(keyfile, "global",
- "Timeservers", NULL, &error);
- if (error) {
- DBG("Error loading timeservers: %s", error->message);
- g_error_free(error);
- }
-
- g_key_file_free(keyfile);
-
- return servers;
-}
-
static gint compare_priority(gconstpointer a, gconstpointer b)
{
const struct connman_timeserver_driver *driver1 = a;
driver_list = g_slist_remove(driver_list, driver);
}
-/* Restart NTP procedure */
-static void connman_timeserver_restart()
-{
- /* If service timeservers are in use, dont restart ntp */
- if (timeservers != NULL)
- return;
-
- if (resolv == NULL) {
- DBG("No online service.");
- return;
- }
-
- /* Cancel current lookup */
- if(resolv_id > 0)
- g_resolv_cancel_lookup(resolv, resolv_id);
-
- /* Reload system timeserver list */
- if (system_timeservers != NULL) {
- g_strfreev(system_timeservers);
- system_timeservers = NULL;
- }
-
- system_timeservers = load_timeservers();
-
- if (system_timeservers == NULL)
- return;
-
- __connman_ntp_stop();
-
- count = 0;
-
- __connman_timeserver_sync_next();
-}
-
-static void resolv_result(GResolvResultStatus status, char **results, gpointer user_data)
-{
- int i;
-
- DBG("status %d", status);
-
- __sync_fetch_and_add(&count, 1);
-
- if (status == G_RESOLV_RESULT_STATUS_SUCCESS) {
- if (results != NULL) {
- for (i = 0; results[i]; i++)
- DBG("result: %s", results[i]);
-
- __connman_ntp_start(results[0]);
-
- return;
- }
- }
-
- __connman_timeserver_sync_next();
-}
-
-void __connman_timeserver_sync_next()
-{
- if (system_timeservers == NULL ||
- system_timeservers[count] == NULL)
- return;
-
- DBG("Trying timeserver %s", system_timeservers[count]);
-
- if (resolv)
- resolv_id = g_resolv_lookup_hostname(resolv,
- system_timeservers[count], resolv_result,
- NULL);
-}
-
-int __connman_timeserver_sync(struct connman_service *service)
+/**
+ * connman_timeserver_append:
+ * @server: server address
+ *
+ * Append time server server address to current list
+ */
+int connman_timeserver_append(const char *server)
{
- char **nameservers = NULL;
- int i;
-
- DBG("service %p", service);
+ GSList *list;
- i = __connman_service_get_index(service);
- if (i < 0)
- return -EINVAL;
+ DBG("server %s", server);
- nameservers = connman_service_get_nameservers(service);
- if (nameservers == NULL)
+ if (server == NULL)
return -EINVAL;
- resolv = g_resolv_new(i);
- if (resolv == NULL)
- return -ENOMEM;
-
- if (getenv("CONNMAN_RESOLV_DEBUG"))
- g_resolv_set_debug(resolv, resolv_debug, "RESOLV");
-
- for (i = 0; nameservers[i] != NULL; i++)
- g_resolv_add_nameserver(resolv, nameservers[i], 53, 0);
-
- count = 0;
-
- system_timeservers = load_timeservers();
-
- timeservers = connman_service_get_timeservers(service);
-
- if (timeservers != NULL && timeservers[0] != NULL) {
- DBG("Using service tiemservers");
- __connman_ntp_start(timeservers[0]);
+ /* This server is already handled by a driver */
+ if (g_hash_table_lookup(server_hash, server))
return 0;
- }
- if (system_timeservers == NULL || system_timeservers[count] == NULL) {
- DBG("No timeservers set.");
- return 0;
- }
+ for (list = driver_list; list; list = list->next) {
+ struct connman_timeserver_driver *driver = list->data;
+ char *new_server;
- DBG("Trying server %s", system_timeservers[count]);
+ if (driver->append == NULL)
+ continue;
- resolv_id = g_resolv_lookup_hostname(resolv, system_timeservers[count],
- resolv_result, NULL);
- return 0;
-}
-
-void __connman_timeserver_stop()
-{
- DBG(" ");
-
- if (resolv != NULL) {
- g_resolv_unref(resolv);
- resolv = NULL;
- }
+ new_server = g_strdup(server);
+ if (new_server == NULL)
+ return -ENOMEM;
- if (system_timeservers != NULL) {
- g_strfreev(system_timeservers);
- system_timeservers = NULL;
+ if (driver->append(server) == 0) {
+ g_hash_table_insert(server_hash, new_server, driver);
+ return 0;
+ } else {
+ g_free(new_server);
+ }
}
- timeservers = NULL;
-
- count = 0;
-
- __connman_ntp_stop();
+ return -ENOENT;
}
-int __connman_timeserver_system_append(const char *server)
+/**
+ * connman_timeserver_remove:
+ * @server: server address
+ *
+ * Remover time server server address from current list
+ */
+int connman_timeserver_remove(const char *server)
{
- int len;
- char **servers = NULL;
-
- if (server == NULL) {
- save_timeservers(servers);
- goto restart;
- }
+ struct connman_timeserver_driver *driver;
DBG("server %s", server);
- servers = load_timeservers();
-
- if (servers != NULL) {
- int i;
-
- for (i = 0; servers[i] != NULL; i++)
- if (g_strcmp0(servers[i], server) == 0) {
- g_strfreev(servers);
- return -EEXIST;
- }
-
- len = g_strv_length(servers);
- servers = g_try_renew(char *, servers, len + 2);
- } else {
- len = 0;
- servers = g_try_new0(char *, len + 2);
- }
-
- if (servers == NULL)
- return -ENOMEM;
+ if (server == NULL)
+ return -EINVAL;
- servers[len] = g_strdup(server);
- servers[len + 1] = NULL;
+ driver = g_hash_table_lookup(server_hash, server);
+ if (driver == NULL)
+ return -EINVAL;
- save_timeservers(servers);
+ g_hash_table_remove(server_hash, server);
- g_strfreev(servers);
-restart:
- connman_timeserver_restart();
+ if (driver->remove == NULL)
+ return -ENOENT;
- return 0;
+ return driver->remove(server);
}
-int __connman_timeserver_system_remove(const char *server)
+void connman_timeserver_sync(void)
{
- char **servers;
- char **temp;
- int len, i, j;
-
- if (server == NULL)
- return -EINVAL;
-
- DBG("server %s", server);
-
- servers = load_timeservers();
-
- if (servers == NULL)
- return 0;
+ GSList *list;
- len = g_strv_length(servers);
- if (len == 1) {
- if (g_strcmp0(servers[0], server) != 0) {
- g_strfreev(servers);
- return 0;
- }
+ DBG("");
- g_strfreev(servers);
- servers = NULL;
- save_timeservers(servers);
- return 0;
- }
+ for (list = driver_list; list; list = list->next) {
+ struct connman_timeserver_driver *driver = list->data;
- temp = g_try_new0(char *, len - 1);
- if (temp == NULL) {
- g_strfreev(servers);
- return -ENOMEM;
- }
+ if (driver->sync == NULL)
+ continue;
- for (i = 0, j = 0; i < len; i++) {
- if (g_strcmp0(servers[i], server) != 0) {
- temp[j] = g_strdup(servers[i]);
- j++;
- }
+ driver->sync();
}
- temp[len - 1] = NULL;
-
- g_strfreev(servers);
- servers = g_strdupv(temp);
- g_strfreev(temp);
-
- save_timeservers(servers);
- g_strfreev(servers);
-
- connman_timeserver_restart();
-
- return 0;
-}
-
-char **__connman_timeserver_system_get()
-{
- char **servers;
-
- servers = load_timeservers();
- return servers;
}
int __connman_timeserver_init(void)
projects / framework / connectivity / connman.git / blobdiff