?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
wined3d: Use wined3d_mask_from_size() in shader_glsl_gather4().
[wine.git] / dlls / mountmgr.sys / dbus.c
blob581d45e770279f143945224d2bfbd636e2a0f219
1 /*
2 * DBus devices support
3 *
4 * Copyright 2006, 2011 Alexandre Julliard
5 *
6 * This library is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Lesser General Public
8 * License as published by the Free Software Foundation; either
9 * version 2.1 of the License, or (at your option) any later version.
10 *
11 * This library 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 GNU
14 * Lesser General Public License for more details.
15 *
16 * You should have received a copy of the GNU Lesser General Public
17 * License along with this library; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
19 */
20
21 #if 0
22 #pragma makedep unix
23 #endif
24
25 #include "config.h"
26
27 #include <errno.h>
28 #include <stdarg.h>
29 #include <stdio.h>
30 #include <dlfcn.h>
31 #include <sys/socket.h>
32 #include <netinet/in.h>
33 #include <arpa/inet.h>
34 #ifdef SONAME_LIBDBUS_1
35 # include <dbus/dbus.h>
36 #endif
37
38 #include "mountmgr.h"
39 #define USE_WS_PREFIX
40 #include "winsock2.h"
41 #include "dhcpcsdk.h"
42 #include "unixlib.h"
43
44 #include "wine/debug.h"
45
46 WINE_DEFAULT_DEBUG_CHANNEL(mountmgr);
47
48 #ifdef SONAME_LIBDBUS_1
49
50 #define DBUS_FUNCS \
51 DO_FUNC(dbus_bus_add_match); \
52 DO_FUNC(dbus_bus_get); \
53 DO_FUNC(dbus_bus_get_private); \
54 DO_FUNC(dbus_bus_remove_match); \
55 DO_FUNC(dbus_connection_add_filter); \
56 DO_FUNC(dbus_connection_read_write_dispatch); \
57 DO_FUNC(dbus_connection_remove_filter); \
58 DO_FUNC(dbus_connection_send_with_reply_and_block); \
59 DO_FUNC(dbus_error_free); \
60 DO_FUNC(dbus_error_init); \
61 DO_FUNC(dbus_error_is_set); \
62 DO_FUNC(dbus_free_string_array); \
63 DO_FUNC(dbus_message_get_args); \
64 DO_FUNC(dbus_message_get_interface); \
65 DO_FUNC(dbus_message_get_member); \
66 DO_FUNC(dbus_message_get_path); \
67 DO_FUNC(dbus_message_get_type); \
68 DO_FUNC(dbus_message_is_signal); \
69 DO_FUNC(dbus_message_iter_append_basic); \
70 DO_FUNC(dbus_message_iter_get_arg_type); \
71 DO_FUNC(dbus_message_iter_get_basic); \
72 DO_FUNC(dbus_message_iter_get_fixed_array); \
73 DO_FUNC(dbus_message_iter_init); \
74 DO_FUNC(dbus_message_iter_init_append); \
75 DO_FUNC(dbus_message_iter_next); \
76 DO_FUNC(dbus_message_iter_recurse); \
77 DO_FUNC(dbus_message_new_method_call); \
78 DO_FUNC(dbus_message_unref)
79
80 #define DO_FUNC(f) static typeof(f) * p_##f
81 DBUS_FUNCS;
82 #undef DO_FUNC
83
84 static int udisks_timeout = -1;
85 static DBusConnection *connection;
86
87 static inline int starts_with( const char *str, const char *prefix )
88 {
89 return !strncmp( str, prefix, strlen(prefix) );
90 }
91
92 static GUID *parse_uuid( GUID *guid, const char *str )
93 {
94 /* standard uuid format */
95 if (strlen(str) == 36 && str[8] == '-' && str[13] == '-' && str[18] == '-' && str[23] == '-')
96 {
97 int i;
98 unsigned char *out = guid->Data4;
99
100 if (sscanf( str, "%x-%hx-%hx-", &guid->Data1, &guid->Data2, &guid->Data3 ) != 3) return NULL;
101 for (i = 19; i < 36; i++)
102 {
103 unsigned char val;
104
105 if (i == 23) continue;
106
107 if (str[i] >= '0' && str[i] <= '9') val = str[i] - '0';
108 else if (str[i] >= 'a' && str[i] <= 'f') val = str[i] - 'a' + 10;
109 else if (str[i] >= 'A' && str[i] <= 'F') val = str[i] - 'A' + 10;
110 else return NULL;
111 val <<= 4;
112 i++;
113
114 if (str[i] >= '0' && str[i] <= '9') val += str[i] - '0';
115 else if (str[i] >= 'a' && str[i] <= 'f') val += str[i] - 'a' + 10;
116 else if (str[i] >= 'A' && str[i] <= 'F') val += str[i] - 'A' + 10;
117 else return NULL;
118 *out++ = val;
119 }
120 return guid;
121 }
122
123 /* check for xxxx-xxxx format (FAT serial number) */
124 if (strlen(str) == 9 && str[4] == '-')
125 {
126 memset( guid, 0, sizeof(*guid) );
127 if (sscanf( str, "%hx-%hx", &guid->Data2, &guid->Data3 ) == 2) return guid;
128 }
129 return NULL;
130 }
131
132 static BOOL load_dbus_functions(void)
133 {
134 void *handle;
135
136 if (!(handle = dlopen( SONAME_LIBDBUS_1, RTLD_NOW )))
137 goto failed;
138
139 #define DO_FUNC(f) if (!(p_##f = dlsym( handle, #f ))) goto failed
140 DBUS_FUNCS;
141 #undef DO_FUNC
142 return TRUE;
143
144 failed:
145 WARN( "failed to load DBUS support: %s\n", dlerror() );
146 return FALSE;
147 }
148
149 static const char *udisks_next_dict_entry( DBusMessageIter *iter, DBusMessageIter *variant )
150 {
151 DBusMessageIter sub;
152 const char *name;
153
154 if (p_dbus_message_iter_get_arg_type( iter ) != DBUS_TYPE_DICT_ENTRY) return NULL;
155 p_dbus_message_iter_recurse( iter, &sub );
156 p_dbus_message_iter_next( iter );
157 p_dbus_message_iter_get_basic( &sub, &name );
158 p_dbus_message_iter_next( &sub );
159 p_dbus_message_iter_recurse( &sub, variant );
160 return name;
161 }
162
163 static enum device_type udisks_parse_media_compatibility( DBusMessageIter *iter )
164 {
165 DBusMessageIter media;
166 enum device_type drive_type = DEVICE_UNKNOWN;
167
168 p_dbus_message_iter_recurse( iter, &media );
169 while (p_dbus_message_iter_get_arg_type( &media ) == DBUS_TYPE_STRING)
170 {
171 const char *media_type;
172 p_dbus_message_iter_get_basic( &media, &media_type );
173 if (starts_with( media_type, "optical_dvd" ))
174 drive_type = DEVICE_DVD;
175 if (starts_with( media_type, "floppy" ))
176 drive_type = DEVICE_FLOPPY;
177 else if (starts_with( media_type, "optical_" ) && drive_type == DEVICE_UNKNOWN)
178 drive_type = DEVICE_CDROM;
179 p_dbus_message_iter_next( &media );
180 }
181 return drive_type;
182 }
183
184 /* UDisks callback for new device */
185 static void udisks_new_device( const char *udi )
186 {
187 static const char *dev_name = "org.freedesktop.UDisks.Device";
188 DBusMessage *request, *reply;
189 DBusMessageIter iter, variant;
190 DBusError error;
191 const char *device = NULL;
192 const char *mount_point = NULL;
193 const char *type = NULL;
194 GUID guid, *guid_ptr = NULL;
195 int removable = FALSE;
196 enum device_type drive_type = DEVICE_UNKNOWN;
197
198 request = p_dbus_message_new_method_call( "org.freedesktop.UDisks", udi,
199 "org.freedesktop.DBus.Properties", "GetAll" );
200 if (!request) return;
201
202 p_dbus_message_iter_init_append( request, &iter );
203 p_dbus_message_iter_append_basic( &iter, DBUS_TYPE_STRING, &dev_name );
204
205 p_dbus_error_init( &error );
206 reply = p_dbus_connection_send_with_reply_and_block( connection, request, -1, &error );
207 p_dbus_message_unref( request );
208 if (!reply)
209 {
210 WARN( "failed: %s\n", error.message );
211 p_dbus_error_free( &error );
212 return;
213 }
214 p_dbus_error_free( &error );
215
216 p_dbus_message_iter_init( reply, &iter );
217 if (p_dbus_message_iter_get_arg_type( &iter ) == DBUS_TYPE_ARRAY)
218 {
219 const char *name;
220
221 p_dbus_message_iter_recurse( &iter, &iter );
222 while ((name = udisks_next_dict_entry( &iter, &variant )))
223 {
224 if (!strcmp( name, "DeviceFile" ))
225 p_dbus_message_iter_get_basic( &variant, &device );
226 else if (!strcmp( name, "DeviceIsRemovable" ))
227 p_dbus_message_iter_get_basic( &variant, &removable );
228 else if (!strcmp( name, "IdType" ))
229 p_dbus_message_iter_get_basic( &variant, &type );
230 else if (!strcmp( name, "DriveMediaCompatibility" ))
231 drive_type = udisks_parse_media_compatibility( &variant );
232 else if (!strcmp( name, "DeviceMountPaths" ))
233 {
234 DBusMessageIter paths;
235 p_dbus_message_iter_recurse( &variant, &paths );
236 if (p_dbus_message_iter_get_arg_type( &paths ) == DBUS_TYPE_STRING)
237 p_dbus_message_iter_get_basic( &paths, &mount_point );
238 }
239 else if (!strcmp( name, "IdUuid" ))
240 {
241 char *uuid_str;
242 p_dbus_message_iter_get_basic( &variant, &uuid_str );
243 guid_ptr = parse_uuid( &guid, uuid_str );
244 }
245 }
246 }
247
248 TRACE( "udi %s device %s mount point %s uuid %s type %s removable %u\n",
249 debugstr_a(udi), debugstr_a(device), debugstr_a(mount_point),
250 debugstr_guid(guid_ptr), debugstr_a(type), removable );
251
252 if (type)
253 {
254 if (!strcmp( type, "iso9660" ))
255 {
256 removable = TRUE;
257 drive_type = DEVICE_CDROM;
258 }
259 else if (!strcmp( type, "udf" ))
260 {
261 removable = TRUE;
262 drive_type = DEVICE_DVD;
263 }
264 }
265
266 if (device)
267 {
268 if (removable) queue_device_op( ADD_DOS_DEVICE, udi, device, mount_point, drive_type, guid_ptr, NULL, NULL );
269 else if (guid_ptr) queue_device_op( ADD_VOLUME, udi, device, mount_point, DEVICE_HARDDISK_VOL, guid_ptr, NULL, NULL );
270 }
271
272 p_dbus_message_unref( reply );
273 }
274
275 /* UDisks callback for removed device */
276 static void udisks_removed_device( const char *udi )
277 {
278 TRACE( "removed %s\n", wine_dbgstr_a(udi) );
279 queue_device_op( REMOVE_DEVICE, udi, NULL, NULL, 0, NULL, NULL, NULL );
280 }
281
282 /* UDisks callback for changed device */
283 static void udisks_changed_device( const char *udi )
284 {
285 udisks_new_device( udi );
286 }
287
288 static BOOL udisks_enumerate_devices(void)
289 {
290 DBusMessage *request, *reply;
291 DBusError error;
292 char **paths;
293 int i, count;
294
295 request = p_dbus_message_new_method_call( "org.freedesktop.UDisks", "/org/freedesktop/UDisks",
296 "org.freedesktop.UDisks", "EnumerateDevices" );
297 if (!request) return FALSE;
298
299 p_dbus_error_init( &error );
300 reply = p_dbus_connection_send_with_reply_and_block( connection, request, udisks_timeout, &error );
301 p_dbus_message_unref( request );
302 if (!reply)
303 {
304 WARN( "failed: %s\n", error.message );
305 p_dbus_error_free( &error );
306 return FALSE;
307 }
308 p_dbus_error_free( &error );
309
310 if (p_dbus_message_get_args( reply, &error, DBUS_TYPE_ARRAY,
311 DBUS_TYPE_OBJECT_PATH, &paths, &count, DBUS_TYPE_INVALID ))
312 {
313 for (i = 0; i < count; i++) udisks_new_device( paths[i] );
314 p_dbus_free_string_array( paths );
315 }
316 else WARN( "unexpected args in EnumerateDevices reply\n" );
317
318 p_dbus_message_unref( reply );
319 return TRUE;
320 }
321
322 /* to make things easier, UDisks2 stores strings as array of bytes instead of strings... */
323 static const char *udisks2_string_from_array( DBusMessageIter *iter )
324 {
325 DBusMessageIter string;
326 const char *array;
327 int size;
328
329 p_dbus_message_iter_recurse( iter, &string );
330 p_dbus_message_iter_get_fixed_array( &string, &array, &size );
331 return array;
332 }
333
334 /* find the drive entry in the dictionary and get its parameters */
335 static void udisks2_get_drive_info( const char *drive_name, DBusMessageIter *dict,
336 enum device_type *drive_type, int *removable, const char **serial )
337 {
338 DBusMessageIter iter, drive, variant;
339 const char *name;
340
341 p_dbus_message_iter_recurse( dict, &iter );
342 while ((name = udisks_next_dict_entry( &iter, &drive )))
343 {
344 if (strcmp( name, drive_name )) continue;
345 while ((name = udisks_next_dict_entry( &drive, &iter )))
346 {
347 if (strcmp( name, "org.freedesktop.UDisks2.Drive" )) continue;
348 while ((name = udisks_next_dict_entry( &iter, &variant )))
349 {
350 if (!strcmp( name, "Removable" ))
351 p_dbus_message_iter_get_basic( &variant, removable );
352 else if (!strcmp( name, "MediaCompatibility" ))
353 *drive_type = udisks_parse_media_compatibility( &variant );
354 else if (!strcmp( name, "Id" ))
355 p_dbus_message_iter_get_basic( &variant, serial );
356 }
357 }
358 }
359 }
360
361 static void udisks2_add_device( const char *udi, DBusMessageIter *dict, DBusMessageIter *block )
362 {
363 DBusMessageIter iter, variant, paths, string;
364 const char *device = NULL;
365 const char *mount_point = NULL;
366 const char *type = NULL;
367 const char *drive = NULL;
368 const char *id = NULL;
369 GUID guid, *guid_ptr = NULL;
370 const char *iface, *name;
371 int removable = FALSE;
372 enum device_type drive_type = DEVICE_UNKNOWN;
373
374 while ((iface = udisks_next_dict_entry( block, &iter )))
375 {
376 if (!strcmp( iface, "org.freedesktop.UDisks2.Filesystem" ))
377 {
378 while ((name = udisks_next_dict_entry( &iter, &variant )))
379 {
380 if (!strcmp( name, "MountPoints" ))
381 {
382 p_dbus_message_iter_recurse( &variant, &paths );
383 if (p_dbus_message_iter_get_arg_type( &paths ) == DBUS_TYPE_ARRAY)
384 {
385 p_dbus_message_iter_recurse( &variant, &string );
386 mount_point = udisks2_string_from_array( &string );
387 }
388 }
389 }
390 }
391 if (!strcmp( iface, "org.freedesktop.UDisks2.Block" ))
392 {
393 while ((name = udisks_next_dict_entry( &iter, &variant )))
394 {
395 if (!strcmp( name, "Device" ))
396 device = udisks2_string_from_array( &variant );
397 else if (!strcmp( name, "IdType" ))
398 p_dbus_message_iter_get_basic( &variant, &type );
399 else if (!strcmp( name, "Drive" ))
400 {
401 p_dbus_message_iter_get_basic( &variant, &drive );
402 udisks2_get_drive_info( drive, dict, &drive_type, &removable, &id );
403 }
404 else if (!strcmp( name, "IdUUID" ))
405 {
406 const char *uuid_str;
407 if (p_dbus_message_iter_get_arg_type( &variant ) == DBUS_TYPE_ARRAY)
408 uuid_str = udisks2_string_from_array( &variant );
409 else
410 p_dbus_message_iter_get_basic( &variant, &uuid_str );
411 guid_ptr = parse_uuid( &guid, uuid_str );
412 }
413 }
414 }
415 }
416
417 TRACE( "udi %s device %s mount point %s uuid %s type %s removable %u\n",
418 debugstr_a(udi), debugstr_a(device), debugstr_a(mount_point),
419 debugstr_guid(guid_ptr), debugstr_a(type), removable );
420
421 if (type)
422 {
423 if (!strcmp( type, "iso9660" ))
424 {
425 removable = TRUE;
426 drive_type = DEVICE_CDROM;
427 }
428 else if (!strcmp( type, "udf" ))
429 {
430 removable = TRUE;
431 drive_type = DEVICE_DVD;
432 }
433 }
434 if (device)
435 {
436 if (removable) queue_device_op( ADD_DOS_DEVICE, udi, device, mount_point, drive_type, guid_ptr, id, NULL );
437 else if (guid_ptr) queue_device_op( ADD_VOLUME, udi, device, mount_point, DEVICE_HARDDISK_VOL, guid_ptr, id, NULL );
438 }
439 }
440
441 /* UDisks2 is almost, but not quite, entirely unlike UDisks.
442 * It would have been easy to make it backwards compatible, but where would be the fun in that?
443 */
444 static BOOL udisks2_add_devices( const char *changed )
445 {
446 DBusMessage *request, *reply;
447 DBusMessageIter dict, iter, block;
448 DBusError error;
449 const char *udi;
450
451 request = p_dbus_message_new_method_call( "org.freedesktop.UDisks2", "/org/freedesktop/UDisks2",
452 "org.freedesktop.DBus.ObjectManager", "GetManagedObjects" );
453 if (!request) return FALSE;
454
455 p_dbus_error_init( &error );
456 reply = p_dbus_connection_send_with_reply_and_block( connection, request, udisks_timeout, &error );
457 p_dbus_message_unref( request );
458 if (!reply)
459 {
460 WARN( "failed: %s\n", error.message );
461 p_dbus_error_free( &error );
462 return FALSE;
463 }
464 p_dbus_error_free( &error );
465
466 p_dbus_message_iter_init( reply, &dict );
467 if (p_dbus_message_iter_get_arg_type( &dict ) == DBUS_TYPE_ARRAY)
468 {
469 p_dbus_message_iter_recurse( &dict, &iter );
470 while ((udi = udisks_next_dict_entry( &iter, &block )))
471 {
472 if (!starts_with( udi, "/org/freedesktop/UDisks2/block_devices/" )) continue;
473 if (changed && strcmp( changed, udi )) continue;
474 udisks2_add_device( udi, &dict, &block );
475 }
476 }
477 else WARN( "unexpected args in GetManagedObjects reply\n" );
478
479 p_dbus_message_unref( reply );
480 return TRUE;
481 }
482
483 static DBusHandlerResult udisks_filter( DBusConnection *ctx, DBusMessage *msg, void *user_data )
484 {
485 char *path;
486 DBusError error;
487
488 p_dbus_error_init( &error );
489
490 /* udisks signals */
491 if (p_dbus_message_is_signal( msg, "org.freedesktop.UDisks", "DeviceAdded" ) &&
492 p_dbus_message_get_args( msg, &error, DBUS_TYPE_OBJECT_PATH, &path, DBUS_TYPE_INVALID ))
493 {
494 udisks_new_device( path );
495 }
496 else if (p_dbus_message_is_signal( msg, "org.freedesktop.UDisks", "DeviceRemoved" ) &&
497 p_dbus_message_get_args( msg, &error, DBUS_TYPE_OBJECT_PATH, &path, DBUS_TYPE_INVALID ))
498 {
499 udisks_removed_device( path );
500 }
501 else if (p_dbus_message_is_signal( msg, "org.freedesktop.UDisks", "DeviceChanged" ) &&
502 p_dbus_message_get_args( msg, &error, DBUS_TYPE_OBJECT_PATH, &path, DBUS_TYPE_INVALID ))
503 {
504 udisks_changed_device( path );
505 }
506 /* udisks2 signals */
507 else if (p_dbus_message_is_signal( msg, "org.freedesktop.DBus.ObjectManager", "InterfacesAdded" ) &&
508 p_dbus_message_get_args( msg, &error, DBUS_TYPE_OBJECT_PATH, &path, DBUS_TYPE_INVALID ))
509 {
510 TRACE( "added %s\n", wine_dbgstr_a(path) );
511 udisks2_add_devices( path );
512 }
513 else if (p_dbus_message_is_signal( msg, "org.freedesktop.DBus.ObjectManager", "InterfacesRemoved" ) &&
514 p_dbus_message_get_args( msg, &error, DBUS_TYPE_OBJECT_PATH, &path, DBUS_TYPE_INVALID ))
515 {
516 udisks_removed_device( path );
517 }
518 else if (p_dbus_message_is_signal( msg, "org.freedesktop.DBus.Properties", "PropertiesChanged" ))
519 {
520 const char *udi = p_dbus_message_get_path( msg );
521 TRACE( "changed %s\n", wine_dbgstr_a(udi) );
522 udisks2_add_devices( udi );
523 }
524 else TRACE( "ignoring message type=%d path=%s interface=%s method=%s\n",
525 p_dbus_message_get_type( msg ), p_dbus_message_get_path( msg ),
526 p_dbus_message_get_interface( msg ), p_dbus_message_get_member( msg ) );
527
528 p_dbus_error_free( &error );
529 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
530 }
531
532 void run_dbus_loop(void)
533 {
534 static const char udisks_match[] = "type='signal',"
535 "interface='org.freedesktop.UDisks',"
536 "sender='org.freedesktop.UDisks'";
537 static const char udisks2_match_interfaces[] = "type='signal',"
538 "interface='org.freedesktop.DBus.ObjectManager',"
539 "path='/org/freedesktop/UDisks2'";
540 static const char udisks2_match_properties[] = "type='signal',"
541 "interface='org.freedesktop.DBus.Properties'";
542
543
544 DBusError error;
545
546 if (!load_dbus_functions()) return;
547
548 p_dbus_error_init( &error );
549 if (!(connection = p_dbus_bus_get( DBUS_BUS_SYSTEM, &error )))
550 {
551 WARN( "failed to get system dbus connection: %s\n", error.message );
552 p_dbus_error_free( &error );
553 return;
554 }
555
556 /* first try UDisks2 */
557
558 p_dbus_connection_add_filter( connection, udisks_filter, NULL, NULL );
559 p_dbus_bus_add_match( connection, udisks2_match_interfaces, &error );
560 p_dbus_bus_add_match( connection, udisks2_match_properties, &error );
561 if (udisks2_add_devices( NULL )) goto found;
562 p_dbus_bus_remove_match( connection, udisks2_match_interfaces, &error );
563 p_dbus_bus_remove_match( connection, udisks2_match_properties, &error );
564
565 /* then try UDisks */
566
567 p_dbus_bus_add_match( connection, udisks_match, &error );
568 if (udisks_enumerate_devices()) goto found;
569 p_dbus_bus_remove_match( connection, udisks_match, &error );
570 p_dbus_connection_remove_filter( connection, udisks_filter, NULL );
571
572 found:
573 while (p_dbus_connection_read_write_dispatch( connection, -1 )) /* nothing */ ;
574 }
575
576 #if !defined(HAVE_SYSTEMCONFIGURATION_SCDYNAMICSTORECOPYDHCPINFO_H) || !defined(HAVE_SYSTEMCONFIGURATION_SCNETWORKCONFIGURATION_H)
577
578 /* The udisks dispatch loop will block all threads using the same connection, so we'll
579 use a private connection. Multiple threads can make methods calls at the same time
580 on the same connection, according to the documentation.
581 */
582 static DBusConnection *dhcp_connection;
583 static DBusConnection *get_dhcp_connection(void)
584 {
585 if (!dhcp_connection)
586 {
587 DBusError error;
588 p_dbus_error_init( &error );
589 if (!(dhcp_connection = p_dbus_bus_get_private( DBUS_BUS_SYSTEM, &error )))
590 {
591 WARN( "failed to get system dbus connection: %s\n", error.message );
592 p_dbus_error_free( &error );
593 }
594 }
595 return dhcp_connection;
596 }
597
598 static DBusMessage *device_by_iface_request( const char *iface )
599 {
600 DBusMessage *request, *reply;
601 DBusMessageIter iter;
602 DBusError error;
603
604 request = p_dbus_message_new_method_call( "org.freedesktop.NetworkManager", "/org/freedesktop/NetworkManager",
605 "org.freedesktop.NetworkManager", "GetDeviceByIpIface" );
606 if (!request) return NULL;
607
608 p_dbus_message_iter_init_append( request, &iter );
609 p_dbus_message_iter_append_basic( &iter, DBUS_TYPE_STRING, &iface );
610
611 p_dbus_error_init( &error );
612 reply = p_dbus_connection_send_with_reply_and_block( get_dhcp_connection(), request, -1, &error );
613 p_dbus_message_unref( request );
614 if (!reply)
615 {
616 WARN( "failed: %s\n", error.message );
617 p_dbus_error_free( &error );
618 return NULL;
619 }
620
621 p_dbus_error_free( &error );
622 return reply;
623 }
624
625 static DBusMessage *dhcp4_config_request( const char *iface )
626 {
627 static const char *device = "org.freedesktop.NetworkManager.Device";
628 static const char *dhcp4_config = "Dhcp4Config";
629 DBusMessage *request, *reply;
630 DBusMessageIter iter;
631 DBusError error;
632 const char *path = NULL;
633
634 if (!(reply = device_by_iface_request( iface ))) return NULL;
635
636 p_dbus_message_iter_init( reply, &iter );
637 if (p_dbus_message_iter_get_arg_type( &iter ) == DBUS_TYPE_OBJECT_PATH) p_dbus_message_iter_get_basic( &iter, &path );
638 if (!path)
639 {
640 p_dbus_message_unref( reply );
641 return NULL;
642 }
643
644 request = p_dbus_message_new_method_call( "org.freedesktop.NetworkManager", path,
645 "org.freedesktop.DBus.Properties", "Get" );
646 p_dbus_message_unref( reply );
647 if (!request) return NULL;
648
649 p_dbus_message_iter_init_append( request, &iter );
650 p_dbus_message_iter_append_basic( &iter, DBUS_TYPE_STRING, &device );
651 p_dbus_message_iter_append_basic( &iter, DBUS_TYPE_STRING, &dhcp4_config );
652
653 p_dbus_error_init( &error );
654 reply = p_dbus_connection_send_with_reply_and_block( get_dhcp_connection(), request, -1, &error );
655 p_dbus_message_unref( request );
656 if (!reply)
657 {
658 WARN( "failed: %s\n", error.message );
659 p_dbus_error_free( &error );
660 return NULL;
661 }
662
663 p_dbus_error_free( &error );
664 return reply;
665 }
666
667 static DBusMessage *dhcp4_config_options_request( const char *unix_name )
668 {
669 static const char *dhcp4_config = "org.freedesktop.NetworkManager.DHCP4Config";
670 static const char *options = "Options";
671 DBusMessage *request, *reply;
672 DBusMessageIter iter, sub;
673 DBusError error;
674 const char *path = NULL;
675
676 if (!(reply = dhcp4_config_request( unix_name ))) return NULL;
677
678 p_dbus_message_iter_init( reply, &iter );
679 if (p_dbus_message_iter_get_arg_type( &iter ) == DBUS_TYPE_VARIANT)
680 {
681 p_dbus_message_iter_recurse( &iter, &sub );
682 p_dbus_message_iter_get_basic( &sub, &path );
683 }
684 if (!path)
685 {
686 p_dbus_message_unref( reply );
687 return NULL;
688 }
689
690 request = p_dbus_message_new_method_call( "org.freedesktop.NetworkManager", path,
691 "org.freedesktop.DBus.Properties", "Get" );
692 p_dbus_message_unref( reply );
693 if (!request) return NULL;
694
695 p_dbus_message_iter_init_append( request, &iter );
696 p_dbus_message_iter_append_basic( &iter, DBUS_TYPE_STRING, &dhcp4_config );
697 p_dbus_message_iter_append_basic( &iter, DBUS_TYPE_STRING, &options );
698
699 p_dbus_error_init( &error );
700 reply = p_dbus_connection_send_with_reply_and_block( get_dhcp_connection(), request, -1, &error );
701 p_dbus_message_unref( request );
702 if (!reply)
703 {
704 p_dbus_error_free( &error );
705 return NULL;
706 }
707
708 p_dbus_error_free( &error );
709 return reply;
710 }
711
712 static const char *dhcp4_config_option_next_dict_entry( DBusMessageIter *iter, DBusMessageIter *variant )
713 {
714 DBusMessageIter sub;
715 const char *name;
716
717 if (p_dbus_message_iter_get_arg_type( iter ) != DBUS_TYPE_DICT_ENTRY) return NULL;
718 p_dbus_message_iter_recurse( iter, &sub );
719 p_dbus_message_iter_next( iter );
720 p_dbus_message_iter_get_basic( &sub, &name );
721 p_dbus_message_iter_next( &sub );
722 p_dbus_message_iter_recurse( &sub, variant );
723 return name;
724 }
725
726 static DBusMessage *dhcp4_config_option_request( const char *unix_name, const char *option, const char **value )
727 {
728 DBusMessage *reply;
729 DBusMessageIter iter, variant;
730 const char *name;
731
732 if (!(reply = dhcp4_config_options_request( unix_name ))) return NULL;
733
734 *value = NULL;
735 p_dbus_message_iter_init( reply, &iter );
736 if (p_dbus_message_iter_get_arg_type( &iter ) == DBUS_TYPE_VARIANT)
737 {
738 p_dbus_message_iter_recurse( &iter, &iter );
739 if (p_dbus_message_iter_get_arg_type( &iter ) == DBUS_TYPE_ARRAY)
740 {
741 p_dbus_message_iter_recurse( &iter, &iter );
742 while ((name = dhcp4_config_option_next_dict_entry( &iter, &variant )))
743 {
744 if (!strcmp( name, option ))
745 {
746 p_dbus_message_iter_get_basic( &variant, value );
747 break;
748 }
749 }
750 }
751 }
752
753 return reply;
754 }
755
756 static const char *map_option( ULONG option )
757 {
758 switch (option)
759 {
760 case OPTION_SUBNET_MASK: return "subnet_mask";
761 case OPTION_ROUTER_ADDRESS: return "next_server";
762 case OPTION_HOST_NAME: return "host_name";
763 case OPTION_DOMAIN_NAME: return "domain_name";
764 case OPTION_BROADCAST_ADDRESS: return "broadcast_address";
765 case OPTION_MSFT_IE_PROXY: return "wpad";
766 default:
767 FIXME( "unhandled option %u\n", option );
768 return "";
769 }
770 }
771
772 NTSTATUS dhcp_request( void *args )
773 {
774 const struct dhcp_request_params *params = args;
775 DBusMessage *reply;
776 const char *value;
777 ULONG ret = 0;
778
779 params->req->offset = params->req->size = 0;
780
781 if (!(reply = dhcp4_config_option_request( params->unix_name, map_option(params->req->id), &value ))) return 0;
782
783 switch (params->req->id)
784 {
785 case OPTION_SUBNET_MASK:
786 case OPTION_ROUTER_ADDRESS:
787 case OPTION_BROADCAST_ADDRESS:
788 {
789 IN_ADDR *ptr = (IN_ADDR *)(params->buffer + params->offset);
790 if (value && params->size >= sizeof(IN_ADDR))
791 {
792 ptr->S_un.S_addr = inet_addr( value );
793 params->req->offset = params->offset;
794 params->req->size = sizeof(*ptr);
795 TRACE( "returning %08x\n", *(DWORD *)ptr );
796 }
797 ret = sizeof(*ptr);
798 break;
799 }
800 case OPTION_HOST_NAME:
801 case OPTION_DOMAIN_NAME:
802 case OPTION_MSFT_IE_PROXY:
803 {
804 char *ptr = params->buffer + params->offset;
805 int len = value ? strlen( value ) : 0;
806 if (len && params->size >= len)
807 {
808 memcpy( ptr, value, len );
809 params->req->offset = params->offset;
810 params->req->size = len;
811 TRACE( "returning %s\n", debugstr_an(ptr, len) );
812 }
813 ret = len;
814 break;
815 }
816 default:
817 FIXME( "option %u not supported\n", params->req->id );
818 break;
819 }
820
821 p_dbus_message_unref( reply );
822 *params->ret_size = ret;
823 return STATUS_SUCCESS;
824 }
825 #endif
826
827 #else /* SONAME_LIBDBUS_1 */
828
829 void run_dbus_loop(void)
830 {
831 TRACE( "Skipping, DBUS support not compiled in\n" );
832 }
833
834 #endif /* SONAME_LIBDBUS_1 */
Windows API implementation