glib/gio/tests/contexts.c

206 lines
5.2 KiB
C
Raw Normal View History

#include <gio/gio.h>
#include <stdlib.h>
#include <string.h>
static gchar *test_file;
char *test_file_buffer;
gsize test_file_size;
static char async_read_buffer[8192];
static void
read_data (GObject *source, GAsyncResult *result, gpointer loop)
{
GInputStream *in = G_INPUT_STREAM (source);
GError *error = NULL;
gssize nread;
nread = g_input_stream_read_finish (in, result, &error);
g_assert_no_error (error);
g_assert_cmpint (nread, >, 0);
g_assert_cmpint (nread, <=, MIN(sizeof (async_read_buffer), test_file_size));
g_assert (memcmp (async_read_buffer, test_file_buffer, nread) == 0);
g_main_loop_quit (loop);
}
static void
opened_for_read (GObject *source, GAsyncResult *result, gpointer loop)
{
GFile *file = G_FILE (source);
GFileInputStream *in;
GError *error = NULL;
in = g_file_read_finish (file, result, &error);
g_assert_no_error (error);
memset (async_read_buffer, 0, sizeof (async_read_buffer));
g_input_stream_read_async (G_INPUT_STREAM (in),
async_read_buffer, sizeof (async_read_buffer),
G_PRIORITY_DEFAULT, NULL,
read_data, loop);
g_object_unref (in);
}
/* Test 1: Async I/O started in a thread with a thread-default context
* will stick to that thread, and will complete even if the default
* main loop is blocked. (NB: the last part would not be true if we
* were testing GFileMonitor!)
*/
static gboolean idle_start_test1_thread (gpointer loop);
static gpointer test1_thread (gpointer user_data);
static gboolean test1_done;
static GCond test1_cond;
static GMutex test1_mutex;
static void
test_thread_independence (void)
{
GMainLoop *loop;
loop = g_main_loop_new (NULL, FALSE);
g_idle_add (idle_start_test1_thread, loop);
g_main_loop_run (loop);
g_main_loop_unref (loop);
}
static gboolean
idle_start_test1_thread (gpointer loop)
{
gint64 time;
GThread *thread;
gboolean io_completed;
g_mutex_lock (&test1_mutex);
thread = g_thread_new ("test1", test1_thread, NULL);
time = g_get_monotonic_time () + 2 * G_TIME_SPAN_SECOND;
while (!test1_done)
{
io_completed = g_cond_wait_until (&test1_cond, &test1_mutex, time);
g_assert (io_completed);
}
g_thread_join (thread);
g_mutex_unlock (&test1_mutex);
g_main_loop_quit (loop);
return G_SOURCE_REMOVE;
}
static gpointer
test1_thread (gpointer user_data)
{
GMainContext *context;
GMainLoop *loop;
GFile *file;
/* Wait for main thread to be waiting on test1_cond */
g_mutex_lock (&test1_mutex);
context = g_main_context_new ();
g_assert (g_main_context_get_thread_default () == NULL);
g_main_context_push_thread_default (context);
g_assert (g_main_context_get_thread_default () == context);
file = g_file_new_for_path (test_file);
g_assert (g_file_supports_thread_contexts (file));
loop = g_main_loop_new (context, FALSE);
g_file_read_async (file, G_PRIORITY_DEFAULT, NULL,
opened_for_read, loop);
Plug mem leaks in contexts test ==2464== 80 (16 direct, 64 indirect) bytes in 1 blocks are definitely lost in loss record 515 of 547 ==2464== at 0x4005BDC: malloc (vg_replace_malloc.c:195) ==2464== by 0x4057094: g_malloc (gmem.c:134) ==2464== by 0x406F2D6: g_slice_alloc (gslice.c:836) ==2464== by 0x406F31B: g_slice_alloc0 (gslice.c:848) ==2464== by 0x41385BB: g_type_create_instance (gtype.c:1867) ==2464== by 0x411E72A: g_object_constructor (gobject.c:1482) ==2464== by 0x411DE1D: g_object_newv (gobject.c:1266) ==2464== by 0x411DB93: g_object_new (gobject.c:1178) ==2464== by 0x4220D74: _g_local_file_new (glocalfile.c:310) ==2464== by 0x422C897: g_local_vfs_get_file_for_path (glocalvfs.c:84) ==2464== by 0x41CA91C: g_vfs_get_file_for_path (gvfs.c:94) ==2464== by 0x418C1B6: g_file_new_for_path (gfile.c:5898) ==2464== by 0x8049509: test1_thread (contexts.c:110) ==2464== 80 (16 direct, 64 indirect) bytes in 1 blocks are definitely lost in loss record 516 of 547 ==2464== at 0x4005BDC: malloc (vg_replace_malloc.c:195) ==2464== by 0x4057094: g_malloc (gmem.c:134) ==2464== by 0x406F2D6: g_slice_alloc (gslice.c:836) ==2464== by 0x406F31B: g_slice_alloc0 (gslice.c:848) ==2464== by 0x41385BB: g_type_create_instance (gtype.c:1867) ==2464== by 0x411E72A: g_object_constructor (gobject.c:1482) ==2464== by 0x411DE1D: g_object_newv (gobject.c:1266) ==2464== by 0x411DB93: g_object_new (gobject.c:1178) ==2464== by 0x4220D74: _g_local_file_new (glocalfile.c:310) ==2464== by 0x422C897: g_local_vfs_get_file_for_path (glocalvfs.c:84) ==2464== by 0x41CA91C: g_vfs_get_file_for_path (gvfs.c:94) ==2464== by 0x418C1B6: g_file_new_for_path (gfile.c:5898) ==2464== by 0x804964D: test_context_independence (contexts.c:144) Bug #628331.
2010-09-03 21:58:51 +02:00
g_object_unref (file);
g_main_loop_run (loop);
g_main_loop_unref (loop);
test1_done = TRUE;
g_cond_signal (&test1_cond);
g_mutex_unlock (&test1_mutex);
g_main_context_pop_thread_default (context);
g_main_context_unref (context);
return NULL;
}
/* Test 2: If we push a thread-default context in the main thread, we
* can run async ops in that context without running the default
* context.
*/
static gboolean test2_fail (gpointer user_data);
static void
test_context_independence (void)
{
GMainContext *context;
GMainLoop *loop;
GFile *file;
guint default_timeout;
GSource *thread_default_timeout;
context = g_main_context_new ();
g_assert (g_main_context_get_thread_default () == NULL);
g_main_context_push_thread_default (context);
g_assert (g_main_context_get_thread_default () == context);
file = g_file_new_for_path (test_file);
g_assert (g_file_supports_thread_contexts (file));
/* Add a timeout to the main loop, to fail immediately if it gets run */
default_timeout = g_timeout_add_full (G_PRIORITY_HIGH, 0,
test2_fail, NULL, NULL);
/* Add a timeout to the alternate loop, to fail if the I/O *doesn't* run */
thread_default_timeout = g_timeout_source_new_seconds (2);
g_source_set_callback (thread_default_timeout, test2_fail, NULL, NULL);
g_source_attach (thread_default_timeout, context);
loop = g_main_loop_new (context, FALSE);
g_file_read_async (file, G_PRIORITY_DEFAULT, NULL,
opened_for_read, loop);
Plug mem leaks in contexts test ==2464== 80 (16 direct, 64 indirect) bytes in 1 blocks are definitely lost in loss record 515 of 547 ==2464== at 0x4005BDC: malloc (vg_replace_malloc.c:195) ==2464== by 0x4057094: g_malloc (gmem.c:134) ==2464== by 0x406F2D6: g_slice_alloc (gslice.c:836) ==2464== by 0x406F31B: g_slice_alloc0 (gslice.c:848) ==2464== by 0x41385BB: g_type_create_instance (gtype.c:1867) ==2464== by 0x411E72A: g_object_constructor (gobject.c:1482) ==2464== by 0x411DE1D: g_object_newv (gobject.c:1266) ==2464== by 0x411DB93: g_object_new (gobject.c:1178) ==2464== by 0x4220D74: _g_local_file_new (glocalfile.c:310) ==2464== by 0x422C897: g_local_vfs_get_file_for_path (glocalvfs.c:84) ==2464== by 0x41CA91C: g_vfs_get_file_for_path (gvfs.c:94) ==2464== by 0x418C1B6: g_file_new_for_path (gfile.c:5898) ==2464== by 0x8049509: test1_thread (contexts.c:110) ==2464== 80 (16 direct, 64 indirect) bytes in 1 blocks are definitely lost in loss record 516 of 547 ==2464== at 0x4005BDC: malloc (vg_replace_malloc.c:195) ==2464== by 0x4057094: g_malloc (gmem.c:134) ==2464== by 0x406F2D6: g_slice_alloc (gslice.c:836) ==2464== by 0x406F31B: g_slice_alloc0 (gslice.c:848) ==2464== by 0x41385BB: g_type_create_instance (gtype.c:1867) ==2464== by 0x411E72A: g_object_constructor (gobject.c:1482) ==2464== by 0x411DE1D: g_object_newv (gobject.c:1266) ==2464== by 0x411DB93: g_object_new (gobject.c:1178) ==2464== by 0x4220D74: _g_local_file_new (glocalfile.c:310) ==2464== by 0x422C897: g_local_vfs_get_file_for_path (glocalvfs.c:84) ==2464== by 0x41CA91C: g_vfs_get_file_for_path (gvfs.c:94) ==2464== by 0x418C1B6: g_file_new_for_path (gfile.c:5898) ==2464== by 0x804964D: test_context_independence (contexts.c:144) Bug #628331.
2010-09-03 21:58:51 +02:00
g_object_unref (file);
g_main_loop_run (loop);
g_main_loop_unref (loop);
g_source_remove (default_timeout);
g_source_destroy (thread_default_timeout);
g_source_unref (thread_default_timeout);
g_main_context_pop_thread_default (context);
g_main_context_unref (context);
}
static gboolean
test2_fail (gpointer user_data)
{
g_assert_not_reached ();
return FALSE;
}
int
main (int argc, char **argv)
{
GError *error = NULL;
int ret;
g_test_init (&argc, &argv, NULL);
test_file = g_test_build_filename (G_TEST_DIST, "contexts.c", NULL);
g_file_get_contents (test_file, &test_file_buffer,
&test_file_size, &error);
g_assert_no_error (error);
g_test_add_func ("/gio/contexts/thread-independence", test_thread_independence);
g_test_add_func ("/gio/contexts/context-independence", test_context_independence);
ret = g_test_run();
g_free (test_file_buffer);
g_free (test_file);
return ret;
}