From: Daniel Wagner <[email protected]>

WIP
---
 src/connman.h |   10 +++
 src/dhcp.c    |  241 ++++++++++++++++++++++-----------------------------------
 src/element.c |    2 -
 src/main.c    |    2 +
 src/network.c |  109 ++++++++++++++------------
 5 files changed, 161 insertions(+), 203 deletions(-)

diff --git a/src/connman.h b/src/connman.h
index 5ad4bcd..2cab9cc 100644
--- a/src/connman.h
+++ b/src/connman.h
@@ -280,6 +280,9 @@ void __connman_timeserver_cleanup(void);
 int __connman_dhcp_init(void);
 void __connman_dhcp_cleanup(void);
 
+int __connman_dhcp_start(struct connman_network *network);
+void __connman_dhcp_stop(struct connman_network *network);
+
 int __connman_ipv4_init(void);
 void __connman_ipv4_cleanup(void);
 
@@ -388,6 +391,13 @@ const char *__connman_network_get_ident(struct 
connman_network *network);
 connman_bool_t __connman_network_get_weakness(struct connman_network *network);
 connman_bool_t __connman_network_get_connecting(struct connman_network 
*network);
 
+int __connman_network_set_dhcp_valid(struct connman_network *network,
+                                       struct connman_ipaddress *ipaddress,
+                                       const char *nameservers, const char 
*domainname,
+                                       const char *hostname, const char 
*timeserver,
+                                       const char *pac);
+int __connman_network_set_dhcp_invalid(struct connman_network *network);
+
 int __connman_config_init();
 void __connman_config_cleanup(void);
 
diff --git a/src/dhcp.c b/src/dhcp.c
index 163b0b7..66413a1 100644
--- a/src/dhcp.c
+++ b/src/dhcp.c
@@ -27,101 +27,20 @@
 #include <string.h>
 #include <stdlib.h>
 
+#include <connman/ipconfig.h>
+
 #include <gdhcp/gdhcp.h>
 
 #include <glib.h>
 
 #include "connman.h"
 
-enum connman_dhcp_state {
-       CONNMAN_DHCP_STATE_UNKNOWN  = 0,
-       CONNMAN_DHCP_STATE_IDLE     = 1,
-       CONNMAN_DHCP_STATE_BOUND    = 2,
-       CONNMAN_DHCP_STATE_RENEW    = 3,
-       CONNMAN_DHCP_STATE_FAIL     = 4,
-};
-
 struct connman_dhcp {
        GDHCPClient *dhcp_client;
-
-       int index;
-       enum connman_dhcp_state state;
-
-       struct connman_element *element;
+       struct connman_network *network;
 };
 
