src/mesh-service-interface.c

   1 /*
   2  * Network Configuration Module
   3  *
   4  * Copyright (c) 2017 Samsung Electronics Co., Ltd. All rights reserved.
   5  *
   6  * Licensed under the Apache License, Version 2.0 (the "License");
   7  * you may not use this file except in compliance with the License.
   8  * You may obtain a copy of the License at
   9  *
  10  * http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  *
  18  */
  19 #include <stdlib.h>
  20 #include <string.h>
  21
  22 #include <glib.h>
  23 #include <gio/gio.h>
  24
  25 #include "mesh.h"
  26 #include "mesh-log.h"
  27 #include "mesh-util.h"
  28 #include "mesh-gdbus.h"
  29 #include "mesh-service.h"
  30 #include "mesh-service-interface.h"
  31 #include "mesh-generated-code.h"
  32
  33 #include "mesh-request.h"
  34 #include "mesh-interface.h"
  35
  36 static NetMesh *meshd_dbus_object;
  37 static Manager *meshd_activator_dbus_object;
  38
  39 /* global list to care resource handle for each client */
  40 static GList *meshd_dbus_client_list;
  41 static GMutex meshd_dbus_client_list_mutex;
  42
  43 typedef struct _meshd_dbus_client_s {
  44         gchar *bus_name;
  45 } meshd_dbus_client_s;
  46
  47 NetMesh* meshd_dbus_get_object()
  48 {
  49         return meshd_dbus_object;
  50 }
  51
  52 int64_t meshd_dbus_generate_signal_number()
  53 {
  54         static int64_t i = 0;
  55
  56         return i++;
  57 }
  58
  59 static int _meshd_dbus_client_list_cleanup(GList *client_list)
  60 {
  61         meshd_dbus_client_s *client;
  62
  63         meshd_check_null_ret_error("client_list", client_list, FALSE);
  64
  65         client = client_list->data;
  66
  67         free(client->bus_name);
  68         client->bus_name = NULL;
  69         free(client);
  70         g_list_free(client_list);
  71
  72         return MESHD_ERROR_NONE;
  73 }
  74
  75 static int _meshd_dbus_client_list_compare_bus_name(const void *a, const void *b)
  76 {
  77         const meshd_dbus_client_s *client = a;
  78
  79         return g_strcmp0(client->bus_name, b);
  80 }
  81
  82 static inline GList* _meshd_dbus_client_list_find_client(const gchar *owner)
  83 {
  84         return g_list_find_custom(meshd_dbus_client_list, owner,
  85                         _meshd_dbus_client_list_compare_bus_name);
  86 }
  87
  88 static void _meshd_dbus_name_owner_changed_cb(GDBusConnection *conn,
  89                 const gchar *sender_name,
  90                 const gchar *object_path,
  91                 const gchar *interface_name,
  92                 const gchar *signal_name,
  93                 GVariant *parameters,
  94                 gpointer user_data)
  95 {
  96         int ret;
  97         GList *client = NULL;
  98         gchar *name, *old_owner, *new_owner;
  99
 100         NOTUSED(conn);
 101         NOTUSED(sender_name);
 102         NOTUSED(object_path);
 103         NOTUSED(interface_name);
 104         NOTUSED(signal_name);
 105         NOTUSED(user_data);
 106
 107         g_variant_get(parameters, "(&s&s&s)", &name, &old_owner, &new_owner);
 108
 109         if (0 == strlen(new_owner)) {
 110                 g_mutex_lock(&meshd_dbus_client_list_mutex);
 111                 client = _meshd_dbus_client_list_find_client(old_owner);
 112                 if (client) { /* found bus name in our bus list */
 113                         MESH_LOGD("bus(%s) stopped", old_owner);
 114                         meshd_dbus_client_list = g_list_remove_link(meshd_dbus_client_list, client);
 115                 }
 116                 g_mutex_unlock(&meshd_dbus_client_list_mutex);
 117
 118                 if (client) {
 119                         ret = _meshd_dbus_client_list_cleanup(client);
 120                         if (MESHD_ERROR_NONE != ret)
 121                                 MESH_LOGE("_meshd_dbus_client_list_cleanup() Fail(%d)", ret);
 122                 }
 123         }
 124 }
 125
 126 static int _meshd_dbus_subscribe_name_owner_changed(GDBusConnection *conn)
 127 {
 128         unsigned int id;
 129
 130         id = g_dbus_connection_signal_subscribe(conn,
 131                         "org.freedesktop.DBus", /* bus name */
 132                         "org.freedesktop.DBus", /* interface */
 133                         "NameOwnerChanged", /* member */
 134                         "/org/freedesktop/DBus", /* path */
 135                         NULL, /* arg0 */
 136                         G_DBUS_SIGNAL_FLAGS_NONE,
 137                         _meshd_dbus_name_owner_changed_cb,
 138                         NULL,
 139                         NULL);
 140         if (0 == id) {
 141                 MESH_LOGE("g_dbus_connection_signal_subscribe() Fail");
 142                 return MESHD_ERROR_IO_ERROR;
 143         }
 144
 145         return MESHD_ERROR_NONE;
 146 }
 147
 148 static gboolean _meshd_dbus_handle_enable(Manager *object,
 149                 GDBusMethodInvocation *invocation,
 150                 gpointer user_data)
 151 {
 152         int ret = MESHD_ERROR_NONE;
 153         mesh_service *service = (mesh_service *)user_data;
 154         mesh_interface_s *info = service->interface_info;
 155
 156         if (service->mesh_activated) {
 157                 /* Already activated */
 158                 manager_complete_enable(object, invocation,
 159                                 MESHD_ERROR_OPERATION_FAILED);
 160         } else {
 161                 /* Do API response first */
 162                 manager_complete_enable(object, invocation, ret);
 163                 service->mesh_activated = TRUE;
 164         }
 165
 166         meshd_check_null_ret_error("info", info, FALSE);
 167
 168         /* Register event handler first */
 169         ret = mesh_request_register_event_handler();
 170         if (MESHD_ERROR_NONE != ret)
 171                 MESH_LOGE("Failed to register mesh event handler !! [%d]", ret);
 172
 173         ret = mesh_interface_initialize(service->interface_info);
 174         if (MESHD_ERROR_NONE != ret) {
 175                 MESH_LOGE("Failed to mesh_interface_initialize [%d]", ret);
 176                 goto FINISH;
 177         }
 178 #if 0
 179         ret = mesh_request_load_saved_mesh_network(&service->saved_mesh_network);
 180         if (MESHD_ERROR_NONE != ret) {
 181                 MESH_LOGE("Failed to mesh_request_load_saved_mesh_network [%d]", ret);
 182                 goto FINISH;
 183         }
 184 #endif
 185 FINISH:
 186         net_mesh_emit_mesh_enabled(meshd_dbus_get_object(), ret);
 187
 188         return TRUE;
 189 }
 190
 191 static gboolean _meshd_dbus_handle_disable(Manager *object,
 192                 GDBusMethodInvocation *invocation,
 193                 gpointer user_data)
 194 {
 195         int ret = MESHD_ERROR_NONE;
 196         mesh_service *service = (mesh_service *)user_data;
 197         mesh_interface_s *info = service->interface_info;
 198
 199         meshd_check_null_ret_error("info", info, FALSE);
 200
 201         /* Make response first */
 202         manager_complete_disable(object, invocation, ret);
 203
 204         ret = mesh_request_unregister_event_handler();
 205         if (MESHD_ERROR_NONE != ret)
 206                 MESH_LOGE("Failed to unregister mesh event handler !! [%d]", ret);
 207
 208         /* Terminate daemon */
 209         meshd_service_exit(service);
 210
 211         return TRUE;
 212 }
 213
 214 static gboolean _meshd_dbus_handle_scan(NetMesh *object,
 215                 GDBusMethodInvocation *invocation,
 216                 gpointer user_data)
 217 {
 218         int ret = MESHD_ERROR_NONE;
 219         mesh_service *service = (mesh_service *)user_data;
 220         mesh_interface_s *info = service->interface_info;
 221
 222         meshd_check_null_ret_error("info", info, FALSE);
 223
 224         ret = mesh_request_scan(service);
 225         if (MESHD_ERROR_NONE != ret)
 226                 MESH_LOGE("Failed to mesh_request_scan !");
 227
 228         net_mesh_complete_scan(object, invocation, ret);
 229
 230         return TRUE;
 231 }
 232
 233 static gboolean _meshd_dbus_handle_specific_scan(NetMesh *object,
 234                 GDBusMethodInvocation *invocation,
 235                 gchar *mesh_id,
 236                 gint channel,
 237                 gpointer user_data)
 238 {
 239         int ret = MESHD_ERROR_NONE;
 240         mesh_service *service = (mesh_service *)user_data;
 241         mesh_interface_s *info = service->interface_info;
 242
 243         meshd_check_null_ret_error("info", info, FALSE);
 244
 245         ret = mesh_request_specific_scan(service, mesh_id, channel);
 246         if (MESHD_ERROR_NONE != ret)
 247                 MESH_LOGE("Failed to mesh_request_specific_scan !");
 248
 249         net_mesh_complete_specific_scan(object, invocation, ret);
 250
 251         return TRUE;
 252 }
 253
 254 static gboolean _meshd_dbus_handle_cancel_scan(NetMesh *object,
 255                 GDBusMethodInvocation *invocation,
 256                 gpointer user_data)
 257 {
 258         int ret = MESHD_ERROR_NONE;
 259         mesh_service *service = (mesh_service *)user_data;
 260
 261         ret = mesh_request_cancel_scan(service);
 262         if (MESHD_ERROR_NONE != ret)
 263                 MESH_LOGE("Failed to mesh_request_cancel_scan");
 264
 265         net_mesh_complete_cancel_scan(object, invocation, ret);
 266
 267         return TRUE;
 268 }
 269
 270 static void _on_scan_result_destroy(gpointer data)
 271 {
 272         mesh_scan_result_s *scan_item = (mesh_scan_result_s *)data;
 273
 274         if (scan_item) {
 275                 g_free(scan_item->mesh_id);
 276                 g_free(scan_item->bssid);
 277                 g_free(scan_item->object_path);
 278         }
 279         g_free(scan_item);
 280 }
 281
 282 static void _on_peer_info_destroy(gpointer data)
 283 {
 284         mesh_peer_info_s *peer = (mesh_peer_info_s *)data;
 285         if (peer)
 286                 g_free(peer->address);
 287         g_free(peer);
 288 }
 289
 290 static void _on_station_list_destroy(gpointer data)
 291 {
 292         mesh_station_info_s *info = (mesh_station_info_s*)data;
 293
 294         if (info) {
 295                 g_free(info->bssid);
 296                 g_free(info);
 297         }
 298 }
 299
 300 static void _on_mpath_list_destroy(gpointer data)
 301 {
 302         mesh_mpath_info_s *info = (mesh_mpath_info_s*)data;
 303
 304         if (info) {
 305                 g_free(info->dest_addr);
 306                 g_free(info->next_hop);
 307                 g_free(info->interface);
 308                 g_free(info);
 309         }
 310 }
 311
 312 static gboolean _meshd_dbus_handle_get_found_mesh_networks(NetMesh *object,
 313                 GDBusMethodInvocation *invocation,
 314                 gpointer user_data)
 315 {
 316         int ret = MESHD_ERROR_NONE;
 317         mesh_service *service = (mesh_service *)user_data;
 318
 319         GVariantBuilder builder;
 320         GVariant* networks;
 321         GList *iter = NULL;
 322         mesh_scan_result_s *scan_item = NULL;
 323
 324         MESH_LOGD("Request to get scanned mesh network list");
 325
 326         ret = mesh_request_get_networks(service);
 327         if (MESHD_ERROR_NONE != ret)
 328                 MESH_LOGE("Failed to mesh_request_get_networks");
 329
 330         g_variant_builder_init(&builder, G_VARIANT_TYPE("aa{sv}"));
 331
 332         /* scanned_mesh_network would be filled above request */
 333         iter = service->scanned_mesh_network;
 334         while (iter != NULL) {
 335                 scan_item = (mesh_scan_result_s*)iter->data;
 336
 337                 g_variant_builder_open(&builder, G_VARIANT_TYPE_VARDICT);
 338                 g_variant_builder_add(&builder, "{sv}", "mesh_id",
 339                                 g_variant_new_string(scan_item->mesh_id));
 340                 g_variant_builder_add(&builder, "{sv}", "bssid",
 341                                 g_variant_new_string(scan_item->bssid));
 342                 g_variant_builder_add(&builder, "{sv}", "rssi",
 343                                 g_variant_new_int32(scan_item->rssi));
 344                 g_variant_builder_add(&builder, "{sv}", "channel",
 345                                 g_variant_new_uint32(scan_item->channel));
 346                 g_variant_builder_add(&builder, "{sv}", "security",
 347                                 g_variant_new_uint32((int)scan_item->security));
 348                 g_variant_builder_add(&builder, "{sv}", "state",
 349                                 g_variant_new_uint32(scan_item->state));
 350                 g_variant_builder_close(&builder);
 351
 352                 iter = g_list_next(iter);
 353         }
 354
 355         networks = g_variant_builder_end(&builder);
 356
 357         net_mesh_complete_get_found_mesh_networks(object, invocation, networks, ret);
 358
 359         return TRUE;
 360 }
 361
 362 static gboolean _meshd_dbus_handle_enable_mesh(NetMesh *object,
 363                 GDBusMethodInvocation *invocation,
 364                 gpointer user_data)
 365 {
 366         int ret = MESHD_ERROR_NONE;
 367         mesh_service *service = (mesh_service *)user_data;
 368
 369         /* It handles creating virtual network and bridge */
 370         ret = mesh_request_enable_network(service);
 371         if (MESHD_ERROR_NONE != ret)
 372                 MESH_LOGE("Failed to mesh_request_enable_network [%d]", ret);
 373
 374 #if 0
 375         /* Detect external network state (i.e. Ethernet)
 376                         and decide to make gate enabled */
 377         ret = mesh_request_set_mesh_gate(info->bridge_interface,
 378                         info->mesh_interface, info->external_interface);
 379         if (MESHD_ERROR_NONE != ret)
 380                 MESH_LOGE("Failed to mesh_request_set_mesh_gate [%d]", ret);
 381 #endif
 382
 383         net_mesh_complete_enable_mesh(object, invocation, ret);
 384
 385         return TRUE;
 386 }
 387
 388 static gboolean _meshd_dbus_handle_disable_mesh(NetMesh *object,
 389                 GDBusMethodInvocation *invocation,
 390                 gpointer user_data)
 391 {
 392         int ret = MESHD_ERROR_NONE;
 393         mesh_service *service = (mesh_service *)user_data;
 394         mesh_interface_s *info = service->interface_info;
 395
 396         meshd_check_null_ret_error("info", info, FALSE);
 397
 398         if (FALSE == service->mesh_activated) {
 399                 MESH_LOGD("Mesh network is not activated yet");
 400                 ret = MESHD_ERROR_OPERATION_FAILED;
 401                 net_mesh_complete_disable_mesh(object, invocation, ret);
 402                 return TRUE;
 403         }
 404
 405         ret = mesh_request_disable_network(service);
 406         if (MESHD_ERROR_NONE != ret)
 407                 MESH_LOGE("Failed to disable mesh network !");
 408
 409         /* Make response */
 410         net_mesh_complete_disable_mesh(object, invocation, ret);
 411
 412         return TRUE;
 413 }
 414
 415 static gboolean _meshd_dbus_handle_get_joined_mesh_network(NetMesh *object,
 416                 GDBusMethodInvocation *invocation,
 417                 gpointer user_data)
 418 {
 419         int ret = MESHD_ERROR_NONE;
 420         mesh_service *service = (mesh_service *)user_data;
 421         mesh_network_info_s *joined = NULL;
 422
 423         ret = mesh_request_get_joined_network(service);
 424         if (MESHD_ERROR_NONE == ret) {
 425                 joined = service->joined_network;
 426                 if (joined) {
 427                         net_mesh_complete_get_joined_mesh_network(object, invocation,
 428                                 joined->mesh_id, joined->bssid,
 429                                 joined->channel, (int)joined->security,
 430                                 joined->state, ret);
 431                 } else {
 432                         net_mesh_complete_get_joined_mesh_network(object, invocation,
 433                                 "", "", 0, 0, 0, MESHD_ERROR_NO_DATA);
 434                 }
 435         } else {
 436                 net_mesh_complete_get_joined_mesh_network(object, invocation,
 437                         "", "", 0, 0, 0, ret);
 438         }
 439
 440         return TRUE;
 441 }
 442
 443 static gboolean _meshd_dbus_handle_get_connected_peers(NetMesh *object,
 444                 GDBusMethodInvocation *invocation,
 445                 gpointer user_data)
 446 {
 447         int ret = MESHD_ERROR_NONE;
 448         mesh_service *service = (mesh_service *)user_data;
 449
 450         GVariantBuilder builder;
 451         GVariant* peer_list;
 452         GList *iter = NULL;
 453         mesh_peer_info_s *peer = NULL;
 454
 455         MESH_LOGD("Request to get connected peers");
 456
 457         ret = mesh_request_get_connected_peers(service);
 458         if (MESHD_ERROR_NONE != ret)
 459                 MESH_LOGE("Failed to mesh_request_get_connected_peers");
 460         g_variant_builder_init(&builder, G_VARIANT_TYPE("aa{sv}"));
 461
 462         iter = service->connected_mesh_peers;
 463         while (iter != NULL) {
 464                 peer = (mesh_peer_info_s*)iter->data;
 465
 466                 g_variant_builder_open(&builder, G_VARIANT_TYPE_VARDICT);
 467                 g_variant_builder_add(&builder, "{sv}", "Address",
 468                                 g_variant_new_string(peer->address));
 469                 g_variant_builder_close(&builder);
 470
 471                 iter = g_list_next(iter);
 472         }
 473
 474         peer_list = g_variant_builder_end(&builder);
 475
 476         net_mesh_complete_get_connected_peers(object, invocation, peer_list, ret);
 477
 478         return TRUE;
 479 }
 480
 481 static gboolean _meshd_dbus_handle_set_gate(NetMesh *object,
 482                 GDBusMethodInvocation *invocation, gboolean stp, gboolean gate_announce,
 483                 gpointer user_data)
 484 {
 485         int ret = MESHD_ERROR_NONE;
 486         mesh_service *service = (mesh_service *)user_data;
 487         mesh_interface_s *info = service->interface_info;
 488
 489         MESH_LOGD("STP = %d", stp);
 490         MESH_LOGD("gate_announce = %d", gate_announce);
 491
 492         /* Set STP and gate_announce */
 493         ret = mesh_request_set_mesh_gate(info->bridge_interface,
 494                         info->mesh_interface, info->external_interface);
 495         if (MESHD_ERROR_NONE != ret)
 496                 MESH_LOGE("Failed to mesh_request_set_mesh_gate [%d]", ret);
 497
 498         net_mesh_complete_set_gate(object, invocation, ret);
 499
 500         return TRUE;
 501 }
 502
 503 static gboolean _meshd_dbus_handle_unset_gate(NetMesh *object,
 504                 GDBusMethodInvocation *invocation,
 505                 gpointer user_data)
 506 {
 507         int ret = MESHD_ERROR_NONE;
 508         mesh_service *service = (mesh_service *)user_data;
 509         mesh_interface_s *info = service->interface_info;
 510
 511         ret = mesh_request_unset_mesh_gate(info->bridge_interface,
 512                         info->mesh_interface, info->external_interface);
 513         if (MESHD_ERROR_NONE != ret)
 514                 MESH_LOGE("Failed to mesh_request_unset_mesh_gate [%d]", ret);
 515
 516         net_mesh_complete_unset_gate(object, invocation, ret);
 517
 518         return TRUE;
 519 }
 520
 521 static gboolean _meshd_dbus_handle_set_softap(NetMesh *object,
 522                 GDBusMethodInvocation *invocation,
 523                 gchar *ssid, gchar *passphrase,
 524                 gchar *mode, gint channel, gint visibility, gint max_sta,
 525                 gint security, gpointer user_data)
 526 {
 527         int ret = MESHD_ERROR_NONE;
 528         mesh_service *service = (mesh_service *)user_data;
 529         mesh_interface_s *info = service->interface_info;
 530
 531         MESH_LOGD("SSID      : %s", ssid);
 532         MESH_LOGD("mode      : %s", mode);
 533         MESH_LOGD("channel   : %d", channel);
 534         MESH_LOGD("visibility: %d", visibility);
 535         MESH_LOGD("max_sta   : %d", max_sta);
 536         MESH_LOGD("security  : %d", security);
 537
 538         /* Save softAP information */
 539         ret = mesh_request_set_softap_config(info->softap_interface,
 540                 ssid, mode, channel, visibility, max_sta,
 541                 security, passphrase);
 542         if (MESHD_ERROR_NONE != ret)
 543                 MESH_LOGE("Failed to mesh_request_set_softap_config [%d]", ret);
 544
 545         net_mesh_complete_set_softap(object, invocation, ret);
 546
 547         return TRUE;
 548 }
 549
 550 static gboolean _meshd_dbus_handle_enable_softap(NetMesh *object,
 551                 GDBusMethodInvocation *invocation, gpointer user_data)
 552 {
 553         int ret = MESHD_ERROR_NONE;
 554         mesh_service *service = (mesh_service *)user_data;
 555         mesh_interface_s *info = service->interface_info;
 556
 557         /* Check softAP interface and execute it */
 558         ret = mesh_request_enable_softap(info->bridge_interface, info->softap_interface);
 559         if (MESHD_ERROR_NONE != ret)
 560                 MESH_LOGE("Failed to mesh_request_enable_softap [%d]", ret);
 561
 562         net_mesh_complete_enable_softap(object, invocation, ret);
 563
 564         return TRUE;
 565 }
 566
 567 static gboolean _meshd_dbus_handle_disable_softap(NetMesh *object,
 568                 GDBusMethodInvocation *invocation, gpointer user_data)
 569 {
 570         int ret = MESHD_ERROR_NONE;
 571         mesh_service *service = (mesh_service *)user_data;
 572         mesh_interface_s *info = service->interface_info;
 573
 574         /* Destroy softAP */
 575         ret = mesh_request_disable_softap(info->bridge_interface, info->softap_interface);
 576         if (MESHD_ERROR_NONE != ret)
 577                 MESH_LOGE("Failed to mesh_request_disable_softap [%d]", ret);
 578
 579         net_mesh_complete_disable_softap(object, invocation, ret);
 580
 581         return TRUE;
 582 }
 583
 584 static gboolean _meshd_dbus_handle_create_mesh_network(NetMesh *object,
 585                 GDBusMethodInvocation *invocation,
 586                 gchar *mesh_id, gint channel, gint security,
 587                 gpointer user_data)
 588 {
 589         int ret = MESHD_ERROR_NONE;
 590         mesh_service *service = (mesh_service *)user_data;
 591         meshd_security_type_e sec = (1 == security) ? MESHD_SECURITY_SAE : MESHD_SECURITY_NONE;
 592
 593         ret = mesh_request_create_mesh_network(service, mesh_id, channel, sec);
 594
 595         net_mesh_complete_create_mesh_network(object, invocation, ret);
 596
 597         return TRUE;
 598 }
 599
 600 static gboolean _meshd_dbus_handle_connect_mesh_network(NetMesh *object,
 601                 GDBusMethodInvocation *invocation,
 602                 gchar *mesh_id, gint channel, gint security, gchar *passphrase,
 603                 gpointer user_data)
 604 {
 605         int ret = MESHD_ERROR_NONE;
 606         mesh_service *service = (mesh_service *)user_data;
 607         meshd_security_type_e sec = (1 == security) ? MESHD_SECURITY_SAE : MESHD_SECURITY_NONE;
 608
 609         ret = mesh_request_connect_mesh_network(service, mesh_id, channel, sec, passphrase);
 610
 611         net_mesh_complete_connect_mesh_network(object, invocation, ret);
 612
 613         return TRUE;
 614 }
 615 static gboolean _meshd_dbus_handle_disconnect_mesh_network(NetMesh *object,
 616                 GDBusMethodInvocation *invocation,
 617                 gchar *mesh_id, gint channel, gint security,
 618                 gpointer user_data)
 619 {
 620         int ret = MESHD_ERROR_NONE;
 621         mesh_service *service = (mesh_service *)user_data;
 622         meshd_security_type_e sec = (1 == security) ? MESHD_SECURITY_SAE : MESHD_SECURITY_NONE;
 623
 624         ret = mesh_request_disconnect_mesh_network(service, mesh_id, channel, sec);
 625
 626         net_mesh_complete_disconnect_mesh_network(object, invocation, ret);
 627
 628         return TRUE;
 629 }
 630
 631 static gboolean _meshd_dbus_handle_forget_mesh_network(NetMesh *object,
 632                 GDBusMethodInvocation *invocation,
 633                 gchar *mesh_id, gint channel, gint security,
 634                 gpointer user_data)
 635 {
 636         int ret = MESHD_ERROR_NONE;
 637         mesh_service *service = (mesh_service *)user_data;
 638         meshd_security_type_e sec = (1 == security) ? MESHD_SECURITY_SAE : MESHD_SECURITY_NONE;
 639
 640         ret = mesh_request_remove_mesh_network(service, mesh_id, channel, sec);
 641
 642         net_mesh_complete_forget_mesh_network(object, invocation, ret);
 643
 644         return TRUE;
 645 }
 646
 647 static gboolean _meshd_dbus_handle_set_interfaces(NetMesh *object,
 648                 GDBusMethodInvocation *invocation,
 649                 gchar *mesh, gchar *gate, gchar *softap,
 650                 gpointer user_data)
 651 {
 652         int ret = MESHD_ERROR_NONE;
 653         mesh_service *service = (mesh_service *)user_data;
 654         mesh_interface_s *info = service->interface_info;
 655
 656         g_free(info->mesh_interface);
 657         info->mesh_interface = g_strdup(mesh);
 658
 659         g_free(info->external_interface);
 660         info->external_interface = g_strdup(gate);
 661
 662         g_free(info->softap_interface);
 663         info->softap_interface = g_strdup(softap);
 664
 665         MESH_LOGD("Interface configuration for mesh network :");
 666         MESH_LOGD("  Base    : [%s]", info->base_interface);
 667         MESH_LOGD("  Mesh    : [%s]", info->mesh_interface);
 668         MESH_LOGD("  Bridge  : [%s]", info->bridge_interface);
 669         MESH_LOGD("  SoftAP  : [%s]", info->softap_interface);
 670         MESH_LOGD("  External: [%s]", info->external_interface);
 671
 672         net_mesh_complete_set_interfaces(object, invocation, ret);
 673
 674         return TRUE;
 675 }
 676
 677 static gboolean _meshd_dbus_handle_get_station_info(NetMesh *object,
 678                 GDBusMethodInvocation *invocation,
 679                 gpointer user_data)
 680 {
 681         int ret = MESHD_ERROR_NONE;
 682
 683         GVariantBuilder builder;
 684         GVariant* station;
 685         GList *iter = NULL;
 686
 687         mesh_service *service = (mesh_service *)user_data;
 688         mesh_interface_s *info = service->interface_info;
 689
 690         /* Clear mesh station list */
 691         g_list_free_full(service->station_list, _on_station_list_destroy);
 692         service->station_list = NULL;
 693
 694         ret = mesh_request_get_station_info(
 695                                 info->mesh_interface, &service->station_list);
 696         if (MESHD_ERROR_NONE != ret) {
 697                 MESH_LOGE("Failed to mesh_request_get_station_info");
 698
 699                 g_dbus_method_invocation_return_error(invocation,
 700                                 G_DBUS_ERROR, G_DBUS_ERROR_FAILED, "Request Failed");
 701         } else {
 702         /*
 703          * sh-3.2#  iw mesh0 station dump
 704          * Station 7c:dd:90:62:37:cf (on mesh0)
 705          * inactive time:       1685 ms
 706          * rx bytes:    34174
 707          * rx packets:  1181
 708          * tx bytes:    6877
 709          * tx packets:  76
 710          * tx retries:  0
 711          * tx failed:   0
 712          * beacon loss: 0
 713          * signal:              -64 dBm
 714          * signal avg:  -63 dBm
 715          * tx bitrate:  54.0 MBit/s
 716          * rx bitrate:  5.5 MBit/s
 717          * mesh llid:   51731
 718          * mesh plid:   35432
 719          * mesh plink:  ESTAB
 720          * mesh local PS mode:  ACTIVE
 721          * mesh peer PS mode:   ACTIVE
 722          * mesh non-peer PS mode:       ACTIVE
 723          * authorized:  yes
 724          * authenticated:       yes
 725          * associated:  yes
 726          * preamble:    long
 727          * WMM/WME:     yes
 728          * MFP:         no
 729          * TDLS peer:   no
 730          * DTIM period: 0
 731          * beacon interval:1000
 732          * short slot time:yes
 733          * connected time:      256 seconds
 734          */
 735                 /* Get station information and make variant data */
 736                 g_variant_builder_init(&builder, G_VARIANT_TYPE("aa{sv}"));
 737
 738                 iter = service->station_list;
 739                 while (iter != NULL) {
 740                         mesh_station_info_s *item = (mesh_station_info_s*)iter->data;
 741
 742                         g_variant_builder_open(&builder, G_VARIANT_TYPE_VARDICT);
 743                         g_variant_builder_add(&builder, "{sv}", "bssid",
 744                                                 g_variant_new_string(item->bssid));
 745                         g_variant_builder_add(&builder, "{sv}", "inactive_time",
 746                                                 g_variant_new_uint32(item->inactive_time));
 747                         g_variant_builder_add(&builder, "{sv}", "rx_bytes",
 748                                                 g_variant_new_uint64(item->rx_bytes));
 749                         g_variant_builder_add(&builder, "{sv}", "rx_packets",
 750                                                 g_variant_new_uint32(item->rx_packets));
 751                         g_variant_builder_add(&builder, "{sv}", "tx_bytes",
 752                                                 g_variant_new_uint64(item->tx_bytes));
 753                         g_variant_builder_add(&builder, "{sv}", "tx_packets",
 754                                                 g_variant_new_uint32(item->tx_packets));
 755                         g_variant_builder_add(&builder, "{sv}", "tx_retries",
 756                                                 g_variant_new_uint32(item->tx_retries));
 757                         g_variant_builder_add(&builder, "{sv}", "tx_failed",
 758                                                 g_variant_new_uint32(item->tx_failed));
 759                         g_variant_builder_add(&builder, "{sv}", "beacon_loss",
 760                                                 g_variant_new_uint32(item->beacon_loss));
 761                         g_variant_builder_add(&builder, "{sv}", "beacon_rx",
 762                                                 g_variant_new_uint64(item->beacon_rx));
 763                         g_variant_builder_add(&builder, "{sv}", "rx_drop_misc",
 764                                                 g_variant_new_uint64(item->rx_drop_misc));
 765                         g_variant_builder_add(&builder, "{sv}", "signal",
 766                                                 g_variant_new_int32(item->rssi));
 767                         g_variant_builder_add(&builder, "{sv}", "signal_avg",
 768                                                 g_variant_new_int32(item->rssi_avg));
 769                         g_variant_builder_add(&builder, "{sv}", "tx_bitrate",
 770                                                 g_variant_new_uint32(item->tx_bitrate)); /* 10 times */
 771                         g_variant_builder_add(&builder, "{sv}", "rx_bitrate",
 772                                                 g_variant_new_uint32(item->rx_bitrate)); /* 10 times */
 773                         g_variant_builder_add(&builder, "{sv}", "mesh_llid",
 774                                                 g_variant_new_uint16(item->llid));
 775                         g_variant_builder_add(&builder, "{sv}", "mesh_plid",
 776                                                 g_variant_new_uint16(item->plid));
 777                         g_variant_builder_add(&builder, "{sv}", "mesh_plink",
 778                                                 g_variant_new_byte(item->mesh_plink)); /* 0 : DISCON, 1 : ESTAB */
 779                         g_variant_builder_add(&builder, "{sv}", "local_ps_mode",
 780                                                 g_variant_new_uint32(item->local_ps_mode)); /* 0 : INACTIVE, 1 : ACTIVE */
 781                         g_variant_builder_add(&builder, "{sv}", "peer_ps_mode",
 782                                                 g_variant_new_uint32(item->peer_ps_mode)); /* 0 : INACTIVE, 1 : ACTIVE */
 783                         g_variant_builder_add(&builder, "{sv}", "non_peer_ps_mode",
 784                                                 g_variant_new_uint32(item->non_peer_ps_mode)); /* 0 : INACTIVE, 1 : ACTIVE */
 785                         g_variant_builder_add(&builder, "{sv}", "authorized",
 786                                                 g_variant_new_boolean(item->authorized));
 787                         g_variant_builder_add(&builder, "{sv}", "associated",
 788                                                 g_variant_new_boolean(item->associated));
 789                         g_variant_builder_add(&builder, "{sv}", "preamble",
 790                                                 g_variant_new_boolean(item->preamble));
 791                         g_variant_builder_add(&builder, "{sv}", "WMM_WME",
 792                                                 g_variant_new_boolean(item->wme));
 793                         g_variant_builder_add(&builder, "{sv}", "MFP",
 794                                                 g_variant_new_boolean(item->mfp));
 795                         g_variant_builder_add(&builder, "{sv}", "TDLS_peer",
 796                                                 g_variant_new_boolean(item->tdls_peer));
 797                         g_variant_builder_add(&builder, "{sv}", "DTIM_period",
 798                                                 g_variant_new_byte(item->dtim_period));
 799                         g_variant_builder_add(&builder, "{sv}", "beacon_interval",
 800                                                 g_variant_new_uint16(item->beacon_interval));
 801                         g_variant_builder_add(&builder, "{sv}", "short_slot_time",
 802                                                 g_variant_new_boolean(item->short_slot_time));
 803                         g_variant_builder_add(&builder, "{sv}", "connected_time",
 804                                                 g_variant_new_uint32(item->connected_time));
 805                         g_variant_builder_close(&builder);
 806
 807                         iter = g_list_next(iter);
 808                 }
 809
 810                 station = g_variant_builder_end(&builder);
 811                 net_mesh_complete_get_station_info(object, invocation, station, ret);
 812
 813                 g_object_unref(station);
 814         }
 815
 816         return TRUE;
 817 }
 818
 819 static gboolean _meshd_dbus_handle_get_mpath_info(NetMesh *object,
 820                 GDBusMethodInvocation *invocation,
 821                 gpointer user_data)
 822 {
 823         int ret = MESHD_ERROR_NONE;
 824         GVariantBuilder builder;
 825         GVariant* mpath_data;
 826         GList *iter = NULL;
 827
 828         mesh_service *service = (mesh_service *)user_data;
 829         mesh_interface_s *info = service->interface_info;
 830
 831         /* Clear mesh path list */
 832         g_list_free_full(service->mpath_list, _on_mpath_list_destroy);
 833         service->mpath_list = NULL;
 834
 835         ret = mesh_request_get_mpath_info(
 836                                 info->mesh_interface, &service->mpath_list);
 837         if (MESHD_ERROR_NONE != ret) {
 838                 MESH_LOGE("Failed to mesh_request_get_mpath_info");
 839
 840                 g_dbus_method_invocation_return_error(invocation,
 841                                 G_DBUS_ERROR, G_DBUS_ERROR_FAILED, "Request Failed");
 842         } else {
 843         /*
 844          * Example) sh-3.2# iw mesh0 mpath dump
 845          * DEST ADDR         NEXT HOP          IFACE    SN      METRIC  QLEN    EXPTIME         DTIM    DRET    FLAGS
 846          * 7c:dd:90:62:37:cf 7c:dd:90:62:37:cf mesh0    221     152             0               10                      100             0               0x5
 847          */
 848                 /* Get mesh path information and make variant data */
 849                 g_variant_builder_init(&builder, G_VARIANT_TYPE("aa{sv}"));
 850
 851                 iter = service->mpath_list;
 852                 while (iter != NULL) {
 853                         mesh_mpath_info_s *item = (mesh_mpath_info_s*)iter->data;
 854
 855                         g_variant_builder_open(&builder, G_VARIANT_TYPE_VARDICT);
 856                         g_variant_builder_add(&builder, "{sv}", "DEST_ADDR",
 857                                                 g_variant_new_string(item->dest_addr));
 858                         g_variant_builder_add(&builder, "{sv}", "NEXT_HOP",
 859                                                 g_variant_new_string(item->next_hop));
 860                         g_variant_builder_add(&builder, "{sv}", "IFACE",
 861                                                 g_variant_new_string(item->interface));
 862                         g_variant_builder_add(&builder, "{sv}", "SN",
 863                                                 g_variant_new_uint32(item->sn));
 864                         g_variant_builder_add(&builder, "{sv}", "METRIC",
 865                                                 g_variant_new_uint32(item->metric));
 866                         g_variant_builder_add(&builder, "{sv}", "QLEN",
 867                                                 g_variant_new_uint32(item->qlen));
 868                         g_variant_builder_add(&builder, "{sv}", "EXPTIME",
 869                                                 g_variant_new_uint32(item->exptime));
 870                         g_variant_builder_add(&builder, "{sv}", "DTIM",
 871                                                 g_variant_new_uint32(item->discovery_timeout));
 872                         g_variant_builder_add(&builder, "{sv}", "DRET",
 873                                                 g_variant_new_byte(item->discovery_retries));
 874                         g_variant_builder_add(&builder, "{sv}", "FLAGS",
 875                                                 g_variant_new_byte(item->flags));
 876                         g_variant_builder_close(&builder);
 877
 878                         iter = g_list_next(iter);
 879                 }
 880
 881                 mpath_data = g_variant_builder_end(&builder);
 882                 net_mesh_complete_get_mpath_info(object, invocation, mpath_data, ret);
 883
 884                 g_object_unref(mpath_data);
 885         }
 886
 887         return TRUE;
 888 }
 889
 890 static void _meshd_dbus_on_activator_bus_acquired(GDBusConnection *conn,
 891                 const gchar *name, gpointer user_data)
 892 {
 893         gboolean ret;
 894         GError *error = NULL;
 895         mesh_service *service = (mesh_service *)user_data;
 896
 897         NOTUSED(name);
 898
 899         meshd_activator_dbus_object = manager_skeleton_new();
 900         if (NULL == meshd_activator_dbus_object) {
 901                 MESH_LOGE("manager_skeleton_new() Fail");
 902                 return;
 903         }
 904
 905         g_signal_connect(meshd_activator_dbus_object, "handle-enable",
 906                         G_CALLBACK(_meshd_dbus_handle_enable), service);
 907         g_signal_connect(meshd_activator_dbus_object, "handle-disable",
 908                         G_CALLBACK(_meshd_dbus_handle_disable), service);
 909
 910         ret = g_dbus_interface_skeleton_export(
 911                                 G_DBUS_INTERFACE_SKELETON(meshd_activator_dbus_object),
 912                                 conn, MESH_DBUS_MANAGER_OBJPATH, &error);
 913         if (FALSE == ret) {
 914                 MESH_LOGE("g_dbus_interface_skeleton_export() Fail(%s)", error->message);
 915                 g_error_free(error);
 916         }
 917 }
 918
 919 static void _meshd_dbus_on_bus_acquired(GDBusConnection *conn, const gchar *name,
 920                 gpointer user_data)
 921 {
 922         gboolean ret;
 923         GError *error = NULL;
 924         mesh_service *service = (mesh_service *)user_data;
 925
 926         NOTUSED(name);
 927
 928         meshd_dbus_object = net_mesh_skeleton_new();
 929         if (NULL == meshd_dbus_object) {
 930                 MESH_LOGE("net_mesh_skeleton_new() Fail");
 931                 return;
 932         }
 933
 934         g_signal_connect(meshd_dbus_object, "handle-scan",
 935                         G_CALLBACK(_meshd_dbus_handle_scan), service);
 936         g_signal_connect(meshd_dbus_object, "handle-specific-scan",
 937                         G_CALLBACK(_meshd_dbus_handle_specific_scan), service);
 938         g_signal_connect(meshd_dbus_object, "handle-cancel-scan",
 939                         G_CALLBACK(_meshd_dbus_handle_cancel_scan), service);
 940         g_signal_connect(meshd_dbus_object, "handle-get-found-mesh-networks",
 941                         G_CALLBACK(_meshd_dbus_handle_get_found_mesh_networks), service);
 942         g_signal_connect(meshd_dbus_object, "handle-enable-mesh",
 943                         G_CALLBACK(_meshd_dbus_handle_enable_mesh), service);
 944         g_signal_connect(meshd_dbus_object, "handle-disable-mesh",
 945                         G_CALLBACK(_meshd_dbus_handle_disable_mesh), service);
 946         g_signal_connect(meshd_dbus_object, "handle-get-joined-mesh-network",
 947                         G_CALLBACK(_meshd_dbus_handle_get_joined_mesh_network), service);
 948         g_signal_connect(meshd_dbus_object, "handle-get-connected-peers",
 949                         G_CALLBACK(_meshd_dbus_handle_get_connected_peers), service);
 950         g_signal_connect(meshd_dbus_object, "handle-set-gate",
 951                         G_CALLBACK(_meshd_dbus_handle_set_gate), service);
 952         g_signal_connect(meshd_dbus_object, "handle-unset-gate",
 953                         G_CALLBACK(_meshd_dbus_handle_unset_gate), service);
 954         g_signal_connect(meshd_dbus_object, "handle-set-softap",
 955                         G_CALLBACK(_meshd_dbus_handle_set_softap), service);
 956         g_signal_connect(meshd_dbus_object, "handle-enable-softap",
 957                         G_CALLBACK(_meshd_dbus_handle_enable_softap), service);
 958         g_signal_connect(meshd_dbus_object, "handle-disable-softap",
 959                         G_CALLBACK(_meshd_dbus_handle_disable_softap), service);
 960         g_signal_connect(meshd_dbus_object, "handle-create-mesh-network",
 961                         G_CALLBACK(_meshd_dbus_handle_create_mesh_network), service);
 962         g_signal_connect(meshd_dbus_object, "handle-connect-mesh-network",
 963                         G_CALLBACK(_meshd_dbus_handle_connect_mesh_network), service);
 964         g_signal_connect(meshd_dbus_object, "handle-disconnect-mesh-network",
 965                         G_CALLBACK(_meshd_dbus_handle_disconnect_mesh_network), service);
 966         g_signal_connect(meshd_dbus_object, "handle-forget-mesh-network",
 967                         G_CALLBACK(_meshd_dbus_handle_forget_mesh_network), service);
 968         g_signal_connect(meshd_dbus_object, "handle-set-interfaces",
 969                         G_CALLBACK(_meshd_dbus_handle_set_interfaces), service);
 970         g_signal_connect(meshd_dbus_object, "handle-get-station-info",
 971                         G_CALLBACK(_meshd_dbus_handle_get_station_info), service);
 972         g_signal_connect(meshd_dbus_object, "handle-get-mpath-info",
 973                         G_CALLBACK(_meshd_dbus_handle_get_mpath_info), service);
 974
 975         ret = g_dbus_interface_skeleton_export(G_DBUS_INTERFACE_SKELETON(meshd_dbus_object),
 976                         conn, MESH_DBUS_OBJPATH, &error);
 977         if (FALSE == ret) {
 978                 MESH_LOGE("g_dbus_interface_skeleton_export() Fail(%s)", error->message);
 979                 g_error_free(error);
 980         }
 981
 982         ret = _meshd_dbus_subscribe_name_owner_changed(conn);
 983         if (MESHD_ERROR_NONE != ret) {
 984                 MESH_LOGE("_meshd_dbus_subscribe_name_owner_changed() Fail(%d)", ret);
 985                 return;
 986         }
 987 }
 988
 989 static void _meshd_dbus_on_name_lost(GDBusConnection *conn, const gchar *name,
 990                 gpointer user_data)
 991 {
 992         NOTUSED(conn);
 993         NOTUSED(user_data);
 994
 995         MESH_LOGD("Lost the name %s", name);
 996 }
 997
 998 static void _meshd_dbus_on_name_acquired(GDBusConnection *conn, const gchar *name,
 999                 gpointer user_data)
