fdo-mirrors/dbus
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/dbus/dbus.git synced 2026-05-05 14:38:10 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

dbus-connection: Test built-in filters

Browse source
This commit is contained in:
Kai A. Hiller 2022-10-10 19:44:29 +02:00 • committed by Simon McVittie
parent c4573311dd
commit 37a65e0a36
1 changed files with 87 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

87
test/loopback.c
View file

@ -61,6 +61,37 @@ assert_no_error (const DBusError *e)
g_error ("expected success but got error: %s: %s", e->name, e->message);
}
/* these are macros so they get the right line number */
#define assert_method_reply(m, sender, destination, signature) \
do { \
g_assert_cmpstr (dbus_message_type_to_string (dbus_message_get_type (m)), \
==, dbus_message_type_to_string (DBUS_MESSAGE_TYPE_METHOD_RETURN)); \
g_assert_cmpstr (dbus_message_get_sender (m), ==, sender); \
g_assert_cmpstr (dbus_message_get_destination (m), ==, destination); \
g_assert_cmpstr (dbus_message_get_path (m), ==, NULL); \
g_assert_cmpstr (dbus_message_get_interface (m), ==, NULL); \
g_assert_cmpstr (dbus_message_get_member (m), ==, NULL); \
g_assert_cmpstr (dbus_message_get_signature (m), ==, signature); \
g_assert_cmpint (dbus_message_get_serial (m), !=, 0); \
g_assert_cmpint (dbus_message_get_reply_serial (m), !=, 0); \
} while (0)
#define assert_error_reply(m, sender, destination, error_name) \
do { \
g_assert_cmpstr (dbus_message_type_to_string (dbus_message_get_type (m)), \
==, dbus_message_type_to_string (DBUS_MESSAGE_TYPE_ERROR)); \
g_assert_cmpstr (dbus_message_get_sender (m), ==, sender); \
g_assert_cmpstr (dbus_message_get_destination (m), ==, destination); \
g_assert_cmpstr (dbus_message_get_error_name (m), ==, error_name); \
g_assert_cmpstr (dbus_message_get_path (m), ==, NULL); \
g_assert_cmpstr (dbus_message_get_interface (m), ==, NULL); \
g_assert_cmpstr (dbus_message_get_member (m), ==, NULL); \
g_assert_cmpstr (dbus_message_get_signature (m), ==, "s"); \
g_assert_cmpint (dbus_message_get_serial (m), !=, 0); \
g_assert_cmpint (dbus_message_get_reply_serial (m), !=, 0); \
} while (0)
static DBusHandlerResult
server_message_cb (DBusConnection *server_conn,
DBusMessage *message,
@ -415,6 +446,59 @@ test_message (Fixture *f,
dbus_clear_message (&outgoing);
}
static void
test_builtin_filters (Fixture *f,
gconstpointer addr)
{
dbus_bool_t have_mem;
dbus_uint32_t serial;
DBusMessage *ping;
DBusMessage *m;
if (f->skip)
return;
test_connect (f, addr);
ping = dbus_message_new_method_call (NULL, "/foo", DBUS_INTERFACE_PEER,
"Ping");
_dbus_connection_set_builtin_filters_enabled (f->client_conn, TRUE);
have_mem = dbus_connection_send (f->server_conn, ping, &serial);
g_assert (have_mem);
g_assert (serial != 0);
while (g_queue_get_length (&f->server_messages) < 1)
test_main_context_iterate (f->ctx, TRUE);
m = g_queue_pop_head (&f->server_messages);
assert_method_reply (m, NULL, NULL, "");
dbus_message_unref (m);
m = g_queue_pop_head (&f->server_messages);
g_assert (m == NULL);
_dbus_connection_set_builtin_filters_enabled (f->client_conn, FALSE);
have_mem = dbus_connection_send (f->server_conn, ping, &serial);
g_assert (have_mem);
g_assert (serial != 0);
while (g_queue_get_length (&f->server_messages) < 1)
test_main_context_iterate (f->ctx, TRUE);
m = g_queue_pop_head (&f->server_messages);
assert_error_reply (m, NULL, NULL,
"org.freedesktop.DBus.Error.UnknownMethod");
dbus_message_unref (m);
m = g_queue_pop_head (&f->server_messages);
g_assert (m == NULL);
dbus_message_unref (ping);
}
static void
teardown (Fixture *f,
gconstpointer addr G_GNUC_UNUSED)
@ -523,6 +607,9 @@ main (int argc,
test_bad_guid, teardown);
#endif
g_test_add ("/builtin-filters", Fixture, "tcp:host=127.0.0.1", setup,
test_builtin_filters, teardown);
ret = g_test_run ();
dbus_shutdown ();
return ret;