1 /* console-kit.h vdagentd ConsoleKit integration code
3 Copyright 2010 Red Hat, Inc.
6 Hans de Goede <hdegoede@redhat.com>
8 This program is free software: you can redistribute it and/or modify
9 it under the terms of the GNU General Public License as published by
10 the Free Software Foundation, either version 3 of the License, or
11 (at your option) any later version.
13 This program is distributed in the hope that it will be useful,
14 but WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 GNU General Public License for more details.
18 You should have received a copy of the GNU General Public License
19 along with this program. If not, see <http://www.gnu.org/licenses/>.
22 #include "console-kit.h"
23 #include <dbus/dbus.h>
30 DBusConnection
*connection
;
37 static char *console_kit_get_first_seat(struct console_kit
*ck
);
38 static char *console_kit_check_active_session_change(struct console_kit
*ck
);
40 struct console_kit
*console_kit_create(FILE *errfile
)
42 struct console_kit
*ck
;
46 ck
= calloc(1, sizeof(*ck
));
50 ck
->errfile
= errfile
;
52 dbus_error_init(&error
);
53 ck
->connection
= dbus_bus_get_private(DBUS_BUS_SYSTEM
, &error
);
54 if (ck
->connection
== NULL
|| dbus_error_is_set(&error
)) {
55 if (dbus_error_is_set(&error
)) {
56 fprintf(ck
->errfile
, "Unable to connect to system bus: %s\n",
58 dbus_error_free(&error
);
60 fprintf(ck
->errfile
, "Unable to connect to system bus\n");
65 if (!dbus_connection_get_unix_fd(ck
->connection
, &ck
->fd
)) {
66 fprintf(ck
->errfile
, "Unable to get connection fd\n");
67 console_kit_destroy(ck
);
71 if (!console_kit_get_first_seat(ck
)) {
72 console_kit_destroy(ck
);
76 /* Register for active session changes */
77 snprintf(match
, sizeof(match
),
78 "type='signal',interface='org.freedesktop.ConsoleKit.Seat',"
79 "path='%s',member='ActiveSessionChanged'", ck
->seat
);
80 dbus_error_init(&error
);
81 dbus_bus_add_match(ck
->connection
, match
, &error
);
82 if (dbus_error_is_set(&error
)) {
83 fprintf(ck
->errfile
, "Match Error (%s)\n", error
.message
);
84 console_kit_destroy(ck
);
91 void console_kit_destroy(struct console_kit
*ck
)
96 dbus_connection_close(ck
->connection
);
98 free(ck
->active_session
);
102 int console_kit_get_fd(struct console_kit
*ck
)
107 static char *console_kit_get_first_seat(struct console_kit
*ck
)
110 DBusMessage
*message
= NULL
;
111 DBusMessage
*reply
= NULL
;
112 DBusMessageIter iter
, subiter
;
116 message
= dbus_message_new_method_call("org.freedesktop.ConsoleKit",
117 "/org/freedesktop/ConsoleKit/Manager",
118 "org.freedesktop.ConsoleKit.Manager",
120 if (message
== NULL
) {
121 fprintf(ck
->errfile
, "Unable to create dbus message\n");
125 dbus_error_init(&error
);
126 reply
= dbus_connection_send_with_reply_and_block(ck
->connection
,
130 if (reply
== NULL
|| dbus_error_is_set(&error
)) {
131 if (dbus_error_is_set(&error
)) {
132 fprintf(ck
->errfile
, "GetSeats failed: %s\n",
134 dbus_error_free(&error
);
136 fprintf(ck
->errfile
, "GetSeats failed\n");
140 dbus_message_iter_init(reply
, &iter
);
141 type
= dbus_message_iter_get_arg_type(&iter
);
142 if (type
!= DBUS_TYPE_ARRAY
) {
144 "expected an array return value, got a '%c' instead\n", type
);
148 dbus_message_iter_recurse(&iter
, &subiter
);
149 type
= dbus_message_iter_get_arg_type(&subiter
);
150 if (type
!= DBUS_TYPE_OBJECT_PATH
) {
152 "expected an object path element, got a '%c' instead\n", type
);
156 dbus_message_iter_get_basic(&subiter
, &seat
);
157 ck
->seat
= strdup(seat
);
161 dbus_message_unref(reply
);
164 if (message
!= NULL
) {
165 dbus_message_unref(message
);
171 const char *console_kit_get_active_session(struct console_kit
*ck
)
174 DBusMessage
*message
= NULL
;
175 DBusMessage
*reply
= NULL
;
176 char *session
= NULL
;
181 if (ck
->active_session
)
182 return console_kit_check_active_session_change(ck
);
184 message
= dbus_message_new_method_call("org.freedesktop.ConsoleKit",
186 "org.freedesktop.ConsoleKit.Seat",
188 if (message
== NULL
) {
189 fprintf(ck
->errfile
, "Unable to create dbus message\n");
193 dbus_error_init(&error
);
194 reply
= dbus_connection_send_with_reply_and_block(ck
->connection
,
198 if (reply
== NULL
|| dbus_error_is_set(&error
)) {
199 if (dbus_error_is_set(&error
)) {
200 fprintf(ck
->errfile
, "GetActiveSession failed: %s\n",
202 dbus_error_free(&error
);
204 fprintf(ck
->errfile
, "GetActiveSession failed\n");
208 dbus_error_init(&error
);
209 if (!dbus_message_get_args(reply
,
211 DBUS_TYPE_OBJECT_PATH
, &session
,
212 DBUS_TYPE_INVALID
)) {
213 if (dbus_error_is_set(&error
)) {
214 fprintf(ck
->errfile
, "error getting ssid from reply: %s\n",
216 dbus_error_free(&error
);
218 fprintf(ck
->errfile
, "error getting ssid from reply\n");
223 ck
->active_session
= strdup(session
);
227 dbus_message_unref(reply
);
230 if (message
!= NULL
) {
231 dbus_message_unref(message
);
234 /* In case the session was changed while we were running */
235 return console_kit_check_active_session_change(ck
);
238 char *console_kit_session_for_pid(struct console_kit
*ck
, uint32_t pid
)
241 DBusMessage
*message
= NULL
;
242 DBusMessage
*reply
= NULL
;
243 DBusMessageIter args
;
249 message
= dbus_message_new_method_call("org.freedesktop.ConsoleKit",
250 "/org/freedesktop/ConsoleKit/Manager",
251 "org.freedesktop.ConsoleKit.Manager",
252 "GetSessionForUnixProcess");
253 if (message
== NULL
) {
254 fprintf(ck
->errfile
, "Unable to create dbus message\n");
258 dbus_message_iter_init_append(message
, &args
);
259 if (!dbus_message_iter_append_basic(&args
, DBUS_TYPE_UINT32
, &pid
)) {
260 fprintf(ck
->errfile
, "Unable to append dbus message args\n");
264 dbus_error_init(&error
);
265 reply
= dbus_connection_send_with_reply_and_block(ck
->connection
,
269 if (reply
== NULL
|| dbus_error_is_set(&error
)) {
270 if (dbus_error_is_set(&error
)) {
271 fprintf(ck
->errfile
, "GetSessionForUnixProcess failed: %s\n",
273 dbus_error_free(&error
);
275 fprintf(ck
->errfile
, "GetSessionForUnixProces failed\n");
279 dbus_error_init(&error
);
280 if (!dbus_message_get_args(reply
,
282 DBUS_TYPE_OBJECT_PATH
, &ssid
,
283 DBUS_TYPE_INVALID
)) {
284 if (dbus_error_is_set(&error
)) {
285 fprintf(ck
->errfile
, "error getting ssid from reply: %s\n",
287 dbus_error_free(&error
);
289 fprintf(ck
->errfile
, "error getting ssid from reply\n");
298 dbus_message_unref(reply
);
301 if (message
!= NULL
) {
302 dbus_message_unref(message
);
308 static char *console_kit_check_active_session_change(struct console_kit
*ck
)
310 DBusMessage
*message
= NULL
;
311 DBusMessageIter iter
;
315 /* non blocking read of the next available message */
316 dbus_connection_read_write(ck
->connection
, 0);
317 while ((message
= dbus_connection_pop_message(ck
->connection
))) {
318 if (dbus_message_get_type(message
) == DBUS_MESSAGE_TYPE_SIGNAL
) {
319 const char *member
= dbus_message_get_member (message
);
320 if (!strcmp(member
, "NameAcquired")) {
321 dbus_message_unref(message
);
324 if (strcmp(member
, "ActiveSessionChanged")) {
325 fprintf(ck
->errfile
, "unexpected signal member: %s\n", member
);
326 dbus_message_unref(message
);
330 fprintf(ck
->errfile
, "received non signal message!\n");
331 dbus_message_unref(message
);
335 free(ck
->active_session
);
336 ck
->active_session
= NULL
;
338 dbus_message_iter_init(message
, &iter
);
339 type
= dbus_message_iter_get_arg_type(&iter
);
340 /* Session should be an object path, but there is a bug in
341 ConsoleKit where it sends a string rather then an object_path
342 accept object_path too in case the bug ever gets fixed */
343 if (type
!= DBUS_TYPE_STRING
&& type
!= DBUS_TYPE_OBJECT_PATH
) {
345 "ActiveSessionChanged message has unexpected type: '%c'\n",
347 dbus_message_unref(message
);
351 dbus_message_iter_get_basic(&iter
, &session
);
352 ck
->active_session
= strdup(session
);
353 dbus_message_unref(message
);
355 /* non blocking read of the next available message */
356 dbus_connection_read_write(ck
->connection
, 0);
359 return ck
->active_session
;