2 Copyright 2009 Lennart Poettering
4 Permission is hereby granted, free of charge, to any person
5 obtaining a copy of this software and associated documentation files
6 (the "Software"), to deal in the Software without restriction,
7 including without limitation the rights to use, copy, modify, merge,
8 publish, distribute, sublicense, and/or sell copies of the Software,
9 and to permit persons to whom the Software is furnished to do so,
10 subject to the following conditions:
12 The above copyright notice and this permission notice shall be
13 included in all copies or substantial portions of the Software.
15 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
16 EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
17 MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
18 NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
19 BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
20 ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
21 CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
38 char *application_name;
39 char *application_device_name;
44 DBusConnection *connection;
51 rd_request_cb_t request_cb;
56 #define SERVICE_PREFIX "org.freedesktop.ReserveDevice1."
57 #define OBJECT_PREFIX "/org/freedesktop/ReserveDevice1/"
59 static const char introspection[] =
60 DBUS_INTROSPECT_1_0_XML_DOCTYPE_DECL_NODE
62 " <!-- If you are looking for documentation make sure to check out\n"
63 " http://git.0pointer.de/?p=reserve.git;a=blob;f=reserve.txt -->\n"
64 " <interface name=\"org.freedesktop.ReserveDevice1\">"
65 " <method name=\"RequestRelease\">"
66 " <arg name=\"priority\" type=\"i\" direction=\"in\"/>"
67 " <arg name=\"result\" type=\"b\" direction=\"out\"/>"
69 " <property name=\"Priority\" type=\"i\" access=\"read\"/>"
70 " <property name=\"ApplicationName\" type=\"s\" access=\"read\"/>"
71 " <property name=\"ApplicationDeviceName\" type=\"s\" access=\"read\"/>"
73 " <interface name=\"org.freedesktop.DBus.Properties\">"
74 " <method name=\"Get\">"
75 " <arg name=\"interface\" direction=\"in\" type=\"s\"/>"
76 " <arg name=\"property\" direction=\"in\" type=\"s\"/>"
77 " <arg name=\"value\" direction=\"out\" type=\"v\"/>"
80 " <interface name=\"org.freedesktop.DBus.Introspectable\">"
81 " <method name=\"Introspect\">"
82 " <arg name=\"data\" type=\"s\" direction=\"out\"/>"
87 static dbus_bool_t add_variant(
92 DBusMessageIter iter, sub;
98 dbus_message_iter_init_append(m, &iter);
100 if (!dbus_message_iter_open_container(&iter, DBUS_TYPE_VARIANT, t, &sub))
103 if (!dbus_message_iter_append_basic(&sub, type, data))
106 if (!dbus_message_iter_close_container(&iter, &sub))
112 static DBusHandlerResult object_handler(
119 DBusMessage *reply = NULL;
121 dbus_error_init(&error);
126 if (dbus_message_is_method_call(
128 "org.freedesktop.ReserveDevice1",
134 if (!dbus_message_get_args(
137 DBUS_TYPE_INT32, &priority,
143 if (priority > d->priority && d->request_cb) {
146 if (d->request_cb(d, 0) > 0) {
154 if (!(reply = dbus_message_new_method_return(m)))
157 if (!dbus_message_append_args(
159 DBUS_TYPE_BOOLEAN, &ret,
163 if (!dbus_connection_send(c, reply, NULL))
166 dbus_message_unref(reply);
168 return DBUS_HANDLER_RESULT_HANDLED;
170 } else if (dbus_message_is_method_call(
172 "org.freedesktop.DBus.Properties",
175 const char *interface, *property;
177 if (!dbus_message_get_args(
180 DBUS_TYPE_STRING, &interface,
181 DBUS_TYPE_STRING, &property,
185 if (strcmp(interface, "org.freedesktop.ReserveDevice1") == 0) {
186 const char *empty = "";
188 if (strcmp(property, "ApplicationName") == 0 && d->application_name) {
189 if (!(reply = dbus_message_new_method_return(m)))
195 d->application_name ? (const char**) &d->application_name : &empty))
198 } else if (strcmp(property, "ApplicationDeviceName") == 0) {
199 if (!(reply = dbus_message_new_method_return(m)))
205 d->application_device_name ? (const char**) &d->application_device_name : &empty))
208 } else if (strcmp(property, "Priority") == 0) {
209 if (!(reply = dbus_message_new_method_return(m)))
218 if (!(reply = dbus_message_new_error_printf(
220 DBUS_ERROR_UNKNOWN_METHOD,
221 "Unknown property %s",
226 if (!dbus_connection_send(c, reply, NULL))
229 dbus_message_unref(reply);
231 return DBUS_HANDLER_RESULT_HANDLED;
234 } else if (dbus_message_is_method_call(
236 "org.freedesktop.DBus.Introspectable",
238 const char *i = introspection;
240 if (!(reply = dbus_message_new_method_return(m)))
243 if (!dbus_message_append_args(
250 if (!dbus_connection_send(c, reply, NULL))
253 dbus_message_unref(reply);
255 return DBUS_HANDLER_RESULT_HANDLED;
258 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
262 dbus_message_unref(reply);
264 if (!(reply = dbus_message_new_error(
266 DBUS_ERROR_INVALID_ARGS,
267 "Invalid arguments")))
270 if (!dbus_connection_send(c, reply, NULL))
273 dbus_message_unref(reply);
275 dbus_error_free(&error);
277 return DBUS_HANDLER_RESULT_HANDLED;
281 dbus_message_unref(reply);
283 dbus_error_free(&error);
285 return DBUS_HANDLER_RESULT_NEED_MEMORY;
288 static DBusHandlerResult filter_handler(
297 dbus_error_init(&error);
301 if (dbus_message_is_signal(m, "org.freedesktop.DBus", "NameLost")) {
304 if (!dbus_message_get_args(
307 DBUS_TYPE_STRING, &name,
311 if (strcmp(name, d->service_name) == 0 && d->owning) {
324 return DBUS_HANDLER_RESULT_HANDLED;
328 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
331 if (!(reply = dbus_message_new_error(
333 DBUS_ERROR_INVALID_ARGS,
334 "Invalid arguments")))
337 if (!dbus_connection_send(c, reply, NULL))
340 dbus_message_unref(reply);
342 dbus_error_free(&error);
344 return DBUS_HANDLER_RESULT_HANDLED;
348 dbus_message_unref(reply);
350 dbus_error_free(&error);
352 return DBUS_HANDLER_RESULT_NEED_MEMORY;
356 static const struct DBusObjectPathVTable vtable ={
357 .message_function = object_handler
362 DBusConnection *connection,
363 const char *device_name,
364 const char *application_name,
366 rd_request_cb_t request_cb,
372 DBusMessage *m = NULL, *reply = NULL;
378 dbus_error_init(error);
389 if (!request_cb && priority != INT32_MAX)
392 if (!(d = calloc(sizeof(rd_device), 1)))
397 if (!(d->device_name = strdup(device_name))) {
402 if (!(d->application_name = strdup(application_name))) {
407 d->priority = priority;
408 d->connection = dbus_connection_ref(connection);
409 d->request_cb = request_cb;
411 if (!(d->service_name = malloc(sizeof(SERVICE_PREFIX) + strlen(device_name)))) {
415 sprintf(d->service_name, SERVICE_PREFIX "%s", d->device_name);
417 if (!(d->object_path = malloc(sizeof(OBJECT_PREFIX) + strlen(device_name)))) {
421 sprintf(d->object_path, OBJECT_PREFIX "%s", d->device_name);
423 if ((k = dbus_bus_request_name(
426 DBUS_NAME_FLAG_DO_NOT_QUEUE|
427 (priority < INT32_MAX ? DBUS_NAME_FLAG_ALLOW_REPLACEMENT : 0),
433 if (k == DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER)
436 if (k != DBUS_REQUEST_NAME_REPLY_EXISTS) {
441 if (priority <= INT32_MIN) {
446 if (!(m = dbus_message_new_method_call(
449 "org.freedesktop.ReserveDevice1",
450 "RequestRelease"))) {
455 if (!dbus_message_append_args(
457 DBUS_TYPE_INT32, &d->priority,
458 DBUS_TYPE_INVALID)) {
463 if (!(reply = dbus_connection_send_with_reply_and_block(
469 if (dbus_error_has_name(error, DBUS_ERROR_TIMED_OUT) ||
470 dbus_error_has_name(error, DBUS_ERROR_UNKNOWN_METHOD) ||
471 dbus_error_has_name(error, DBUS_ERROR_NO_REPLY)) {
472 /* This must be treated as denied. */
481 if (!dbus_message_get_args(
484 DBUS_TYPE_BOOLEAN, &good,
485 DBUS_TYPE_INVALID)) {
495 if ((k = dbus_bus_request_name(
498 DBUS_NAME_FLAG_DO_NOT_QUEUE|
499 (priority < INT32_MAX ? DBUS_NAME_FLAG_ALLOW_REPLACEMENT : 0)|
500 DBUS_NAME_FLAG_REPLACE_EXISTING,
506 if (k != DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER) {
514 if (!(dbus_connection_register_object_path(
525 if (!dbus_connection_add_filter(
541 dbus_message_unref(m);
544 dbus_message_unref(reply);
546 if (&_error == error)
547 dbus_error_free(&_error);
568 dbus_connection_remove_filter(
574 dbus_connection_unregister_object_path(
580 dbus_error_init(&error);
582 dbus_bus_release_name(
587 dbus_error_free(&error);
590 free(d->device_name);
591 free(d->application_name);
592 free(d->application_device_name);
593 free(d->service_name);
594 free(d->object_path);
597 dbus_connection_unref(d->connection);
602 int rd_set_application_device_name(rd_device *d, const char *n) {
610 if (!(t = strdup(n)))
613 free(d->application_device_name);
614 d->application_device_name = t;
618 void rd_set_userdata(rd_device *d, void *userdata) {
624 d->userdata = userdata;
627 void* rd_get_userdata(rd_device *d) {