1 /* -*- mode: C; c-file-style: "gnu"; indent-tabs-mode: nil; -*- */ 2 /* dbus-message-util.c Would be in dbus-message.c, but only used by bus/tests 3 * 4 * Copyright (C) 2002, 2003, 2004, 2005 Red Hat Inc. 5 * Copyright (C) 2002, 2003 CodeFactory AB 6 * 7 * Licensed under the Academic Free License version 2.1 8 * 9 * This program is free software; you can redistribute it and/or modify 10 * it under the terms of the GNU General Public License as published by 11 * the Free Software Foundation; either version 2 of the License, or 12 * (at your option) any later version. 13 * 14 * This program is distributed in the hope that it will be useful, 15 * but WITHOUT ANY WARRANTY; without even the implied warranty of 16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 17 * GNU General Public License for more details. 18 * 19 * You should have received a copy of the GNU General Public License 20 * along with this program; if not, write to the Free Software 21 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA 22 * 23 */ 24 25 #include <config.h> 26 #include "dbus-internals.h" 27 #include "dbus-test.h" 28 #include "dbus-message-private.h" 29 #include "dbus-marshal-recursive.h" 30 #include "dbus-string.h" 31 #ifdef HAVE_UNIX_FD_PASSING 32 #include "dbus-sysdeps-unix.h" 33 #endif 34 35 #ifdef __linux__ 36 /* Necessary for the Linux-specific fd leak checking code only */ 37 #include <sys/types.h> 38 #include <dirent.h> 39 #include <stdlib.h> 40 #include <errno.h> 41 #endif 42 43 /** 44 * @addtogroup DBusMessage 45 * @{ 46 */ 47 48 #ifdef DBUS_BUILD_TESTS 49 /** 50 * Reads arguments from a message iterator given a variable argument 51 * list. Only arguments of basic type and arrays of fixed-length 52 * basic type may be read with this function. See 53 * dbus_message_get_args() for more details. 54 * 55 * @param iter the message iterator 56 * @param error error to be filled in on failure 57 * @param first_arg_type the first argument type 58 * @param ... location for first argument value, then list of type-location pairs 59 * @returns #FALSE if the error was set 60 */ 61 static dbus_bool_t 62 dbus_message_iter_get_args (DBusMessageIter *iter, 63 DBusError *error, 64 int first_arg_type, 65 ...) 66 { 67 dbus_bool_t retval; 68 va_list var_args; 69 70 _dbus_return_val_if_fail (iter != NULL, FALSE); 71 _dbus_return_val_if_error_is_set (error, FALSE); 72 73 va_start (var_args, first_arg_type); 74 retval = _dbus_message_iter_get_args_valist (iter, error, first_arg_type, var_args); 75 va_end (var_args); 76 77 return retval; 78 } 79 #endif /* DBUS_BUILD_TESTS */ 80 81 /** @} */ 82 83 #ifdef DBUS_BUILD_TESTS 84 #include "dbus-test.h" 85 #include "dbus-message-factory.h" 86 #include <stdio.h> 87 #include <stdlib.h> 88 89 static int validities_seen[DBUS_VALIDITY_LAST + _DBUS_NEGATIVE_VALIDITY_COUNT]; 90 91 static void 92 reset_validities_seen (void) 93 { 94 int i; 95 i = 0; 96 while (i < _DBUS_N_ELEMENTS (validities_seen)) 97 { 98 validities_seen[i] = 0; 99 ++i; 100 } 101 } 102 103 static void 104 record_validity_seen (DBusValidity validity) 105 { 106 validities_seen[validity + _DBUS_NEGATIVE_VALIDITY_COUNT] += 1; 107 } 108 109 static void 110 print_validities_seen (dbus_bool_t not_seen) 111 { 112 int i; 113 i = 0; 114 while (i < _DBUS_N_ELEMENTS (validities_seen)) 115 { 116 if ((i - _DBUS_NEGATIVE_VALIDITY_COUNT) == DBUS_VALIDITY_UNKNOWN || 117 (i - _DBUS_NEGATIVE_VALIDITY_COUNT) == DBUS_INVALID_FOR_UNKNOWN_REASON) 118 ; 119 else if ((not_seen && validities_seen[i] == 0) || 120 (!not_seen && validities_seen[i] > 0)) 121 printf ("validity %3d seen %d times\n", 122 i - _DBUS_NEGATIVE_VALIDITY_COUNT, 123 validities_seen[i]); 124 ++i; 125 } 126 } 127 128 static void 129 check_memleaks (void) 130 { 131 dbus_shutdown (); 132 133 if (_dbus_get_malloc_blocks_outstanding () != 0) 134 { 135 _dbus_warn ("%d dbus_malloc blocks were not freed in %s\n", 136 _dbus_get_malloc_blocks_outstanding (), __FILE__); 137 _dbus_assert_not_reached ("memleaks"); 138 } 139 } 140 141 #ifdef __linux__ 142 struct DBusInitialFDs { 143 fd_set set; 144 }; 145 #endif 146 147 DBusInitialFDs * 148 _dbus_check_fdleaks_enter (void) 149 { 150 #ifdef __linux__ 151 DIR *d; 152 DBusInitialFDs *fds; 153 154 /* this is plain malloc so it won't interfere with leak checking */ 155 fds = malloc (sizeof (DBusInitialFDs)); 156 _dbus_assert (fds != NULL); 157 158 /* This works on Linux only */ 159 160 if ((d = opendir ("/proc/self/fd"))) 161 { 162 struct dirent *de; 163 164 while ((de = readdir(d))) 165 { 166 long l; 167 char *e = NULL; 168 int fd; 169 170 if (de->d_name[0] == '.') 171 continue; 172 173 errno = 0; 174 l = strtol (de->d_name, &e, 10); 175 _dbus_assert (errno == 0 && e && !*e); 176 177 fd = (int) l; 178 179 if (fd < 3) 180 continue; 181 182 if (fd == dirfd (d)) 183 continue; 184 185 FD_SET (fd, &fds->set); 186 } 187 188 closedir (d); 189 } 190 191 return fds; 192 #else 193 return NULL; 194 #endif 195 } 196 197 void 198 _dbus_check_fdleaks_leave (DBusInitialFDs *fds) 199 { 200 #ifdef __linux__ 201 DIR *d; 202 203 /* This works on Linux only */ 204 205 if ((d = opendir ("/proc/self/fd"))) 206 { 207 struct dirent *de; 208 209 while ((de = readdir(d))) 210 { 211 long l; 212 char *e = NULL; 213 int fd; 214 215 if (de->d_name[0] == '.') 216 continue; 217 218 errno = 0; 219 l = strtol (de->d_name, &e, 10); 220 _dbus_assert (errno == 0 && e && !*e); 221 222 fd = (int) l; 223 224 if (fd < 3) 225 continue; 226 227 if (fd == dirfd (d)) 228 continue; 229 230 if (FD_ISSET (fd, &fds->set)) 231 continue; 232 233 _dbus_warn ("file descriptor %i leaked in %s.\n", fd, __FILE__); 234 _dbus_assert_not_reached ("fdleaks"); 235 } 236 237 closedir (d); 238 } 239 240 free (fds); 241 #else 242 _dbus_assert (fds == NULL); 243 #endif 244 } 245 246 static dbus_bool_t 247 check_have_valid_message (DBusMessageLoader *loader) 248 { 249 DBusMessage *message; 250 dbus_bool_t retval; 251 252 message = NULL; 253 retval = FALSE; 254 255 if (_dbus_message_loader_get_is_corrupted (loader)) 256 { 257 _dbus_warn ("loader corrupted on message that was expected to be valid; invalid reason %d\n", 258 loader->corruption_reason); 259 goto failed; 260 } 261 262 message = _dbus_message_loader_pop_message (loader); 263 if (message == NULL) 264 { 265 _dbus_warn ("didn't load message that was expected to be valid (message not popped)\n"); 266 goto failed; 267 } 268 269 if (_dbus_string_get_length (&loader->data) > 0) 270 { 271 _dbus_warn ("had leftover bytes from expected-to-be-valid single message\n"); 272 goto failed; 273 } 274 275 #if 0 276 /* FIXME */ 277 /* Verify that we're able to properly deal with the message. 278 * For example, this would detect improper handling of messages 279 * in nonstandard byte order. 280 */ 281 if (!check_message_handling (message)) 282 goto failed; 283 #endif 284 285 record_validity_seen (DBUS_VALID); 286 287 retval = TRUE; 288 289 failed: 290 if (message) 291 dbus_message_unref (message); 292 293 return retval; 294 } 295 296 static dbus_bool_t 297 check_invalid_message (DBusMessageLoader *loader, 298 DBusValidity expected_validity) 299 { 300 dbus_bool_t retval; 301 302 retval = FALSE; 303 304 if (!_dbus_message_loader_get_is_corrupted (loader)) 305 { 306 _dbus_warn ("loader not corrupted on message that was expected to be invalid\n"); 307 goto failed; 308 } 309 310 record_validity_seen (loader->corruption_reason); 311 312 if (expected_validity != DBUS_INVALID_FOR_UNKNOWN_REASON && 313 loader->corruption_reason != expected_validity) 314 { 315 _dbus_warn ("expected message to be corrupted for reason %d and was corrupted for %d instead\n", 316 expected_validity, loader->corruption_reason); 317 goto failed; 318 } 319 320 retval = TRUE; 321 322 failed: 323 return retval; 324 } 325 326 static dbus_bool_t 327 check_incomplete_message (DBusMessageLoader *loader) 328 { 329 DBusMessage *message; 330 dbus_bool_t retval; 331 332 message = NULL; 333 retval = FALSE; 334 335 if (_dbus_message_loader_get_is_corrupted (loader)) 336 { 337 _dbus_warn ("loader corrupted on message that was expected to be valid (but incomplete), corruption reason %d\n", 338 loader->corruption_reason); 339 goto failed; 340 } 341 342 message = _dbus_message_loader_pop_message (loader); 343 if (message != NULL) 344 { 345 _dbus_warn ("loaded message that was expected to be incomplete\n"); 346 goto failed; 347 } 348 349 record_validity_seen (DBUS_VALID_BUT_INCOMPLETE); 350 retval = TRUE; 351 352 failed: 353 if (message) 354 dbus_message_unref (message); 355 return retval; 356 } 357 358 static dbus_bool_t 359 check_loader_results (DBusMessageLoader *loader, 360 DBusValidity expected_validity) 361 { 362 if (!_dbus_message_loader_queue_messages (loader)) 363 _dbus_assert_not_reached ("no memory to queue messages"); 364 365 if (expected_validity == DBUS_VALID) 366 return check_have_valid_message (loader); 367 else if (expected_validity == DBUS_VALID_BUT_INCOMPLETE) 368 return check_incomplete_message (loader); 369 else if (expected_validity == DBUS_VALIDITY_UNKNOWN) 370 { 371 /* here we just know we didn't segfault and that was the 372 * only test. Also, we record that we got coverage 373 * for the validity reason. 374 */ 375 if (_dbus_message_loader_get_is_corrupted (loader)) 376 record_validity_seen (loader->corruption_reason); 377 378 return TRUE; 379 } 380 else 381 return check_invalid_message (loader, expected_validity); 382 } 383 384 /** 385 * Loads the message in the given message file. 386 * 387 * @param filename filename to load 388 * @param data string to load message into 389 * @returns #TRUE if the message was loaded 390 */ 391 dbus_bool_t 392 dbus_internal_do_not_use_load_message_file (const DBusString *filename, 393 DBusString *data) 394 { 395 dbus_bool_t retval; 396 DBusError error = DBUS_ERROR_INIT; 397 398 retval = FALSE; 399 400 _dbus_verbose ("Loading raw %s\n", _dbus_string_get_const_data (filename)); 401 if (!_dbus_file_get_contents (data, filename, &error)) 402 { 403 _dbus_warn ("Could not load message file %s: %s\n", 404 _dbus_string_get_const_data (filename), 405 error.message); 406 dbus_error_free (&error); 407 goto failed; 408 } 409 410 retval = TRUE; 411 412 failed: 413 414 return retval; 415 } 416 417 /** 418 * Tries loading the message in the given message file 419 * and verifies that DBusMessageLoader can handle it. 420 * 421 * @param filename filename to load 422 * @param expected_validity what the message has to be like to return #TRUE 423 * @returns #TRUE if the message has the expected validity 424 */ 425 dbus_bool_t 426 dbus_internal_do_not_use_try_message_file (const DBusString *filename, 427 DBusValidity expected_validity) 428 { 429 DBusString data; 430 dbus_bool_t retval; 431 432 retval = FALSE; 433 434 if (!_dbus_string_init (&data)) 435 _dbus_assert_not_reached ("could not allocate string\n"); 436 437 if (!dbus_internal_do_not_use_load_message_file (filename, &data)) 438 goto failed; 439 440 retval = dbus_internal_do_not_use_try_message_data (&data, expected_validity); 441 442 failed: 443 444 if (!retval) 445 { 446 if (_dbus_string_get_length (&data) > 0) 447 _dbus_verbose_bytes_of_string (&data, 0, 448 _dbus_string_get_length (&data)); 449 450 _dbus_warn ("Failed message loader test on %s\n", 451 _dbus_string_get_const_data (filename)); 452 } 453 454 _dbus_string_free (&data); 455 456 return retval; 457 } 458 459 /** 460 * Tries loading the given message data. 461 * 462 * 463 * @param data the message data 464 * @param expected_validity what the message has to be like to return #TRUE 465 * @returns #TRUE if the message has the expected validity 466 */ 467 dbus_bool_t 468 dbus_internal_do_not_use_try_message_data (const DBusString *data, 469 DBusValidity expected_validity) 470 { 471 DBusMessageLoader *loader; 472 dbus_bool_t retval; 473 int len; 474 int i; 475 476 loader = NULL; 477 retval = FALSE; 478 479 /* Write the data one byte at a time */ 480 481 loader = _dbus_message_loader_new (); 482 483 /* check some trivial loader functions */ 484 _dbus_message_loader_ref (loader); 485 _dbus_message_loader_unref (loader); 486 _dbus_message_loader_get_max_message_size (loader); 487 488 len = _dbus_string_get_length (data); 489 for (i = 0; i < len; i++) 490 { 491 DBusString *buffer; 492 493 _dbus_message_loader_get_buffer (loader, &buffer); 494 _dbus_string_append_byte (buffer, 495 _dbus_string_get_byte (data, i)); 496 _dbus_message_loader_return_buffer (loader, buffer, 1); 497 } 498 499 if (!check_loader_results (loader, expected_validity)) 500 goto failed; 501 502 _dbus_message_loader_unref (loader); 503 loader = NULL; 504 505 /* Write the data all at once */ 506 507 loader = _dbus_message_loader_new (); 508 509 { 510 DBusString *buffer; 511 512 _dbus_message_loader_get_buffer (loader, &buffer); 513 _dbus_string_copy (data, 0, buffer, 514 _dbus_string_get_length (buffer)); 515 _dbus_message_loader_return_buffer (loader, buffer, 1); 516 } 517 518 if (!check_loader_results (loader, expected_validity)) 519 goto failed; 520 521 _dbus_message_loader_unref (loader); 522 loader = NULL; 523 524 /* Write the data 2 bytes at a time */ 525 526 loader = _dbus_message_loader_new (); 527 528 len = _dbus_string_get_length (data); 529 for (i = 0; i < len; i += 2) 530 { 531 DBusString *buffer; 532 533 _dbus_message_loader_get_buffer (loader, &buffer); 534 _dbus_string_append_byte (buffer, 535 _dbus_string_get_byte (data, i)); 536 if ((i+1) < len) 537 _dbus_string_append_byte (buffer, 538 _dbus_string_get_byte (data, i+1)); 539 _dbus_message_loader_return_buffer (loader, buffer, 1); 540 } 541 542 if (!check_loader_results (loader, expected_validity)) 543 goto failed; 544 545 _dbus_message_loader_unref (loader); 546 loader = NULL; 547 548 retval = TRUE; 549 550 failed: 551 552 if (loader) 553 _dbus_message_loader_unref (loader); 554 555 return retval; 556 } 557 558 static dbus_bool_t 559 process_test_subdir (const DBusString *test_base_dir, 560 const char *subdir, 561 DBusValidity expected_validity, 562 DBusForeachMessageFileFunc function, 563 void *user_data) 564 { 565 DBusString test_directory; 566 DBusString filename; 567 DBusDirIter *dir; 568 dbus_bool_t retval; 569 DBusError error = DBUS_ERROR_INIT; 570 571 retval = FALSE; 572 dir = NULL; 573 574 if (!_dbus_string_init (&test_directory)) 575 _dbus_assert_not_reached ("didn't allocate test_directory\n"); 576 577 _dbus_string_init_const (&filename, subdir); 578 579 if (!_dbus_string_copy (test_base_dir, 0, 580 &test_directory, 0)) 581 _dbus_assert_not_reached ("couldn't copy test_base_dir to test_directory"); 582 583 if (!_dbus_concat_dir_and_file (&test_directory, &filename)) 584 _dbus_assert_not_reached ("couldn't allocate full path"); 585 586 _dbus_string_free (&filename); 587 if (!_dbus_string_init (&filename)) 588 _dbus_assert_not_reached ("didn't allocate filename string\n"); 589 590 dir = _dbus_directory_open (&test_directory, &error); 591 if (dir == NULL) 592 { 593 _dbus_warn ("Could not open %s: %s\n", 594 _dbus_string_get_const_data (&test_directory), 595 error.message); 596 dbus_error_free (&error); 597 goto failed; 598 } 599 600 printf ("Testing %s:\n", subdir); 601 602 next: 603 while (_dbus_directory_get_next_file (dir, &filename, &error)) 604 { 605 DBusString full_path; 606 607 if (!_dbus_string_init (&full_path)) 608 _dbus_assert_not_reached ("couldn't init string"); 609 610 if (!_dbus_string_copy (&test_directory, 0, &full_path, 0)) 611 _dbus_assert_not_reached ("couldn't copy dir to full_path"); 612 613 if (!_dbus_concat_dir_and_file (&full_path, &filename)) 614 _dbus_assert_not_reached ("couldn't concat file to dir"); 615 616 if (_dbus_string_ends_with_c_str (&filename, ".message-raw")) 617 ; 618 else 619 { 620 if (_dbus_string_ends_with_c_str (&filename, ".message")) 621 { 622 printf ("SKIP: Could not load %s, message builder language no longer supported\n", 623 _dbus_string_get_const_data (&filename)); 624 } 625 626 _dbus_verbose ("Skipping non-.message file %s\n", 627 _dbus_string_get_const_data (&filename)); 628 _dbus_string_free (&full_path); 629 goto next; 630 } 631 632 printf (" %s\n", 633 _dbus_string_get_const_data (&filename)); 634 635 if (! (*function) (&full_path, 636 expected_validity, user_data)) 637 { 638 _dbus_string_free (&full_path); 639 goto failed; 640 } 641 else 642 _dbus_string_free (&full_path); 643 } 644 645 if (dbus_error_is_set (&error)) 646 { 647 _dbus_warn ("Could not get next file in %s: %s\n", 648 _dbus_string_get_const_data (&test_directory), 649 error.message); 650 dbus_error_free (&error); 651 goto failed; 652 } 653 654 retval = TRUE; 655 656 failed: 657 658 if (dir) 659 _dbus_directory_close (dir); 660 _dbus_string_free (&test_directory); 661 _dbus_string_free (&filename); 662 663 return retval; 664 } 665 666 /** 667 * Runs the given function on every message file in the test suite. 668 * The function should return #FALSE on test failure or fatal error. 669 * 670 * @param test_data_dir root dir of the test suite data files (top_srcdir/test/data) 671 * @param func the function to run 672 * @param user_data data for function 673 * @returns #FALSE if there's a failure 674 */ 675 dbus_bool_t 676 dbus_internal_do_not_use_foreach_message_file (const char *test_data_dir, 677 DBusForeachMessageFileFunc func, 678 void *user_data) 679 { 680 DBusString test_directory; 681 dbus_bool_t retval; 682 683 retval = FALSE; 684 685 _dbus_string_init_const (&test_directory, test_data_dir); 686 687 if (!process_test_subdir (&test_directory, "valid-messages", 688 DBUS_VALID, func, user_data)) 689 goto failed; 690 691 check_memleaks (); 692 693 if (!process_test_subdir (&test_directory, "invalid-messages", 694 DBUS_INVALID_FOR_UNKNOWN_REASON, func, user_data)) 695 goto failed; 696 697 check_memleaks (); 698 699 if (!process_test_subdir (&test_directory, "incomplete-messages", 700 DBUS_VALID_BUT_INCOMPLETE, func, user_data)) 701 goto failed; 702 703 check_memleaks (); 704 705 retval = TRUE; 706 707 failed: 708 709 _dbus_string_free (&test_directory); 710 711 return retval; 712 } 713 714 #if 0 715 #define GET_AND_CHECK(iter, typename, literal) \ 716 do { \ 717 if (dbus_message_iter_get_arg_type (&iter) != DBUS_TYPE_##typename) \ 718 _dbus_assert_not_reached ("got wrong argument type from message iter"); \ 719 dbus_message_iter_get_basic (&iter, &v_##typename); \ 720 if (v_##typename != literal) \ 721 _dbus_assert_not_reached ("got wrong value from message iter"); \ 722 } while (0) 723 724 #define GET_AND_CHECK_STRCMP(iter, typename, literal) \ 725 do { \ 726 if (dbus_message_iter_get_arg_type (&iter) != DBUS_TYPE_##typename) \ 727 _dbus_assert_not_reached ("got wrong argument type from message iter"); \ 728 dbus_message_iter_get_basic (&iter, &v_##typename); \ 729 if (strcmp (v_##typename, literal) != 0) \ 730 _dbus_assert_not_reached ("got wrong value from message iter"); \ 731 } while (0) 732 733 #define GET_AND_CHECK_AND_NEXT(iter, typename, literal) \ 734 do { \ 735 GET_AND_CHECK(iter, typename, literal); \ 736 if (!dbus_message_iter_next (&iter)) \ 737 _dbus_assert_not_reached ("failed to move iter to next"); \ 738 } while (0) 739 740 #define GET_AND_CHECK_STRCMP_AND_NEXT(iter, typename, literal) \ 741 do { \ 742 GET_AND_CHECK_STRCMP(iter, typename, literal); \ 743 if (!dbus_message_iter_next (&iter)) \ 744 _dbus_assert_not_reached ("failed to move iter to next"); \ 745 } while (0) 746 747 static void 748 message_iter_test (DBusMessage *message) 749 { 750 DBusMessageIter iter, array, array2; 751 const char *v_STRING; 752 double v_DOUBLE; 753 dbus_int16_t v_INT16; 754 dbus_uint16_t v_UINT16; 755 dbus_int32_t v_INT32; 756 dbus_uint32_t v_UINT32; 757 #ifdef DBUS_HAVE_INT64 758 dbus_int64_t v_INT64; 759 dbus_uint64_t v_UINT64; 760 #endif 761 unsigned char v_BYTE; 762 dbus_bool_t v_BOOLEAN; 763 764 const dbus_int32_t *our_int_array; 765 int len; 766 767 dbus_message_iter_init (message, &iter); 768 769 GET_AND_CHECK_STRCMP_AND_NEXT (iter, STRING, "Test string"); 770 GET_AND_CHECK_AND_NEXT (iter, INT32, -0x12345678); 771 GET_AND_CHECK_AND_NEXT (iter, UINT32, 0xedd1e); 772 GET_AND_CHECK_AND_NEXT (iter, DOUBLE, 3.14159); 773 774 if (dbus_message_iter_get_arg_type (&iter) != DBUS_TYPE_ARRAY) 775 _dbus_assert_not_reached ("Argument type not an array"); 776 777 if (dbus_message_iter_get_element_type (&iter) != DBUS_TYPE_DOUBLE) 778 _dbus_assert_not_reached ("Array type not double"); 779 780 dbus_message_iter_recurse (&iter, &array); 781 782 GET_AND_CHECK_AND_NEXT (array, DOUBLE, 1.5); 783 GET_AND_CHECK (array, DOUBLE, 2.5); 784 785 if (dbus_message_iter_next (&array)) 786 _dbus_assert_not_reached ("Didn't reach end of array"); 787 788 if (!dbus_message_iter_next (&iter)) 789 _dbus_assert_not_reached ("Reached end of arguments"); 790 791 GET_AND_CHECK_AND_NEXT (iter, BYTE, 0xF0); 792 793 if (dbus_message_iter_get_arg_type (&iter) != DBUS_TYPE_ARRAY) 794 _dbus_assert_not_reached ("no array"); 795 796 if (dbus_message_iter_get_element_type (&iter) != DBUS_TYPE_INT32) 797 _dbus_assert_not_reached ("Array type not int32"); 798 799 /* Empty array */ 800 dbus_message_iter_recurse (&iter, &array); 801 802 if (dbus_message_iter_next (&array)) 803 _dbus_assert_not_reached ("Didn't reach end of array"); 804 805 if (!dbus_message_iter_next (&iter)) 806 _dbus_assert_not_reached ("Reached end of arguments"); 807 808 GET_AND_CHECK (iter, BYTE, 0xF0); 809 810 if (dbus_message_iter_next (&iter)) 811 _dbus_assert_not_reached ("Didn't reach end of arguments"); 812 } 813 #endif 814 815 static void 816 verify_test_message (DBusMessage *message) 817 { 818 DBusMessageIter iter; 819 DBusError error = DBUS_ERROR_INIT; 820 dbus_int16_t our_int16; 821 dbus_uint16_t our_uint16; 822 dbus_int32_t our_int; 823 dbus_uint32_t our_uint; 824 const char *our_str; 825 double our_double; 826 double v_DOUBLE; 827 dbus_bool_t our_bool; 828 unsigned char our_byte_1, our_byte_2; 829 const dbus_uint32_t *our_uint32_array = (void*)0xdeadbeef; 830 int our_uint32_array_len; 831 dbus_int32_t *our_int32_array = (void*)0xdeadbeef; 832 int our_int32_array_len; 833 #ifdef DBUS_HAVE_INT64 834 dbus_int64_t our_int64; 835 dbus_uint64_t our_uint64; 836 dbus_int64_t *our_uint64_array = (void*)0xdeadbeef; 837 int our_uint64_array_len; 838 const dbus_int64_t *our_int64_array = (void*)0xdeadbeef; 839 int our_int64_array_len; 840 #endif 841 const double *our_double_array = (void*)0xdeadbeef; 842 int our_double_array_len; 843 const unsigned char *our_byte_array = (void*)0xdeadbeef; 844 int our_byte_array_len; 845 const dbus_bool_t *our_boolean_array = (void*)0xdeadbeef; 846 int our_boolean_array_len; 847 char **our_string_array; 848 int our_string_array_len; 849 850 dbus_message_iter_init (message, &iter); 851 852 if (!dbus_message_iter_get_args (&iter, &error, 853 DBUS_TYPE_INT16, &our_int16, 854 DBUS_TYPE_UINT16, &our_uint16, 855 DBUS_TYPE_INT32, &our_int, 856 DBUS_TYPE_UINT32, &our_uint, 857 #ifdef DBUS_HAVE_INT64 858 DBUS_TYPE_INT64, &our_int64, 859 DBUS_TYPE_UINT64, &our_uint64, 860 #endif 861 DBUS_TYPE_STRING, &our_str, 862 DBUS_TYPE_DOUBLE, &our_double, 863 DBUS_TYPE_BOOLEAN, &our_bool, 864 DBUS_TYPE_BYTE, &our_byte_1, 865 DBUS_TYPE_BYTE, &our_byte_2, 866 DBUS_TYPE_ARRAY, DBUS_TYPE_UINT32, 867 &our_uint32_array, &our_uint32_array_len, 868 DBUS_TYPE_ARRAY, DBUS_TYPE_INT32, 869 &our_int32_array, &our_int32_array_len, 870 #ifdef DBUS_HAVE_INT64 871 DBUS_TYPE_ARRAY, DBUS_TYPE_UINT64, 872 &our_uint64_array, &our_uint64_array_len, 873 DBUS_TYPE_ARRAY, DBUS_TYPE_INT64, 874 &our_int64_array, &our_int64_array_len, 875 #endif 876 DBUS_TYPE_ARRAY, DBUS_TYPE_DOUBLE, 877 &our_double_array, &our_double_array_len, 878 DBUS_TYPE_ARRAY, DBUS_TYPE_BYTE, 879 &our_byte_array, &our_byte_array_len, 880 DBUS_TYPE_ARRAY, DBUS_TYPE_BOOLEAN, 881 &our_boolean_array, &our_boolean_array_len, 882 DBUS_TYPE_ARRAY, DBUS_TYPE_STRING, 883 &our_string_array, &our_string_array_len, 884 0)) 885 { 886 _dbus_warn ("error: %s - %s\n", error.name, 887 (error.message != NULL) ? error.message : "no message"); 888 _dbus_assert_not_reached ("Could not get arguments"); 889 } 890 891 if (our_int16 != -0x123) 892 _dbus_assert_not_reached ("16-bit integers differ!"); 893 894 if (our_uint16 != 0x123) 895 _dbus_assert_not_reached ("16-bit uints differ!"); 896 897 if (our_int != -0x12345678) 898 _dbus_assert_not_reached ("integers differ!"); 899 900 if (our_uint != 0x12300042) 901 _dbus_assert_not_reached ("uints differ!"); 902 903 #ifdef DBUS_HAVE_INT64 904 if (our_int64 != DBUS_INT64_CONSTANT (-0x123456789abcd)) 905 _dbus_assert_not_reached ("64-bit integers differ!"); 906 if (our_uint64 != DBUS_UINT64_CONSTANT (0x123456789abcd)) 907 _dbus_assert_not_reached ("64-bit unsigned integers differ!"); 908 #endif 909 910 v_DOUBLE = 3.14159; 911 if (! _DBUS_DOUBLES_BITWISE_EQUAL (our_double, v_DOUBLE)) 912 _dbus_assert_not_reached ("doubles differ!"); 913 914 if (strcmp (our_str, "Test string") != 0) 915 _dbus_assert_not_reached ("strings differ!"); 916 917 if (!our_bool) 918 _dbus_assert_not_reached ("booleans differ"); 919 920 if (our_byte_1 != 42) 921 _dbus_assert_not_reached ("bytes differ!"); 922 923 if (our_byte_2 != 24) 924 _dbus_assert_not_reached ("bytes differ!"); 925 926 if (our_uint32_array_len != 4 || 927 our_uint32_array[0] != 0x12345678 || 928 our_uint32_array[1] != 0x23456781 || 929 our_uint32_array[2] != 0x34567812 || 930 our_uint32_array[3] != 0x45678123) 931 _dbus_assert_not_reached ("uint array differs"); 932 933 if (our_int32_array_len != 4 || 934 our_int32_array[0] != 0x12345678 || 935 our_int32_array[1] != -0x23456781 || 936 our_int32_array[2] != 0x34567812 || 937 our_int32_array[3] != -0x45678123) 938 _dbus_assert_not_reached ("int array differs"); 939 940 #ifdef DBUS_HAVE_INT64 941 if (our_uint64_array_len != 4 || 942 our_uint64_array[0] != 0x12345678 || 943 our_uint64_array[1] != 0x23456781 || 944 our_uint64_array[2] != 0x34567812 || 945 our_uint64_array[3] != 0x45678123) 946 _dbus_assert_not_reached ("uint64 array differs"); 947 948 if (our_int64_array_len != 4 || 949 our_int64_array[0] != 0x12345678 || 950 our_int64_array[1] != -0x23456781 || 951 our_int64_array[2] != 0x34567812 || 952 our_int64_array[3] != -0x45678123) 953 _dbus_assert_not_reached ("int64 array differs"); 954 #endif /* DBUS_HAVE_INT64 */ 955 956 if (our_double_array_len != 3) 957 _dbus_assert_not_reached ("double array had wrong length"); 958 959 /* On all IEEE machines (i.e. everything sane) exact equality 960 * should be preserved over the wire 961 */ 962 v_DOUBLE = 0.1234; 963 if (! _DBUS_DOUBLES_BITWISE_EQUAL (our_double_array[0], v_DOUBLE)) 964 _dbus_assert_not_reached ("double array had wrong values"); 965 v_DOUBLE = 9876.54321; 966 if (! _DBUS_DOUBLES_BITWISE_EQUAL (our_double_array[1], v_DOUBLE)) 967 _dbus_assert_not_reached ("double array had wrong values"); 968 v_DOUBLE = -300.0; 969 if (! _DBUS_DOUBLES_BITWISE_EQUAL (our_double_array[2], v_DOUBLE)) 970 _dbus_assert_not_reached ("double array had wrong values"); 971 972 if (our_byte_array_len != 4) 973 _dbus_assert_not_reached ("byte array had wrong length"); 974 975 if (our_byte_array[0] != 'a' || 976 our_byte_array[1] != 'b' || 977 our_byte_array[2] != 'c' || 978 our_byte_array[3] != 234) 979 _dbus_assert_not_reached ("byte array had wrong values"); 980 981 if (our_boolean_array_len != 5) 982 _dbus_assert_not_reached ("bool array had wrong length"); 983 984 if (our_boolean_array[0] != TRUE || 985 our_boolean_array[1] != FALSE || 986 our_boolean_array[2] != TRUE || 987 our_boolean_array[3] != TRUE || 988 our_boolean_array[4] != FALSE) 989 _dbus_assert_not_reached ("bool array had wrong values"); 990 991 if (our_string_array_len != 4) 992 _dbus_assert_not_reached ("string array was wrong length"); 993 994 if (strcmp (our_string_array[0], "Foo") != 0 || 995 strcmp (our_string_array[1], "bar") != 0 || 996 strcmp (our_string_array[2], "") != 0 || 997 strcmp (our_string_array[3], "woo woo woo woo") != 0) 998 _dbus_assert_not_reached ("string array had wrong values"); 999 1000 dbus_free_string_array (our_string_array); 1001 1002 if (dbus_message_iter_next (&iter)) 1003 _dbus_assert_not_reached ("Didn't reach end of arguments"); 1004 } 1005 1006 /** 1007 * @ingroup DBusMessageInternals 1008 * Unit test for DBusMessage. 1009 * 1010 * @returns #TRUE on success. 1011 */ 1012 dbus_bool_t 1013 _dbus_message_test (const char *test_data_dir) 1014 { 1015 DBusMessage *message, *message_without_unix_fds; 1016 DBusMessageLoader *loader; 1017 int i; 1018 const char *data; 1019 DBusMessage *copy; 1020 const char *name1; 1021 const char *name2; 1022 const dbus_uint32_t our_uint32_array[] = 1023 { 0x12345678, 0x23456781, 0x34567812, 0x45678123 }; 1024 const dbus_int32_t our_int32_array[] = 1025 { 0x12345678, -0x23456781, 0x34567812, -0x45678123 }; 1026 const dbus_uint32_t *v_ARRAY_UINT32 = our_uint32_array; 1027 const dbus_int32_t *v_ARRAY_INT32 = our_int32_array; 1028 #ifdef DBUS_HAVE_INT64 1029 const dbus_uint64_t our_uint64_array[] = 1030 { 0x12345678, 0x23456781, 0x34567812, 0x45678123 }; 1031 const dbus_int64_t our_int64_array[] = 1032 { 0x12345678, -0x23456781, 0x34567812, -0x45678123 }; 1033 const dbus_uint64_t *v_ARRAY_UINT64 = our_uint64_array; 1034 const dbus_int64_t *v_ARRAY_INT64 = our_int64_array; 1035 #endif 1036 const char *our_string_array[] = { "Foo", "bar", "", "woo woo woo woo" }; 1037 const char **v_ARRAY_STRING = our_string_array; 1038 const double our_double_array[] = { 0.1234, 9876.54321, -300.0 }; 1039 const double *v_ARRAY_DOUBLE = our_double_array; 1040 const unsigned char our_byte_array[] = { 'a', 'b', 'c', 234 }; 1041 const unsigned char *v_ARRAY_BYTE = our_byte_array; 1042 const dbus_bool_t our_boolean_array[] = { TRUE, FALSE, TRUE, TRUE, FALSE }; 1043 const dbus_bool_t *v_ARRAY_BOOLEAN = our_boolean_array; 1044 char sig[64]; 1045 const char *s; 1046 const char *v_STRING; 1047 double v_DOUBLE; 1048 dbus_int16_t v_INT16; 1049 dbus_uint16_t v_UINT16; 1050 dbus_int32_t v_INT32; 1051 dbus_uint32_t v_UINT32; 1052 #ifdef DBUS_HAVE_INT64 1053 dbus_int64_t v_INT64; 1054 dbus_uint64_t v_UINT64; 1055 #endif 1056 unsigned char v_BYTE; 1057 unsigned char v2_BYTE; 1058 dbus_bool_t v_BOOLEAN; 1059 DBusMessageIter iter, array_iter, struct_iter; 1060 #ifdef HAVE_UNIX_FD_PASSING 1061 int v_UNIX_FD; 1062 #endif 1063 char **decomposed; 1064 DBusInitialFDs *initial_fds; 1065 1066 initial_fds = _dbus_check_fdleaks_enter (); 1067 1068 message = dbus_message_new_method_call ("org.freedesktop.DBus.TestService", 1069 "/org/freedesktop/TestPath", 1070 "Foo.TestInterface", 1071 "TestMethod"); 1072 _dbus_assert (dbus_message_has_destination (message, "org.freedesktop.DBus.TestService")); 1073 _dbus_assert (dbus_message_is_method_call (message, "Foo.TestInterface", 1074 "TestMethod")); 1075 _dbus_assert (strcmp (dbus_message_get_path (message), 1076 "/org/freedesktop/TestPath") == 0); 1077 dbus_message_set_serial (message, 1234); 1078 1079 /* string length including nul byte not a multiple of 4 */ 1080 if (!dbus_message_set_sender (message, "org.foo.bar1")) 1081 _dbus_assert_not_reached ("out of memory"); 1082 1083 _dbus_assert (dbus_message_has_sender (message, "org.foo.bar1")); 1084 dbus_message_set_reply_serial (message, 5678); 1085 1086 _dbus_verbose_bytes_of_string (&message->header.data, 0, 1087 _dbus_string_get_length (&message->header.data)); 1088 _dbus_verbose_bytes_of_string (&message->body, 0, 1089 _dbus_string_get_length (&message->body)); 1090 1091 if (!dbus_message_set_sender (message, NULL)) 1092 _dbus_assert_not_reached ("out of memory"); 1093 1094 1095 _dbus_verbose_bytes_of_string (&message->header.data, 0, 1096 _dbus_string_get_length (&message->header.data)); 1097 _dbus_verbose_bytes_of_string (&message->body, 0, 1098 _dbus_string_get_length (&message->body)); 1099 1100 1101 _dbus_assert (!dbus_message_has_sender (message, "org.foo.bar1")); 1102 _dbus_assert (dbus_message_get_serial (message) == 1234); 1103 _dbus_assert (dbus_message_get_reply_serial (message) == 5678); 1104 _dbus_assert (dbus_message_has_destination (message, "org.freedesktop.DBus.TestService")); 1105 1106 _dbus_assert (dbus_message_get_no_reply (message) == FALSE); 1107 dbus_message_set_no_reply (message, TRUE); 1108 _dbus_assert (dbus_message_get_no_reply (message) == TRUE); 1109 dbus_message_set_no_reply (message, FALSE); 1110 _dbus_assert (dbus_message_get_no_reply (message) == FALSE); 1111 1112 /* Set/get some header fields */ 1113 1114 if (!dbus_message_set_path (message, "/foo")) 1115 _dbus_assert_not_reached ("out of memory"); 1116 _dbus_assert (strcmp (dbus_message_get_path (message), 1117 "/foo") == 0); 1118 1119 if (!dbus_message_set_interface (message, "org.Foo")) 1120 _dbus_assert_not_reached ("out of memory"); 1121 _dbus_assert (strcmp (dbus_message_get_interface (message), 1122 "org.Foo") == 0); 1123 1124 if (!dbus_message_set_member (message, "Bar")) 1125 _dbus_assert_not_reached ("out of memory"); 1126 _dbus_assert (strcmp (dbus_message_get_member (message), 1127 "Bar") == 0); 1128 1129 /* Set/get them with longer values */ 1130 if (!dbus_message_set_path (message, "/foo/bar")) 1131 _dbus_assert_not_reached ("out of memory"); 1132 _dbus_assert (strcmp (dbus_message_get_path (message), 1133 "/foo/bar") == 0); 1134 1135 if (!dbus_message_set_interface (message, "org.Foo.Bar")) 1136 _dbus_assert_not_reached ("out of memory"); 1137 _dbus_assert (strcmp (dbus_message_get_interface (message), 1138 "org.Foo.Bar") == 0); 1139 1140 if (!dbus_message_set_member (message, "BarFoo")) 1141 _dbus_assert_not_reached ("out of memory"); 1142 _dbus_assert (strcmp (dbus_message_get_member (message), 1143 "BarFoo") == 0); 1144 1145 /* Realloc shorter again */ 1146 1147 if (!dbus_message_set_path (message, "/foo")) 1148 _dbus_assert_not_reached ("out of memory"); 1149 _dbus_assert (strcmp (dbus_message_get_path (message), 1150 "/foo") == 0); 1151 1152 if (!dbus_message_set_interface (message, "org.Foo")) 1153 _dbus_assert_not_reached ("out of memory"); 1154 _dbus_assert (strcmp (dbus_message_get_interface (message), 1155 "org.Foo") == 0); 1156 1157 if (!dbus_message_set_member (message, "Bar")) 1158 _dbus_assert_not_reached ("out of memory"); 1159 _dbus_assert (strcmp (dbus_message_get_member (message), 1160 "Bar") == 0); 1161 1162 /* Path decomposing */ 1163 dbus_message_set_path (message, NULL); 1164 dbus_message_get_path_decomposed (message, &decomposed); 1165 _dbus_assert (decomposed == NULL); 1166 dbus_free_string_array (decomposed); 1167 1168 dbus_message_set_path (message, "/"); 1169 dbus_message_get_path_decomposed (message, &decomposed); 1170 _dbus_assert (decomposed != NULL); 1171 _dbus_assert (decomposed[0] == NULL); 1172 dbus_free_string_array (decomposed); 1173 1174 dbus_message_set_path (message, "/a/b"); 1175 dbus_message_get_path_decomposed (message, &decomposed); 1176 _dbus_assert (decomposed != NULL); 1177 _dbus_assert (strcmp (decomposed[0], "a") == 0); 1178 _dbus_assert (strcmp (decomposed[1], "b") == 0); 1179 _dbus_assert (decomposed[2] == NULL); 1180 dbus_free_string_array (decomposed); 1181 1182 dbus_message_set_path (message, "/spam/eggs"); 1183 dbus_message_get_path_decomposed (message, &decomposed); 1184 _dbus_assert (decomposed != NULL); 1185 _dbus_assert (strcmp (decomposed[0], "spam") == 0); 1186 _dbus_assert (strcmp (decomposed[1], "eggs") == 0); 1187 _dbus_assert (decomposed[2] == NULL); 1188 dbus_free_string_array (decomposed); 1189 1190 dbus_message_unref (message); 1191 1192 /* Test the vararg functions */ 1193 message = dbus_message_new_method_call ("org.freedesktop.DBus.TestService", 1194 "/org/freedesktop/TestPath", 1195 "Foo.TestInterface", 1196 "TestMethod"); 1197 dbus_message_set_serial (message, 1); 1198 dbus_message_set_reply_serial (message, 5678); 1199 1200 v_INT16 = -0x123; 1201 v_UINT16 = 0x123; 1202 v_INT32 = -0x12345678; 1203 v_UINT32 = 0x12300042; 1204 #ifdef DBUS_HAVE_INT64 1205 v_INT64 = DBUS_INT64_CONSTANT (-0x123456789abcd); 1206 v_UINT64 = DBUS_UINT64_CONSTANT (0x123456789abcd); 1207 #endif 1208 v_STRING = "Test string"; 1209 v_DOUBLE = 3.14159; 1210 v_BOOLEAN = TRUE; 1211 v_BYTE = 42; 1212 v2_BYTE = 24; 1213 #ifdef HAVE_UNIX_FD_PASSING 1214 v_UNIX_FD = 1; 1215 #endif 1216 1217 dbus_message_append_args (message, 1218 DBUS_TYPE_INT16, &v_INT16, 1219 DBUS_TYPE_UINT16, &v_UINT16, 1220 DBUS_TYPE_INT32, &v_INT32, 1221 DBUS_TYPE_UINT32, &v_UINT32, 1222 #ifdef DBUS_HAVE_INT64 1223 DBUS_TYPE_INT64, &v_INT64, 1224 DBUS_TYPE_UINT64, &v_UINT64, 1225 #endif 1226 DBUS_TYPE_STRING, &v_STRING, 1227 DBUS_TYPE_DOUBLE, &v_DOUBLE, 1228 DBUS_TYPE_BOOLEAN, &v_BOOLEAN, 1229 DBUS_TYPE_BYTE, &v_BYTE, 1230 DBUS_TYPE_BYTE, &v2_BYTE, 1231 DBUS_TYPE_ARRAY, DBUS_TYPE_UINT32, &v_ARRAY_UINT32, 1232 _DBUS_N_ELEMENTS (our_uint32_array), 1233 DBUS_TYPE_ARRAY, DBUS_TYPE_INT32, &v_ARRAY_INT32, 1234 _DBUS_N_ELEMENTS (our_int32_array), 1235 #ifdef DBUS_HAVE_INT64 1236 DBUS_TYPE_ARRAY, DBUS_TYPE_UINT64, &v_ARRAY_UINT64, 1237 _DBUS_N_ELEMENTS (our_uint64_array), 1238 DBUS_TYPE_ARRAY, DBUS_TYPE_INT64, &v_ARRAY_INT64, 1239 _DBUS_N_ELEMENTS (our_int64_array), 1240 #endif 1241 DBUS_TYPE_ARRAY, DBUS_TYPE_DOUBLE, &v_ARRAY_DOUBLE, 1242 _DBUS_N_ELEMENTS (our_double_array), 1243 DBUS_TYPE_ARRAY, DBUS_TYPE_BYTE, &v_ARRAY_BYTE, 1244 _DBUS_N_ELEMENTS (our_byte_array), 1245 DBUS_TYPE_ARRAY, DBUS_TYPE_BOOLEAN, &v_ARRAY_BOOLEAN, 1246 _DBUS_N_ELEMENTS (our_boolean_array), 1247 DBUS_TYPE_ARRAY, DBUS_TYPE_STRING, &v_ARRAY_STRING, 1248 _DBUS_N_ELEMENTS (our_string_array), 1249 1250 DBUS_TYPE_INVALID); 1251 1252 i = 0; 1253 sig[i++] = DBUS_TYPE_INT16; 1254 sig[i++] = DBUS_TYPE_UINT16; 1255 sig[i++] = DBUS_TYPE_INT32; 1256 sig[i++] = DBUS_TYPE_UINT32; 1257 #ifdef DBUS_HAVE_INT64 1258 sig[i++] = DBUS_TYPE_INT64; 1259 sig[i++] = DBUS_TYPE_UINT64; 1260 #endif 1261 sig[i++] = DBUS_TYPE_STRING; 1262 sig[i++] = DBUS_TYPE_DOUBLE; 1263 sig[i++] = DBUS_TYPE_BOOLEAN; 1264 sig[i++] = DBUS_TYPE_BYTE; 1265 sig[i++] = DBUS_TYPE_BYTE; 1266 sig[i++] = DBUS_TYPE_ARRAY; 1267 sig[i++] = DBUS_TYPE_UINT32; 1268 sig[i++] = DBUS_TYPE_ARRAY; 1269 sig[i++] = DBUS_TYPE_INT32; 1270 #ifdef DBUS_HAVE_INT64 1271 sig[i++] = DBUS_TYPE_ARRAY; 1272 sig[i++] = DBUS_TYPE_UINT64; 1273 sig[i++] = DBUS_TYPE_ARRAY; 1274 sig[i++] = DBUS_TYPE_INT64; 1275 #endif 1276 sig[i++] = DBUS_TYPE_ARRAY; 1277 sig[i++] = DBUS_TYPE_DOUBLE; 1278 sig[i++] = DBUS_TYPE_ARRAY; 1279 sig[i++] = DBUS_TYPE_BYTE; 1280 sig[i++] = DBUS_TYPE_ARRAY; 1281 sig[i++] = DBUS_TYPE_BOOLEAN; 1282 sig[i++] = DBUS_TYPE_ARRAY; 1283 sig[i++] = DBUS_TYPE_STRING; 1284 1285 message_without_unix_fds = dbus_message_copy(message); 1286 _dbus_assert(message_without_unix_fds); 1287 #ifdef HAVE_UNIX_FD_PASSING 1288 dbus_message_append_args (message, 1289 DBUS_TYPE_UNIX_FD, &v_UNIX_FD, 1290 DBUS_TYPE_INVALID); 1291 sig[i++] = DBUS_TYPE_UNIX_FD; 1292 #endif 1293 sig[i++] = DBUS_TYPE_INVALID; 1294 1295 _dbus_assert (i < (int) _DBUS_N_ELEMENTS (sig)); 1296 1297 _dbus_verbose ("HEADER\n"); 1298 _dbus_verbose_bytes_of_string (&message->header.data, 0, 1299 _dbus_string_get_length (&message->header.data)); 1300 _dbus_verbose ("BODY\n"); 1301 _dbus_verbose_bytes_of_string (&message->body, 0, 1302 _dbus_string_get_length (&message->body)); 1303 1304 _dbus_verbose ("Signature expected \"%s\" actual \"%s\"\n", 1305 sig, dbus_message_get_signature (message)); 1306 1307 s = dbus_message_get_signature (message); 1308 1309 _dbus_assert (dbus_message_has_signature (message, sig)); 1310 _dbus_assert (strcmp (s, sig) == 0); 1311 1312 verify_test_message (message); 1313 1314 copy = dbus_message_copy (message); 1315 1316 _dbus_assert (dbus_message_get_reply_serial (message) == 1317 dbus_message_get_reply_serial (copy)); 1318 _dbus_assert (message->header.padding == copy->header.padding); 1319 1320 _dbus_assert (_dbus_string_get_length (&message->header.data) == 1321 _dbus_string_get_length (©->header.data)); 1322 1323 _dbus_assert (_dbus_string_get_length (&message->body) == 1324 _dbus_string_get_length (©->body)); 1325 1326 verify_test_message (copy); 1327 1328 name1 = dbus_message_get_interface (message); 1329 name2 = dbus_message_get_interface (copy); 1330 1331 _dbus_assert (strcmp (name1, name2) == 0); 1332 1333 name1 = dbus_message_get_member (message); 1334 name2 = dbus_message_get_member (copy); 1335 1336 _dbus_assert (strcmp (name1, name2) == 0); 1337 1338 dbus_message_unref (copy); 1339 1340 /* Message loader test */ 1341 dbus_message_lock (message); 1342 loader = _dbus_message_loader_new (); 1343 1344 /* check ref/unref */ 1345 _dbus_message_loader_ref (loader); 1346 _dbus_message_loader_unref (loader); 1347 1348 /* Write the header data one byte at a time */ 1349 data = _dbus_string_get_const_data (&message->header.data); 1350 for (i = 0; i < _dbus_string_get_length (&message->header.data); i++) 1351 { 1352 DBusString *buffer; 1353 1354 _dbus_message_loader_get_buffer (loader, &buffer); 1355 _dbus_string_append_byte (buffer, data[i]); 1356 _dbus_message_loader_return_buffer (loader, buffer, 1); 1357 } 1358 1359 /* Write the body data one byte at a time */ 1360 data = _dbus_string_get_const_data (&message->body); 1361 for (i = 0; i < _dbus_string_get_length (&message->body); i++) 1362 { 1363 DBusString *buffer; 1364 1365 _dbus_message_loader_get_buffer (loader, &buffer); 1366 _dbus_string_append_byte (buffer, data[i]); 1367 _dbus_message_loader_return_buffer (loader, buffer, 1); 1368 } 1369 1370 #ifdef HAVE_UNIX_FD_PASSING 1371 { 1372 int *unix_fds; 1373 unsigned n_unix_fds; 1374 /* Write unix fd */ 1375 _dbus_message_loader_get_unix_fds(loader, &unix_fds, &n_unix_fds); 1376 _dbus_assert(n_unix_fds > 0); 1377 _dbus_assert(message->n_unix_fds == 1); 1378 unix_fds[0] = _dbus_dup(message->unix_fds[0], NULL); 1379 _dbus_assert(unix_fds[0] >= 0); 1380 _dbus_message_loader_return_unix_fds(loader, unix_fds, 1); 1381 } 1382 #endif 1383 1384 dbus_message_unref (message); 1385 1386 /* Now pop back the message */ 1387 if (!_dbus_message_loader_queue_messages (loader)) 1388 _dbus_assert_not_reached ("no memory to queue messages"); 1389 1390 if (_dbus_message_loader_get_is_corrupted (loader)) 1391 _dbus_assert_not_reached ("message loader corrupted"); 1392 1393 message = _dbus_message_loader_pop_message (loader); 1394 if (!message) 1395 _dbus_assert_not_reached ("received a NULL message"); 1396 1397 if (dbus_message_get_reply_serial (message) != 5678) 1398 _dbus_assert_not_reached ("reply serial fields differ"); 1399 1400 dbus_message_unref (message); 1401 1402 /* ovveride the serial, since it was reset by dbus_message_copy() */ 1403 dbus_message_set_serial(message_without_unix_fds, 8901); 1404 1405 dbus_message_lock (message_without_unix_fds); 1406 1407 verify_test_message (message_without_unix_fds); 1408 1409 { 1410 /* Marshal and demarshal the message. */ 1411 1412 DBusMessage *message2; 1413 DBusError error = DBUS_ERROR_INIT; 1414 char *marshalled = NULL; 1415 int len = 0; 1416 char garbage_header[DBUS_MINIMUM_HEADER_SIZE] = "xxx"; 1417 1418 if (!dbus_message_marshal (message_without_unix_fds, &marshalled, &len)) 1419 _dbus_assert_not_reached ("failed to marshal message"); 1420 1421 _dbus_assert (len != 0); 1422 _dbus_assert (marshalled != NULL); 1423 1424 _dbus_assert (dbus_message_demarshal_bytes_needed (marshalled, len) == len); 1425 message2 = dbus_message_demarshal (marshalled, len, &error); 1426 1427 _dbus_assert (message2 != NULL); 1428 _dbus_assert (!dbus_error_is_set (&error)); 1429 verify_test_message (message2); 1430 1431 dbus_message_unref (message2); 1432 dbus_free (marshalled); 1433 1434 /* Demarshal invalid message. */ 1435 1436 message2 = dbus_message_demarshal ("invalid", 7, &error); 1437 _dbus_assert (message2 == NULL); 1438 _dbus_assert (dbus_error_is_set (&error)); 1439 dbus_error_free (&error); 1440 1441 /* Demarshal invalid (empty) message. */ 1442 1443 message2 = dbus_message_demarshal ("", 0, &error); 1444 _dbus_assert (message2 == NULL); 1445 _dbus_assert (dbus_error_is_set (&error)); 1446 dbus_error_free (&error); 1447 1448 /* Bytes needed to demarshal empty message: 0 (more) */ 1449 1450 _dbus_assert (dbus_message_demarshal_bytes_needed ("", 0) == 0); 1451 1452 /* Bytes needed to demarshal invalid message: -1 (error). */ 1453 1454 _dbus_assert (dbus_message_demarshal_bytes_needed (garbage_header, DBUS_MINIMUM_HEADER_SIZE) == -1); 1455 } 1456 1457 dbus_message_unref (message_without_unix_fds); 1458 _dbus_message_loader_unref (loader); 1459 1460 check_memleaks (); 1461 _dbus_check_fdleaks_leave (initial_fds); 1462 initial_fds = _dbus_check_fdleaks_enter (); 1463 1464 /* Check that we can abandon a container */ 1465 message = dbus_message_new_method_call ("org.freedesktop.DBus.TestService", 1466 "/org/freedesktop/TestPath", 1467 "Foo.TestInterface", 1468 "Method"); 1469 1470 dbus_message_iter_init_append (message, &iter); 1471 1472 _dbus_assert (dbus_message_iter_open_container (&iter, DBUS_TYPE_ARRAY, 1473 (DBUS_STRUCT_BEGIN_CHAR_AS_STRING 1474 DBUS_TYPE_STRING_AS_STRING 1475 DBUS_TYPE_STRING_AS_STRING 1476 DBUS_STRUCT_END_CHAR_AS_STRING), 1477 &array_iter)); 1478 _dbus_assert (dbus_message_iter_open_container (&array_iter, DBUS_TYPE_STRUCT, 1479 NULL, &struct_iter)); 1480 1481 s = "peaches"; 1482 _dbus_assert (dbus_message_iter_append_basic (&struct_iter, DBUS_TYPE_STRING, 1483 &s)); 1484 1485 /* uh-oh, error, try and unwind */ 1486 1487 dbus_message_iter_abandon_container (&array_iter, &struct_iter); 1488 dbus_message_iter_abandon_container (&array_iter, &iter); 1489 1490 dbus_message_unref (message); 1491 1492 /* Load all the sample messages from the message factory */ 1493 { 1494 DBusMessageDataIter diter; 1495 DBusMessageData mdata; 1496 int count; 1497 1498 reset_validities_seen (); 1499 1500 count = 0; 1501 _dbus_message_data_iter_init (&diter); 1502 1503 while (_dbus_message_data_iter_get_and_next (&diter, 1504 &mdata)) 1505 { 1506 if (!dbus_internal_do_not_use_try_message_data (&mdata.data, 1507 mdata.expected_validity)) 1508 { 1509 _dbus_warn ("expected validity %d and did not get it\n", 1510 mdata.expected_validity); 1511 _dbus_assert_not_reached ("message data failed"); 1512 } 1513 1514 _dbus_message_data_free (&mdata); 1515 1516 count += 1; 1517 } 1518 1519 printf ("%d sample messages tested\n", count); 1520 1521 print_validities_seen (FALSE); 1522 print_validities_seen (TRUE); 1523 } 1524 1525 check_memleaks (); 1526 _dbus_check_fdleaks_leave (initial_fds); 1527 1528 /* Now load every message in test_data_dir if we have one */ 1529 if (test_data_dir == NULL) 1530 return TRUE; 1531 1532 initial_fds = _dbus_check_fdleaks_enter (); 1533 1534 if (!dbus_internal_do_not_use_foreach_message_file (test_data_dir, 1535 (DBusForeachMessageFileFunc) 1536 dbus_internal_do_not_use_try_message_file, 1537 NULL)) 1538 _dbus_assert_not_reached ("foreach_message_file test failed"); 1539 1540 _dbus_check_fdleaks_leave (initial_fds); 1541 1542 return TRUE; 1543 } 1544 1545 #endif /* DBUS_BUILD_TESTS */ 1546
