src/provider.c

   1 /*
   2  *
   3  *  Connection Manager
   4  *
   5  *  Copyright (C) 2007-2012  Intel Corporation. All rights reserved.
   6  *
   7  *  This program is free software; you can redistribute it and/or modify
   8  *  it under the terms of the GNU General Public License version 2 as
   9  *  published by the Free Software Foundation.
  10  *
  11  *  This program is distributed in the hope that it will be useful,
  12  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14  *  GNU General Public License for more details.
  15  *
  16  *  You should have received a copy of the GNU General Public License
  17  *  along with this program; if not, write to the Free Software
  18  *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
  19  *
  20  */
  21
  22 #ifdef HAVE_CONFIG_H
  23 #include <config.h>
  24 #endif
  25
  26 #include <errno.h>
  27 #include <stdio.h>
  28 #include <string.h>
  29 #include <stdlib.h>
  30 #include <gdbus.h>
  31
  32 #include "connman.h"
  33
  34 static DBusConnection *connection = NULL;
  35
  36 static GHashTable *provider_hash = NULL;
  37
  38 static GSList *driver_list = NULL;
  39
  40 struct connman_route {
  41         int family;
  42         char *host;
  43         char *netmask;
  44         char *gateway;
  45 };
  46
  47 struct connman_provider {
  48         int refcount;
  49         struct connman_service *vpn_service;
  50         int index;
  51         char *identifier;
  52         char *name;
  53         char *type;
  54         char *host;
  55         char *domain;
  56         int family;
  57         GHashTable *routes;
  58         struct connman_provider_driver *driver;
  59         void *driver_data;
  60         GHashTable *setting_strings;
  61         GHashTable *user_routes;
  62         gchar **user_networks;
  63         gsize num_user_networks;
  64 };
  65
  66 void __connman_provider_append_properties(struct connman_provider *provider,
  67                                                         DBusMessageIter *iter)
  68 {
  69         if (provider->host != NULL)
  70                 connman_dbus_dict_append_basic(iter, "Host",
  71                                         DBUS_TYPE_STRING, &provider->host);
  72
  73         if (provider->domain != NULL)
  74                 connman_dbus_dict_append_basic(iter, "Domain",
  75                                         DBUS_TYPE_STRING, &provider->domain);
  76
  77         if (provider->type != NULL)
  78                 connman_dbus_dict_append_basic(iter, "Type", DBUS_TYPE_STRING,
  79                                                  &provider->type);
  80 }
  81
  82 int __connman_provider_append_user_route(struct connman_provider *provider,
  83                         int family, const char *network, const char *netmask)
  84 {
  85         struct connman_route *route;
  86         char *key = g_strdup_printf("%d/%s/%s", family, network, netmask);
  87
  88         DBG("family %d network %s netmask %s", family, network, netmask);
  89
  90         route = g_hash_table_lookup(provider->user_routes, key);
  91         if (route == NULL) {
  92                 route = g_try_new0(struct connman_route, 1);
  93                 if (route == NULL) {
  94                         connman_error("out of memory");
  95                         return -ENOMEM;
  96                 }
  97
  98                 route->family = family;
  99                 route->host = g_strdup(network);
 100                 route->netmask = g_strdup(netmask);
 101
 102                 g_hash_table_replace(provider->user_routes, key, route);
 103         } else
 104                 g_free(key);
 105
 106         return 0;
 107 }
 108
 109 static void set_user_networks(struct connman_provider *provider,
 110                                                         char **networks)
 111 {
 112         int i = 0;
 113
 114         while (networks[i] != NULL) {
 115                 char **elems = g_strsplit(networks[i], "/", 0);
 116                 char *network, *netmask;
 117                 int family = PF_UNSPEC, ret;
 118
 119                 if (elems == NULL)
 120                         break;
 121
 122                 network = elems[0];
 123                 if (network == NULL || *network == '\0') {
 124                         DBG("no network/netmask set");
 125                         g_strfreev(elems);
 126                         break;
 127                 }
 128
 129                 netmask = elems[1];
 130                 if (netmask != NULL && *netmask == '\0') {
 131                         DBG("no netmask set");
 132                         g_strfreev(elems);
 133                         break;
 134                 }
 135
 136                 if (g_strrstr(network, ":") != NULL)
 137                         family = AF_INET6;
 138                 else if (g_strrstr(network, ".") != NULL) {
 139                         family = AF_INET;
 140
 141                         if (g_strrstr(netmask, ".") == NULL) {
 142                                 /* We have netmask length */
 143                                 in_addr_t addr;
 144                                 struct in_addr netmask_in;
 145                                 unsigned char prefix_len = 32;
 146
 147                                 if (netmask != NULL)
 148                                         prefix_len = atoi(netmask);
 149
 150                                 addr = 0xffffffff << (32 - prefix_len);
 151                                 netmask_in.s_addr = htonl(addr);
 152                                 netmask = inet_ntoa(netmask_in);
 153
 154                                 DBG("network %s netmask %s", network, netmask);
 155                         }
 156                 }
 157
 158                 ret = __connman_provider_append_user_route(provider,
 159                                                 family, network, netmask);
 160                 g_strfreev(elems);
 161
 162                 if (ret != 0)
 163                         break;
 164
 165                 i++;
 166         }
 167 }
 168
 169 static int provider_load_from_keyfile(struct connman_provider *provider,
 170                 GKeyFile *keyfile)
 171 {
 172         gsize idx = 0;
 173         gchar **settings;
 174         gchar *key, *value;
 175         gsize length;
 176
 177         settings = g_key_file_get_keys(keyfile, provider->identifier, &length,
 178                                 NULL);
 179         if (settings == NULL) {
 180                 g_key_file_free(keyfile);
 181                 return -ENOENT;
 182         }
 183
 184         while (idx < length) {
 185                 key = settings[idx];
 186                 if (key != NULL) {
 187                         if (g_str_equal(key, "Networks") == TRUE) {
 188                                 g_strfreev(provider->user_networks);
 189                                 provider->user_networks =
 190                                         g_key_file_get_string_list(keyfile,
 191                                                 provider->identifier,
 192                                                 key,
 193                                                 &provider->num_user_networks,
 194                                                 NULL);
 195                         } else {
 196                                 value = g_key_file_get_string(keyfile,
 197                                                         provider->identifier,
 198                                                         key, NULL);
 199                                 connman_provider_set_string(provider, key,
 200                                                         value);
 201                                 g_free(value);
 202                         }
 203                 }
 204                 idx += 1;
 205         }
 206         g_strfreev(settings);
 207
 208         if (provider->user_networks != NULL)
 209                 set_user_networks(provider, provider->user_networks);
 210
 211         return 0;
 212 }
 213
 214 static int connman_provider_load(struct connman_provider *provider)
 215 {
 216         GKeyFile *keyfile;
 217
 218         DBG("provider %p", provider);
 219
 220         keyfile = __connman_storage_load_provider(provider->identifier);
 221         if (keyfile == NULL)
 222                 return -ENOENT;
 223
 224         provider_load_from_keyfile(provider, keyfile);
 225
 226         g_key_file_free(keyfile);
 227         return 0;
 228 }
 229
 230 static int connman_provider_save(struct connman_provider *provider)
 231 {
 232         GKeyFile *keyfile;
 233
 234         DBG("provider %p", provider);
 235
 236         keyfile = g_key_file_new();
 237         if (keyfile == NULL)
 238                 return -ENOMEM;
 239
 240         g_key_file_set_string(keyfile, provider->identifier,
 241                         "Name", provider->name);
 242         g_key_file_set_string(keyfile, provider->identifier,
 243                         "Type", provider->type);
 244         g_key_file_set_string(keyfile, provider->identifier,
 245                         "Host", provider->host);
 246         g_key_file_set_string(keyfile, provider->identifier,
 247                         "VPN.Domain", provider->domain);
 248         if (provider->user_networks != NULL)
 249                 g_key_file_set_string_list(keyfile, provider->identifier,
 250                                 "Networks",
 251                                 (const gchar **)provider->user_networks,
 252                                 provider->num_user_networks);
 253
 254         if (provider->driver != NULL && provider->driver->save != NULL)
 255                 provider->driver->save(provider, keyfile);
 256
 257         __connman_storage_save_provider(keyfile, provider->identifier);
 258         g_key_file_free(keyfile);
 259
 260         return 0;
 261 }
 262
 263 static struct connman_provider *connman_provider_lookup(const char *identifier)
 264 {
 265         struct connman_provider *provider = NULL;
 266
 267         provider = g_hash_table_lookup(provider_hash, identifier);
 268
 269         return provider;
 270 }
 271
 272 static gboolean match_driver(struct connman_provider *provider,
 273                                 struct connman_provider_driver *driver)
 274 {
 275         if (g_strcmp0(driver->name, provider->type) == 0)
 276                 return TRUE;
 277
 278         return FALSE;
 279 }
 280
 281 static int provider_probe(struct connman_provider *provider)
 282 {
 283         GSList *list;
 284
 285         DBG("provider %p name %s", provider, provider->name);
 286
 287         if (provider->driver != NULL)
 288                 return -EALREADY;
 289
 290         for (list = driver_list; list; list = list->next) {
 291                 struct connman_provider_driver *driver = list->data;
 292
 293                 if (match_driver(provider, driver) == FALSE)
 294                         continue;
 295
 296                 DBG("driver %p name %s", driver, driver->name);
 297
 298                 if (driver->probe != NULL && driver->probe(provider) == 0) {
 299                         provider->driver = driver;
 300                         break;
 301                 }
 302         }
 303
 304         if (provider->driver == NULL)
 305                 return -ENODEV;
 306
 307         return 0;
 308 }
 309
 310 static void provider_remove(struct connman_provider *provider)
 311 {
 312         if (provider->driver != NULL) {
 313                 provider->driver->remove(provider);
 314                 provider->driver = NULL;
 315         }
 316 }
 317
 318 static int provider_register(struct connman_provider *provider)
 319 {
 320         return provider_probe(provider);
 321 }
 322
 323 static void provider_unregister(struct connman_provider *provider)
 324 {
 325         provider_remove(provider);
 326 }
 327
 328 struct connman_provider *
 329 connman_provider_ref_debug(struct connman_provider *provider,
 330                         const char *file, int line, const char *caller)
 331 {
 332         DBG("%p ref %d by %s:%d:%s()", provider, provider->refcount + 1,
 333                 file, line, caller);
 334
 335         __sync_fetch_and_add(&provider->refcount, 1);
 336
 337         return provider;
 338 }
 339
 340 static void provider_destruct(struct connman_provider *provider)
 341 {
 342         DBG("provider %p", provider);
 343
 344         g_free(provider->name);
 345         g_free(provider->type);
 346         g_free(provider->host);
 347         g_free(provider->domain);
 348         g_free(provider->identifier);
 349         g_strfreev(provider->user_networks);
 350         g_hash_table_destroy(provider->routes);
 351         g_hash_table_destroy(provider->user_routes);
 352         g_hash_table_destroy(provider->setting_strings);
 353         g_free(provider);
 354 }
 355
 356 void connman_provider_unref_debug(struct connman_provider *provider,
 357                                 const char *file, int line, const char *caller)
 358 {
 359         DBG("%p ref %d by %s:%d:%s()", provider, provider->refcount - 1,
 360                 file, line, caller);
 361
 362         if (__sync_fetch_and_sub(&provider->refcount, 1) != 1)
 363                 return;
 364
 365         provider_remove(provider);
 366
 367         provider_destruct(provider);
 368 }
 369
 370 static int provider_indicate_state(struct connman_provider *provider,
 371                                         enum connman_service_state state)
 372 {
 373         DBG("state %d", state);
 374
 375         __connman_service_ipconfig_indicate_state(provider->vpn_service, state,
 376                                         CONNMAN_IPCONFIG_TYPE_IPV4);
 377
 378         return __connman_service_ipconfig_indicate_state(provider->vpn_service,
 379                                         state, CONNMAN_IPCONFIG_TYPE_IPV6);
 380 }
 381
 382 int __connman_provider_disconnect(struct connman_provider *provider)
 383 {
 384         int err;
 385
 386         DBG("provider %p", provider);
 387
 388         if (provider->driver != NULL && provider->driver->disconnect != NULL)
 389                 err = provider->driver->disconnect(provider);
 390         else
 391                 return -EOPNOTSUPP;
 392
 393         if (provider->vpn_service != NULL)
 394                 provider_indicate_state(provider,
 395                                         CONNMAN_SERVICE_STATE_DISCONNECT);
 396
 397         if (err < 0) {
 398                 if (err != -EINPROGRESS)
 399                         return err;
 400
 401                 return -EINPROGRESS;
 402         }
 403
 404         return 0;
 405 }
 406
 407 int __connman_provider_connect(struct connman_provider *provider)
 408 {
 409         int err;
 410
 411         DBG("provider %p", provider);
 412
 413         if (provider->driver != NULL && provider->driver->connect != NULL)
 414                 err = provider->driver->connect(provider);
 415         else
 416                 return -EOPNOTSUPP;
 417
 418         if (err < 0) {
 419                 if (err != -EINPROGRESS)
 420                         return err;
 421
 422                 provider_indicate_state(provider,
 423                                         CONNMAN_SERVICE_STATE_ASSOCIATION);
 424
 425                 return -EINPROGRESS;
 426         }
 427
 428         return 0;
 429 }
 430
 431 int __connman_provider_remove(const char *path)
 432 {
 433         struct connman_provider *provider;
 434         GHashTableIter iter;
 435         gpointer value, key;
 436
 437         DBG("path %s", path);
 438
 439         g_hash_table_iter_init(&iter, provider_hash);
 440         while (g_hash_table_iter_next(&iter, &key, &value) == TRUE) {
 441                 const char *srv_path;
 442                 provider = value;
 443
 444                 if (provider->vpn_service == NULL)
 445                         continue;
 446
 447                 srv_path = __connman_service_get_path(provider->vpn_service);
 448
 449                 if (g_strcmp0(srv_path, path) == 0) {
 450                         DBG("Removing VPN %s", provider->identifier);
 451
 452                         provider_unregister(provider);
 453                         g_hash_table_remove(provider_hash,
 454                                                 provider->identifier);
 455                         return 0;
 456                 }
 457         }
 458
 459         return -ENXIO;
 460 }
 461
 462 static void provider_append_routes(gpointer key, gpointer value,
 463                                         gpointer user_data)
 464 {
 465         struct connman_route *route = value;
 466         struct connman_provider *provider = user_data;
 467         int index = provider->index;
 468
 469         if (route->family == AF_INET6) {
 470                 unsigned char prefix_len = atoi(route->netmask);
 471
 472                 connman_inet_add_ipv6_network_route(index, route->host,
 473                                                         route->gateway,
 474                                                         prefix_len);
 475         } else {
 476                 connman_inet_add_network_route(index, route->host,
 477                                                 route->gateway,
 478                                                 route->netmask);
 479         }
 480 }
 481
 482 static int set_connected(struct connman_provider *provider,
 483                                         connman_bool_t connected)
 484 {
 485         struct connman_service *service = provider->vpn_service;
 486         struct connman_ipconfig *ipconfig;
 487
 488         if (service == NULL)
 489                 return -ENODEV;
 490
 491         ipconfig = __connman_service_get_ipconfig(service, provider->family);
 492
 493         if (connected == TRUE) {
 494                 if (ipconfig == NULL) {
 495                         provider_indicate_state(provider,
 496                                                 CONNMAN_SERVICE_STATE_FAILURE);
 497                         return -EIO;
 498                 }
 499
 500                 __connman_ipconfig_address_add(ipconfig);
 501                 __connman_ipconfig_gateway_add(ipconfig);
 502
 503                 provider_indicate_state(provider,
 504                                         CONNMAN_SERVICE_STATE_READY);
 505
 506                 g_hash_table_foreach(provider->routes, provider_append_routes,
 507                                         provider);
 508
 509                 g_hash_table_foreach(provider->user_routes, provider_append_routes,
 510                                         provider);
 511
 512         } else {
 513                 if (ipconfig != NULL) {
 514                         provider_indicate_state(provider,
 515                                         CONNMAN_SERVICE_STATE_DISCONNECT);
 516                         __connman_ipconfig_gateway_remove(ipconfig);
 517                 }
 518
 519                 provider_indicate_state(provider,
 520                                         CONNMAN_SERVICE_STATE_IDLE);
 521         }
 522
 523         return 0;
 524 }
 525
 526 int connman_provider_set_state(struct connman_provider *provider,
 527                                         enum connman_provider_state state)
 528 {
 529         if (provider == NULL || provider->vpn_service == NULL)
 530                 return -EINVAL;
 531
 532         switch (state) {
 533         case CONNMAN_PROVIDER_STATE_UNKNOWN:
 534                 return -EINVAL;
 535         case CONNMAN_PROVIDER_STATE_IDLE:
 536                 return set_connected(provider, FALSE);
 537         case CONNMAN_PROVIDER_STATE_CONNECT:
 538                 return provider_indicate_state(provider,
 539                                         CONNMAN_SERVICE_STATE_ASSOCIATION);
 540         case CONNMAN_PROVIDER_STATE_READY:
 541                 return set_connected(provider, TRUE);
 542         case CONNMAN_PROVIDER_STATE_DISCONNECT:
 543                 return provider_indicate_state(provider,
 544                                         CONNMAN_SERVICE_STATE_DISCONNECT);
 545         case CONNMAN_PROVIDER_STATE_FAILURE:
 546                 return provider_indicate_state(provider,
 547                                         CONNMAN_SERVICE_STATE_FAILURE);
 548         }
 549
 550         return -EINVAL;
 551 }
 552
 553 int connman_provider_indicate_error(struct connman_provider *provider,
 554                                         enum connman_provider_error error)
 555 {
 556         enum connman_service_error service_error;
 557
 558         switch (error) {
 559         case CONNMAN_PROVIDER_ERROR_LOGIN_FAILED:
 560                 service_error = CONNMAN_SERVICE_ERROR_LOGIN_FAILED;
 561                 break;
 562         case CONNMAN_PROVIDER_ERROR_AUTH_FAILED:
 563                 service_error = CONNMAN_SERVICE_ERROR_AUTH_FAILED;
 564                 break;
 565         case CONNMAN_PROVIDER_ERROR_CONNECT_FAILED:
 566                 service_error = CONNMAN_SERVICE_ERROR_CONNECT_FAILED;
 567                 break;
 568         default:
 569                 service_error = CONNMAN_SERVICE_ERROR_UNKNOWN;
 570                 break;
 571         }
 572
 573         return __connman_service_indicate_error(provider->vpn_service,
 574                                                         service_error);
 575 }
 576
 577 static void unregister_provider(gpointer data)
 578 {
 579         struct connman_provider *provider = data;
 580
 581         DBG("provider %p service %p", provider, provider->vpn_service);
 582
 583         if (provider->vpn_service != NULL) {
 584                 connman_service_unref(provider->vpn_service);
 585                 provider->vpn_service = NULL;
 586         }
 587
 588         connman_provider_unref(provider);
 589 }
 590
 591 static void destroy_route(gpointer user_data)
 592 {
 593         struct connman_route *route = user_data;
 594
 595         g_free(route->host);
 596         g_free(route->netmask);
 597         g_free(route->gateway);
 598         g_free(route);
 599 }
 600
 601 static void provider_initialize(struct connman_provider *provider)
 602 {
 603         DBG("provider %p", provider);
 604
 605         provider->index = 0;
 606         provider->name = NULL;
 607         provider->type = NULL;
 608         provider->domain = NULL;
 609         provider->identifier = NULL;
 610         provider->user_networks = NULL;
 611         provider->routes = g_hash_table_new_full(g_direct_hash, g_direct_equal,
 612                                         NULL, destroy_route);
 613         provider->user_routes = g_hash_table_new_full(g_str_hash, g_str_equal,
 614                                         g_free, destroy_route);
 615         provider->setting_strings = g_hash_table_new_full(g_str_hash, g_str_equal,
 616                                                         g_free, g_free);
 617 }
 618
 619 static struct connman_provider *connman_provider_new(void)
 620 {
 621         struct connman_provider *provider;
 622
 623         provider = g_try_new0(struct connman_provider, 1);
 624         if (provider == NULL)
 625                 return NULL;
 626
 627         provider->refcount = 1;
 628
 629         DBG("provider %p", provider);
 630         provider_initialize(provider);
 631
 632         return provider;
 633 }
 634
 635 static struct connman_provider *connman_provider_get(const char *identifier)
 636 {
 637         struct connman_provider *provider;
 638
 639         provider = g_hash_table_lookup(provider_hash, identifier);
 640         if (provider != NULL)
 641                 return provider;
 642
 643         provider = connman_provider_new();
 644         if (provider == NULL)
 645                 return NULL;
 646
 647         DBG("provider %p", provider);
 648
 649         provider->identifier = g_strdup(identifier);
 650
 651         g_hash_table_insert(provider_hash, provider->identifier, provider);
 652
 653         return provider;
 654 }
 655
 656 static void provider_dbus_ident(char *ident)
 657 {
 658         int i, len = strlen(ident);
 659
 660         for (i = 0; i < len; i++) {
 661                 if (ident[i] >= '0' && ident[i] <= '9')
 662                         continue;
 663                 if (ident[i] >= 'a' && ident[i] <= 'z')
 664                         continue;
 665                 if (ident[i] >= 'A' && ident[i] <= 'Z')
 666                         continue;
 667                 ident[i] = '_';
 668         }
 669 }
 670
 671 static struct connman_provider *provider_create_from_keyfile(GKeyFile *keyfile,
 672                 const char *ident)
 673 {
 674         struct connman_provider *provider;
 675
 676         if (keyfile == NULL || ident == NULL)
 677                 return NULL;
 678
 679         provider = connman_provider_lookup(ident);
 680         if (provider == NULL) {
 681                 provider = connman_provider_get(ident);
 682                 if (provider == NULL) {
 683                         DBG("can not create provider");
 684                         return NULL;
 685                 }
 686
 687                 provider_load_from_keyfile(provider, keyfile);
 688
 689                 if (provider->name == NULL || provider->host == NULL ||
 690                                 provider->domain == NULL) {
 691                         DBG("cannot get name, host or domain");
 692                         connman_provider_unref(provider);
 693                         return NULL;
 694                 }
 695
 696                 provider_register(provider);
 697         }
 698         return provider;
 699 }
 700
 701 static int provider_create_service(struct connman_provider *provider)
 702 {
 703         if (provider->vpn_service != NULL) {
 704                 connman_bool_t connected;
 705
 706                 connected = __connman_service_is_connected_state(
 707                         provider->vpn_service, CONNMAN_IPCONFIG_TYPE_IPV4);
 708                 if (connected == TRUE)
 709                         return -EALREADY;
 710
 711                 connected = __connman_service_is_connected_state(
 712                         provider->vpn_service, CONNMAN_IPCONFIG_TYPE_IPV6);
 713                 if (connected == TRUE)
 714                         return -EALREADY;
 715
 716                 return 0;
 717         }
 718
 719         provider->vpn_service =
 720                 __connman_service_create_from_provider(provider);
 721
 722         if (provider->vpn_service == NULL)
 723                 return -EOPNOTSUPP;
 724
 725         return 0;
 726 }
 727
 728 static void provider_create_all_from_type(const char *provider_type)
 729 {
 730         unsigned int i;
 731         char **providers;
 732         char *id, *type;
 733         GKeyFile *keyfile;
 734         struct connman_provider *provider;
 735
 736         DBG("provider type %s", provider_type);
 737
 738         providers = __connman_storage_get_providers();
 739
 740         for (i = 0; providers[i] != NULL; i+=1) {
 741
 742                 if (strncmp(providers[i], "provider_", 9) != 0)
 743                         continue;
 744
 745                 id = providers[i] + 9;
 746                 keyfile = __connman_storage_load_provider(id);
 747
 748                 if (keyfile == NULL)
 749                         continue;
 750
 751                 type = g_key_file_get_string(keyfile, id, "Type", NULL);
 752
 753                 DBG("keyfile %p id %s type %s", keyfile, id, type);
 754
 755                 if (strcmp(provider_type, type) != 0) {
 756                         g_free(type);
 757                         g_key_file_free(keyfile);
 758                         continue;
 759                 }
 760
 761                 provider = provider_create_from_keyfile(keyfile, id);
 762                 if (provider != NULL) {
 763                         if (provider_create_service(provider) == -EOPNOTSUPP) {
 764                                 DBG("could not create service");
 765                                 connman_provider_unref(provider);
 766                         }
 767                 }
 768
 769                 g_free(type);
 770                 g_key_file_free(keyfile);
 771         }
 772         g_strfreev(providers);
 773 }
 774
 775 static char **get_user_networks(DBusMessageIter *array, int *count)
 776 {
 777         DBusMessageIter entry;
 778         char **networks = NULL;
 779         GSList *list = NULL, *l;
 780         int len;
 781
 782         dbus_message_iter_recurse(array, &entry);
 783
 784         while (dbus_message_iter_get_arg_type(&entry) == DBUS_TYPE_STRING) {
 785                 const char *val;
 786                 dbus_message_iter_get_basic(&entry, &val);
 787
 788                 list = g_slist_prepend(list, g_strdup(val));
 789                 dbus_message_iter_next(&entry);
 790         }
 791
 792         len = g_slist_length(list);
 793         if (len == 0)
 794                 goto out;
 795
 796         networks = g_try_new(char *, len + 1);
 797         if (networks == NULL)
 798                 goto out;
 799
 800         *count = len;
 801         networks[len] = 0;
 802
 803         for (l = list; l != NULL; l = g_slist_next(l))
 804                 networks[--len] = l->data;
 805
 806 out:
 807         g_slist_free(list);
 808
 809         return networks;
 810 }
 811
 812 int __connman_provider_create_and_connect(DBusMessage *msg)
 813 {
 814         struct connman_provider *provider;
 815         DBusMessageIter iter, array;
 816         const char *type = NULL, *name = NULL, *service_path;
 817         const char *host = NULL, *domain = NULL;
 818         char **networks = NULL;
 819         char *ident;
 820         int err, count = 0;
 821
 822         dbus_message_iter_init(msg, &iter);
 823         dbus_message_iter_recurse(&iter, &array);
 824
 825         while (dbus_message_iter_get_arg_type(&array) == DBUS_TYPE_DICT_ENTRY) {
 826                 DBusMessageIter entry, value;
 827                 const char *key;
 828
 829                 dbus_message_iter_recurse(&array, &entry);
 830                 dbus_message_iter_get_basic(&entry, &key);
 831
 832                 dbus_message_iter_next(&entry);
 833                 dbus_message_iter_recurse(&entry, &value);
 834
 835                 switch (dbus_message_iter_get_arg_type(&value)) {
 836                 case DBUS_TYPE_STRING:
 837                         if (g_str_equal(key, "Type") == TRUE)
 838                                 dbus_message_iter_get_basic(&value, &type);
 839                         else if (g_str_equal(key, "Name") == TRUE)
 840                                 dbus_message_iter_get_basic(&value, &name);
 841                         else if (g_str_equal(key, "Host") == TRUE)
 842                                 dbus_message_iter_get_basic(&value, &host);
 843                         else if (g_str_equal(key, "VPN.Domain") == TRUE)
 844                                 dbus_message_iter_get_basic(&value, &domain);
 845                         break;
 846                 case DBUS_TYPE_ARRAY:
 847                         if (g_str_equal(key, "Networks") == TRUE)
 848                                 networks = get_user_networks(&value, &count);
 849                         break;
 850                 }
 851
 852                 dbus_message_iter_next(&array);
 853         }
 854
 855         if (host == NULL || domain == NULL)
 856                 return -EINVAL;
 857
 858         DBG("Type %s name %s networks %p", type, name, networks);
 859
 860         if (type == NULL || name == NULL)
 861                 return -EOPNOTSUPP;
 862
 863         ident = g_strdup_printf("%s_%s", host, domain);
 864         provider_dbus_ident(ident);
 865
 866         DBG("ident %s", ident);
 867
 868         provider = connman_provider_lookup(ident);
 869         if (provider == NULL) {
 870                 provider = connman_provider_get(ident);
 871                 if (provider == NULL) {
 872                         DBG("can not create provider");
 873                         g_free(ident);
 874                         return -EOPNOTSUPP;
 875                 }
 876
 877                 provider->host = g_strdup(host);
 878                 provider->domain = g_strdup(domain);
 879                 provider->name = g_strdup(name);
 880                 provider->type = g_strdup(type);
 881
 882                 if (provider_register(provider) == 0)
 883                         connman_provider_load(provider);
 884         }
 885
 886         if (networks != NULL) {
 887                 g_strfreev(provider->user_networks);
 888                 provider->user_networks = networks;
 889                 provider->num_user_networks = count;
 890                 set_user_networks(provider, provider->user_networks);
 891         }
 892
 893         dbus_message_iter_init(msg, &iter);
 894         dbus_message_iter_recurse(&iter, &array);
 895
 896         while (dbus_message_iter_get_arg_type(&array) == DBUS_TYPE_DICT_ENTRY) {
 897                 DBusMessageIter entry, value;
 898                 const char *key, *str;
 899
 900                 dbus_message_iter_recurse(&array, &entry);
 901                 dbus_message_iter_get_basic(&entry, &key);
 902
 903                 dbus_message_iter_next(&entry);
 904                 dbus_message_iter_recurse(&entry, &value);
 905
 906                 switch (dbus_message_iter_get_arg_type(&value)) {
 907                 case DBUS_TYPE_STRING:
 908                         dbus_message_iter_get_basic(&value, &str);
 909                         connman_provider_set_string(provider, key, str);
 910                         break;
 911                 }
 912
 913                 dbus_message_iter_next(&array);
 914         }
 915
 916         g_free(ident);
 917
 918         err = provider_create_service(provider);
 919         if (err == -EALREADY) {
 920                 DBG("provider already connected");
 921         } else {
 922                 if (err == -EOPNOTSUPP) {
 923                         goto unref;
 924                 } else {
 925                         err = __connman_service_connect(provider->vpn_service);
 926
 927                         if (err < 0 && err != -EINPROGRESS)
 928                                 goto failed;
 929                 }
 930         }
 931
 932         connman_provider_save(provider);
 933         service_path = __connman_service_get_path(provider->vpn_service);
 934         g_dbus_send_reply(connection, msg,
 935                                 DBUS_TYPE_OBJECT_PATH, &service_path,
 936                                                         DBUS_TYPE_INVALID);
 937         return 0;
 938
 939 failed:
 940         connman_service_unref(provider->vpn_service);
 941         provider->vpn_service = NULL;
 942
 943 unref:
 944         DBG("can not connect, delete provider");
 945
 946         g_hash_table_remove(provider_hash, provider->identifier);
 947
 948         return err;
 949 }
 950
 951 const char * __connman_provider_get_ident(struct connman_provider *provider)
 952 {
 953         if (provider == NULL)
 954                 return NULL;
 955
 956         return provider->identifier;
 957 }
 958
 959 int connman_provider_set_string(struct connman_provider *provider,
 960                                         const char *key, const char *value)
 961 {
 962         DBG("provider %p key %s value %s", provider, key, value);
 963
 964         if (g_str_equal(key, "Type") == TRUE) {
 965                 g_free(provider->type);
 966                 provider->type = g_strdup(value);
 967         } else if (g_str_equal(key, "Name") == TRUE) {
 968                 g_free(provider->name);
 969                 provider->name = g_strdup(value);
 970         } else if (g_str_equal(key, "Host") == TRUE) {
 971                 g_free(provider->host);
 972                 provider->host = g_strdup(value);
 973         } else if (g_str_equal(key, "VPN.Domain") == TRUE) {
 974                 g_free(provider->domain);
 975                 provider->domain = g_strdup(value);
 976         } else
 977                 g_hash_table_replace(provider->setting_strings,
 978                                 g_strdup(key), g_strdup(value));
 979         return 0;
 980 }
 981
 982 const char *connman_provider_get_string(struct connman_provider *provider,
 983                                                         const char *key)
 984 {
 985         DBG("provider %p key %s", provider, key);
 986
 987         if (g_str_equal(key, "Type") == TRUE)
 988                 return provider->type;
 989         else if (g_str_equal(key, "Name") == TRUE)
 990                 return provider->name;
 991         else if (g_str_equal(key, "Host") == TRUE)
 992                 return provider->host;
 993         else if (g_str_equal(key, "VPN.Domain") == TRUE)
 994                 return provider->domain;
 995
 996         return g_hash_table_lookup(provider->setting_strings, key);
 997 }
 998
 999 connman_bool_t