-static void dhcp_set_value(struct connman_dhcp *dhcp,
-                               const char *key, const char *value)
-{
-       char **nameservers;
-
-       if (g_strcmp0(key, "Address") == 0) {
-               g_free(dhcp->element->ipv4.address);
-               dhcp->element->ipv4.address = g_strdup(value);
-       } else if (g_strcmp0(key, "Netmask") == 0) {
-               g_free(dhcp->element->ipv4.netmask);
-               dhcp->element->ipv4.netmask = g_strdup(value);
-       } else if (g_strcmp0(key, "Gateway") == 0) {
-               g_free(dhcp->element->ipv4.gateway);
-               dhcp->element->ipv4.gateway = g_strdup(value);
-       } else if (g_strcmp0(key, "Network") == 0) {
-               g_free(dhcp->element->ipv4.network);
-               dhcp->element->ipv4.network = g_strdup(value);
-       } else if (g_strcmp0(key, "Broadcast") == 0) {
-               g_free(dhcp->element->ipv4.broadcast);
-               dhcp->element->ipv4.broadcast = g_strdup(value);
-       } else if (g_strcmp0(key, "Nameserver") == 0) {
-               g_free(dhcp->element->ipv4.nameserver);
-               nameservers = g_strsplit_set(value, " ", 0);
-               /* FIXME: The ipv4 structure can only hold one nameserver, so
-                * we are only able to pass along the first nameserver sent by
-                * the DHCP server.  If this situation changes, we should
-                * retain all of them.
-                */
-               dhcp->element->ipv4.nameserver = g_strdup(nameservers[0]);
-               g_strfreev(nameservers);
-       } else if (g_strcmp0(key, "Domainname") == 0) {
-               g_free(dhcp->element->domainname);
-               dhcp->element->domainname = g_strdup(value);
-
-               __connman_utsname_set_domainname(value);
-       } else if (g_strcmp0(key, "Hostname") == 0) {
-               g_free(dhcp->element->hostname);
-               dhcp->element->hostname = g_strdup(value);
-
-               __connman_utsname_set_hostname(value);
-       } else if (g_strcmp0(key, "Timeserver") == 0) {
-               connman_info("Timeserver %s", value);
-
-               g_free(dhcp->element->ipv4.timeserver);
-               dhcp->element->ipv4.timeserver = g_strdup(value);
-       } else if (g_strcmp0(key, "MTU") == 0) {
-       } else if (g_strcmp0(key, "PAC") == 0) {
-               connman_info("PAC configuration %s", value);
-
-               g_free(dhcp->element->ipv4.pac);
-               dhcp->element->ipv4.pac = g_strdup(value);
-       }
-}
-
-static void dhcp_bound(struct connman_dhcp *dhcp)
-{
-       struct connman_element *element;
-
-       DBG("dhcp %p", dhcp);
-
-       element = connman_element_create(NULL);
-       if (element == NULL)
-               return;
-
-       element->type = CONNMAN_ELEMENT_TYPE_IPV4;
-       element->index = dhcp->index;
-
-       connman_element_update(dhcp->element);
-
-       if (connman_element_register(element, dhcp->element) < 0)
-               connman_element_unref(element);
-}
+static GHashTable *network_table;
 
 static void no_lease_cb(GDHCPClient *dhcp_client, gpointer user_data)
 {
@@ -129,13 +48,16 @@ static void no_lease_cb(GDHCPClient *dhcp_client, gpointer 
user_data)
 
        DBG("No lease available");
 
-       connman_element_set_error(dhcp->element,
-                                       CONNMAN_ELEMENT_ERROR_FAILED);
+       __connman_network_set_dhcp_invalid(dhcp->network);
 }
 
 static void lease_lost_cb(GDHCPClient *dhcp_client, gpointer user_data)
 {
+       struct connman_dhcp *dhcp = user_data;
+
        DBG("Lease lost");
+
+       __connman_network_set_dhcp_invalid(dhcp->network);
 }
 
 static void ipv4ll_lost_cb(GDHCPClient *dhcp_client, gpointer user_data)
@@ -144,26 +66,36 @@ static void ipv4ll_lost_cb(GDHCPClient *dhcp_client, 
gpointer user_data)
 
        DBG("Lease lost");
 
-       connman_element_unregister_children(dhcp->element);
+       __connman_network_set_dhcp_invalid(dhcp->network);
 }
 
 static void lease_available_cb(GDHCPClient *dhcp_client, gpointer user_data)
 {
        struct connman_dhcp *dhcp = user_data;
        GList *list, *option = NULL;
-       char *address, *nameservers;
+       char *address, *netmask = NULL, *gateway = NULL, *net = NULL;
+       char *domainname = NULL, *hostname = NULL;
+       char *timeserver = NULL, *pac = NULL, *nameservers = NULL;
        size_t ns_strlen = 0;
+       struct connman_ipaddress *ipaddress;
 
        DBG("Lease available");
 
+       ipaddress = connman_ipaddress_alloc(CONNMAN_IPCONFIG_TYPE_IPV4);
+       if (ipaddress == NULL) {
+               connman_error("Can not allocate ipaddress");
+               return;
+       }
+
        address = g_dhcp_client_get_address(dhcp_client);
-       if (address != NULL)
-               dhcp_set_value(dhcp, "Address", address);
-       g_free(address);
 
        option = g_dhcp_client_get_option(dhcp_client, G_DHCP_SUBNET);
        if (option != NULL)
-               dhcp_set_value(dhcp, "Netmask", option->data);
+               netmask = g_strdup(option->data);
+
+       option = g_dhcp_client_get_option(dhcp_client, G_DHCP_ROUTER);
+       if (option != NULL)
+               gateway = g_strdup(option->data);
 
        option = g_dhcp_client_get_option(dhcp_client, G_DHCP_DNS_SERVER);
        for (list = option; list; list = list->next)
@@ -176,53 +108,72 @@ static void lease_available_cb(GDHCPClient *dhcp_client, 
gpointer user_data)
                        sprintf(ns_index, "%s ", (char *) list->data);
                        ns_index += strlen((char *) list->data) + 1;
                }
