Check that watches are removed, then invalidated, then unreffed
[platform/upstream/dbus.git] / test / marshal.c
1 /* Simple sanity-check for D-Bus message serialization.
2  *
3  * Author: Simon McVittie <simon.mcvittie@collabora.co.uk>
4  * Copyright © 2010-2011 Nokia Corporation
5  *
6  * Permission is hereby granted, free of charge, to any person
7  * obtaining a copy of this software and associated documentation files
8  * (the "Software"), to deal in the Software without restriction,
9  * including without limitation the rights to use, copy, modify, merge,
10  * publish, distribute, sublicense, and/or sell copies of the Software,
11  * and to permit persons to whom the Software is furnished to do so,
12  * subject to the following conditions:
13  *
14  * The above copyright notice and this permission notice shall be
15  * included in all copies or substantial portions of the Software.
16  *
17  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
18  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
19  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
20  * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
21  * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
22  * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
23  * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
24  * SOFTWARE.
25  */
26
27 #include <config.h>
28
29 #include <glib.h>
30
31 #include <dbus/dbus.h>
32 #include <dbus/dbus-glib-lowlevel.h>
33
34 typedef struct {
35     DBusError e;
36 } Fixture;
37
38 static void
39 assert_no_error (const DBusError *e)
40 {
41   if (G_UNLIKELY (dbus_error_is_set (e)))
42     g_error ("expected success but got error: %s: %s", e->name, e->message);
43 }
44
45 static void
46 setup (Fixture *f,
47     gconstpointer arg G_GNUC_UNUSED)
48 {
49   dbus_error_init (&f->e);
50 }
51
52 /* this is meant to be obviously correct, not efficient! */
53 static guint32
54 get_uint32 (const gchar *blob,
55     gsize offset,
56     char endian)
57 {
58   if (endian == 'l')
59     {
60       return
61         blob[offset] |
62         (blob[offset + 1] << 8) |
63         (blob[offset + 2] << 16) |
64         (blob[offset + 3] << 24);
65     }
66   else if (endian == 'B')
67     {
68       return
69         (blob[offset] << 24) |
70         (blob[offset + 1] << 16) |
71         (blob[offset + 2] << 8) |
72         blob[offset + 3];
73     }
74   else
75     {
76       g_assert_not_reached ();
77     }
78 }
79
80 #define BLOB_LENGTH (sizeof (le_blob) - 1)
81 #define OFFSET_BODY_LENGTH (4)
82 #define OFFSET_SERIAL (8)
83
84 const gchar le_blob[] =
85     /* byte 0 */
86     /* yyyyuu fixed headers */
87     "l"                     /* little-endian */
88     "\2"                    /* reply (which is the simplest message) */
89     "\2"                    /* no auto-starting */
90     "\1"                    /* D-Bus version = 1 */
91     /* byte 4 */
92     "\4\0\0\0"              /* bytes in body = 4 */
93     /* byte 8 */
94     "\x78\x56\x34\x12"      /* serial number = 0x12345678 */
95     /* byte 12 */
96     /* a(uv) variable headers start here */
97     "\x0f\0\0\0"            /* bytes in array of variable headers = 15 */
98                             /* pad to 8-byte boundary = nothing */
99     /* byte 16 */
100     "\5"                    /* in reply to: */
101         "\1u\0"             /* variant signature = u */
102                             /* pad to 4-byte boundary = nothing */
103         "\x12\xef\xcd\xab"  /* 0xabcdef12 */
104                             /* pad to 8-byte boundary = nothing */
105     /* byte 24 */
106     "\x08"                  /* signature: */
107         "\1g\0"             /* variant signature = g */
108         "\1u\0"             /* 1 byte, u, NUL (no alignment needed) */
109         "\0"                /* pad to 8-byte boundary for body */
110     /* body; byte 32 */
111     "\xef\xbe\xad\xde"      /* 0xdeadbeef */
112     ;
113
114 const gchar be_blob[] =
115     /* byte 0 */
116     /* yyyyuu fixed headers */
117     "B"                     /* big-endian */
118     "\2"                    /* reply (which is the simplest message) */
119     "\2"                    /* no auto-starting */
120     "\1"                    /* D-Bus version = 1 */
121     /* byte 4 */
122     "\0\0\0\4"              /* bytes in body = 4 */
123     /* byte 8 */
124     "\x12\x34\x56\x78"      /* serial number = 0x12345678 */
125     /* byte 12 */
126     /* a(uv) variable headers start here */
127     "\0\0\0\x0f"            /* bytes in array of variable headers = 15 */
128                             /* pad to 8-byte boundary = nothing */
129     /* byte 16 */
130     "\5"                    /* in reply to: */
131         "\1u\0"             /* variant signature = u */
132                             /* pad to 4-byte boundary = nothing */
133         "\xab\xcd\xef\x12"  /* 0xabcdef12 */
134                             /* pad to 8-byte boundary = nothing */
135     /* byte 24 */
136     "\x08"                  /* signature: */
137         "\1g\0"             /* variant signature = g */
138         "\1u\0"             /* 1 byte, u, NUL (no alignment needed) */
139         "\0"                /* pad to 8-byte boundary for body */
140     /* body; byte 32 */
141     "\xde\xad\xbe\xef"      /* 0xdeadbeef */
142     ;
143
144 static void
145 test_endian (Fixture *f,
146     gconstpointer arg)
147 {
148   const gchar *blob = arg;
149   const gchar *native_blob;
150   char *output;
151   DBusMessage *m;
152   int len;
153   dbus_uint32_t u;
154   dbus_bool_t ok;
155
156   g_assert_cmpuint ((guint) sizeof (le_blob), ==, (guint) sizeof (be_blob));
157
158   g_assert_cmpuint (get_uint32 (blob, OFFSET_BODY_LENGTH, blob[0]), ==, 4);
159   g_assert_cmpuint (get_uint32 (blob, OFFSET_SERIAL, blob[0]), ==,
160       0x12345678u);
161
162   len = dbus_message_demarshal_bytes_needed (blob, sizeof (le_blob));
163   /* everything in the string except the implicit "\0" at the end is part of
164    * the message */
165   g_assert_cmpint (len, ==, BLOB_LENGTH);
166
167   m = dbus_message_demarshal (blob, sizeof (le_blob), &f->e);
168   assert_no_error (&f->e);
169   g_assert (m != NULL);
170
171   g_assert_cmpuint (dbus_message_get_serial (m), ==, 0x12345678u);
172   g_assert_cmpuint (dbus_message_get_reply_serial (m), ==, 0xabcdef12u);
173   g_assert_cmpstr (dbus_message_get_signature (m), ==, "u");
174
175   /* Implementation detail: appending to the message results in it being
176    * byteswapped into compiler byte order, which exposed a bug in libdbus,
177    * fd.o #38120. (If that changes, this test might not exercise that
178    * particular bug but will still be valid.) */
179   u = 0xdecafbadu;
180   ok = dbus_message_append_args (m,
181       DBUS_TYPE_UINT32, &u,
182       DBUS_TYPE_INVALID);
183   g_assert (ok);
184
185   dbus_message_marshal (m, &output, &len);
186
187   g_assert (output[0] == 'l' || output[0] == 'B');
188   /* the single-byte fields are unaffected, even if the endianness was
189    * swapped */
190   g_assert_cmpint (output[1], ==, blob[1]);
191   g_assert_cmpint (output[2], ==, blob[2]);
192   g_assert_cmpint (output[3], ==, blob[3]);
193   /* the length and serial are in the new endianness, the length has expanded
194    * to 8, and the serial is correct */
195   g_assert_cmpuint (get_uint32 (output, OFFSET_BODY_LENGTH, output[0]), ==, 8);
196   g_assert_cmpuint (get_uint32 (output, OFFSET_SERIAL, output[0]), ==,
197       0x12345678u);
198   /* the second "u" in the signature replaced a padding byte, so only
199    * the length of the body changed */
200   g_assert_cmpint (len, ==, BLOB_LENGTH + 4);
201 }
202
203 static void
204 test_needed (Fixture *f,
205     gconstpointer arg)
206 {
207   const gchar *blob = arg;
208
209   /* We need at least 16 bytes to know how long the message is - that's just
210    * a fact of the D-Bus protocol. */
211   g_assert_cmpint (
212       dbus_message_demarshal_bytes_needed (blob, 0), ==, 0);
213   g_assert_cmpint (
214       dbus_message_demarshal_bytes_needed (blob, 15), ==, 0);
215   /* This is enough that we should be able to tell how much we need. */
216   g_assert_cmpint (
217       dbus_message_demarshal_bytes_needed (blob, 16), ==, BLOB_LENGTH);
218   /* The header is 32 bytes long (here), so that's another interesting
219    * boundary. */
220   g_assert_cmpint (
221       dbus_message_demarshal_bytes_needed (blob, 31), ==, BLOB_LENGTH);
222   g_assert_cmpint (
223       dbus_message_demarshal_bytes_needed (blob, 32), ==, BLOB_LENGTH);
224   g_assert_cmpint (
225       dbus_message_demarshal_bytes_needed (blob, 33), ==, BLOB_LENGTH);
226   g_assert_cmpint (
227       dbus_message_demarshal_bytes_needed (blob, BLOB_LENGTH - 1), ==,
228       BLOB_LENGTH);
229   g_assert_cmpint (
230       dbus_message_demarshal_bytes_needed (blob, BLOB_LENGTH), ==,
231       BLOB_LENGTH);
232   g_assert_cmpint (
233       dbus_message_demarshal_bytes_needed (blob, sizeof (be_blob)), ==,
234       BLOB_LENGTH);
235 }
236
237 static void
238 teardown (Fixture *f,
239     gconstpointer arg G_GNUC_UNUSED)
240 {
241   dbus_error_free (&f->e);
242 }
243
244 int
245 main (int argc,
246     char **argv)
247 {
248   g_test_init (&argc, &argv, NULL);
249
250   g_test_add ("/demarshal/le", Fixture, le_blob, setup, test_endian, teardown);
251   g_test_add ("/demarshal/be", Fixture, be_blob, setup, test_endian, teardown);
252   g_test_add ("/demarshal/needed/le", Fixture, le_blob, setup, test_needed,
253       teardown);
254   g_test_add ("/demarshal/needed/be", Fixture, be_blob, setup, test_needed,
255       teardown);
256
257   return g_test_run ();
258 }