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
39 char *application_name
;
40 char *application_device_name
;
45 DBusConnection
*connection
;
52 rd_request_cb_t request_cb
;
57 #define SERVICE_PREFIX "org.freedesktop.ReserveDevice1."
58 #define OBJECT_PREFIX "/org/freedesktop/ReserveDevice1/"
60 static const char introspection
[] =
61 DBUS_INTROSPECT_1_0_XML_DOCTYPE_DECL_NODE
63 " <!-- If you are looking for documentation make sure to check out\n"
64 " http://git.0pointer.de/?p=reserve.git;a=blob;f=reserve.txt -->\n"
65 " <interface name=\"org.freedesktop.ReserveDevice1\">"
66 " <method name=\"RequestRelease\">"
67 " <arg name=\"priority\" type=\"i\" direction=\"in\"/>"
68 " <arg name=\"result\" type=\"b\" direction=\"out\"/>"
70 " <property name=\"Priority\" type=\"i\" access=\"read\"/>"
71 " <property name=\"ApplicationName\" type=\"s\" access=\"read\"/>"
72 " <property name=\"ApplicationDeviceName\" type=\"s\" access=\"read\"/>"
74 " <interface name=\"org.freedesktop.DBus.Properties\">"
75 " <method name=\"Get\">"
76 " <arg name=\"interface\" direction=\"in\" type=\"s\"/>"
77 " <arg name=\"property\" direction=\"in\" type=\"s\"/>"
78 " <arg name=\"value\" direction=\"out\" type=\"v\"/>"
81 " <interface name=\"org.freedesktop.DBus.Introspectable\">"
82 " <method name=\"Introspect\">"
83 " <arg name=\"data\" type=\"s\" direction=\"out\"/>"
88 static dbus_bool_t
add_variant(
93 DBusMessageIter iter
, sub
;
99 dbus_message_iter_init_append(m
, &iter
);
101 if (!dbus_message_iter_open_container(&iter
, DBUS_TYPE_VARIANT
, t
, &sub
))
104 if (!dbus_message_iter_append_basic(&sub
, type
, data
))
107 if (!dbus_message_iter_close_container(&iter
, &sub
))
113 static DBusHandlerResult
object_handler(
120 DBusMessage
*reply
= NULL
;
122 dbus_error_init(&error
);
124 d
= (rd_device
*)userdata
;
127 if (dbus_message_is_method_call(
129 "org.freedesktop.ReserveDevice1",
135 if (!dbus_message_get_args(
138 DBUS_TYPE_INT32
, &priority
,
144 if (priority
> d
->priority
&& d
->request_cb
) {
147 if (d
->request_cb(d
, 0) > 0) {
155 if (!(reply
= dbus_message_new_method_return(m
)))
158 if (!dbus_message_append_args(
160 DBUS_TYPE_BOOLEAN
, &ret
,
164 if (!dbus_connection_send(c
, reply
, NULL
))
167 dbus_message_unref(reply
);
169 return DBUS_HANDLER_RESULT_HANDLED
;
171 } else if (dbus_message_is_method_call(
173 "org.freedesktop.DBus.Properties",
176 const char *interface
, *property
;
178 if (!dbus_message_get_args(
181 DBUS_TYPE_STRING
, &interface
,
182 DBUS_TYPE_STRING
, &property
,
186 if (strcmp(interface
, "org.freedesktop.ReserveDevice1") == 0) {
187 const char *empty
= "";
189 if (strcmp(property
, "ApplicationName") == 0 && d
->application_name
) {
190 if (!(reply
= dbus_message_new_method_return(m
)))
196 d
->application_name
? (const char**) &d
->application_name
: &empty
))
199 } else if (strcmp(property
, "ApplicationDeviceName") == 0) {
200 if (!(reply
= dbus_message_new_method_return(m
)))
206 d
->application_device_name
? (const char**) &d
->application_device_name
: &empty
))
209 } else if (strcmp(property
, "Priority") == 0) {
210 if (!(reply
= dbus_message_new_method_return(m
)))
219 if (!(reply
= dbus_message_new_error_printf(
221 DBUS_ERROR_UNKNOWN_METHOD
,
222 "Unknown property %s",
227 if (!dbus_connection_send(c
, reply
, NULL
))
230 dbus_message_unref(reply
);
232 return DBUS_HANDLER_RESULT_HANDLED
;
235 } else if (dbus_message_is_method_call(
237 "org.freedesktop.DBus.Introspectable",
239 const char *i
= introspection
;
241 if (!(reply
= dbus_message_new_method_return(m
)))
244 if (!dbus_message_append_args(
251 if (!dbus_connection_send(c
, reply
, NULL
))
254 dbus_message_unref(reply
);
256 return DBUS_HANDLER_RESULT_HANDLED
;
259 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED
;
263 dbus_message_unref(reply
);
265 if (!(reply
= dbus_message_new_error(
267 DBUS_ERROR_INVALID_ARGS
,
268 "Invalid arguments")))
271 if (!dbus_connection_send(c
, reply
, NULL
))
274 dbus_message_unref(reply
);
276 dbus_error_free(&error
);
278 return DBUS_HANDLER_RESULT_HANDLED
;
282 dbus_message_unref(reply
);
284 dbus_error_free(&error
);
286 return DBUS_HANDLER_RESULT_NEED_MEMORY
;
289 static DBusHandlerResult
filter_handler(
298 dbus_error_init(&error
);
300 d
= (rd_device
*)userdata
;
302 if (dbus_message_is_signal(m
, "org.freedesktop.DBus", "NameLost")) {
305 if (!dbus_message_get_args(
308 DBUS_TYPE_STRING
, &name
,
312 if (strcmp(name
, d
->service_name
) == 0 && d
->owning
) {
325 return DBUS_HANDLER_RESULT_HANDLED
;
329 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED
;
332 if (!(reply
= dbus_message_new_error(
334 DBUS_ERROR_INVALID_ARGS
,
335 "Invalid arguments")))
338 if (!dbus_connection_send(c
, reply
, NULL
))
341 dbus_message_unref(reply
);
343 dbus_error_free(&error
);
345 return DBUS_HANDLER_RESULT_HANDLED
;
349 dbus_message_unref(reply
);
351 dbus_error_free(&error
);
353 return DBUS_HANDLER_RESULT_NEED_MEMORY
;
356 static DBusObjectPathVTable vtable
;
360 DBusConnection
*connection
,
361 const char *device_name
,
362 const char *application_name
,
364 rd_request_cb_t request_cb
,
370 DBusMessage
*m
= NULL
, *reply
= NULL
;
373 vtable
.message_function
= object_handler
;
378 dbus_error_init(error
);
389 if (!request_cb
&& priority
!= INT32_MAX
)
392 if (!(d
= (rd_device
*)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
= (char*)malloc(sizeof(SERVICE_PREFIX
) + strlen(device_name
)))) {
415 sprintf(d
->service_name
, SERVICE_PREFIX
"%s", d
->device_name
);
417 if (!(d
->object_path
= (char*)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
) {