daemon/a2j_proxy.c

   1 /* -*- Mode: C ; c-basic-offset: 2 -*- */
   2 /*
   3  * LADI Session Handler (ladish)
   4  *
   5  * Copyright (C) 2008,2009 Nedko Arnaudov <nedko@arnaudov.name>
   6  *
   7  **************************************************************************
   8  * This file contains code that interface with a2jmidid through D-Bus
   9  **************************************************************************
  10  *
  11  * LADI Session Handler is free software; you can redistribute it and/or modify
  12  * it under the terms of the GNU General Public License as published by
  13  * the Free Software Foundation; either version 2 of the License, or
  14  * (at your option) any later version.
  15  *
  16  * LADI Session Handler is distributed in the hope that it will be useful,
  17  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  18  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  19  * GNU General Public License for more details.
  20  *
  21  * You should have received a copy of the GNU General Public License
  22  * along with LADI Session Handler. If not, see <http://www.gnu.org/licenses/>
  23  * or write to the Free Software Foundation, Inc.,
  24  * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
  25  */
  26
  27 #include "common.h"
  28 #include "a2j_proxy.h"
  29 #include "../dbus/helpers.h"
  30
  31 #define A2J_SERVICE       "org.gna.home.a2jmidid"
  32 #define A2J_OBJECT        "/"
  33 #define A2J_IFACE_CONTROL "org.gna.home.a2jmidid.control"
  34
  35 static const char * g_signals[] =
  36 {
  37   "bridge_started",
  38   "bridge_stopped",
  39   NULL
  40 };
  41
  42 static bool g_a2j_started = false;
  43 static char * g_a2j_jack_client_name = NULL;
  44
  45 static
  46 DBusHandlerResult
  47 message_hook(
  48   DBusConnection * connection,
  49   DBusMessage * message,
  50   void * proxy)
  51 {
  52   const char * object_name;
  53   const char * old_owner;
  54   const char * new_owner;
  55
  56   if (dbus_message_is_signal(message, DBUS_INTERFACE_DBUS, "NameOwnerChanged"))
  57   {
  58     if (!dbus_message_get_args(
  59           message, &g_dbus_error,
  60           DBUS_TYPE_STRING, &object_name,
  61           DBUS_TYPE_STRING, &old_owner,
  62           DBUS_TYPE_STRING, &new_owner,
  63           DBUS_TYPE_INVALID))
  64     {
  65       log_error("dbus_message_get_args() failed to extract NameOwnerChanged signal arguments (%s)", g_dbus_error.message);
  66       dbus_error_free(&g_dbus_error);
  67       return DBUS_HANDLER_RESULT_HANDLED;
  68     }
  69
  70     if (strcmp(object_name, A2J_SERVICE) != 0)
  71     {
  72       return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
  73     }
  74
  75     if (old_owner[0] == '\0')
  76     {
  77       log_info("a2j activatation detected.");
  78     }
  79     else if (new_owner[0] == '\0')
  80     {
  81       log_info("a2j deactivatation detected.");
  82     }
  83
  84     return DBUS_HANDLER_RESULT_HANDLED;
  85   }
  86
  87   if (dbus_message_is_signal(message, A2J_IFACE_CONTROL, "bridge_started"))
  88   {
  89     log_info("a2j bridge start detected.");
  90
  91     if (g_a2j_jack_client_name != NULL)
  92     {
  93       free(g_a2j_jack_client_name);
  94       g_a2j_jack_client_name = NULL;
  95     }
  96
  97     g_a2j_started = true;
  98
  99     return DBUS_HANDLER_RESULT_HANDLED;
 100   }
 101
 102   if (dbus_message_is_signal(message, A2J_IFACE_CONTROL, "bridge_stopped"))
 103   {
 104     if (g_a2j_jack_client_name != NULL)
 105     {
 106       free(g_a2j_jack_client_name);
 107       g_a2j_jack_client_name = NULL;
 108     }
 109
 110     g_a2j_started = false;
 111
 112     log_info("a2j bridge stop detected.");
 113     return DBUS_HANDLER_RESULT_HANDLED;
 114   }
 115
 116   return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
 117 }
 118
 119 bool a2j_proxy_init(void)
 120 {
 121   char rule[1024];
 122   const char ** signal;
 123
 124   dbus_bus_add_match(
 125     g_dbus_connection,
 126     "type='signal',interface='"DBUS_INTERFACE_DBUS"',member=NameOwnerChanged,arg0='"A2J_SERVICE"'",
 127     &g_dbus_error);
 128   if (dbus_error_is_set(&g_dbus_error))
 129   {
 130     log_error("Failed to add D-Bus match rule: %s", g_dbus_error.message);
 131     dbus_error_free(&g_dbus_error);
 132     return false;
 133   }
 134
 135   g_a2j_started = a2j_proxy_is_started();
 136   if (g_a2j_started)
 137   {
 138     a2j_proxy_get_jack_client_name_noncached(&g_a2j_jack_client_name);
 139   }
 140
 141   for (signal = g_signals; *signal != NULL; signal++)
 142   {
 143     snprintf(
 144       rule,
 145       sizeof(rule),
 146       "type='signal',sender='"A2J_SERVICE"',path='"A2J_OBJECT"',interface='"A2J_IFACE_CONTROL"',member='%s'",
 147       *signal);
 148
 149     dbus_bus_add_match(g_dbus_connection, rule, &g_dbus_error);
 150     if (dbus_error_is_set(&g_dbus_error))
 151     {
 152       log_error("Failed to add D-Bus match rule: %s", g_dbus_error.message);
 153       dbus_error_free(&g_dbus_error);
 154       return false;
 155     }
 156   }
 157
 158   if (!dbus_connection_add_filter(g_dbus_connection, message_hook, NULL, NULL))
 159   {
 160     log_error("Failed to add D-Bus filter");
 161     return false;
 162   }
 163
 164   return true;
 165 }
 166
 167 void a2j_proxy_uninit(void)
 168 {
 169   dbus_connection_remove_filter(g_dbus_connection, message_hook, NULL);
 170 }
 171
 172 const char * a2j_proxy_get_jack_client_name_cached(void)
 173 {
 174   if (g_a2j_jack_client_name == NULL)
 175   {
 176     a2j_proxy_get_jack_client_name_noncached(&g_a2j_jack_client_name);
 177   }
 178
 179   return g_a2j_jack_client_name;
 180 }
 181
 182 bool a2j_proxy_get_jack_client_name_noncached(char ** client_name_ptr_ptr)
 183 {
 184   DBusMessage * reply_ptr;
 185   const char * name;
 186
 187   if (!dbus_call(A2J_SERVICE, A2J_OBJECT, A2J_IFACE_CONTROL, "get_jack_client_name", "", NULL, &reply_ptr))
 188   {
 189     //log_error("a2j::get_jack_client_name() failed.");
 190     return false;
 191   }
 192
 193   if (!dbus_message_get_args(reply_ptr, &g_dbus_error, DBUS_TYPE_STRING, &name, DBUS_TYPE_INVALID))
 194   {
 195     dbus_message_unref(reply_ptr);
 196     dbus_error_free(&g_dbus_error);
 197     log_error("decoding reply of get_jack_client_name failed.");
 198     return false;
 199   }
 200
 201   *client_name_ptr_ptr = strdup(name);
 202
 203   dbus_message_unref(reply_ptr);
 204
 205   if (*client_name_ptr_ptr == NULL)
 206   {
 207     log_error("strdup() failed for a2j jack client name string");
 208     return false;
 209   }
 210
 211   return true;
 212 }
 213
 214 bool
 215 a2j_proxy_map_jack_port(
 216     const char * jack_port_name,
 217     char ** alsa_client_name_ptr_ptr,
 218     char ** alsa_port_name_ptr_ptr,
 219     uint32_t * alsa_client_id_ptr)
 220 {
 221   DBusMessage * reply_ptr;
 222   dbus_uint32_t alsa_client_id;
 223   dbus_uint32_t alsa_port_id;
 224   const char * alsa_client_name;
 225   const char * alsa_port_name;
 226
 227   if (!dbus_call(A2J_SERVICE, A2J_OBJECT, A2J_IFACE_CONTROL, "map_jack_port_to_alsa", "s", &jack_port_name, NULL, &reply_ptr))
 228   {
 229     log_error("a2j::map_jack_port_to_alsa() failed.");
 230     return false;
 231   }
 232
 233   if (!dbus_message_get_args(
 234         reply_ptr,
 235         &g_dbus_error,
 236         DBUS_TYPE_UINT32,
 237         &alsa_client_id,
 238         DBUS_TYPE_UINT32,
 239         &alsa_port_id,
 240         DBUS_TYPE_STRING,
 241         &alsa_client_name,
 242         DBUS_TYPE_STRING,
 243         &alsa_port_name,
 244         DBUS_TYPE_INVALID))
 245   {
 246     dbus_message_unref(reply_ptr);
 247     dbus_error_free(&g_dbus_error);
 248     log_error("decoding reply of map_jack_port_to_alsa failed.");
 249     return false;
 250   }
 251
 252   *alsa_client_name_ptr_ptr = strdup(alsa_client_name);
 253   if (*alsa_client_name_ptr_ptr == NULL)
 254   {
 255     dbus_message_unref(reply_ptr);
 256     log_error("strdup() failed for a2j alsa client name string");
 257     return false;
 258   }
 259
 260   *alsa_port_name_ptr_ptr = strdup(alsa_port_name);
 261   if (*alsa_port_name_ptr_ptr == NULL)
 262   {
 263     dbus_message_unref(reply_ptr);
 264     log_error("strdup() failed for a2j alsa port name string");
 265     free(*alsa_client_name_ptr_ptr);
 266     return false;
 267   }
 268
 269   *alsa_client_id_ptr = alsa_client_id;
 270
 271   dbus_message_unref(reply_ptr);
 272
 273   return true;
 274 }
 275
 276 bool a2j_proxy_is_started(void)
 277 {
 278   dbus_bool_t started;
 279
 280   if (!dbus_call(A2J_SERVICE, A2J_OBJECT, A2J_IFACE_CONTROL, "is_started", "", "b", &started))
 281   {
 282     log_error("a2j::is_started() failed.");
 283     return false;
 284   }
 285
 286   return started;
 287 }
 288
 289 bool a2j_proxy_start_bridge(void)
 290 {
 291   if (!dbus_call(A2J_SERVICE, A2J_OBJECT, A2J_IFACE_CONTROL, "start", "", ""))
 292   {
 293     log_error("a2j::start() failed.");
 294     return false;
 295   }
 296
 297   return true;
 298 }
 299
 300 bool a2j_proxy_stop_bridge(void)
 301 {
 302   if (!dbus_call(A2J_SERVICE, A2J_OBJECT, A2J_IFACE_CONTROL, "stop", "", ""))
 303   {
 304     log_error("a2j::stop() failed.");
 305     return false;
 306   }
 307
 308   return true;
 309 }