1 /* -*- Mode: C ; c-basic-offset: 2 -*- */
3 * LADI Session Handler (ladish)
5 * Copyright (C) 2008,2009 Nedko Arnaudov <nedko@arnaudov.name>
7 **************************************************************************
8 * This file contains code that interface with a2jmidid through D-Bus
9 **************************************************************************
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.
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.
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.
28 #include "a2j_proxy.h"
29 #include "../dbus/helpers.h"
31 #define A2J_SERVICE "org.gna.home.a2jmidid"
32 #define A2J_OBJECT "/"
33 #define A2J_IFACE_CONTROL "org.gna.home.a2jmidid.control"
35 static const char * g_signals
[] =
42 static bool g_a2j_started
= false;
43 static char * g_a2j_jack_client_name
= NULL
;
48 DBusConnection
* connection
,
49 DBusMessage
* message
,
52 const char * object_name
;
53 const char * old_owner
;
54 const char * new_owner
;
56 if (dbus_message_is_signal(message
, DBUS_INTERFACE_DBUS
, "NameOwnerChanged"))
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
,
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
;
70 if (strcmp(object_name
, A2J_SERVICE
) != 0)
72 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED
;
75 if (old_owner
[0] == '\0')
77 log_info("a2j activatation detected.");
79 else if (new_owner
[0] == '\0')
81 log_info("a2j deactivatation detected.");
84 return DBUS_HANDLER_RESULT_HANDLED
;
87 if (dbus_message_is_signal(message
, A2J_IFACE_CONTROL
, "bridge_started"))
89 log_info("a2j bridge started.");
91 if (g_a2j_jack_client_name
!= NULL
)
93 free(g_a2j_jack_client_name
);
94 g_a2j_jack_client_name
= NULL
;
99 return DBUS_HANDLER_RESULT_HANDLED
;
102 if (dbus_message_is_signal(message
, A2J_IFACE_CONTROL
, "bridge_stopped"))
104 if (g_a2j_jack_client_name
!= NULL
)
106 free(g_a2j_jack_client_name
);
107 g_a2j_jack_client_name
= NULL
;
110 g_a2j_started
= false;
112 log_info("a2j bridge stopped.");
113 return DBUS_HANDLER_RESULT_HANDLED
;
116 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED
;
119 bool a2j_proxy_init(void)
122 const char ** signal
;
126 "type='signal',interface='"DBUS_INTERFACE_DBUS
"',member=NameOwnerChanged,arg0='"A2J_SERVICE
"'",
128 if (dbus_error_is_set(&g_dbus_error
))
130 log_error("Failed to add D-Bus match rule: %s", g_dbus_error
.message
);
131 dbus_error_free(&g_dbus_error
);
135 g_a2j_started
= a2j_proxy_is_started();
138 a2j_proxy_get_jack_client_name_noncached(&g_a2j_jack_client_name
);
141 for (signal
= g_signals
; *signal
!= NULL
; signal
++)
146 "type='signal',sender='"A2J_SERVICE
"',path='"A2J_OBJECT
"',interface='"A2J_IFACE_CONTROL
"',member='%s'",
149 dbus_bus_add_match(g_dbus_connection
, rule
, &g_dbus_error
);
150 if (dbus_error_is_set(&g_dbus_error
))
152 log_error("Failed to add D-Bus match rule: %s", g_dbus_error
.message
);
153 dbus_error_free(&g_dbus_error
);
158 if (!dbus_connection_add_filter(g_dbus_connection
, message_hook
, NULL
, NULL
))
160 log_error("Failed to add D-Bus filter");
167 void a2j_proxy_uninit(void)
169 dbus_connection_remove_filter(g_dbus_connection
, message_hook
, NULL
);
172 const char * a2j_proxy_get_jack_client_name_cached(void)
174 if (g_a2j_jack_client_name
== NULL
)
176 a2j_proxy_get_jack_client_name_noncached(&g_a2j_jack_client_name
);
179 return g_a2j_jack_client_name
;
182 bool a2j_proxy_get_jack_client_name_noncached(char ** client_name_ptr_ptr
)
184 DBusMessage
* reply_ptr
;
187 if (!dbus_call(A2J_SERVICE
, A2J_OBJECT
, A2J_IFACE_CONTROL
, "get_jack_client_name", "", NULL
, &reply_ptr
))
189 //log_error("a2j::get_jack_client_name() failed.");
193 if (!dbus_message_get_args(reply_ptr
, &g_dbus_error
, DBUS_TYPE_STRING
, &name
, DBUS_TYPE_INVALID
))
195 dbus_message_unref(reply_ptr
);
196 dbus_error_free(&g_dbus_error
);
197 log_error("decoding reply of get_jack_client_name failed.");
201 *client_name_ptr_ptr
= strdup(name
);
203 dbus_message_unref(reply_ptr
);
205 if (*client_name_ptr_ptr
== NULL
)
207 log_error("strdup() failed for a2j jack client name string");
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
)
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
;
227 if (!dbus_call(A2J_SERVICE
, A2J_OBJECT
, A2J_IFACE_CONTROL
, "map_jack_port_to_alsa", "s", &jack_port_name
, NULL
, &reply_ptr
))
229 log_error("a2j::map_jack_port_to_alsa() failed.");
233 if (!dbus_message_get_args(
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.");
252 *alsa_client_name_ptr_ptr
= strdup(alsa_client_name
);
253 if (*alsa_client_name_ptr_ptr
== NULL
)
255 dbus_message_unref(reply_ptr
);
256 log_error("strdup() failed for a2j alsa client name string");
260 *alsa_port_name_ptr_ptr
= strdup(alsa_port_name
);
261 if (*alsa_port_name_ptr_ptr
== NULL
)
263 dbus_message_unref(reply_ptr
);
264 log_error("strdup() failed for a2j alsa port name string");
265 free(*alsa_client_name_ptr_ptr
);
269 *alsa_client_id_ptr
= alsa_client_id
;
271 dbus_message_unref(reply_ptr
);
276 bool a2j_proxy_is_started(void)
280 if (!dbus_call(A2J_SERVICE
, A2J_OBJECT
, A2J_IFACE_CONTROL
, "is_started", "", "b", &started
))
282 log_error("a2j::is_started() failed.");
289 bool a2j_proxy_start_bridge(void)
291 if (!dbus_call(A2J_SERVICE
, A2J_OBJECT
, A2J_IFACE_CONTROL
, "start", "", ""))
293 log_error("a2j::start() failed.");
300 bool a2j_proxy_stop_bridge(void)
302 if (!dbus_call(A2J_SERVICE
, A2J_OBJECT
, A2J_IFACE_CONTROL
, "stop", "", ""))
304 log_error("a2j::stop() failed.");