1000 __connman_provider_check_routes(struct connman_provider *provider)
1001 {
1002         if (provider == NULL)
1003                 return FALSE;
1004
1005         if (provider->user_routes != NULL &&
1006                         g_hash_table_size(provider->user_routes) > 0)
1007                 return TRUE;
1008
1009         if (provider->routes != NULL &&
1010                         g_hash_table_size(provider->routes) > 0)
1011                 return TRUE;
1012
1013         return FALSE;
1014 }
1015
1016 void *connman_provider_get_data(struct connman_provider *provider)
1017 {
1018         return provider->driver_data;
1019 }
1020
1021 void connman_provider_set_data(struct connman_provider *provider, void *data)
1022 {
1023         provider->driver_data = data;
1024 }
1025
1026 void connman_provider_set_index(struct connman_provider *provider, int index)
1027 {
1028         struct connman_service *service = provider->vpn_service;
1029         struct connman_ipconfig *ipconfig;
1030
1031         DBG("");
1032
1033         if (service == NULL)
1034                 return;
1035
1036         ipconfig = __connman_service_get_ip4config(service);
1037
1038         if (ipconfig == NULL) {
1039                 __connman_service_create_ip4config(service, index);
1040
1041                 ipconfig = __connman_service_get_ip4config(service);
1042                 if (ipconfig == NULL) {
1043                         DBG("Couldnt create ipconfig");
1044                         goto done;
1045                 }
1046         }
1047
1048         __connman_ipconfig_set_method(ipconfig, CONNMAN_IPCONFIG_METHOD_FIXED);
1049         __connman_ipconfig_set_index(ipconfig, index);
1050
1051
1052         ipconfig = __connman_service_get_ip6config(service);
1053
1054         if (ipconfig == NULL) {
1055                 __connman_service_create_ip6config(service, index);
1056
1057                 ipconfig = __connman_service_get_ip6config(service);
1058                 if (ipconfig == NULL) {
1059                         DBG("Couldnt create ipconfig for IPv6");
1060                         goto done;
1061                 }
1062         }
1063
1064         __connman_ipconfig_set_method(ipconfig, CONNMAN_IPCONFIG_METHOD_OFF);
1065         __connman_ipconfig_set_index(ipconfig, index);
1066
1067 done:
1068         provider->index = index;
1069 }
1070
1071 int connman_provider_get_index(struct connman_provider *provider)
1072 {
1073         return provider->index;
1074 }
1075
1076 int connman_provider_set_ipaddress(struct connman_provider *provider,
1077                                         struct connman_ipaddress *ipaddress)
1078 {
1079         struct connman_ipconfig *ipconfig = NULL;
1080
1081         ipconfig = __connman_service_get_ipconfig(provider->vpn_service,
1082                                                         ipaddress->family);
1083         if (ipconfig == NULL)
1084                 return -EINVAL;
1085
1086         provider->family = ipaddress->family;
1087
1088         __connman_ipconfig_set_local(ipconfig, ipaddress->local);
1089         __connman_ipconfig_set_peer(ipconfig, ipaddress->peer);
1090         __connman_ipconfig_set_broadcast(ipconfig, ipaddress->broadcast);
1091         __connman_ipconfig_set_gateway(ipconfig, ipaddress->gateway);
1092         __connman_ipconfig_set_prefixlen(ipconfig, ipaddress->prefixlen);
1093
1094         return 0;
1095 }
1096
1097 int connman_provider_set_pac(struct connman_provider *provider, const char *pac)
1098 {
1099         DBG("provider %p pac %s", provider, pac);
1100
1101         __connman_service_set_pac(provider->vpn_service, pac);
1102
1103         return 0;
1104 }
1105
1106
1107 int connman_provider_set_domain(struct connman_provider *provider,
1108                                         const char *domain)
1109 {
1110         DBG("provider %p domain %s", provider, domain);
1111
1112         g_free(provider->domain);
1113         provider->domain = g_strdup(domain);
1114
1115         __connman_service_set_domainname(provider->vpn_service, domain);
1116
1117         return 0;
1118 }
1119
1120 int connman_provider_set_nameservers(struct connman_provider *provider,
1121                                         const char *nameservers)
1122 {
1123         int i;
1124         char **nameservers_array = NULL;
1125
1126         DBG("provider %p nameservers %s", provider, nameservers);
1127
1128         __connman_service_nameserver_clear(provider->vpn_service);
1129
1130         if (nameservers == NULL)
1131                 return 0;
1132
1133         nameservers_array = g_strsplit(nameservers, " ", 0);
1134
1135         for (i = 0; nameservers_array[i] != NULL; i++) {
1136                 __connman_service_nameserver_append(provider->vpn_service,
1137                                                 nameservers_array[i], FALSE);
1138         }
1139
1140         g_strfreev(nameservers_array);
1141
1142         return 0;
1143 }
1144
1145 enum provider_route_type {
1146         PROVIDER_ROUTE_TYPE_NONE = 0,
1147         PROVIDER_ROUTE_TYPE_MASK = 1,
1148         PROVIDER_ROUTE_TYPE_ADDR = 2,
1149         PROVIDER_ROUTE_TYPE_GW   = 3,
1150 };
1151
1152 static int route_env_parse(struct connman_provider *provider, const char *key,
1153                                 int *family, unsigned long *idx,
1154                                 enum provider_route_type *type)
1155 {
1156         char *end;
1157         const char *start;
1158
1159         DBG("name %s", provider->name);
1160
1161         if (!strcmp(provider->type, "openvpn")) {
1162                 if (g_str_has_prefix(key, "route_network_") == TRUE) {
1163                         start = key + strlen("route_network_");
1164                         *type = PROVIDER_ROUTE_TYPE_ADDR;
1165                 } else if (g_str_has_prefix(key, "route_netmask_") == TRUE) {
1166                         start = key + strlen("route_netmask_");
1167                         *type = PROVIDER_ROUTE_TYPE_MASK;
1168                 } else if (g_str_has_prefix(key, "route_gateway_") == TRUE) {
1169                         start = key + strlen("route_gateway_");
1170                         *type = PROVIDER_ROUTE_TYPE_GW;
1171                 } else
1172                         return -EINVAL;
1173
1174                 *family = AF_INET;
1175                 *idx = g_ascii_strtoull(start, &end, 10);
1176
1177         } else if (!strcmp(provider->type, "openconnect")) {
1178                 if (g_str_has_prefix(key, "CISCO_SPLIT_INC_") == TRUE) {
1179                         *family = AF_INET;
1180                         start = key + strlen("CISCO_SPLIT_INC_");
1181                 } else if (g_str_has_prefix(key, "CISCO_IPV6_SPLIT_INC_") == TRUE) {
1182                         *family = AF_INET6;
1183                         start = key + strlen("CISCO_IPV6_SPLIT_INC_");
1184                 } else
1185                         return -EINVAL;
1186
1187                 *idx = g_ascii_strtoull(start, &end, 10);
1188
1189                 if (strncmp(end, "_ADDR", 5) == 0)
1190                         *type = PROVIDER_ROUTE_TYPE_ADDR;
1191                 else if (strncmp(end, "_MASK", 5) == 0)
1192                         *type = PROVIDER_ROUTE_TYPE_MASK;
1193                 else if (strncmp(end, "_MASKLEN", 8) == 0 &&
1194                                 *family == AF_INET6) {
1195                         *type = PROVIDER_ROUTE_TYPE_MASK;
1196                 } else
1197                         return -EINVAL;
1198         }
1199
1200         return 0;
1201 }
1202
1203 int connman_provider_append_route(struct connman_provider *provider,
1204                                         const char *key, const char *value)
1205 {
1206         struct connman_route *route;
1207         int ret, family = 0;
1208         unsigned long idx = 0;
1209         enum provider_route_type type = PROVIDER_ROUTE_TYPE_NONE;
1210
1211         DBG("key %s value %s", key, value);
1212
1213         ret = route_env_parse(provider, key, &family, &idx, &type);
1214         if (ret < 0)
1215                 return ret;
1216
1217         DBG("idx %lu family %d type %d", idx, family, type);
1218
1219         route = g_hash_table_lookup(provider->routes, GINT_TO_POINTER(idx));
1220         if (route == NULL) {
1221                 route = g_try_new0(struct connman_route, 1);
1222                 if (route == NULL) {
1223                         connman_error("out of memory");
1224                         return -ENOMEM;
1225                 }
1226
1227                 route->family = family;
1228
1229                 g_hash_table_replace(provider->routes, GINT_TO_POINTER(idx),
1230                                                 route);
1231         }
1232
1233         switch (type) {
1234         case PROVIDER_ROUTE_TYPE_NONE:
1235                 break;
1236         case PROVIDER_ROUTE_TYPE_MASK:
1237                 route->netmask = g_strdup(value);
1238                 break;
1239         case PROVIDER_ROUTE_TYPE_ADDR:
1240                 route->host = g_strdup(value);
1241                 break;
1242         case PROVIDER_ROUTE_TYPE_GW:
1243                 route->gateway = g_strdup(value);
1244                 break;
1245         }
1246
1247         return 0;
1248 }
1249
1250 const char *connman_provider_get_driver_name(struct connman_provider *provider)
1251 {
1252         if (provider->driver == NULL)
1253                 return NULL;
1254
1255         return provider->driver->name;
1256 }
1257
1258 const char *connman_provider_get_save_group(struct connman_provider *provider)
1259 {
1260         return provider->identifier;
1261 }
1262
1263 static gint compare_priority(gconstpointer a, gconstpointer b)
1264 {
1265         return 0;
1266 }
1267
1268 static void clean_provider(gpointer key, gpointer value, gpointer user_data)
1269 {
1270         struct connman_provider *provider = value;
1271
1272         if (provider->driver != NULL && provider->driver->remove)
1273                 provider->driver->remove(provider);
1274 }
1275
1276 int connman_provider_driver_register(struct connman_provider_driver *driver)
1277 {
1278         DBG("driver %p name %s", driver, driver->name);
1279
1280         driver_list = g_slist_insert_sorted(driver_list, driver,
1281                                                         compare_priority);
1282         provider_create_all_from_type(driver->name);
1283         return 0;
1284 }
1285
1286 void connman_provider_driver_unregister(struct connman_provider_driver *driver)
1287 {
1288         DBG("driver %p name %s", driver, driver->name);
1289
1290         driver_list = g_slist_remove(driver_list, driver);
1291 }
1292
1293 static void provider_remove_all(gpointer key, gpointer value,
1294                                                 gpointer user_data)
1295 {
1296         struct connman_provider *provider = value;
1297
1298         __connman_provider_remove(provider->identifier);
1299 }
1300
1301 static void provider_offline_mode(connman_bool_t enabled)
1302 {
1303         DBG("enabled %d", enabled);
1304
1305         if (enabled == TRUE)
1306                 g_hash_table_foreach(provider_hash, provider_remove_all, NULL);
1307
1308 }
1309
1310 static struct connman_provider *provider_get(int index)
1311 {
1312         GHashTableIter iter;
1313         gpointer value, key;
1314
1315         g_hash_table_iter_init(&iter, provider_hash);
1316
1317         while (g_hash_table_iter_next(&iter, &key, &value) == TRUE) {
1318                 struct connman_provider *provider = value;
1319
1320                 if (provider->index == index)
1321                         return provider;
1322         }
1323
1324         return NULL;
1325 }
1326
1327 static void provider_service_changed(struct connman_service *service,
1328                                 enum connman_service_state state)
1329 {
1330         struct connman_provider *provider;
1331         int vpn_index, service_index;
1332
1333         if (service == NULL)
1334                 return;
1335
1336         switch (state) {
1337         case CONNMAN_SERVICE_STATE_UNKNOWN:
1338         case CONNMAN_SERVICE_STATE_IDLE:
1339         case CONNMAN_SERVICE_STATE_ASSOCIATION:
1340         case CONNMAN_SERVICE_STATE_CONFIGURATION:
1341         case CONNMAN_SERVICE_STATE_READY:
1342         case CONNMAN_SERVICE_STATE_ONLINE:
1343                 return;
1344         case CONNMAN_SERVICE_STATE_DISCONNECT:
1345         case CONNMAN_SERVICE_STATE_FAILURE:
1346                 break;
1347         }
1348
1349         service_index = __connman_service_get_index(service);
1350
1351         vpn_index = __connman_connection_get_vpn_index(service_index);
1352
1353         DBG("service %p %s state %d index %d/%d", service,
1354                 __connman_service_get_ident(service),
1355                 state, service_index, vpn_index);
1356
1357         if (vpn_index < 0)
1358                 return;
1359
1360         provider = provider_get(vpn_index);
1361         if (provider == NULL)
1362                 return;
1363
1364         DBG("disconnect %p index %d", provider, vpn_index);
1365
1366         __connman_provider_disconnect(provider);
1367
1368         return;
1369 }
1370
1371 static struct connman_notifier provider_notifier = {
1372         .name                   = "provider",
1373         .offline_mode           = provider_offline_mode,
1374         .service_state_changed  = provider_service_changed,
1375 };
1376
1377 int __connman_provider_init(void)
1378 {
1379         int err;
1380
1381         DBG("");
1382
1383         connection = connman_dbus_get_connection();
1384
1385         provider_hash = g_hash_table_new_full(g_str_hash, g_str_equal,
1386                                                 NULL, unregister_provider);
1387
1388         err = connman_notifier_register(&provider_notifier);
1389         if (err < 0) {
1390                 g_hash_table_destroy(provider_hash);
1391                 dbus_connection_unref(connection);
1392         }
1393
1394         return err;
1395 }
1396
1397 void __connman_provider_cleanup(void)
1398 {
1399         DBG("");
1400
1401         connman_notifier_unregister(&provider_notifier);
1402
1403         g_hash_table_foreach(provider_hash, clean_provider, NULL);
1404
1405         g_hash_table_destroy(provider_hash);
1406         provider_hash = NULL;
1407
1408         dbus_connection_unref(connection);
1409 }