fdo-mirrors/dbus
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/dbus/dbus.git synced 2025-12-23 01:20:16 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

corrupt test: compile successfully against older GLib (Debian stable)

Browse source 
We don't really need g_socket_send_with_blocking here.

Also, don't leak the GLib socket objects.

Bug: https://bugs.freedesktop.org/show_bug.cgi?id=41219
Reviewed-by: Lennart Poettering <lennart@poettering.net>
This commit is contained in:
Simon McVittie 2011-09-15 18:27:27 +01:00
parent c587e56b8a
commit a36d4918a6
1 changed files with 37 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

60
test/corrupt.c
View file

@ -160,6 +160,38 @@ test_message (Fixture *f,
dbus_message_unref (outgoing); dbus_message_unref (outgoing);
} }
static void
send_n_bytes (GSocket *socket,
const gchar *blob,
gssize blob_len)
{
gssize len, total_sent;
GError *gerror = NULL;
total_sent = 0;
while (total_sent < blob_len)
{
len = g_socket_send (socket,
blob + total_sent,
blob_len - total_sent,
NULL, &gerror);
/* this is NULL-safe: a NULL error does not match */
if (g_error_matches (gerror, G_IO_ERROR, G_IO_ERROR_WOULD_BLOCK))
{
/* we could wait for G_IO_OUT, but life's too short; just sleep */
g_clear_error (&gerror);
g_usleep (G_USEC_PER_SEC / 10);
continue;
}
g_assert_no_error (gerror);
g_assert (len >= 0);
total_sent += len;
}
}
/* Enough bytes for it to be obvious that this connection is broken */ /* Enough bytes for it to be obvious that this connection is broken */
#define CORRUPT_LEN 1024 #define CORRUPT_LEN 1024
@ -174,7 +206,6 @@ test_corrupt (Fixture *f,
GSocket *socket; GSocket *socket;
GError *gerror = NULL; GError *gerror = NULL;
int fd; int fd;
gssize len, total_sent;
DBusMessage *incoming; DBusMessage *incoming;
test_message (f, addr); test_message (f, addr);
@ -191,17 +222,7 @@ test_corrupt (Fixture *f,
g_assert_no_error (gerror); g_assert_no_error (gerror);
g_assert (socket != NULL); g_assert (socket != NULL);
total_sent = 0; send_n_bytes (socket, not_a_dbus_message, CORRUPT_LEN);
while (total_sent < CORRUPT_LEN)
{
len = g_socket_send_with_blocking (socket,
not_a_dbus_message + total_sent, CORRUPT_LEN - total_sent,
TRUE, NULL, &gerror);
g_assert_no_error (gerror);
g_assert (len >= 0);
total_sent += len;
}
/* Now spin on the client connection: the server just sent it complete /* Now spin on the client connection: the server just sent it complete
* rubbish, so it should disconnect */ * rubbish, so it should disconnect */
@ -225,6 +246,7 @@ test_corrupt (Fixture *f,
"/org/freedesktop/DBus/Local"); "/org/freedesktop/DBus/Local");
dbus_message_unref (incoming); dbus_message_unref (incoming);
g_object_unref (socket);
} }
static void static void
@ -237,7 +259,7 @@ test_byte_order (Fixture *f,
char *blob; char *blob;
const gchar *arg = not_a_dbus_message; const gchar *arg = not_a_dbus_message;
const gchar * const *args = &arg; const gchar * const *args = &arg;
int blob_len, len, total_sent; int blob_len;
DBusMessage *message; DBusMessage *message;
dbus_bool_t mem; dbus_bool_t mem;
@ -277,16 +299,7 @@ test_byte_order (Fixture *f,
g_assert_no_error (gerror); g_assert_no_error (gerror);
g_assert (socket != NULL); g_assert (socket != NULL);
total_sent = 0; send_n_bytes (socket, blob, blob_len);
while (total_sent < blob_len)
{
len = g_socket_send_with_blocking (socket, blob + total_sent,
blob_len - total_sent, TRUE, NULL, &gerror);
g_assert_no_error (gerror);
g_assert (len >= 0);
total_sent += len;
}
dbus_free (blob); dbus_free (blob);
@ -312,6 +325,7 @@ test_byte_order (Fixture *f,
"/org/freedesktop/DBus/Local"); "/org/freedesktop/DBus/Local");
dbus_message_unref (message); dbus_message_unref (message);
g_object_unref (socket);
} }
static void static void