1000 {
1001         NOTUSED(conn);
1002         NOTUSED(user_data);
1003
1004         MESH_LOGD("Acquired the name %s", name);
1005 }
1006
1007 static gboolean _meshd_dbus_interface_init(mesh_service *service)
1008 {
1009         guint id;
1010         guint activation_dbus_id;
1011         meshd_check_null_ret_error("service", service, FALSE);
1012
1013         id = g_bus_own_name(G_BUS_TYPE_SYSTEM,
1014                         MESH_DBUS_INTERFACE,
1015                         G_BUS_NAME_OWNER_FLAGS_REPLACE,
1016                         _meshd_dbus_on_bus_acquired,
1017                         _meshd_dbus_on_name_acquired,
1018                         _meshd_dbus_on_name_lost,
1019                         service,
1020                         NULL);
1021         if (0 == id) {
1022                 MESH_LOGE("g_bus_own_name() Fail");
1023                 return FALSE;
1024         }
1025
1026         /* Get D-Bus owner to activate mesh service daemon */
1027         activation_dbus_id = g_bus_own_name(G_BUS_TYPE_SYSTEM,
1028                         MESH_DBUS_INTERFACE".manager",
1029                         G_BUS_NAME_OWNER_FLAGS_REPLACE,
1030                         _meshd_dbus_on_activator_bus_acquired,
1031                         NULL,
1032                         NULL,
1033                         service,
1034                         NULL);
1035
1036         service->dbus_id = id;
1037         service->activation_dbus_id = activation_dbus_id;
1038         service->interface_info = g_new0(mesh_interface_s, 1);
1039         service->scanned_mesh_network = NULL;
1040
1041         /* Initialize DBus sendor logic */
1042         meshd_dbus_start(service);
1043
1044         return TRUE;
1045 }
1046
1047 static void _meshd_dbus_deinit(mesh_service *service)
1048 {
1049         mesh_interface_s *info = NULL;
1050         meshd_check_null_ret("service", service);
1051
1052         /* De-Initialize DBus sendor logic */
1053         meshd_dbus_stop(service);
1054
1055         g_bus_unown_name(service->dbus_id);
1056         g_bus_unown_name(service->activation_dbus_id);
1057
1058         info = service->interface_info;
1059         meshd_check_null_ret("info", info);
1060         if (info->bridge_interface)
1061                 g_free(info->bridge_interface);
1062         if (info->base_interface)
1063                 g_free(info->base_interface);
1064         if (info->mesh_interface)
1065                 g_free(info->mesh_interface);
1066         if (info->softap_interface)
1067                 g_free(info->softap_interface);
1068         if (info->external_interface)
1069                 g_free(info->external_interface);
1070
1071         if (service->joined_network) {
1072                 g_free(service->joined_network->mesh_id);
1073                 g_free(service->joined_network->bssid);
1074                 g_free(service->joined_network);
1075                 service->joined_network = NULL;
1076         }
1077
1078         /* Clear scan list */
1079         g_list_free_full(service->scanned_mesh_network, _on_scan_result_destroy);
1080         service->scanned_mesh_network = NULL;
1081
1082         /* Clear connected peers list */
1083         g_list_free_full(service->connected_mesh_peers, _on_peer_info_destroy);
1084         service->connected_mesh_peers = NULL;
1085
1086         g_free(service->interface_info);
1087         service->interface_info = NULL;
1088 }
1089
1090 /**< Mesh service interface initialization */
1091 gboolean meshd_service_interface_init(mesh_service *service)
1092 {
1093         guint ret;
1094         meshd_check_null_ret_error("service", service, FALSE);
1095
1096         /* Initialize dbus interface */
1097         ret = _meshd_dbus_interface_init(service);
1098         if (FALSE == ret) {
1099                 MESH_LOGE("_meshd_dbus_interface_init failed!!!");
1100                 return FALSE;
1101         }
1102
1103         return TRUE;
1104 }
1105
1106 /**< Mesh service interface de-initialization */
1107 void meshd_service_interface_deinit(mesh_service *service)
1108 {
1109         meshd_check_null_ret("service", service);
1110
1111         /* De-initialize dbus interface */
1112         _meshd_dbus_deinit(service);
1113 }