gio/tests/monitor.c

   1 #include <gio/gio.h>
   2 #include <gstdio.h>
   3
   4 typedef struct
   5 {
   6   gchar *tmp_dir;
   7 } Fixture;
   8
   9 static void
  10 setup (Fixture       *fixture,
  11        gconstpointer  user_data)
  12 {
  13   GError *error = NULL;
  14
  15   fixture->tmp_dir = g_dir_make_tmp ("gio-test-file-monitor_XXXXXX", &error);
  16   g_assert_no_error (error);
  17
  18   g_test_message ("Using temporary directory: %s", fixture->tmp_dir);
  19 }
  20
  21 static void
  22 teardown (Fixture       *fixture,
  23           gconstpointer  user_data)
  24 {
  25   g_assert_cmpint (g_rmdir (fixture->tmp_dir), ==, 0);
  26   g_clear_pointer (&fixture->tmp_dir, g_free);
  27 }
  28
  29 typedef struct {
  30   GFile *file;
  31   GOutputStream *stream;
  32   GMainLoop *loop;
  33   gint state;
  34 } MonitorData;
  35
  36 static gboolean
  37 create_file_idle (gpointer data)
  38 {
  39   MonitorData *d = data;
  40   GError *error = NULL;
  41
  42   g_assert (d->state == 0);
  43
  44   d->stream = (GOutputStream*)g_file_create (d->file, 0, NULL, &error);
  45   g_assert_no_error (error);
  46
  47   d->state = 1;
  48
  49   return G_SOURCE_REMOVE;
  50 }
  51
  52 static gboolean
  53 write_file_idle (gpointer data)
  54 {
  55   MonitorData *d = data;
  56   GError *error = NULL;
  57
  58   g_assert (d->state == 2);
  59
  60   g_output_stream_write (d->stream, "abcd", 4, NULL, &error);
  61   g_assert_no_error (error);
  62   g_object_unref (d->stream);
  63   d->stream = NULL;
  64
  65   d->state = 3;
  66
  67
  68   return G_SOURCE_REMOVE;
  69 }
  70
  71 static gboolean
  72 delete_file_idle (gpointer data)
  73 {
  74   MonitorData *d = data;
  75   GError *error = NULL;
  76
  77   g_assert (d->state == 4);
  78
  79   g_file_delete (d->file, NULL, &error);
  80   g_assert_no_error (error);
  81
  82   d->state = 5;
  83
  84   return G_SOURCE_REMOVE;
  85 }
  86
  87 static void
  88 changed_cb (GFileMonitor      *monitor,
  89             GFile             *file,
  90             GFile             *other_file,
  91             GFileMonitorEvent  event,
  92             gpointer           data)
  93 {
  94   MonitorData *d = data;
  95
  96   switch (d->state)
  97     {
  98     case 1:
  99       g_assert (event == G_FILE_MONITOR_EVENT_CREATED);
 100       d->state = 2;
 101       g_idle_add (write_file_idle, data);
 102       break;
 103     case 3:
 104       g_assert (event == G_FILE_MONITOR_EVENT_CHANGED ||
 105                 event == G_FILE_MONITOR_EVENT_CHANGES_DONE_HINT);
 106       if (event == G_FILE_MONITOR_EVENT_CHANGES_DONE_HINT)
 107         {
 108           d->state = 4;
 109           g_idle_add (delete_file_idle, data);
 110         }
 111       break;
 112     case 5:
 113       g_assert (event == G_FILE_MONITOR_EVENT_DELETED);
 114       d->state = 6;
 115       if (d->loop)
 116         g_main_loop_quit (d->loop);
 117       break;
 118     default:
 119       g_assert_not_reached ();
 120       break;
 121     }
 122 }
 123
 124 static void
 125 file_changed_cb (GFileMonitor      *monitor,
 126                  GFile             *file,
 127                  GFile             *other_file,
 128                  GFileMonitorEvent  event,
 129                  gpointer           data)
 130 {
 131   gint *state = data;
 132
 133   switch (*state)
 134     {
 135     case 0:
 136       g_assert (event == G_FILE_MONITOR_EVENT_CREATED);
 137       *state = 1;
 138       break;
 139     case 1:
 140       g_assert (event == G_FILE_MONITOR_EVENT_CHANGED ||
 141                 event == G_FILE_MONITOR_EVENT_CHANGES_DONE_HINT);
 142       if (event == G_FILE_MONITOR_EVENT_CHANGES_DONE_HINT)
 143         *state = 2;
 144       break;
 145     case 2:
 146       g_assert (event == G_FILE_MONITOR_EVENT_DELETED);
 147       *state = 3;
 148       break;
 149     default:
 150       g_assert_not_reached ();
 151       break;
 152     }
 153 }
 154
 155 static void
 156 test_directory_monitor (Fixture       *fixture,
 157                         gconstpointer  user_data)
 158 {
 159   GFile *file;
 160   GFile *child;
 161   GFileMonitor *dir_monitor;
 162   GFileMonitor *file_monitor;
 163   GError *error = NULL;
 164   MonitorData data;
 165   gint state;
 166   GMainLoop *loop;
 167
 168   file = g_file_new_for_path (fixture->tmp_dir);
 169   dir_monitor = g_file_monitor_directory (file, 0, NULL, &error);
 170   g_assert_no_error (error);
 171
 172   child = g_file_get_child (file, "test-file");
 173   file_monitor = g_file_monitor_file (child, 0, NULL, &error);
 174   g_assert_no_error (error);
 175
 176   loop = g_main_loop_new (NULL, FALSE);
 177
 178   g_signal_connect (dir_monitor, "changed", G_CALLBACK (changed_cb), &data);
 179   g_signal_connect (file_monitor, "changed", G_CALLBACK (file_changed_cb), &state);
 180
 181   data.loop = loop;
 182   data.file = child;
 183   data.state = 0;
 184   state = 0;
 185
 186   g_idle_add (create_file_idle, &data);
 187
 188   g_main_loop_run (loop);
 189
 190   g_assert_cmpint (data.state, ==, 6);
 191   g_assert_cmpint (state, ==, 3);
 192
 193   g_main_loop_unref (loop);
 194   g_object_unref (dir_monitor);
 195   g_object_unref (file_monitor);
 196   g_object_unref (child);
 197   g_object_unref (file);
 198 }
 199
 200 int
 201 main (int argc, char *argv[])
 202 {
 203   g_test_init (&argc, &argv, NULL);
 204
 205   g_test_add ("/monitor/directory", Fixture, NULL, setup, test_directory_monitor, teardown);
 206
 207   return g_test_run ();
 208 }