-
-               dhcp_set_value(dhcp, "Nameserver", nameservers);
        }
-       g_free(nameservers);
 
        option = g_dhcp_client_get_option(dhcp_client, G_DHCP_DOMAIN_NAME);
        if (option != NULL)
-               dhcp_set_value(dhcp, "Domainname", option->data);
-
-       option = g_dhcp_client_get_option(dhcp_client, G_DHCP_ROUTER);
-       if (option != NULL)
-               dhcp_set_value(dhcp, "Gateway", option->data);
+               domainname = g_strdup(option->data);
 
        option = g_dhcp_client_get_option(dhcp_client, G_DHCP_HOST_NAME);
        if (option != NULL)
-               dhcp_set_value(dhcp, "Hostname", option->data);
+               hostname = g_strdup(option->data);
 
        option = g_dhcp_client_get_option(dhcp_client, G_DHCP_NTP_SERVER);
        if (option != NULL)
-               dhcp_set_value(dhcp, "Timeserver", option->data);
+               timeserver = g_strdup(option->data);
 
        option = g_dhcp_client_get_option(dhcp_client, 252);
        if (option != NULL)
-               dhcp_set_value(dhcp, "PAC", option->data);
+               pac = g_strdup(option->data);
+
+       connman_ipaddress_set_ipv4(ipaddress, address, netmask, gateway);
+
+       if (domainname != NULL)
+               __connman_utsname_set_domainname(domainname);
 
-       dhcp_bound(dhcp);
+       if (hostname != NULL)
+               __connman_utsname_set_hostname(hostname);
+
+       __connman_network_set_dhcp_valid(dhcp->network, ipaddress,
+                                               nameservers, domainname,
+                                               hostname, timeserver, pac);
+
+       connman_ipaddress_free(ipaddress);
+       g_free(address);
+       g_free(netmask);
+       g_free(gateway);
+       g_free(net);
+       g_free(domainname);
+       g_free(hostname);
+       g_free(timeserver);
+       g_free(pac);
+       g_free(nameservers);
 }
 
 static void ipv4ll_available_cb(GDHCPClient *dhcp_client, gpointer user_data)
 {
        struct connman_dhcp *dhcp = user_data;
        char *address, *netmask;
+       struct connman_ipaddress *ipaddress;
 
        DBG("IPV4LL available");
 
        address = g_dhcp_client_get_address(dhcp_client);
-       if (address != NULL)
-               dhcp_set_value(dhcp, "Address", address);
-
        netmask = g_dhcp_client_get_netmask(dhcp_client);
-       if (netmask != NULL)
-               dhcp_set_value(dhcp, "Netmask", netmask);
+
+       ipaddress = connman_ipaddress_alloc(CONNMAN_IPCONFIG_TYPE_IPV4);
+       if (ipaddress == NULL) {
+               connman_error("Can not allocate ipaddress");
+               return;
+       }
+
+       connman_ipaddress_set_ipv4(ipaddress, address, netmask, NULL);
+
+       __connman_network_set_dhcp_valid(dhcp->network, ipaddress,
+                                               NULL, NULL, NULL, NULL, NULL);
 
        g_free(address);
        g_free(netmask);
-
-       dhcp_bound(dhcp);
 }
 
 static void dhcp_debug(const char *str, void *data)
@@ -239,7 +190,7 @@ static int dhcp_request(struct connman_dhcp *dhcp)
 
        DBG("dhcp %p", dhcp);
 
-       index = dhcp->index;
+       index = connman_network_get_index(dhcp->network);
 
        dhcp_client = g_dhcp_client_new(G_DHCP_IPV4, index, &error);
        if (error != G_DHCP_CLIENT_ERROR_NONE)
@@ -292,66 +243,58 @@ static int dhcp_release(struct connman_dhcp *dhcp)
        return 0;
 }
 
-static int dhcp_probe(struct connman_element *element)
+static void remove_network(gpointer user_data)
+{
+       struct connman_dhcp *dhcp = user_data;
+
+       DBG("dhcp %p", dhcp);
+
+       g_free(dhcp);
+}
+
+int __connman_dhcp_start(struct connman_network *network)
 {
        struct connman_dhcp *dhcp;
 
-       DBG("element %p name %s", element, element->name);
+       DBG("");
 
        dhcp = g_try_new0(struct connman_dhcp, 1);
        if (dhcp == NULL)
                return -ENOMEM;
 
-       dhcp->index = element->index;
-       dhcp->state = CONNMAN_DHCP_STATE_IDLE;
-
-       dhcp->element = element;
-
-       connman_element_set_data(element, dhcp);
+       dhcp->network = network;
 
-       dhcp_request(dhcp);
+       g_hash_table_replace(network_table, network, dhcp);
 
-       return 0;
+       return dhcp_request(dhcp);
 }
 
