dbus_iface_control.c

   1 /* -*- Mode: C ; c-basic-offset: 2 -*- */
   2 /*
   3  * ALSA SEQ < - > JACK MIDI bridge
   4  *
   5  * Copyright (c) 2008,2009 Nedko Arnaudov <nedko@arnaudov.name>
   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 as published by
   9  *  the Free Software Foundation; version 2 of the License.
  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., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA
  19  */
  20
  21 #include <stdbool.h>
  22 #include <dbus/dbus.h>
  23 #include <alsa/asoundlib.h>
  24 #include <jack/jack.h>
  25 #include <jack/midiport.h>
  26 #include <jack/ringbuffer.h>
  27
  28 #include "dbus_internal.h"
  29 #include "a2jmidid.h"
  30 #include "log.h"
  31 #include "list.h"
  32 #include "structs.h"
  33 #include "port_thread.h"
  34 #include "conf.h"
  35
  36 #define INTERFACE_NAME "org.gna.home.a2jmidid.control"
  37
  38 void
  39 a2j_dbus_signal_emit_bridge_started()
  40 {
  41   a2j_dbus_signal("/", INTERFACE_NAME, "bridge_started", DBUS_TYPE_INVALID);
  42 }
  43
  44 void
  45 a2j_dbus_signal_emit_bridge_stopped()
  46 {
  47   a2j_dbus_signal("/", INTERFACE_NAME, "bridge_stopped", DBUS_TYPE_INVALID);
  48 }
  49
  50 static
  51 void
  52 a2j_dbus_exit(
  53   struct a2j_dbus_method_call * call_ptr)
  54 {
  55         g_keep_walking = false;
  56   a2j_dbus_construct_method_return_void(call_ptr);
  57 }
  58
  59 static void a2j_dbus_set_hw_export(struct a2j_dbus_method_call * call_ptr)
  60 {
  61   DBusError error;
  62   dbus_bool_t hw_export;
  63
  64   if (a2j_is_started())
  65   {
  66     a2j_dbus_error(call_ptr, A2J_DBUS_ERROR_BRIDGE_RUNNING, "Bridge is started");
  67     return;
  68   }
  69
  70   dbus_error_init(&error);
  71
  72   if (!dbus_message_get_args(
  73         call_ptr->message,
  74         &error,
  75         DBUS_TYPE_BOOLEAN, &hw_export,
  76         DBUS_TYPE_INVALID))
  77   {
  78     a2j_dbus_error(call_ptr, A2J_DBUS_ERROR_INVALID_ARGS, "Invalid arguments to method \"%s\"", call_ptr->method_name);
  79     dbus_error_free(&error);
  80     return;
  81   }
  82
  83   g_a2j_export_hw_ports = hw_export;
  84
  85   a2j_info("Hardware ports %s be exported.", g_a2j_export_hw_ports ? "will": "will not");
  86
  87   a2j_dbus_construct_method_return_void(call_ptr);
  88 }
  89
  90 static
  91 void
  92 a2j_dbus_start(
  93   struct a2j_dbus_method_call * call_ptr)
  94 {
  95         if (!a2j_start())
  96   {
  97     a2j_dbus_error(call_ptr, A2J_DBUS_ERROR_GENERIC, "a2j_start() failed.");
  98   }
  99   else
 100   {
 101     a2j_dbus_construct_method_return_void(call_ptr);
 102   }
 103 }
 104
 105 static
 106 void
 107 a2j_dbus_stop(
 108   struct a2j_dbus_method_call * call_ptr)
 109 {
 110         if (!a2j_stop())
 111   {
 112     a2j_dbus_error(call_ptr, A2J_DBUS_ERROR_GENERIC, "a2j_stop() failed.");
 113   }
 114   else
 115   {
 116     a2j_dbus_construct_method_return_void(call_ptr);
 117   }
 118 }
 119
 120 static
 121 void
 122 a2j_dbus_is_started(
 123   struct a2j_dbus_method_call * call_ptr)
 124 {
 125   dbus_bool_t is_started;
 126
 127         is_started = a2j_is_started();
 128
 129   a2j_dbus_construct_method_return_single(
 130     call_ptr,
 131     DBUS_TYPE_BOOLEAN,
 132     &is_started);
 133 }
 134
 135 static
 136 void
 137 a2j_dbus_get_jack_client_name(
 138   struct a2j_dbus_method_call * call_ptr)
 139 {
 140   const char * jack_client_name;
 141
 142   jack_client_name = A2J_JACK_CLIENT_NAME;
 143
 144   a2j_dbus_construct_method_return_single(
 145     call_ptr,
 146     DBUS_TYPE_STRING,
 147     &jack_client_name);
 148 }
 149
 150 static
 151 void
 152 a2j_dbus_map_alsa_to_jack_port(
 153   struct a2j_dbus_method_call * call_ptr)
 154 {
 155   DBusError error;
 156   dbus_uint32_t client_id;
 157   dbus_uint32_t port_id;
 158   dbus_bool_t map_playback;
 159   snd_seq_addr_t addr;
 160   struct a2j_port * port_ptr;
 161   const char * direction_string;
 162   struct a2j_stream * stream_ptr;
 163   const char * jack_port;
 164
 165   dbus_error_init(&error);
 166
 167   if (!dbus_message_get_args(
 168         call_ptr->message,
 169         &error,
 170         DBUS_TYPE_UINT32, &client_id,
 171         DBUS_TYPE_UINT32, &port_id,
 172         DBUS_TYPE_BOOLEAN, &map_playback,
 173         DBUS_TYPE_INVALID))
 174   {
 175     a2j_dbus_error(call_ptr, A2J_DBUS_ERROR_INVALID_ARGS, "Invalid arguments to method \"%s\"", call_ptr->method_name);
 176     dbus_error_free(&error);
 177     return;
 178   }
 179
 180   if (!a2j_is_started())
 181   {
 182     a2j_dbus_error(call_ptr, A2J_DBUS_ERROR_BRIDGE_NOT_RUNNING, "Bridge not started");
 183     return;
 184   }
 185
 186   addr.client = client_id;
 187   addr.port = port_id;
 188
 189   if (map_playback)
 190   {
 191     stream_ptr = g_a2j->stream + A2J_PORT_PLAYBACK;
 192     direction_string = "playback";
 193   }
 194   else
 195   {
 196     stream_ptr = g_a2j->stream + A2J_PORT_CAPTURE;
 197     direction_string = "capture";
 198   }
 199
 200   port_ptr = a2j_find_port_by_addr(stream_ptr, addr);
 201   if (port_ptr == NULL)
 202   {
 203     a2j_dbus_error(call_ptr, A2J_DBUS_ERROR_UNKNOWN_PORT, "Unknown ALSA sequencer port %u:%u (%s)", (unsigned int)client_id, (unsigned int)port_id, direction_string);
 204     return;
 205   }
 206
 207   jack_port = port_ptr->name;
 208
 209   a2j_info("map %u:%u (%s) -> '%s'", (unsigned int)client_id, (unsigned int)port_id, direction_string, jack_port);
 210
 211   a2j_dbus_construct_method_return_single(
 212     call_ptr,
 213     DBUS_TYPE_STRING,
 214     &jack_port);
 215 }
 216
 217 static
 218 void
 219 a2j_dbus_map_jack_port_to_alsa(
 220   struct a2j_dbus_method_call * call_ptr)
 221 {
 222   snd_seq_client_info_t * client_info_ptr;
 223   snd_seq_port_info_t * port_info_ptr;
 224   DBusError error;
 225   const char * jack_port;
 226   struct a2j_port * port_ptr;
 227   const char * client_name;
 228   const char * port_name;
 229   dbus_uint32_t client_id;
 230   dbus_uint32_t port_id;
 231         DBusMessageIter iter;
 232
 233
 234   snd_seq_client_info_alloca(&client_info_ptr);
 235   snd_seq_port_info_alloca(&port_info_ptr);
 236
 237   dbus_error_init(&error);
 238
 239   if (!dbus_message_get_args(
 240         call_ptr->message,
 241         &error,
 242         DBUS_TYPE_STRING, &jack_port,
 243         DBUS_TYPE_INVALID))
 244   {
 245     a2j_dbus_error(call_ptr, A2J_DBUS_ERROR_INVALID_ARGS, "Invalid arguments to method \"%s\"", call_ptr->method_name);
 246     dbus_error_free(&error);
 247     return;
 248   }
 249
 250   if (!a2j_is_started())
 251   {
 252     a2j_dbus_error(call_ptr, A2J_DBUS_ERROR_BRIDGE_NOT_RUNNING, "Bridge not started");
 253     return;
 254   }
 255
 256   port_ptr = a2j_find_port_by_jack_port_name(g_a2j->stream + A2J_PORT_CAPTURE, jack_port);
 257   if (port_ptr == NULL)
 258   {
 259     port_ptr = a2j_find_port_by_jack_port_name(g_a2j->stream + A2J_PORT_PLAYBACK, jack_port);
 260     if (port_ptr == NULL)
 261     {
 262       a2j_dbus_error(call_ptr, A2J_DBUS_ERROR_UNKNOWN_PORT, "Unknown JACK port '%s'", jack_port);
 263       return;
 264     }
 265   }
 266
 267   if (snd_seq_get_any_client_info(g_a2j->seq, port_ptr->remote.client, client_info_ptr) >= 0)
 268   {
 269     client_name = snd_seq_client_info_get_name(client_info_ptr);
 270   }
 271   else
 272   {
 273     client_name = "";
 274   }
 275
 276   if (snd_seq_get_any_port_info(g_a2j->seq, port_ptr->remote.client, port_ptr->remote.port, port_info_ptr) >= 0)
 277   {
 278     port_name = snd_seq_port_info_get_name(port_info_ptr);
 279   }
 280   else
 281   {
 282     port_name = "";
 283   }
 284
 285   a2j_info("map '%s' -> %u:%u ('%s':'%s')", jack_port, (unsigned int)port_ptr->remote.client, (unsigned int)port_ptr->remote.port, client_name, port_name);
 286
 287   client_id = port_ptr->remote.client;
 288   port_id = port_ptr->remote.port;
 289
 290         call_ptr->reply = dbus_message_new_method_return(call_ptr->message);
 291         if (call_ptr->reply == NULL)
 292   {
 293                 goto fail;
 294   }
 295
 296         dbus_message_iter_init_append(call_ptr->reply, &iter);
 297
 298   if (!dbus_message_iter_append_basic(&iter, DBUS_TYPE_UINT32, &client_id))
 299   {
 300     goto fail_unref;
 301   }
 302
 303   if (!dbus_message_iter_append_basic(&iter, DBUS_TYPE_UINT32, &port_id))
 304   {
 305     goto fail_unref;
 306   }
 307
 308   if (!dbus_message_iter_append_basic(&iter, DBUS_TYPE_STRING, &client_name))
 309   {
 310     goto fail_unref;
 311   }
 312
 313   if (!dbus_message_iter_append_basic(&iter, DBUS_TYPE_STRING, &port_name))
 314   {
 315     goto fail_unref;
 316   }
 317
 318         return;
 319
 320 fail_unref:
 321         dbus_message_unref(call_ptr->reply);
 322         call_ptr->reply = NULL;
 323
 324 fail:
 325         a2j_error("Ran out of memory trying to construct method return");
 326 }
 327
 328 A2J_DBUS_METHOD_ARGUMENTS_BEGIN(exit)
 329 A2J_DBUS_METHOD_ARGUMENTS_END
 330
 331 A2J_DBUS_METHOD_ARGUMENTS_BEGIN(start)
 332 A2J_DBUS_METHOD_ARGUMENTS_END
 333
 334 A2J_DBUS_METHOD_ARGUMENTS_BEGIN(stop)
 335 A2J_DBUS_METHOD_ARGUMENTS_END
 336
 337 A2J_DBUS_METHOD_ARGUMENTS_BEGIN(is_started)
 338   A2J_DBUS_METHOD_ARGUMENT("started", DBUS_TYPE_BOOLEAN_AS_STRING, A2J_DBUS_DIRECTION_OUT)
 339 A2J_DBUS_METHOD_ARGUMENTS_END
 340
 341 A2J_DBUS_METHOD_ARGUMENTS_BEGIN(get_jack_client_name)
 342   A2J_DBUS_METHOD_ARGUMENT("jack_client_name", DBUS_TYPE_STRING_AS_STRING, A2J_DBUS_DIRECTION_OUT)
 343 A2J_DBUS_METHOD_ARGUMENTS_END
 344
 345 A2J_DBUS_METHOD_ARGUMENTS_BEGIN(map_alsa_to_jack_port)
 346   A2J_DBUS_METHOD_ARGUMENT("alsa_client_id", DBUS_TYPE_UINT32_AS_STRING, A2J_DBUS_DIRECTION_IN)
 347   A2J_DBUS_METHOD_ARGUMENT("alsa_port_id", DBUS_TYPE_UINT32_AS_STRING, A2J_DBUS_DIRECTION_IN)
 348   A2J_DBUS_METHOD_ARGUMENT("map_playback", DBUS_TYPE_BOOLEAN_AS_STRING, A2J_DBUS_DIRECTION_IN)
 349   A2J_DBUS_METHOD_ARGUMENT("jack_port_name", DBUS_TYPE_STRING_AS_STRING, A2J_DBUS_DIRECTION_OUT)
 350 A2J_DBUS_METHOD_ARGUMENTS_END
 351
 352 A2J_DBUS_METHOD_ARGUMENTS_BEGIN(map_jack_port_to_alsa)
 353   A2J_DBUS_METHOD_ARGUMENT("jack_port_name", "s", A2J_DBUS_DIRECTION_IN)
 354   A2J_DBUS_METHOD_ARGUMENT("alsa_client_id", DBUS_TYPE_UINT32_AS_STRING, A2J_DBUS_DIRECTION_OUT)
 355   A2J_DBUS_METHOD_ARGUMENT("alsa_port_id", DBUS_TYPE_UINT32_AS_STRING, A2J_DBUS_DIRECTION_OUT)
 356   A2J_DBUS_METHOD_ARGUMENT("alsa_client_name", DBUS_TYPE_STRING_AS_STRING, A2J_DBUS_DIRECTION_OUT)
 357   A2J_DBUS_METHOD_ARGUMENT("alsa_port_name", DBUS_TYPE_STRING_AS_STRING, A2J_DBUS_DIRECTION_OUT)
 358 A2J_DBUS_METHOD_ARGUMENTS_END
 359
 360 A2J_DBUS_METHOD_ARGUMENTS_BEGIN(set_hw_export)
 361   A2J_DBUS_METHOD_ARGUMENT("hw_export", DBUS_TYPE_BOOLEAN_AS_STRING, A2J_DBUS_DIRECTION_IN)
 362 A2J_DBUS_METHOD_ARGUMENTS_END
 363
 364 A2J_DBUS_METHODS_BEGIN
 365   A2J_DBUS_METHOD_DESCRIBE(exit, a2j_dbus_exit)
 366   A2J_DBUS_METHOD_DESCRIBE(start, a2j_dbus_start)
 367   A2J_DBUS_METHOD_DESCRIBE(stop, a2j_dbus_stop)
 368   A2J_DBUS_METHOD_DESCRIBE(is_started, a2j_dbus_is_started)
 369   A2J_DBUS_METHOD_DESCRIBE(get_jack_client_name, a2j_dbus_get_jack_client_name)
 370   A2J_DBUS_METHOD_DESCRIBE(map_alsa_to_jack_port, a2j_dbus_map_alsa_to_jack_port)
 371   A2J_DBUS_METHOD_DESCRIBE(map_jack_port_to_alsa, a2j_dbus_map_jack_port_to_alsa)
 372   A2J_DBUS_METHOD_DESCRIBE(set_hw_export, a2j_dbus_set_hw_export)
 373 A2J_DBUS_METHODS_END
 374
 375 A2J_DBUS_SIGNAL_ARGUMENTS_BEGIN(bridge_started)
 376 A2J_DBUS_SIGNAL_ARGUMENTS_END
 377
 378 A2J_DBUS_SIGNAL_ARGUMENTS_BEGIN(bridge_stopped)
 379 A2J_DBUS_SIGNAL_ARGUMENTS_END
 380
 381 A2J_DBUS_SIGNALS_BEGIN
 382   A2J_DBUS_SIGNAL_DESCRIBE(bridge_started)
 383   A2J_DBUS_SIGNAL_DESCRIBE(bridge_stopped)
 384 A2J_DBUS_SIGNALS_END
 385
 386 A2J_DBUS_IFACE_BEGIN(g_a2j_iface_control, INTERFACE_NAME)
 387   A2J_DBUS_IFACE_EXPOSE_METHODS
 388   A2J_DBUS_IFACE_EXPOSE_SIGNALS
 389 A2J_DBUS_IFACE_END