-static void dhcp_remove(struct connman_element *element)
+void __connman_dhcp_stop(struct connman_network *network)
 {
-       struct connman_dhcp *dhcp = connman_element_get_data(element);
+       struct connman_dhcp *dhcp;
 
-       DBG("element %p name %s", element, element->name);
+       DBG("");
 
-       connman_element_set_data(element, NULL);
+       dhcp = g_hash_table_lookup(network_table, network);
+       if (dhcp == NULL)
+               return;
 
        dhcp_release(dhcp);
-       g_free(dhcp);
-
-       connman_element_unref(element);
-}
-
-static void dhcp_change(struct connman_element *element)
-{
-       DBG("element %p name %s", element, element->name);
 
-       if (element->state == CONNMAN_ELEMENT_STATE_ERROR)
-               connman_element_set_error(element->parent,
-                                       CONNMAN_ELEMENT_ERROR_DHCP_FAILED);
+       g_hash_table_remove(network_table, network);
 }
 
-static struct connman_driver dhcp_driver = {
-       .name           = "dhcp",
-       .type           = CONNMAN_ELEMENT_TYPE_DHCP,
-       .priority       = CONNMAN_DRIVER_PRIORITY_LOW,
-       .probe          = dhcp_probe,
-       .remove         = dhcp_remove,
-       .change         = dhcp_change,
-};
-
 int __connman_dhcp_init(void)
 {
-       return connman_driver_register(&dhcp_driver);
+       DBG("");
+
+       network_table = g_hash_table_new_full(g_direct_hash, g_direct_equal,
+                                                       NULL, remove_network);
 }
 
 void __connman_dhcp_cleanup(void)
 {
-       connman_driver_unregister(&dhcp_driver);
+       DBG("");
+
+       g_hash_table_destroy(network_table);
 }
diff --git a/src/element.c b/src/element.c
index 78120ce..2b7bb93 100644
--- a/src/element.c
+++ b/src/element.c
@@ -1399,7 +1399,6 @@ void __connman_element_start(void)
 
        __connman_connection_init();
        __connman_ipv4_init();
-       __connman_dhcp_init();
        __connman_wpad_init();
        __connman_wispr_init();
 
@@ -1414,7 +1413,6 @@ void __connman_element_stop(void)
 
        __connman_wispr_cleanup();
        __connman_wpad_cleanup();
-       __connman_dhcp_cleanup();
        __connman_ipv4_cleanup();
        __connman_provider_cleanup();
        __connman_connection_cleanup();
diff --git a/src/main.c b/src/main.c
index 08f2555..c7574df 100644
--- a/src/main.c
+++ b/src/main.c
@@ -236,6 +236,7 @@ int main(int argc, char *argv[])
        __connman_detect_init();
        __connman_session_init();
        __connman_timeserver_init();
+       __connman_dhcp_init();
 
        __connman_plugin_init(option_plugin, option_noplugin);
 
@@ -257,6 +258,7 @@ int main(int argc, char *argv[])
 
        __connman_plugin_cleanup();
 
+       __connman_dhcp_cleanup();
        __connman_timeserver_cleanup();
        __connman_session_cleanup();
        __connman_detect_cleanup();
diff --git a/src/network.c b/src/network.c
index 612e923..7c1de42 100644
--- a/src/network.c
+++ b/src/network.c
@@ -441,6 +441,51 @@ connman_bool_t __connman_network_get_connecting(struct 
connman_network *network)
        return network->connecting;
 }
 
+int __connman_network_set_dhcp_valid(struct connman_network *network,
+                                       struct connman_ipaddress *ipaddress,
+                                       const char *nameservers, const char 
*domainname,
+                                       const char *hostname, const char 
*timeserver,
+                                       const char *pac)
+{
+       struct connman_service *service;
+       int index;
+       int err;
+
+       DBG("");
+
+       service = __connman_service_lookup_from_network(network);
+       if (service == NULL) {
+               connman_network_set_error(network,
+                       CONNMAN_NETWORK_ERROR_CONFIGURE_FAIL);
+               return -EINVAL;
+       }
+
+       connman_network_set_associating(network, FALSE);
+
+       index = connman_network_get_index(network);
+       connman_inet_set_address(index, ipaddress);
+       connman_inet_set_gateway_address(index, ipaddress->gateway);
+
+       __connman_service_append_nameserver(service, nameservers);
+
+       __connman_service_set_domainname(service, domainname);
+
+       network->connecting = FALSE;
+
+       connman_network_set_associating(network, FALSE);
+
+       __connman_service_indicate_state(service, CONNMAN_SERVICE_STATE_READY);
+
+       return 0;
+}
+
+int __connman_network_set_dhcp_invalid(struct connman_network *network)
+{
+       DBG("XXX");
+
+       return 0;
+}
+
 /**
  * connman_network_set_available:
  * @network: network structure
@@ -682,26 +727,18 @@ static void set_connected_manual(struct connman_network 
*network)
 
 static int set_connected_dhcp(struct connman_network *network)
 {
-       struct connman_element *element;
-       int error;
-
-       DBG("network %p", network);
+       int err;
 
-       element = connman_element_create(NULL);
-       if (element == NULL)
-               return -ENOMEM;
+       DBG("");
 
-       element->type  = CONNMAN_ELEMENT_TYPE_DHCP;
-       element->index = network->element.index;
+       set_configuration(network);
 
-       error = connman_element_register(element, &network->element);
-       if (error < 0) {
-               connman_element_unref(element);
-               return error;
+       err = __connman_dhcp_start(network);
+       if (err < 0) {
+               connman_error("Can not request DHCP lease");
+               return err;
        }
 
-       set_configuration(network);
-
        return 0;
 }
 
@@ -788,13 +825,14 @@ static gboolean set_connected(gpointer user_data)
                        set_connected_manual(network);
                        return TRUE;
                case CONNMAN_IPCONFIG_METHOD_DHCP:
-                       if (set_connected_dhcp(network) < 0) {
+                       ret = set_connected_dhcp(network);
+                       if (ret != 0) {
                                connman_network_set_error(network,
                                        CONNMAN_NETWORK_ERROR_ASSOCIATE_FAIL);
                                return FALSE;
                        }
+                       return TRUE;;
                }
-
        } else {
                struct connman_service *service;
 
@@ -955,39 +993,6 @@ int __connman_network_disconnect(struct connman_network 
*network)
        return err;
 }
 
-static int dhcp_start(struct connman_network *network)
-{
-       struct connman_element *element;
-       int error;
-
-       element = connman_element_create(NULL);
-       if (element == NULL)
-               return -ENOMEM;
-
-       element->type  = CONNMAN_ELEMENT_TYPE_DHCP;
-       element->index = network->element.index;
-
-       error = connman_element_register(element, &network->element);
-       if (error < 0) {
-               connman_element_unref(element);
-               return error;
-       }
-
-       return 0;
-}
-
-static int dhcp_stop(struct connman_network *network)
-{
-       connman_element_unregister_children_type(&network->element,
-                                       CONNMAN_ELEMENT_TYPE_CONNECTION);
-       connman_element_unregister_children_type(&network->element,
-                                               CONNMAN_ELEMENT_TYPE_IPV4);
-       connman_element_unregister_children_type(&network->element,
-                                               CONNMAN_ELEMENT_TYPE_DHCP);
-
-       return 0;
-}
-
 static int manual_ipv4_set(struct connman_network *network,
                                struct connman_ipconfig *ipconfig)
 {
@@ -1036,7 +1041,7 @@ int __connman_network_clear_ipconfig(struct 
connman_network *network,
                __connman_ipconfig_clear_address(ipconfig);
                break;
        case CONNMAN_IPCONFIG_METHOD_DHCP:
-               dhcp_stop(network);
+               __connman_dhcp_stop(network);
                break;
        }
 
@@ -1087,7 +1092,7 @@ int __connman_network_set_ipconfig(struct connman_network 
*network,
                case CONNMAN_IPCONFIG_METHOD_MANUAL:
                        return manual_ipv4_set(network, ipconfig_ipv4);
                case CONNMAN_IPCONFIG_METHOD_DHCP:
-                       return dhcp_start(network);
+                       return __connman_dhcp_start(network);
                }
        }
 
-- 
1.7.3.5

_______________________________________________
connman mailing list
[email protected]
http://lists.connman.net/listinfo/connman

Reply via email to