+#include <locale.h>
#include <string.h>
#include <stdio.h>
#include <stdlib.h>
#endif
static void
-test_basic (void)
+test_basic_for_file (GFile *file,
+ const gchar *suffix)
{
- GFile *file;
gchar *s;
- file = g_file_new_for_path ("./some/directory/testfile");
-
s = g_file_get_basename (file);
g_assert_cmpstr (s, ==, "testfile");
g_free (s);
s = g_file_get_uri (file);
- g_assert (g_str_has_prefix (s, "file://"));
- g_assert (g_str_has_suffix (s, "/some/directory/testfile"));
+ g_assert_true (g_str_has_prefix (s, "file://"));
+ g_assert_true (g_str_has_suffix (s, suffix));
g_free (s);
- g_assert (g_file_has_uri_scheme (file, "file"));
+ g_assert_true (g_file_has_uri_scheme (file, "file"));
s = g_file_get_uri_scheme (file);
g_assert_cmpstr (s, ==, "file");
g_free (s);
+}
+
+static void
+test_basic (void)
+{
+ GFile *file;
+
+ file = g_file_new_for_path ("./some/directory/testfile");
+ test_basic_for_file (file, "/some/directory/testfile");
+ g_object_unref (file);
+}
+
+static void
+test_build_filename (void)
+{
+ GFile *file;
+
+ file = g_file_new_build_filename (".", "some", "directory", "testfile", NULL);
+ test_basic_for_file (file, "/some/directory/testfile");
+ g_object_unref (file);
+ file = g_file_new_build_filename ("testfile", NULL);
+ test_basic_for_file (file, "/testfile");
g_object_unref (file);
}
file2 = g_file_new_for_path ("./some/directory");
root = g_file_new_for_path ("/");
- g_assert (g_file_has_parent (file, file2));
+ g_assert_true (g_file_has_parent (file, file2));
parent = g_file_get_parent (file);
- g_assert (g_file_equal (parent, file2));
+ g_assert_true (g_file_equal (parent, file2));
g_object_unref (parent);
- g_assert (g_file_get_parent (root) == NULL);
+ g_assert_null (g_file_get_parent (root));
g_object_unref (file);
g_object_unref (file2);
file = g_file_new_for_path ("./some/directory");
child = g_file_get_child (file, "child");
- g_assert (g_file_has_parent (child, file));
+ g_assert_true (g_file_has_parent (child, file));
child2 = g_file_get_child_for_display_name (file, "child2", NULL);
- g_assert (g_file_has_parent (child2, file));
+ g_assert_true (g_file_has_parent (child2, file));
g_object_unref (child);
g_object_unref (child2);
}
static void
+test_empty_path (void)
+{
+ GFile *file = NULL;
+
+ g_test_bug ("https://gitlab.gnome.org/GNOME/glib/-/issues/2328");
+ g_test_summary ("Check that creating a file with an empty path results in errors");
+
+ /* Creating the file must always succeed. */
+ file = g_file_new_for_path ("");
+ g_assert_nonnull (file);
+
+ /* But then querying its path should indicate it’s invalid. */
+ g_assert_null (g_file_get_path (file));
+ g_assert_null (g_file_get_basename (file));
+ g_assert_null (g_file_get_parent (file));
+
+ g_object_unref (file);
+}
+
+static void
test_type (void)
{
GFile *datapath_f;
file = g_file_parse_name ("~foo");
name = g_file_get_parse_name (file);
- g_assert (name != NULL);
+ g_assert_nonnull (name);
g_object_unref (file);
g_free (name);
}
typedef struct
{
+ GMainContext *context;
GFile *file;
GFileMonitor *monitor;
GOutputStream *ostream;
GInputStream *istream;
- GMainLoop *loop;
gint buffersize;
gint monitor_created;
gint monitor_deleted;
gint monitor_changed;
gchar *monitor_path;
- gint pos;
- gchar *data;
+ gsize pos;
+ const gchar *data;
gchar *buffer;
guint timeout;
+ gboolean file_deleted;
+ gboolean timed_out;
} CreateDeleteData;
static void
{
CreateDeleteData *data = user_data;
gchar *path;
+ const gchar *peeked_path;
path = g_file_get_path (file);
+ peeked_path = g_file_peek_path (file);
g_assert_cmpstr (data->monitor_path, ==, path);
+ g_assert_cmpstr (path, ==, peeked_path);
g_free (path);
if (event_type == G_FILE_MONITOR_EVENT_CREATED)
data->monitor_deleted++;
if (event_type == G_FILE_MONITOR_EVENT_CHANGED)
data->monitor_changed++;
-}
-
-static gboolean
-quit_idle (gpointer user_data)
-{
- CreateDeleteData *data = user_data;
-
- g_source_remove (data->timeout);
- g_main_loop_quit (data->loop);
-
- return FALSE;
+ g_main_context_wakeup (data->context);
}
static void
error = NULL;
ret = g_input_stream_close_finish (data->istream, res, &error);
g_assert_no_error (error);
- g_assert (ret);
+ g_assert_true (ret);
- g_assert (g_input_stream_is_closed (data->istream));
+ g_assert_true (g_input_stream_is_closed (data->istream));
ret = g_file_delete (data->file, NULL, &error);
- g_assert (ret);
+ g_assert_true (ret);
g_assert_no_error (error);
- /* work around file monitor bug:
- * inotify events are only processed every 1000 ms, regardless
- * of the rate limit set on the file monitor
- */
- g_timeout_add (2000, quit_idle, data);
+ data->file_deleted = TRUE;
+ g_main_context_wakeup (data->context);
}
static void
else
{
g_assert_cmpstr (data->buffer, ==, data->data);
- g_assert (!g_input_stream_is_closed (data->istream));
+ g_assert_false (g_input_stream_is_closed (data->istream));
g_input_stream_close_async (data->istream, 0, NULL, iclosed_cb, data);
}
}
error = NULL;
ret = g_output_stream_close_finish (data->ostream, res, &error);
g_assert_no_error (error);
- g_assert (ret);
- g_assert (g_output_stream_is_closed (data->ostream));
+ g_assert_true (ret);
+ g_assert_true (g_output_stream_is_closed (data->ostream));
g_file_read_async (data->file, 0, NULL, opened_cb, data);
}
}
else
{
- g_assert (!g_output_stream_is_closed (data->ostream));
+ g_assert_false (g_output_stream_is_closed (data->ostream));
g_output_stream_close_async (data->ostream, 0, NULL, oclosed_cb, data);
}
}
error = NULL;
base = g_file_create_finish (G_FILE (source), res, &error);
g_assert_no_error (error);
- g_assert (g_file_query_exists (data->file, NULL));
+ g_assert_true (g_file_query_exists (data->file, NULL));
if (data->buffersize == 0)
data->ostream = G_OUTPUT_STREAM (g_object_ref (base));
}
static gboolean
-stop_timeout (gpointer data)
+stop_timeout (gpointer user_data)
{
- g_assert_not_reached ();
+ CreateDeleteData *data = user_data;
- return FALSE;
+ data->timed_out = TRUE;
+ g_main_context_wakeup (data->context);
+
+ return G_SOURCE_REMOVE;
}
/*
data->file = g_file_new_tmp ("g_file_create_delete_XXXXXX",
&iostream, NULL);
- g_assert (data->file != NULL);
+ g_assert_nonnull (data->file);
g_object_unref (iostream);
data->monitor_path = g_file_get_path (data->file);
remove (data->monitor_path);
- g_assert (!g_file_query_exists (data->file, NULL));
+ g_assert_false (g_file_query_exists (data->file, NULL));
error = NULL;
data->monitor = g_file_monitor_file (data->file, 0, NULL, &error);
* that the monitor will notice a create immediately followed by a
* delete, rather than coalescing them into nothing.
*/
- if (!strcmp (G_OBJECT_TYPE_NAME (data->monitor), "GPollFileMonitor"))
+ /* This test also doesn't work with GKqueueFileMonitor because of
+ * the same reason. Kqueue is able to return a kevent when a file is
+ * created or deleted in a directory. However, the kernel doesn't tell
+ * the program file names, so GKqueueFileMonitor has to calculate the
+ * difference itself. This is usually too slow for rapid file creation
+ * and deletion tests.
+ */
+ if (strcmp (G_OBJECT_TYPE_NAME (data->monitor), "GPollFileMonitor") == 0 ||
+ strcmp (G_OBJECT_TYPE_NAME (data->monitor), "GKqueueFileMonitor") == 0)
{
g_test_skip ("skipping test for this GFileMonitor implementation");
goto skip;
g_signal_connect (data->monitor, "changed", G_CALLBACK (monitor_changed), data);
- data->loop = g_main_loop_new (NULL, FALSE);
-
- data->timeout = g_timeout_add (5000, stop_timeout, NULL);
+ /* Use the global default main context */
+ data->context = NULL;
+ data->timeout = g_timeout_add_seconds (10, stop_timeout, data);
g_file_create_async (data->file, 0, 0, NULL, created_cb, data);
- g_main_loop_run (data->loop);
+ while (!data->timed_out &&
+ (data->monitor_created == 0 ||
+ data->monitor_deleted == 0 ||
+ data->monitor_changed == 0 ||
+ !data->file_deleted))
+ g_main_context_iteration (data->context, TRUE);
+
+ g_source_remove (data->timeout);
+ g_assert_false (data->timed_out);
+ g_assert_true (data->file_deleted);
g_assert_cmpint (data->monitor_created, ==, 1);
g_assert_cmpint (data->monitor_deleted, ==, 1);
g_assert_cmpint (data->monitor_changed, >, 0);
- g_assert (!g_file_monitor_is_cancelled (data->monitor));
+ g_assert_false (g_file_monitor_is_cancelled (data->monitor));
g_file_monitor_cancel (data->monitor);
- g_assert (g_file_monitor_is_cancelled (data->monitor));
+ g_assert_true (g_file_monitor_is_cancelled (data->monitor));
- g_main_loop_unref (data->loop);
+ g_clear_pointer (&data->context, g_main_context_unref);
g_object_unref (data->ostream);
g_object_unref (data->istream);
skip:
g_object_unref (data->monitor);
g_object_unref (data->file);
- free (data->monitor_path);
+ g_free (data->monitor_path);
g_free (data->buffer);
g_free (data);
}
+static const gchar *original_data =
+ "/**\n"
+ " * g_file_replace_contents_async:\n"
+ "**/\n";
+
static const gchar *replace_data =
"/**\n"
" * g_file_replace_contents_async:\n"
" * @file: input #GFile.\n"
" * @contents: string of contents to replace the file with.\n"
" * @length: the length of @contents in bytes.\n"
- " * @etag: (allow-none): a new <link linkend=\"gfile-etag\">entity tag</link> for the @file, or %NULL\n"
+ " * @etag: (nullable): a new <link linkend=\"gfile-etag\">entity tag</link> for the @file, or %NULL\n"
" * @make_backup: %TRUE if a backup should be created.\n"
" * @flags: a set of #GFileCreateFlags.\n"
" * @cancellable: optional #GCancellable object, %NULL to ignore.\n"
error = NULL;
ret = g_file_load_contents_finish (data->file, res, &contents, &length, NULL, &error);
- g_assert (ret);
+ g_assert_true (ret);
g_assert_no_error (error);
g_assert_cmpint (length, ==, strlen (data->data));
g_assert_cmpstr (contents, ==, data->data);
error = NULL;
ret = g_file_delete (data->file, NULL, &error);
g_assert_no_error (error);
- g_assert (ret);
- g_assert (!g_file_query_exists (data->file, NULL));
+ g_assert_true (ret);
+ g_assert_false (g_file_query_exists (data->file, NULL));
g_main_loop_quit (data->loop);
}
test_replace_load (void)
{
ReplaceLoadData *data;
- gchar *path;
+ const gchar *path;
GFileIOStream *iostream;
data = g_new0 (ReplaceLoadData, 1);
data->file = g_file_new_tmp ("g_file_replace_load_XXXXXX",
&iostream, NULL);
- g_assert (data->file != NULL);
+ g_assert_nonnull (data->file);
g_object_unref (iostream);
- path = g_file_get_path (data->file);
+ path = g_file_peek_path (data->file);
remove (path);
- g_assert (!g_file_query_exists (data->file, NULL));
+ g_assert_false (g_file_query_exists (data->file, NULL));
data->loop = g_main_loop_new (NULL, FALSE);
g_main_loop_unref (data->loop);
g_object_unref (data->file);
g_free (data);
- free (path);
}
static void
GFileInfo *info;
GCancellable *cancellable;
gchar *path;
- gsize nwrote;
+ gchar *contents;
+ gsize nwrote, length;
guint count;
GError *error = NULL;
- g_test_bug ("629301");
+ g_test_bug ("https://bugzilla.gnome.org/629301");
path = g_dir_make_tmp ("g_file_replace_cancel_XXXXXX", &error);
g_assert_no_error (error);
file = g_file_get_child (tmpdir, "file");
g_file_replace_contents (file,
- replace_data,
- strlen (replace_data),
+ original_data,
+ strlen (original_data),
NULL, FALSE, 0, NULL,
NULL, &error);
g_assert_no_error (error);
info = g_file_enumerator_next_file (fenum, NULL, &error);
g_assert_no_error (error);
- g_assert (info != NULL);
+ g_assert_nonnull (info);
g_object_unref (info);
info = g_file_enumerator_next_file (fenum, NULL, &error);
g_assert_no_error (error);
- g_assert (info != NULL);
+ g_assert_nonnull (info);
g_object_unref (info);
g_file_enumerator_close (fenum, NULL, &error);
while (TRUE)
{
gboolean ret = g_file_enumerator_iterate (fenum, &info, NULL, NULL, &error);
- g_assert (ret);
+ g_assert_true (ret);
g_assert_no_error (error);
if (!info)
break;
GFile *child;
gboolean ret = g_file_enumerator_iterate (fenum, NULL, &child, NULL, &error);
- g_assert (ret);
+ g_assert_true (ret);
g_assert_no_error (error);
if (!child)
break;
- g_assert (G_IS_FILE (child));
+ g_assert_true (G_IS_FILE (child));
count++;
}
g_assert_cmpint (count, ==, 2);
g_object_unref (cancellable);
g_object_unref (ostream);
+ /* Make sure that file contents wasn't actually replaced. */
+ g_file_load_contents (file,
+ NULL,
+ &contents,
+ &length,
+ NULL,
+ &error);
+ g_assert_no_error (error);
+ g_assert_cmpstr (contents, ==, original_data);
+ g_free (contents);
+
g_file_delete (file, NULL, &error);
g_assert_no_error (error);
g_object_unref (file);
}
static void
+test_replace_symlink (void)
+{
+#ifdef G_OS_UNIX
+ gchar *tmpdir_path = NULL;
+ GFile *tmpdir = NULL, *source_file = NULL, *target_file = NULL;
+ GFileOutputStream *stream = NULL;
+ const gchar *new_contents = "this is a test message which should be written to source and not target";
+ gsize n_written;
+ GFileEnumerator *enumerator = NULL;
+ GFileInfo *info = NULL;
+ gchar *contents = NULL;
+ gsize length = 0;
+ GError *local_error = NULL;
+
+ g_test_bug ("https://gitlab.gnome.org/GNOME/glib/-/issues/2325");
+ g_test_summary ("Test that G_FILE_CREATE_REPLACE_DESTINATION doesn’t follow symlinks");
+
+ /* Create a fresh, empty working directory. */
+ tmpdir_path = g_dir_make_tmp ("g_file_replace_symlink_XXXXXX", &local_error);
+ g_assert_no_error (local_error);
+ tmpdir = g_file_new_for_path (tmpdir_path);
+
+ g_test_message ("Using temporary directory %s", tmpdir_path);
+ g_free (tmpdir_path);
+
+ /* Create symlink `source` which points to `target`. */
+ source_file = g_file_get_child (tmpdir, "source");
+ target_file = g_file_get_child (tmpdir, "target");
+ g_file_make_symbolic_link (source_file, "target", NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ /* Ensure that `target` doesn’t exist */
+ g_assert_false (g_file_query_exists (target_file, NULL));
+
+ /* Replace the `source` symlink with a regular file using
+ * %G_FILE_CREATE_REPLACE_DESTINATION, which should replace it *without*
+ * following the symlink */
+ stream = g_file_replace (source_file, NULL, FALSE /* no backup */,
+ G_FILE_CREATE_REPLACE_DESTINATION, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ g_output_stream_write_all (G_OUTPUT_STREAM (stream), new_contents, strlen (new_contents),
+ &n_written, NULL, &local_error);
+ g_assert_no_error (local_error);
+ g_assert_cmpint (n_written, ==, strlen (new_contents));
+
+ g_output_stream_close (G_OUTPUT_STREAM (stream), NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ g_clear_object (&stream);
+
+ /* At this point, there should still only be one file: `source`. It should
+ * now be a regular file. `target` should not exist. */
+ enumerator = g_file_enumerate_children (tmpdir,
+ G_FILE_ATTRIBUTE_STANDARD_NAME ","
+ G_FILE_ATTRIBUTE_STANDARD_TYPE,
+ G_FILE_QUERY_INFO_NOFOLLOW_SYMLINKS, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ info = g_file_enumerator_next_file (enumerator, NULL, &local_error);
+ g_assert_no_error (local_error);
+ g_assert_nonnull (info);
+
+ g_assert_cmpstr (g_file_info_get_name (info), ==, "source");
+ g_assert_cmpint (g_file_info_get_file_type (info), ==, G_FILE_TYPE_REGULAR);
+
+ g_clear_object (&info);
+
+ info = g_file_enumerator_next_file (enumerator, NULL, &local_error);
+ g_assert_no_error (local_error);
+ g_assert_null (info);
+
+ g_file_enumerator_close (enumerator, NULL, &local_error);
+ g_assert_no_error (local_error);
+ g_clear_object (&enumerator);
+
+ /* Double-check that `target` doesn’t exist */
+ g_assert_false (g_file_query_exists (target_file, NULL));
+
+ /* Check the content of `source`. */
+ g_file_load_contents (source_file,
+ NULL,
+ &contents,
+ &length,
+ NULL,
+ &local_error);
+ g_assert_no_error (local_error);
+ g_assert_cmpstr (contents, ==, new_contents);
+ g_assert_cmpuint (length, ==, strlen (new_contents));
+ g_free (contents);
+
+ /* Tidy up. */
+ g_file_delete (source_file, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ g_file_delete (tmpdir, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ g_clear_object (&target_file);
+ g_clear_object (&source_file);
+ g_clear_object (&tmpdir);
+#else /* if !G_OS_UNIX */
+ g_test_skip ("Symlink replacement tests can only be run on Unix")
+#endif
+}
+
+static void
+test_replace_symlink_using_etag (void)
+{
+#ifdef G_OS_UNIX
+ gchar *tmpdir_path = NULL;
+ GFile *tmpdir = NULL, *source_file = NULL, *target_file = NULL;
+ GFileOutputStream *stream = NULL;
+ const gchar *old_contents = "this is a test message which should be written to target and then overwritten";
+ gchar *old_etag = NULL;
+ const gchar *new_contents = "this is an updated message";
+ gsize n_written;
+ gchar *contents = NULL;
+ gsize length = 0;
+ GFileInfo *info = NULL;
+ GError *local_error = NULL;
+
+ g_test_bug ("https://gitlab.gnome.org/GNOME/glib/-/issues/2417");
+ g_test_summary ("Test that ETag checks work when replacing a file through a symlink");
+
+ /* Create a fresh, empty working directory. */
+ tmpdir_path = g_dir_make_tmp ("g_file_replace_symlink_using_etag_XXXXXX", &local_error);
+ g_assert_no_error (local_error);
+ tmpdir = g_file_new_for_path (tmpdir_path);
+
+ g_test_message ("Using temporary directory %s", tmpdir_path);
+ g_free (tmpdir_path);
+
+ /* Create symlink `source` which points to `target`. */
+ source_file = g_file_get_child (tmpdir, "source");
+ target_file = g_file_get_child (tmpdir, "target");
+ g_file_make_symbolic_link (source_file, "target", NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ /* Sleep for at least 1s to ensure the mtimes of `source` and `target` differ,
+ * as that’s what _g_local_file_info_create_etag() uses to create the ETag,
+ * and one failure mode we’re testing for is that the ETags of `source` and
+ * `target` are conflated. */
+ sleep (1);
+
+ /* Create `target` with some arbitrary content. */
+ stream = g_file_create (target_file, G_FILE_CREATE_NONE, NULL, &local_error);
+ g_assert_no_error (local_error);
+ g_output_stream_write_all (G_OUTPUT_STREAM (stream), old_contents, strlen (old_contents),
+ &n_written, NULL, &local_error);
+ g_assert_no_error (local_error);
+ g_assert_cmpint (n_written, ==, strlen (old_contents));
+
+ g_output_stream_close (G_OUTPUT_STREAM (stream), NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ old_etag = g_file_output_stream_get_etag (stream);
+ g_assert_nonnull (old_etag);
+ g_assert_cmpstr (old_etag, !=, "");
+
+ g_clear_object (&stream);
+
+ /* Sleep again to ensure the ETag changes again. */
+ sleep (1);
+
+ /* Write out a new copy of the `target`, checking its ETag first. This should
+ * replace `target` by following the symlink. */
+ stream = g_file_replace (source_file, old_etag, FALSE /* no backup */,
+ G_FILE_CREATE_NONE, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ g_output_stream_write_all (G_OUTPUT_STREAM (stream), new_contents, strlen (new_contents),
+ &n_written, NULL, &local_error);
+ g_assert_no_error (local_error);
+ g_assert_cmpint (n_written, ==, strlen (new_contents));
+
+ g_output_stream_close (G_OUTPUT_STREAM (stream), NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ g_clear_object (&stream);
+
+ /* At this point, there should be a regular file, `target`, containing
+ * @new_contents; and a symlink `source` which points to `target`. */
+ g_assert_cmpint (g_file_query_file_type (source_file, G_FILE_QUERY_INFO_NOFOLLOW_SYMLINKS, NULL), ==, G_FILE_TYPE_SYMBOLIC_LINK);
+ g_assert_cmpint (g_file_query_file_type (target_file, G_FILE_QUERY_INFO_NOFOLLOW_SYMLINKS, NULL), ==, G_FILE_TYPE_REGULAR);
+
+ /* Check the content of `target`. */
+ g_file_load_contents (target_file,
+ NULL,
+ &contents,
+ &length,
+ NULL,
+ &local_error);
+ g_assert_no_error (local_error);
+ g_assert_cmpstr (contents, ==, new_contents);
+ g_assert_cmpuint (length, ==, strlen (new_contents));
+ g_free (contents);
+
+ /* And check its ETag value has changed. */
+ info = g_file_query_info (target_file, G_FILE_ATTRIBUTE_ETAG_VALUE,
+ G_FILE_QUERY_INFO_NONE, NULL, &local_error);
+ g_assert_no_error (local_error);
+ g_assert_cmpstr (g_file_info_get_etag (info), !=, old_etag);
+
+ g_clear_object (&info);
+ g_free (old_etag);
+
+ /* Tidy up. */
+ g_file_delete (target_file, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ g_file_delete (source_file, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ g_file_delete (tmpdir, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ g_clear_object (&target_file);
+ g_clear_object (&source_file);
+ g_clear_object (&tmpdir);
+#else /* if !G_OS_UNIX */
+ g_test_skip ("Symlink replacement tests can only be run on Unix")
+#endif
+}
+
+/* FIXME: These tests have only been checked on Linux. Most of them are probably
+ * applicable on Windows, too, but that has not been tested yet.
+ * See https://gitlab.gnome.org/GNOME/glib/-/issues/2325 */
+#ifdef __linux__
+
+/* Different kinds of file which create_test_file() can create. */
+typedef enum
+{
+ FILE_TEST_SETUP_TYPE_NONEXISTENT,
+ FILE_TEST_SETUP_TYPE_REGULAR_EMPTY,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY,
+ FILE_TEST_SETUP_TYPE_DIRECTORY,
+ FILE_TEST_SETUP_TYPE_SOCKET,
+ FILE_TEST_SETUP_TYPE_SYMLINK_DANGLING,
+ FILE_TEST_SETUP_TYPE_SYMLINK_VALID,
+} FileTestSetupType;
+
+/* Create file `tmpdir/basename`, of type @setup_type, and chmod it to
+ * @setup_mode. Return the #GFile representing it. Abort on any errors. */
+static GFile *
+create_test_file (GFile *tmpdir,
+ const gchar *basename,
+ FileTestSetupType setup_type,
+ guint setup_mode)
+{
+ GFile *test_file = g_file_get_child (tmpdir, basename);
+ gchar *target_basename = g_strdup_printf ("%s-target", basename); /* for symlinks */
+ GFile *target_file = g_file_get_child (tmpdir, target_basename);
+ GError *local_error = NULL;
+
+ switch (setup_type)
+ {
+ case FILE_TEST_SETUP_TYPE_NONEXISTENT:
+ /* Nothing to do here. */
+ g_assert (setup_mode == 0);
+ break;
+ case FILE_TEST_SETUP_TYPE_REGULAR_EMPTY:
+ case FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY:
+ {
+ gchar *contents = NULL;
+
+ if (setup_type == FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY)
+ contents = g_strdup_printf ("this is some test content in %s", basename);
+ else
+ contents = g_strdup ("");
+
+ g_file_set_contents (g_file_peek_path (test_file), contents, -1, &local_error);
+ g_assert_no_error (local_error);
+
+ g_file_set_attribute_uint32 (test_file, G_FILE_ATTRIBUTE_UNIX_MODE,
+ setup_mode, G_FILE_QUERY_INFO_NOFOLLOW_SYMLINKS,
+ NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ g_free (contents);
+ break;
+ }
+ case FILE_TEST_SETUP_TYPE_DIRECTORY:
+ g_assert (setup_mode == 0);
+
+ g_file_make_directory (test_file, NULL, &local_error);
+ g_assert_no_error (local_error);
+ break;
+ case FILE_TEST_SETUP_TYPE_SOCKET:
+ g_assert_no_errno (mknod (g_file_peek_path (test_file), S_IFSOCK | setup_mode, 0));
+ break;
+ case FILE_TEST_SETUP_TYPE_SYMLINK_VALID:
+ g_file_set_contents (g_file_peek_path (target_file), "target file", -1, &local_error);
+ g_assert_no_error (local_error);
+ G_GNUC_FALLTHROUGH;
+ case FILE_TEST_SETUP_TYPE_SYMLINK_DANGLING:
+ /* Permissions on a symlink are not used by the kernel, so are only
+ * applicable if the symlink is valid (and are applied to the target) */
+ g_assert (setup_type != FILE_TEST_SETUP_TYPE_SYMLINK_DANGLING || setup_mode == 0);
+
+ g_file_make_symbolic_link (test_file, target_basename, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ if (setup_type == FILE_TEST_SETUP_TYPE_SYMLINK_VALID)
+ {
+ g_file_set_attribute_uint32 (test_file, G_FILE_ATTRIBUTE_UNIX_MODE,
+ setup_mode, G_FILE_QUERY_INFO_NONE,
+ NULL, &local_error);
+ g_assert_no_error (local_error);
+ }
+
+ if (setup_type == FILE_TEST_SETUP_TYPE_SYMLINK_DANGLING)
+ {
+ /* Ensure that the target doesn’t exist */
+ g_assert_false (g_file_query_exists (target_file, NULL));
+ }
+ break;
+ default:
+ g_assert_not_reached ();
+ }
+
+ g_clear_object (&target_file);
+ g_free (target_basename);
+
+ return g_steal_pointer (&test_file);
+}
+
+/* Check that @test_file is of the @expected_type, has the @expected_mode, and
+ * (if it’s a regular file) has the @expected_contents or (if it’s a symlink)
+ * has the symlink target given by @expected_contents.
+ *
+ * @test_file must point to the file `tmpdir/basename`.
+ *
+ * Aborts on any errors or mismatches against the expectations.
+ */
+static void
+check_test_file (GFile *test_file,
+ GFile *tmpdir,
+ const gchar *basename,
+ FileTestSetupType expected_type,
+ guint expected_mode,
+ const gchar *expected_contents)
+{
+ gchar *target_basename = g_strdup_printf ("%s-target", basename); /* for symlinks */
+ GFile *target_file = g_file_get_child (tmpdir, target_basename);
+ GFileType test_file_type = g_file_query_file_type (test_file, G_FILE_QUERY_INFO_NOFOLLOW_SYMLINKS, NULL);
+ GFileInfo *info = NULL;
+ GError *local_error = NULL;
+
+ switch (expected_type)
+ {
+ case FILE_TEST_SETUP_TYPE_NONEXISTENT:
+ g_assert (expected_mode == 0);
+ g_assert (expected_contents == NULL);
+
+ g_assert_false (g_file_query_exists (test_file, NULL));
+ g_assert_cmpint (test_file_type, ==, G_FILE_TYPE_UNKNOWN);
+ break;
+ case FILE_TEST_SETUP_TYPE_REGULAR_EMPTY:
+ case FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY:
+ g_assert (expected_type != FILE_TEST_SETUP_TYPE_REGULAR_EMPTY || expected_contents == NULL);
+ g_assert (expected_type != FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY || expected_contents != NULL);
+
+ g_assert_cmpint (test_file_type, ==, G_FILE_TYPE_REGULAR);
+
+ info = g_file_query_info (test_file,
+ G_FILE_ATTRIBUTE_STANDARD_SIZE ","
+ G_FILE_ATTRIBUTE_UNIX_MODE,
+ G_FILE_QUERY_INFO_NOFOLLOW_SYMLINKS, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ if (expected_type == FILE_TEST_SETUP_TYPE_REGULAR_EMPTY)
+ g_assert_cmpint (g_file_info_get_size (info), ==, 0);
+ else
+ g_assert_cmpint (g_file_info_get_size (info), >, 0);
+
+ if (expected_contents != NULL)
+ {
+ gchar *contents = NULL;
+ gsize length = 0;
+
+ g_file_get_contents (g_file_peek_path (test_file), &contents, &length, &local_error);
+ g_assert_no_error (local_error);
+
+ g_assert_cmpstr (contents, ==, expected_contents);
+ g_free (contents);
+ }
+
+ g_assert_cmpuint (g_file_info_get_attribute_uint32 (info, G_FILE_ATTRIBUTE_UNIX_MODE) & 0777, ==, expected_mode);
+
+ break;
+ case FILE_TEST_SETUP_TYPE_DIRECTORY:
+ g_assert (expected_mode == 0);
+ g_assert (expected_contents == NULL);
+
+ g_assert_cmpint (test_file_type, ==, G_FILE_TYPE_DIRECTORY);
+ break;
+ case FILE_TEST_SETUP_TYPE_SOCKET:
+ g_assert (expected_contents == NULL);
+
+ g_assert_cmpint (test_file_type, ==, G_FILE_TYPE_SPECIAL);
+
+ info = g_file_query_info (test_file,
+ G_FILE_ATTRIBUTE_UNIX_MODE,
+ G_FILE_QUERY_INFO_NOFOLLOW_SYMLINKS, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ g_assert_cmpuint (g_file_info_get_attribute_uint32 (info, G_FILE_ATTRIBUTE_UNIX_MODE) & 0777, ==, expected_mode);
+ break;
+ case FILE_TEST_SETUP_TYPE_SYMLINK_VALID:
+ case FILE_TEST_SETUP_TYPE_SYMLINK_DANGLING:
+ {
+ GFile *symlink_target_file = NULL;
+
+ /* Permissions on a symlink are not used by the kernel, so are only
+ * applicable if the symlink is valid (and are applied to the target) */
+ g_assert (expected_type != FILE_TEST_SETUP_TYPE_SYMLINK_DANGLING || expected_mode == 0);
+ g_assert (expected_contents != NULL);
+
+ g_assert_cmpint (test_file_type, ==, G_FILE_TYPE_SYMBOLIC_LINK);
+
+ info = g_file_query_info (test_file,
+ G_FILE_ATTRIBUTE_STANDARD_SYMLINK_TARGET,
+ G_FILE_QUERY_INFO_NOFOLLOW_SYMLINKS, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ g_assert_cmpstr (g_file_info_get_symlink_target (info), ==, expected_contents);
+
+ symlink_target_file = g_file_get_child (tmpdir, g_file_info_get_symlink_target (info));
+ if (expected_type == FILE_TEST_SETUP_TYPE_SYMLINK_VALID)
+ g_assert_true (g_file_query_exists (symlink_target_file, NULL));
+ else
+ g_assert_false (g_file_query_exists (symlink_target_file, NULL));
+
+ if (expected_type == FILE_TEST_SETUP_TYPE_SYMLINK_VALID)
+ {
+ GFileInfo *target_info = NULL;
+
+ /* Need to re-query the info so we follow symlinks */
+ target_info = g_file_query_info (test_file,
+ G_FILE_ATTRIBUTE_UNIX_MODE,
+ G_FILE_QUERY_INFO_NONE, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ g_assert_cmpuint (g_file_info_get_attribute_uint32 (target_info, G_FILE_ATTRIBUTE_UNIX_MODE) & 0777, ==, expected_mode);
+
+ g_clear_object (&target_info);
+ }
+
+ g_clear_object (&symlink_target_file);
+ break;
+ }
+ default:
+ g_assert_not_reached ();
+ }
+
+ g_clear_object (&info);
+ g_clear_object (&target_file);
+ g_free (target_basename);
+}
+
+#endif /* __linux__ */
+
+/* A big test for g_file_replace() and g_file_replace_readwrite(). The
+ * @test_data is a boolean: %TRUE to test g_file_replace_readwrite(), %FALSE to
+ * test g_file_replace(). The test setup and checks are identical for both
+ * functions; in the case of testing g_file_replace_readwrite(), only the output
+ * stream side of the returned #GIOStream is tested. i.e. We test the write
+ * behaviour of both functions is identical.
+ *
+ * This is intended to test all static behaviour of the function: for each test
+ * scenario, a temporary directory is set up with a source file (and maybe some
+ * other files) in a set configuration, g_file_replace{,_readwrite}() is called,
+ * and the final state of the directory is checked.
+ *
+ * This test does not check dynamic behaviour or race conditions. For example,
+ * it does not test what happens if the source file is deleted from another
+ * process half-way through a call to g_file_replace().
+ */
+static void
+test_replace (gconstpointer test_data)
+{
+#ifdef __linux__
+ gboolean read_write = GPOINTER_TO_UINT (test_data);
+ const gchar *new_contents = "this is a new test message which should be written to source";
+ const gchar *original_source_contents = "this is some test content in source";
+ const gchar *original_backup_contents = "this is some test content in source~";
+ mode_t current_umask = umask (0);
+ guint32 default_public_mode = 0666 & ~current_umask;
+ guint32 default_private_mode = 0600;
+
+ const struct
+ {
+ /* Arguments to pass to g_file_replace(). */
+ gboolean replace_make_backup;
+ GFileCreateFlags replace_flags;
+ const gchar *replace_etag; /* (nullable) */
+
+ /* File system setup. */
+ FileTestSetupType setup_source_type;
+ guint setup_source_mode;
+ FileTestSetupType setup_backup_type;
+ guint setup_backup_mode;
+
+ /* Expected results. */
+ gboolean expected_success;
+ GQuark expected_error_domain;
+ gint expected_error_code;
+
+ /* Expected final file system state. */
+ guint expected_n_files;
+ FileTestSetupType expected_source_type;
+ guint expected_source_mode;
+ const gchar *expected_source_contents; /* content for a regular file, or target for a symlink; NULL otherwise */
+ FileTestSetupType expected_backup_type;
+ guint expected_backup_mode;
+ const gchar *expected_backup_contents; /* content for a regular file, or target for a symlink; NULL otherwise */
+ }
+ tests[] =
+ {
+ /* replace_make_backup == FALSE, replace_flags == NONE, replace_etag == NULL,
+ * all the different values of setup_source_type, mostly with a backup
+ * file created to check it’s not modified */
+ {
+ FALSE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ TRUE, 0, 0,
+ 1, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0, NULL,
+ },
+ {
+ FALSE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_EMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+ {
+ FALSE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+ {
+ FALSE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_DIRECTORY, 0,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FALSE, G_IO_ERROR, G_IO_ERROR_IS_DIRECTORY,
+ 2, FILE_TEST_SETUP_TYPE_DIRECTORY, 0, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+ {
+ FALSE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_SOCKET, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FALSE, G_IO_ERROR, G_IO_ERROR_NOT_REGULAR_FILE,
+ 2, FILE_TEST_SETUP_TYPE_SOCKET, default_public_mode, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+ {
+ FALSE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_SYMLINK_DANGLING, 0,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ 3, FILE_TEST_SETUP_TYPE_SYMLINK_VALID, default_public_mode, "source-target",
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+ {
+ FALSE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_SYMLINK_VALID, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ 3, FILE_TEST_SETUP_TYPE_SYMLINK_VALID, default_public_mode, "source-target",
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+
+ /* replace_etag set to an invalid value, with setup_source_type as a
+ * regular non-empty file; replacement should fail */
+ {
+ FALSE, G_FILE_CREATE_NONE, "incorrect etag",
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FALSE, G_IO_ERROR, G_IO_ERROR_WRONG_ETAG,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+
+ /* replace_make_backup == TRUE, replace_flags == NONE, replace_etag == NULL,
+ * all the different values of setup_source_type, with a backup
+ * file created to check it’s either replaced or the operation fails */
+ {
+ TRUE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ TRUE, 0, 0,
+ 1, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0, NULL,
+ },
+ {
+ TRUE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_EMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_EMPTY, default_public_mode, NULL,
+ },
+ {
+ TRUE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ },
+ {
+ TRUE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_DIRECTORY, 0,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FALSE, G_IO_ERROR, G_IO_ERROR_IS_DIRECTORY,
+ 2, FILE_TEST_SETUP_TYPE_DIRECTORY, 0, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+ {
+ TRUE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_SOCKET, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FALSE, G_IO_ERROR, G_IO_ERROR_NOT_REGULAR_FILE,
+ 2, FILE_TEST_SETUP_TYPE_SOCKET, default_public_mode, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+ {
+ TRUE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_SYMLINK_DANGLING, 0,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ /* The final situation here is a bit odd; the backup file is a bit
+ * pointless as the original source file was a dangling symlink.
+ * Theoretically the backup file should be that symlink, pointing to
+ * `source-target`, and hence no longer dangling, as that file has now
+ * been created as the new source content, since REPLACE_DESTINATION was
+ * not specified. However, the code instead creates an empty regular
+ * file as the backup. FIXME: This seems acceptable for now, but not
+ * entirely ideal and would be good to fix at some point. */
+ 3, FILE_TEST_SETUP_TYPE_SYMLINK_VALID, default_public_mode, "source-target",
+ FILE_TEST_SETUP_TYPE_REGULAR_EMPTY, 0777 & ~current_umask, NULL,
+ },
+ {
+ TRUE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_SYMLINK_VALID, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ /* FIXME: The permissions for the backup file are just the default umask,
+ * but should probably be the same as the permissions for the source
+ * file (`default_public_mode`). This probably arises from the fact that
+ * symlinks don’t have permissions. */
+ 3, FILE_TEST_SETUP_TYPE_SYMLINK_VALID, default_public_mode, "source-target",
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, 0777 & ~current_umask, "target file",
+ },
+
+ /* replace_make_backup == TRUE, replace_flags == NONE, replace_etag == NULL,
+ * setup_source_type is a regular file, with a backup file of every type
+ * created to check it’s either replaced or the operation fails */
+ {
+ TRUE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ },
+ {
+ TRUE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_EMPTY, default_public_mode,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ },
+ {
+ TRUE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ },
+ {
+ TRUE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_DIRECTORY, 0,
+ FALSE, G_IO_ERROR, G_IO_ERROR_CANT_CREATE_BACKUP,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ FILE_TEST_SETUP_TYPE_DIRECTORY, 0, NULL,
+ },
+ {
+ TRUE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_SOCKET, default_public_mode,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ },
+ {
+ TRUE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_SYMLINK_DANGLING, 0,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ },
+ {
+ TRUE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_SYMLINK_VALID, default_public_mode,
+ TRUE, 0, 0,
+ /* the third file is `source~-target`, the original target of the old
+ * backup symlink */
+ 3, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ },
+
+ /* replace_make_backup == FALSE, replace_flags == REPLACE_DESTINATION,
+ * replace_etag == NULL, all the different values of setup_source_type,
+ * mostly with a backup file created to check it’s not modified */
+ {
+ FALSE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ TRUE, 0, 0,
+ 1, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0, NULL,
+ },
+ {
+ FALSE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_EMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+ {
+ FALSE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+ {
+ FALSE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_DIRECTORY, 0,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FALSE, G_IO_ERROR, G_IO_ERROR_IS_DIRECTORY,
+ 2, FILE_TEST_SETUP_TYPE_DIRECTORY, 0, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+ {
+ FALSE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_SOCKET, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FALSE, G_IO_ERROR, G_IO_ERROR_NOT_REGULAR_FILE,
+ 2, FILE_TEST_SETUP_TYPE_SOCKET, default_public_mode, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+ {
+ FALSE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_SYMLINK_DANGLING, 0,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+ {
+ FALSE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_SYMLINK_VALID, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ /* the third file is `source-target`, the original target of the old
+ * source file */
+ 3, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+
+ /* replace_flags == REPLACE_DESTINATION, replace_etag set to an invalid
+ * value, with setup_source_type as a regular non-empty file; replacement
+ * should fail */
+ {
+ FALSE, G_FILE_CREATE_REPLACE_DESTINATION, "incorrect etag",
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FALSE, G_IO_ERROR, G_IO_ERROR_WRONG_ETAG,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+
+ /* replace_make_backup == TRUE, replace_flags == REPLACE_DESTINATION,
+ * replace_etag == NULL, all the different values of setup_source_type,
+ * with a backup file created to check it’s either replaced or the
+ * operation fails */
+ {
+ TRUE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ TRUE, 0, 0,
+ 1, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0, NULL,
+ },
+ {
+ TRUE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_EMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_EMPTY, default_public_mode, NULL,
+ },
+ {
+ TRUE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ },
+ {
+ TRUE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_DIRECTORY, 0,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FALSE, G_IO_ERROR, G_IO_ERROR_IS_DIRECTORY,
+ 2, FILE_TEST_SETUP_TYPE_DIRECTORY, 0, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+ {
+ TRUE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_SOCKET, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FALSE, G_IO_ERROR, G_IO_ERROR_NOT_REGULAR_FILE,
+ 2, FILE_TEST_SETUP_TYPE_SOCKET, default_public_mode, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_backup_contents,
+ },
+ {
+ TRUE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_SYMLINK_DANGLING, 0,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_SYMLINK_DANGLING, 0, "source-target",
+ },
+ {
+ TRUE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_SYMLINK_VALID, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ /* the third file is `source-target`, the original target of the old
+ * source file */
+ 3, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_SYMLINK_VALID, default_public_mode, "source-target",
+ },
+
+ /* replace_make_backup == TRUE, replace_flags == REPLACE_DESTINATION,
+ * replace_etag == NULL, setup_source_type is a regular file, with a
+ * backup file of every type created to check it’s either replaced or the
+ * operation fails */
+ {
+ TRUE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ },
+ {
+ TRUE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_EMPTY, default_public_mode,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ },
+ {
+ TRUE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ },
+ {
+ TRUE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_DIRECTORY, 0,
+ FALSE, G_IO_ERROR, G_IO_ERROR_CANT_CREATE_BACKUP,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ FILE_TEST_SETUP_TYPE_DIRECTORY, 0, NULL,
+ },
+ {
+ TRUE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_SOCKET, default_public_mode,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ },
+ {
+ TRUE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_SYMLINK_DANGLING, 0,
+ TRUE, 0, 0,
+ 2, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ },
+ {
+ TRUE, G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_SYMLINK_VALID, default_public_mode,
+ TRUE, 0, 0,
+ /* the third file is `source~-target`, the original target of the old
+ * backup symlink */
+ 3, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, original_source_contents,
+ },
+
+ /* several different setups with replace_flags == PRIVATE */
+ {
+ FALSE, G_FILE_CREATE_PRIVATE, NULL,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ TRUE, 0, 0,
+ 1, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_private_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0, NULL,
+ },
+ {
+ FALSE, G_FILE_CREATE_PRIVATE, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ TRUE, 0, 0,
+ /* the file isn’t being replaced, so it should keep its existing permissions */
+ 1, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0, NULL,
+ },
+ {
+ FALSE, G_FILE_CREATE_PRIVATE | G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ TRUE, 0, 0,
+ 1, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_private_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0, NULL,
+ },
+ {
+ FALSE, G_FILE_CREATE_PRIVATE | G_FILE_CREATE_REPLACE_DESTINATION, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_public_mode,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ TRUE, 0, 0,
+ 1, FILE_TEST_SETUP_TYPE_REGULAR_NONEMPTY, default_private_mode, new_contents,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0, NULL,
+ },
+
+ /* make the initial source file unreadable, so the replace operation
+ * should fail */
+ {
+ FALSE, G_FILE_CREATE_NONE, NULL,
+ FILE_TEST_SETUP_TYPE_REGULAR_EMPTY, 0 /* most restrictive permissions */,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0,
+ FALSE, G_IO_ERROR, G_IO_ERROR_PERMISSION_DENIED,
+ 1, FILE_TEST_SETUP_TYPE_REGULAR_EMPTY, 0, NULL,
+ FILE_TEST_SETUP_TYPE_NONEXISTENT, 0, NULL,
+ },
+ };
+ gsize i;
+
+ g_test_summary ("Test various situations for g_file_replace()");
+
+ /* Reset the umask after querying it above. There’s no way to query it without
+ * changing it. */
+ umask (current_umask);
+ g_test_message ("Current umask: %u", current_umask);
+
+ for (i = 0; i < G_N_ELEMENTS (tests); i++)
+ {
+ gchar *tmpdir_path = NULL;
+ GFile *tmpdir = NULL, *source_file = NULL, *backup_file = NULL;
+ GFileOutputStream *output_stream = NULL;
+ GFileIOStream *io_stream = NULL;
+ GFileEnumerator *enumerator = NULL;
+ GFileInfo *info = NULL;
+ guint n_files;
+ GError *local_error = NULL;
+
+ /* Create a fresh, empty working directory. */
+ tmpdir_path = g_dir_make_tmp ("g_file_replace_XXXXXX", &local_error);
+ g_assert_no_error (local_error);
+ tmpdir = g_file_new_for_path (tmpdir_path);
+
+ g_test_message ("Test %" G_GSIZE_FORMAT ", using temporary directory %s", i, tmpdir_path);
+ g_free (tmpdir_path);
+
+ /* Set up the test directory. */
+ source_file = create_test_file (tmpdir, "source", tests[i].setup_source_type, tests[i].setup_source_mode);
+ backup_file = create_test_file (tmpdir, "source~", tests[i].setup_backup_type, tests[i].setup_backup_mode);
+
+ /* Replace the source file. Check the error state only after finishing
+ * writing, as the replace operation is split across g_file_replace() and
+ * g_output_stream_close(). */
+ if (read_write)
+ io_stream = g_file_replace_readwrite (source_file,
+ tests[i].replace_etag,
+ tests[i].replace_make_backup,
+ tests[i].replace_flags,
+ NULL,
+ &local_error);
+ else
+ output_stream = g_file_replace (source_file,
+ tests[i].replace_etag,
+ tests[i].replace_make_backup,
+ tests[i].replace_flags,
+ NULL,
+ &local_error);
+
+ if (tests[i].expected_success)
+ {
+ g_assert_no_error (local_error);
+ if (read_write)
+ g_assert_nonnull (io_stream);
+ else
+ g_assert_nonnull (output_stream);
+ }
+
+ /* Write new content to it. */
+ if (io_stream != NULL)
+ {
+ GOutputStream *io_output_stream = g_io_stream_get_output_stream (G_IO_STREAM (io_stream));
+ gsize n_written;
+
+ g_output_stream_write_all (G_OUTPUT_STREAM (io_output_stream), new_contents, strlen (new_contents),
+ &n_written, NULL, &local_error);
+
+ if (tests[i].expected_success)
+ {
+ g_assert_no_error (local_error);
+ g_assert_cmpint (n_written, ==, strlen (new_contents));
+ }
+
+ g_io_stream_close (G_IO_STREAM (io_stream), NULL, (local_error == NULL) ? &local_error : NULL);
+
+ if (tests[i].expected_success)
+ g_assert_no_error (local_error);
+ }
+ else if (output_stream != NULL)
+ {
+ gsize n_written;
+
+ g_output_stream_write_all (G_OUTPUT_STREAM (output_stream), new_contents, strlen (new_contents),
+ &n_written, NULL, &local_error);
+
+ if (tests[i].expected_success)
+ {
+ g_assert_no_error (local_error);
+ g_assert_cmpint (n_written, ==, strlen (new_contents));
+ }
+
+ g_output_stream_close (G_OUTPUT_STREAM (output_stream), NULL, (local_error == NULL) ? &local_error : NULL);
+
+ if (tests[i].expected_success)
+ g_assert_no_error (local_error);
+ }
+
+ if (tests[i].expected_success)
+ g_assert_no_error (local_error);
+ else
+ g_assert_error (local_error, tests[i].expected_error_domain, tests[i].expected_error_code);
+
+ g_clear_error (&local_error);
+ g_clear_object (&io_stream);
+ g_clear_object (&output_stream);
+
+ /* Verify the final state of the directory. */
+ enumerator = g_file_enumerate_children (tmpdir,
+ G_FILE_ATTRIBUTE_STANDARD_NAME,
+ G_FILE_QUERY_INFO_NOFOLLOW_SYMLINKS, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ n_files = 0;
+ do
+ {
+ g_file_enumerator_iterate (enumerator, &info, NULL, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ if (info != NULL)
+ n_files++;
+ }
+ while (info != NULL);
+
+ g_clear_object (&enumerator);
+
+ g_assert_cmpuint (n_files, ==, tests[i].expected_n_files);
+
+ check_test_file (source_file, tmpdir, "source", tests[i].expected_source_type, tests[i].expected_source_mode, tests[i].expected_source_contents);
+ check_test_file (backup_file, tmpdir, "source~", tests[i].expected_backup_type, tests[i].expected_backup_mode, tests[i].expected_backup_contents);
+
+ /* Tidy up. Ignore failure apart from when deleting the directory, which
+ * should be empty. */
+ g_file_delete (source_file, NULL, NULL);
+ g_file_delete (backup_file, NULL, NULL);
+
+ /* Other files which are occasionally generated by the tests. */
+ {
+ GFile *backup_target_file = g_file_get_child (tmpdir, "source~-target");
+ g_file_delete (backup_target_file, NULL, NULL);
+ g_clear_object (&backup_target_file);
+ }
+ {
+ GFile *backup_target_file = g_file_get_child (tmpdir, "source-target");
+ g_file_delete (backup_target_file, NULL, NULL);
+ g_clear_object (&backup_target_file);
+ }
+
+ g_file_delete (tmpdir, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ g_clear_object (&backup_file);
+ g_clear_object (&source_file);
+ g_clear_object (&tmpdir);
+ }
+#else /* if !__linux__ */
+ g_test_skip ("File replacement tests can only be run on Linux");
+#endif
+}
+
+static void
on_file_deleted (GObject *object,
GAsyncResult *result,
gpointer user_data)
g_assert_no_error (local_error);
g_object_unref (iostream);
- g_assert (g_file_query_exists (file, NULL));
+ g_assert_true (g_file_query_exists (file, NULL));
loop = g_main_loop_new (NULL, TRUE);
g_main_loop_run (loop);
- g_assert (!g_file_query_exists (file, NULL));
+ g_assert_false (g_file_query_exists (file, NULL));
g_main_loop_unref (loop);
g_object_unref (file);
}
-#ifdef G_OS_UNIX
static void
test_copy_preserve_mode (void)
{
- GFile *tmpfile;
- GFile *dest_tmpfile;
- GFileInfo *dest_info;
- GFileIOStream *iostream;
- GError *local_error = NULL;
- GError **error = &local_error;
- guint32 romode = S_IFREG | 0600;
- guint32 dest_mode;
-
- tmpfile = g_file_new_tmp ("tmp-copy-preserve-modeXXXXXX",
- &iostream, error);
- g_assert_no_error (local_error);
- g_io_stream_close ((GIOStream*)iostream, NULL, error);
- g_assert_no_error (local_error);
- g_clear_object (&iostream);
-
- g_file_set_attribute (tmpfile, G_FILE_ATTRIBUTE_UNIX_MODE, G_FILE_ATTRIBUTE_TYPE_UINT32,
- &romode, G_FILE_QUERY_INFO_NOFOLLOW_SYMLINKS,
- NULL, error);
- g_assert_no_error (local_error);
-
- dest_tmpfile = g_file_new_tmp ("tmp-copy-preserve-modeXXXXXX",
- &iostream, error);
- g_assert_no_error (local_error);
- g_io_stream_close ((GIOStream*)iostream, NULL, error);
- g_assert_no_error (local_error);
- g_clear_object (&iostream);
-
- g_file_copy (tmpfile, dest_tmpfile, G_FILE_COPY_OVERWRITE | G_FILE_COPY_NOFOLLOW_SYMLINKS | G_FILE_COPY_ALL_METADATA,
- NULL, NULL, NULL, error);
- g_assert_no_error (local_error);
-
- dest_info = g_file_query_info (dest_tmpfile, G_FILE_ATTRIBUTE_UNIX_MODE, G_FILE_QUERY_INFO_NOFOLLOW_SYMLINKS,
- NULL, error);
- g_assert_no_error (local_error);
-
- dest_mode = g_file_info_get_attribute_uint32 (dest_info, G_FILE_ATTRIBUTE_UNIX_MODE);
-
- g_assert_cmpint (dest_mode, ==, romode);
-
- (void) g_file_delete (tmpfile, NULL, NULL);
- (void) g_file_delete (dest_tmpfile, NULL, NULL);
-
- g_clear_object (&tmpfile);
- g_clear_object (&dest_tmpfile);
- g_clear_object (&dest_info);
-}
+#ifdef G_OS_UNIX
+ mode_t current_umask = umask (0);
+ const struct
+ {
+ guint32 source_mode;
+ guint32 expected_destination_mode;
+ gboolean create_destination_before_copy;
+ GFileCopyFlags copy_flags;
+ }
+ vectors[] =
+ {
+ /* Overwriting the destination file should copy the permissions from the
+ * source file, even if %G_FILE_COPY_ALL_METADATA is set: */
+ { 0600, 0600, TRUE, G_FILE_COPY_OVERWRITE | G_FILE_COPY_NOFOLLOW_SYMLINKS | G_FILE_COPY_ALL_METADATA },
+ { 0600, 0600, TRUE, G_FILE_COPY_OVERWRITE | G_FILE_COPY_NOFOLLOW_SYMLINKS },
+ /* The same behaviour should hold if the destination file is not being
+ * overwritten because it doesn’t already exist: */
+ { 0600, 0600, FALSE, G_FILE_COPY_NOFOLLOW_SYMLINKS | G_FILE_COPY_ALL_METADATA },
+ { 0600, 0600, FALSE, G_FILE_COPY_NOFOLLOW_SYMLINKS },
+ /* Anything with %G_FILE_COPY_TARGET_DEFAULT_PERMS should use the current
+ * umask for the destination file: */
+ { 0600, 0666 & ~current_umask, TRUE, G_FILE_COPY_TARGET_DEFAULT_PERMS | G_FILE_COPY_OVERWRITE | G_FILE_COPY_NOFOLLOW_SYMLINKS | G_FILE_COPY_ALL_METADATA },
+ { 0600, 0666 & ~current_umask, TRUE, G_FILE_COPY_TARGET_DEFAULT_PERMS | G_FILE_COPY_OVERWRITE | G_FILE_COPY_NOFOLLOW_SYMLINKS },
+ { 0600, 0666 & ~current_umask, FALSE, G_FILE_COPY_TARGET_DEFAULT_PERMS | G_FILE_COPY_NOFOLLOW_SYMLINKS | G_FILE_COPY_ALL_METADATA },
+ { 0600, 0666 & ~current_umask, FALSE, G_FILE_COPY_TARGET_DEFAULT_PERMS | G_FILE_COPY_NOFOLLOW_SYMLINKS },
+ };
+ gsize i;
+
+ /* Reset the umask after querying it above. There’s no way to query it without
+ * changing it. */
+ umask (current_umask);
+ g_test_message ("Current umask: %u", current_umask);
+
+ for (i = 0; i < G_N_ELEMENTS (vectors); i++)
+ {
+ GFile *tmpfile;
+ GFile *dest_tmpfile;
+ GFileInfo *dest_info;
+ GFileIOStream *iostream;
+ GError *local_error = NULL;
+ guint32 romode = vectors[i].source_mode;
+ guint32 dest_mode;
+
+ g_test_message ("Vector %" G_GSIZE_FORMAT, i);
+
+ tmpfile = g_file_new_tmp ("tmp-copy-preserve-modeXXXXXX",
+ &iostream, &local_error);
+ g_assert_no_error (local_error);
+ g_io_stream_close ((GIOStream*)iostream, NULL, &local_error);
+ g_assert_no_error (local_error);
+ g_clear_object (&iostream);
+
+ g_file_set_attribute (tmpfile, G_FILE_ATTRIBUTE_UNIX_MODE, G_FILE_ATTRIBUTE_TYPE_UINT32,
+ &romode, G_FILE_QUERY_INFO_NOFOLLOW_SYMLINKS,
+ NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ dest_tmpfile = g_file_new_tmp ("tmp-copy-preserve-modeXXXXXX",
+ &iostream, &local_error);
+ g_assert_no_error (local_error);
+ g_io_stream_close ((GIOStream*)iostream, NULL, &local_error);
+ g_assert_no_error (local_error);
+ g_clear_object (&iostream);
+
+ if (!vectors[i].create_destination_before_copy)
+ {
+ g_file_delete (dest_tmpfile, NULL, &local_error);
+ g_assert_no_error (local_error);
+ }
+
+ g_file_copy (tmpfile, dest_tmpfile, vectors[i].copy_flags,
+ NULL, NULL, NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ dest_info = g_file_query_info (dest_tmpfile, G_FILE_ATTRIBUTE_UNIX_MODE, G_FILE_QUERY_INFO_NOFOLLOW_SYMLINKS,
+ NULL, &local_error);
+ g_assert_no_error (local_error);
+
+ dest_mode = g_file_info_get_attribute_uint32 (dest_info, G_FILE_ATTRIBUTE_UNIX_MODE);
+
+ g_assert_cmpint (dest_mode & ~S_IFMT, ==, vectors[i].expected_destination_mode);
+ g_assert_cmpint (dest_mode & S_IFMT, ==, S_IFREG);
+
+ (void) g_file_delete (tmpfile, NULL, NULL);
+ (void) g_file_delete (dest_tmpfile, NULL, NULL);
+
+ g_clear_object (&tmpfile);
+ g_clear_object (&dest_tmpfile);
+ g_clear_object (&dest_info);
+ }
+#else /* if !G_OS_UNIX */
+ g_test_skip ("File permissions tests can only be run on Unix")
#endif
+}
static gchar *
splice_to_string (GInputStream *stream,
return ret;
}
-static guint64
-get_size_from_du (const gchar *path)
+static gboolean
+get_size_from_du (const gchar *path, guint64 *size)
{
GSubprocess *du;
+ gboolean ok;
gchar *result;
gchar *endptr;
- guint64 size;
GError *error = NULL;
+ gchar *du_path = NULL;
+
+ /* If we can’t find du, don’t try and run the test. */
+ du_path = g_find_program_in_path ("du");
+ if (du_path == NULL)
+ return FALSE;
+ g_free (du_path);
du = g_subprocess_new (G_SUBPROCESS_FLAGS_STDOUT_PIPE,
&error,
result = splice_to_string (g_subprocess_get_stdout_pipe (du), &error);
g_assert_no_error (error);
- size = g_ascii_strtoll (result, &endptr, 10);
+ *size = g_ascii_strtoll (result, &endptr, 10);
+
+ g_subprocess_wait (du, NULL, &error);
+ g_assert_no_error (error);
+
+ ok = g_subprocess_get_successful (du);
g_object_unref (du);
g_free (result);
- return size;
+ return ok;
}
static void
path = g_test_build_filename (G_TEST_DIST, "desktop-files", NULL);
file = g_file_new_for_path (path);
- if (g_find_program_in_path ("du"))
- {
- size = get_size_from_du (path);
- }
- else
+ if (!get_size_from_du (path, &size))
{
- g_test_message ("du not found, skipping byte measurement");
+ g_test_message ("du not found or fail to run, skipping byte measurement");
size = 0;
}
&num_dirs,
&num_files,
&error);
- g_assert (ok);
+ g_assert_true (ok);
g_assert_no_error (error);
if (size > 0)
g_assert_cmpuint (num_bytes, ==, size);
g_assert_cmpuint (num_dirs, ==, 6);
- g_assert_cmpuint (num_files, ==, 30);
+ g_assert_cmpuint (num_files, ==, 32);
g_object_unref (file);
g_free (path);
gboolean ok;
ok = g_file_measure_disk_usage_finish (G_FILE (source), res, &num_bytes, &num_dirs, &num_files, &error);
- g_assert (ok);
+ g_assert_true (ok);
g_assert_no_error (error);
if (data->expected_bytes > 0)
path = g_test_build_filename (G_TEST_DIST, "desktop-files", NULL);
file = g_file_new_for_path (path);
- if (g_find_program_in_path ("du"))
- {
- data->expected_bytes = get_size_from_du (path);
- }
- else
+ if (!get_size_from_du (path, &data->expected_bytes))
{
- g_test_message ("du not found, skipping byte measurement");
+ g_test_message ("du not found or fail to run, skipping byte measurement");
data->expected_bytes = 0;
}
g_free (path);
data->expected_dirs = 6;
- data->expected_files = 30;
+ data->expected_files = 32;
g_file_measure_disk_usage_async (file,
G_FILE_MEASURE_APPARENT_SIZE,
measure_done, data);
}
-int
-main (int argc, char *argv[])
+static void
+test_load_bytes (void)
{
- g_test_init (&argc, &argv, NULL);
+ gchar filename[] = "g_file_load_bytes_XXXXXX";
+ GError *error = NULL;
+ GBytes *bytes;
+ GFile *file;
+ int len;
+ int fd;
+ int ret;
+
+ fd = g_mkstemp (filename);
+ g_assert_cmpint (fd, !=, -1);
+ len = strlen ("test_load_bytes");
+ ret = write (fd, "test_load_bytes", len);
+ g_assert_cmpint (ret, ==, len);
+ close (fd);
+
+ file = g_file_new_for_path (filename);
+ bytes = g_file_load_bytes (file, NULL, NULL, &error);
+ g_assert_no_error (error);
+ g_assert_nonnull (bytes);
+ g_assert_cmpint (len, ==, g_bytes_get_size (bytes));
+ g_assert_cmpstr ("test_load_bytes", ==, (gchar *)g_bytes_get_data (bytes, NULL));
- g_test_bug_base ("http://bugzilla.gnome.org/");
+ g_file_delete (file, NULL, NULL);
- g_test_add_func ("/file/basic", test_basic);
- g_test_add_func ("/file/parent", test_parent);
- g_test_add_func ("/file/child", test_child);
- g_test_add_func ("/file/type", test_type);
- g_test_add_func ("/file/parse-name", test_parse_name);
- g_test_add_data_func ("/file/async-create-delete/0", GINT_TO_POINTER (0), test_create_delete);
- g_test_add_data_func ("/file/async-create-delete/1", GINT_TO_POINTER (1), test_create_delete);
- g_test_add_data_func ("/file/async-create-delete/10", GINT_TO_POINTER (10), test_create_delete);
- g_test_add_data_func ("/file/async-create-delete/25", GINT_TO_POINTER (25), test_create_delete);
- g_test_add_data_func ("/file/async-create-delete/4096", GINT_TO_POINTER (4096), test_create_delete);
- g_test_add_func ("/file/replace-load", test_replace_load);
- g_test_add_func ("/file/replace-cancel", test_replace_cancel);
- g_test_add_func ("/file/async-delete", test_async_delete);
-#ifdef G_OS_UNIX
- g_test_add_func ("/file/copy-preserve-mode", test_copy_preserve_mode);
-#endif
+ g_bytes_unref (bytes);
+ g_object_unref (file);
+}
+
+typedef struct
+{
+ GMainLoop *main_loop;
+ GFile *file;
+ GBytes *bytes;
+} LoadBytesAsyncData;
+
+static void
+test_load_bytes_cb (GObject *object,
+ GAsyncResult *result,
+ gpointer user_data)
+{
+ GFile *file = G_FILE (object);
+ LoadBytesAsyncData *data = user_data;
+ GError *error = NULL;
+
+ data->bytes = g_file_load_bytes_finish (file, result, NULL, &error);
+ g_assert_no_error (error);
+ g_assert_nonnull (data->bytes);
+
+ g_main_loop_quit (data->main_loop);
+}
+
+static void
+test_load_bytes_async (void)
+{
+ LoadBytesAsyncData data = { 0 };
+ gchar filename[] = "g_file_load_bytes_XXXXXX";
+ int len;
+ int fd;
+ int ret;
+
+ fd = g_mkstemp (filename);
+ g_assert_cmpint (fd, !=, -1);
+ len = strlen ("test_load_bytes_async");
+ ret = write (fd, "test_load_bytes_async", len);
+ g_assert_cmpint (ret, ==, len);
+ close (fd);
+
+ data.main_loop = g_main_loop_new (NULL, FALSE);
+ data.file = g_file_new_for_path (filename);
+
+ g_file_load_bytes_async (data.file, NULL, test_load_bytes_cb, &data);
+ g_main_loop_run (data.main_loop);
+
+ g_assert_cmpint (len, ==, g_bytes_get_size (data.bytes));
+ g_assert_cmpstr ("test_load_bytes_async", ==, (gchar *)g_bytes_get_data (data.bytes, NULL));
+
+ g_file_delete (data.file, NULL, NULL);
+ g_object_unref (data.file);
+ g_bytes_unref (data.bytes);
+ g_main_loop_unref (data.main_loop);
+}
+
+static void
+test_writev_helper (GOutputVector *vectors,
+ gsize n_vectors,
+ gboolean use_bytes_written,
+ const guint8 *expected_contents,
+ gsize expected_length)
+{
+ GFile *file;
+ GFileIOStream *iostream = NULL;
+ GOutputStream *ostream;
+ GError *error = NULL;
+ gsize bytes_written = 0;
+ gboolean res;
+ guint8 *contents;
+ gsize length;
+
+ file = g_file_new_tmp ("g_file_writev_XXXXXX",
+ &iostream, NULL);
+ g_assert_nonnull (file);
+ g_assert_nonnull (iostream);
+
+ ostream = g_io_stream_get_output_stream (G_IO_STREAM (iostream));
+
+ res = g_output_stream_writev_all (ostream, vectors, n_vectors, use_bytes_written ? &bytes_written : NULL, NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+ if (use_bytes_written)
+ g_assert_cmpuint (bytes_written, ==, expected_length);
+
+ res = g_io_stream_close (G_IO_STREAM (iostream), NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+ g_object_unref (iostream);
+
+ res = g_file_load_contents (file, NULL, (gchar **) &contents, &length, NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+
+ g_assert_cmpmem (contents, length, expected_contents, expected_length);
+
+ g_free (contents);
+
+ g_file_delete (file, NULL, NULL);
+ g_object_unref (file);
+}
+
+/* Test that writev() on local file output streams works on a non-empty vector */
+static void
+test_writev (void)
+{
+ GOutputVector vectors[3];
+ const guint8 buffer[] = {1, 2, 3, 4, 5,
+ 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12,
+ 1, 2, 3};
+
+ vectors[0].buffer = buffer;
+ vectors[0].size = 5;
+
+ vectors[1].buffer = buffer + 5;
+ vectors[1].size = 12;
+
+ vectors[2].buffer = buffer + 5 + 12;
+ vectors[2].size = 3;
+
+ test_writev_helper (vectors, G_N_ELEMENTS (vectors), TRUE, buffer, sizeof buffer);
+}
+
+/* Test that writev() on local file output streams works on a non-empty vector without returning bytes_written */
+static void
+test_writev_no_bytes_written (void)
+{
+ GOutputVector vectors[3];
+ const guint8 buffer[] = {1, 2, 3, 4, 5,
+ 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12,
+ 1, 2, 3};
+
+ vectors[0].buffer = buffer;
+ vectors[0].size = 5;
+
+ vectors[1].buffer = buffer + 5;
+ vectors[1].size = 12;
+
+ vectors[2].buffer = buffer + 5 + 12;
+ vectors[2].size = 3;
+
+ test_writev_helper (vectors, G_N_ELEMENTS (vectors), FALSE, buffer, sizeof buffer);
+}
+
+/* Test that writev() on local file output streams works on 0 vectors */
+static void
+test_writev_no_vectors (void)
+{
+ test_writev_helper (NULL, 0, TRUE, NULL, 0);
+}
+
+/* Test that writev() on local file output streams works on empty vectors */
+static void
+test_writev_empty_vectors (void)
+{
+ GOutputVector vectors[3];
+
+ vectors[0].buffer = NULL;
+ vectors[0].size = 0;
+ vectors[1].buffer = NULL;
+ vectors[1].size = 0;
+ vectors[2].buffer = NULL;
+ vectors[2].size = 0;
+
+ test_writev_helper (vectors, G_N_ELEMENTS (vectors), TRUE, NULL, 0);
+}
+
+/* Test that writev() fails if the sum of sizes in the vector is too big */
+static void
+test_writev_too_big_vectors (void)
+{
+ GFile *file;
+ GFileIOStream *iostream = NULL;
+ GOutputStream *ostream;
+ GError *error = NULL;
+ gsize bytes_written = 0;
+ gboolean res;
+ guint8 *contents;
+ gsize length;
+ GOutputVector vectors[3];
+
+ vectors[0].buffer = (void*) 1;
+ vectors[0].size = G_MAXSIZE / 2;
+
+ vectors[1].buffer = (void*) 1;
+ vectors[1].size = G_MAXSIZE / 2;
+
+ vectors[2].buffer = (void*) 1;
+ vectors[2].size = G_MAXSIZE / 2;
+
+ file = g_file_new_tmp ("g_file_writev_XXXXXX",
+ &iostream, NULL);
+ g_assert_nonnull (file);
+ g_assert_nonnull (iostream);
+
+ ostream = g_io_stream_get_output_stream (G_IO_STREAM (iostream));
+
+ res = g_output_stream_writev_all (ostream, vectors, G_N_ELEMENTS (vectors), &bytes_written, NULL, &error);
+ g_assert_error (error, G_IO_ERROR, G_IO_ERROR_INVALID_ARGUMENT);
+ g_assert_cmpuint (bytes_written, ==, 0);
+ g_assert_false (res);
+ g_clear_error (&error);
+
+ res = g_io_stream_close (G_IO_STREAM (iostream), NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+ g_object_unref (iostream);
+
+ res = g_file_load_contents (file, NULL, (gchar **) &contents, &length, NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+
+ g_assert_cmpmem (contents, length, NULL, 0);
+
+ g_free (contents);
+
+ g_file_delete (file, NULL, NULL);
+ g_object_unref (file);
+}
+
+typedef struct
+{
+ gsize bytes_written;
+ GOutputVector *vectors;
+ gsize n_vectors;
+ GError *error;
+ gboolean done;
+} WritevAsyncData;
+
+static void
+test_writev_async_cb (GObject *object,
+ GAsyncResult *result,
+ gpointer user_data)
+{
+ GOutputStream *ostream = G_OUTPUT_STREAM (object);
+ WritevAsyncData *data = user_data;
+ GError *error = NULL;
+ gsize bytes_written;
+ gboolean res;
+
+ res = g_output_stream_writev_finish (ostream, result, &bytes_written, &error);
+ g_assert_true (res);
+ g_assert_no_error (error);
+ data->bytes_written += bytes_written;
+
+ /* skip vectors that have been written in full */
+ while (data->n_vectors > 0 && bytes_written >= data->vectors[0].size)
+ {
+ bytes_written -= data->vectors[0].size;
+ ++data->vectors;
+ --data->n_vectors;
+ }
+ /* skip partially written vector data */
+ if (bytes_written > 0 && data->n_vectors > 0)
+ {
+ data->vectors[0].size -= bytes_written;
+ data->vectors[0].buffer = ((guint8 *) data->vectors[0].buffer) + bytes_written;
+ }
+
+ if (data->n_vectors > 0)
+ g_output_stream_writev_async (ostream, data->vectors, data->n_vectors, 0, NULL, test_writev_async_cb, &data);
+}
+
+/* Test that writev_async() on local file output streams works on a non-empty vector */
+static void
+test_writev_async (void)
+{
+ WritevAsyncData data = { 0 };
+ GFile *file;
+ GFileIOStream *iostream = NULL;
+ GOutputVector vectors[3];
+ const guint8 buffer[] = {1, 2, 3, 4, 5,
+ 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12,
+ 1, 2, 3};
+ GOutputStream *ostream;
+ GError *error = NULL;
+ gboolean res;
+ guint8 *contents;
+ gsize length;
+
+ vectors[0].buffer = buffer;
+ vectors[0].size = 5;
+
+ vectors[1].buffer = buffer + 5;
+ vectors[1].size = 12;
+
+ vectors[2].buffer = buffer + 5 + 12;
+ vectors[2].size = 3;
+
+ file = g_file_new_tmp ("g_file_writev_XXXXXX",
+ &iostream, NULL);
+ g_assert_nonnull (file);
+ g_assert_nonnull (iostream);
+
+ data.vectors = vectors;
+ data.n_vectors = G_N_ELEMENTS (vectors);
+
+ ostream = g_io_stream_get_output_stream (G_IO_STREAM (iostream));
+
+ g_output_stream_writev_async (ostream, data.vectors, data.n_vectors, 0, NULL, test_writev_async_cb, &data);
+
+ while (data.n_vectors > 0)
+ g_main_context_iteration (NULL, TRUE);
+
+ g_assert_cmpuint (data.bytes_written, ==, sizeof buffer);
+
+ res = g_io_stream_close (G_IO_STREAM (iostream), NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+ g_object_unref (iostream);
+
+ res = g_file_load_contents (file, NULL, (gchar **) &contents, &length, NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+
+ g_assert_cmpmem (contents, length, buffer, sizeof buffer);
+
+ g_free (contents);
+
+ g_file_delete (file, NULL, NULL);
+ g_object_unref (file);
+}
+
+static void
+test_writev_all_cb (GObject *object,
+ GAsyncResult *result,
+ gpointer user_data)
+{
+ GOutputStream *ostream = G_OUTPUT_STREAM (object);
+ WritevAsyncData *data = user_data;
+
+ g_output_stream_writev_all_finish (ostream, result, &data->bytes_written, &data->error);
+ data->done = TRUE;
+}
+
+/* Test that writev_async_all() on local file output streams works on a non-empty vector */
+static void
+test_writev_async_all (void)
+{
+ WritevAsyncData data = { 0 };
+ GFile *file;
+ GFileIOStream *iostream = NULL;
+ GOutputStream *ostream;
+ GOutputVector vectors[3];
+ const guint8 buffer[] = {1, 2, 3, 4, 5,
+ 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12,
+ 1, 2, 3};
+ GError *error = NULL;
+ gboolean res;
+ guint8 *contents;
+ gsize length;
+
+ vectors[0].buffer = buffer;
+ vectors[0].size = 5;
+
+ vectors[1].buffer = buffer + 5;
+ vectors[1].size = 12;
+
+ vectors[2].buffer = buffer + 5 + 12;
+ vectors[2].size = 3;
+
+ file = g_file_new_tmp ("g_file_writev_XXXXXX",
+ &iostream, NULL);
+ g_assert_nonnull (file);
+ g_assert_nonnull (iostream);
+
+ ostream = g_io_stream_get_output_stream (G_IO_STREAM (iostream));
+
+ g_output_stream_writev_all_async (ostream, vectors, G_N_ELEMENTS (vectors), 0, NULL, test_writev_all_cb, &data);
+
+ while (!data.done)
+ g_main_context_iteration (NULL, TRUE);
+
+ g_assert_cmpuint (data.bytes_written, ==, sizeof buffer);
+ g_assert_no_error (data.error);
+
+ res = g_io_stream_close (G_IO_STREAM (iostream), NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+ g_object_unref (iostream);
+
+ res = g_file_load_contents (file, NULL, (gchar **) &contents, &length, NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+
+ g_assert_cmpmem (contents, length, buffer, sizeof buffer);
+
+ g_free (contents);
+
+ g_file_delete (file, NULL, NULL);
+ g_object_unref (file);
+}
+
+/* Test that writev_async_all() on local file output streams handles cancellation correctly */
+static void
+test_writev_async_all_cancellation (void)
+{
+ WritevAsyncData data = { 0 };
+ GFile *file;
+ GFileIOStream *iostream = NULL;
+ GOutputVector vectors[3];
+ const guint8 buffer[] = {1, 2, 3, 4, 5,
+ 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12,
+ 1, 2, 3};
+ GOutputStream *ostream;
+ GError *error = NULL;
+ gboolean res;
+ guint8 *contents;
+ gsize length;
+ GCancellable *cancellable;
+
+ vectors[0].buffer = buffer;
+ vectors[0].size = 5;
+
+ vectors[1].buffer = buffer + 5;
+ vectors[1].size = 12;
+
+ vectors[2].buffer = buffer + 5 + 12;
+ vectors[2].size = 3;
+
+ file = g_file_new_tmp ("g_file_writev_XXXXXX",
+ &iostream, NULL);
+ g_assert_nonnull (file);
+ g_assert_nonnull (iostream);
+
+ ostream = g_io_stream_get_output_stream (G_IO_STREAM (iostream));
+
+ cancellable = g_cancellable_new ();
+ g_cancellable_cancel (cancellable);
+
+ g_output_stream_writev_all_async (ostream, vectors, G_N_ELEMENTS (vectors), 0, cancellable, test_writev_all_cb, &data);
+
+ while (!data.done)
+ g_main_context_iteration (NULL, TRUE);
+
+ g_assert_cmpuint (data.bytes_written, ==, 0);
+ g_assert_error (data.error, G_IO_ERROR, G_IO_ERROR_CANCELLED);
+ g_clear_error (&data.error);
+
+ res = g_io_stream_close (G_IO_STREAM (iostream), NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+ g_object_unref (iostream);
+
+ res = g_file_load_contents (file, NULL, (gchar **) &contents, &length, NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+ g_assert_cmpuint (length, ==, 0);
+
+ g_free (contents);
+
+ g_file_delete (file, NULL, NULL);
+ g_object_unref (file);
+ g_object_unref (cancellable);
+}
+
+/* Test that writev_async_all() with empty vectors is handled correctly */
+static void
+test_writev_async_all_empty_vectors (void)
+{
+ WritevAsyncData data = { 0 };
+ GFile *file;
+ GFileIOStream *iostream = NULL;
+ GOutputVector vectors[3];
+ GOutputStream *ostream;
+ GError *error = NULL;
+ gboolean res;
+ guint8 *contents;
+ gsize length;
+
+ vectors[0].buffer = NULL;
+ vectors[0].size = 0;
+
+ vectors[1].buffer = NULL;
+ vectors[1].size = 0;
+
+ vectors[2].buffer = NULL;
+ vectors[2].size = 0;
+
+ file = g_file_new_tmp ("g_file_writev_XXXXXX",
+ &iostream, NULL);
+ g_assert_nonnull (file);
+ g_assert_nonnull (iostream);
+
+ ostream = g_io_stream_get_output_stream (G_IO_STREAM (iostream));
+
+ g_output_stream_writev_all_async (ostream, vectors, G_N_ELEMENTS (vectors), 0, NULL, test_writev_all_cb, &data);
+
+ while (!data.done)
+ g_main_context_iteration (NULL, TRUE);
+
+ g_assert_cmpuint (data.bytes_written, ==, 0);
+ g_assert_no_error (data.error);
+ g_clear_error (&data.error);
+
+ res = g_io_stream_close (G_IO_STREAM (iostream), NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+ g_object_unref (iostream);
+
+ res = g_file_load_contents (file, NULL, (gchar **) &contents, &length, NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+ g_assert_cmpuint (length, ==, 0);
+
+ g_free (contents);
+
+ g_file_delete (file, NULL, NULL);
+ g_object_unref (file);
+}
+
+/* Test that writev_async_all() with no vectors is handled correctly */
+static void
+test_writev_async_all_no_vectors (void)
+{
+ WritevAsyncData data = { 0 };
+ GFile *file;
+ GFileIOStream *iostream = NULL;
+ GOutputStream *ostream;
+ GError *error = NULL;
+ gboolean res;
+ guint8 *contents;
+ gsize length;
+
+ file = g_file_new_tmp ("g_file_writev_XXXXXX",
+ &iostream, NULL);
+ g_assert_nonnull (file);
+ g_assert_nonnull (iostream);
+
+ ostream = g_io_stream_get_output_stream (G_IO_STREAM (iostream));
+
+ g_output_stream_writev_all_async (ostream, NULL, 0, 0, NULL, test_writev_all_cb, &data);
+
+ while (!data.done)
+ g_main_context_iteration (NULL, TRUE);
+
+ g_assert_cmpuint (data.bytes_written, ==, 0);
+ g_assert_no_error (data.error);
+ g_clear_error (&data.error);
+
+ res = g_io_stream_close (G_IO_STREAM (iostream), NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+ g_object_unref (iostream);
+
+ res = g_file_load_contents (file, NULL, (gchar **) &contents, &length, NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+ g_assert_cmpuint (length, ==, 0);
+
+ g_free (contents);
+
+ g_file_delete (file, NULL, NULL);
+ g_object_unref (file);
+}
+
+/* Test that writev_async_all() with too big vectors is handled correctly */
+static void
+test_writev_async_all_too_big_vectors (void)
+{
+ WritevAsyncData data = { 0 };
+ GFile *file;
+ GFileIOStream *iostream = NULL;
+ GOutputVector vectors[3];
+ GOutputStream *ostream;
+ GError *error = NULL;
+ gboolean res;
+ guint8 *contents;
+ gsize length;
+
+ vectors[0].buffer = (void*) 1;
+ vectors[0].size = G_MAXSIZE / 2;
+
+ vectors[1].buffer = (void*) 1;
+ vectors[1].size = G_MAXSIZE / 2;
+
+ vectors[2].buffer = (void*) 1;
+ vectors[2].size = G_MAXSIZE / 2;
+
+ file = g_file_new_tmp ("g_file_writev_XXXXXX",
+ &iostream, NULL);
+ g_assert_nonnull (file);
+ g_assert_nonnull (iostream);
+
+ ostream = g_io_stream_get_output_stream (G_IO_STREAM (iostream));
+
+ g_output_stream_writev_all_async (ostream, vectors, G_N_ELEMENTS (vectors), 0, NULL, test_writev_all_cb, &data);
+
+ while (!data.done)
+ g_main_context_iteration (NULL, TRUE);
+
+ g_assert_cmpuint (data.bytes_written, ==, 0);
+ g_assert_error (data.error, G_IO_ERROR, G_IO_ERROR_INVALID_ARGUMENT);
+ g_clear_error (&data.error);
+
+ res = g_io_stream_close (G_IO_STREAM (iostream), NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+ g_object_unref (iostream);
+
+ res = g_file_load_contents (file, NULL, (gchar **) &contents, &length, NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+ g_assert_cmpuint (length, ==, 0);
+
+ g_free (contents);
+
+ g_file_delete (file, NULL, NULL);
+ g_object_unref (file);
+}
+
+static void
+test_build_attribute_list_for_copy (void)
+{
+ GFile *tmpfile;
+ GFileIOStream *iostream;
+ GError *error = NULL;
+ const GFileCopyFlags test_flags[] =
+ {
+ G_FILE_COPY_NONE,
+ G_FILE_COPY_TARGET_DEFAULT_PERMS,
+ G_FILE_COPY_ALL_METADATA,
+ G_FILE_COPY_ALL_METADATA | G_FILE_COPY_TARGET_DEFAULT_PERMS,
+ };
+ gsize i;
+ char *attrs;
+ gchar *attrs_with_commas;
+
+ tmpfile = g_file_new_tmp ("tmp-build-attribute-list-for-copyXXXXXX",
+ &iostream, &error);
+ g_assert_no_error (error);
+ g_io_stream_close ((GIOStream*)iostream, NULL, &error);
+ g_assert_no_error (error);
+ g_clear_object (&iostream);
+
+ for (i = 0; i < G_N_ELEMENTS (test_flags); i++)
+ {
+ GFileCopyFlags flags = test_flags[i];
+
+ attrs = g_file_build_attribute_list_for_copy (tmpfile, flags, NULL, &error);
+ g_test_message ("Attributes for copy: %s", attrs);
+ g_assert_no_error (error);
+ g_assert_nonnull (attrs);
+ attrs_with_commas = g_strconcat (",", attrs, ",", NULL);
+ g_free (attrs);
+
+ /* See g_local_file_class_init for reference. */
+ if (flags & G_FILE_COPY_TARGET_DEFAULT_PERMS)
+ g_assert_null (g_strstr_len (attrs_with_commas, -1, "," G_FILE_ATTRIBUTE_UNIX_MODE ","));
+ else
+ g_assert_nonnull (g_strstr_len (attrs_with_commas, -1, "," G_FILE_ATTRIBUTE_UNIX_MODE ","));
+#ifdef G_OS_UNIX
+ if (flags & G_FILE_COPY_ALL_METADATA)
+ {
+ g_assert_nonnull (g_strstr_len (attrs_with_commas, -1, "," G_FILE_ATTRIBUTE_UNIX_UID ","));
+ g_assert_nonnull (g_strstr_len (attrs_with_commas, -1, "," G_FILE_ATTRIBUTE_UNIX_GID ","));
+ }
+ else
+ {
+ g_assert_null (g_strstr_len (attrs_with_commas, -1, "," G_FILE_ATTRIBUTE_UNIX_UID ","));
+ g_assert_null (g_strstr_len (attrs_with_commas, -1, "," G_FILE_ATTRIBUTE_UNIX_GID ","));
+ }
+#endif
+#ifdef HAVE_UTIMES
+ g_assert_nonnull (g_strstr_len (attrs_with_commas, -1, "," G_FILE_ATTRIBUTE_TIME_MODIFIED ","));
+ g_assert_nonnull (g_strstr_len (attrs_with_commas, -1, "," G_FILE_ATTRIBUTE_TIME_MODIFIED_USEC ","));
+ if (flags & G_FILE_COPY_ALL_METADATA)
+ {
+ g_assert_nonnull (g_strstr_len (attrs_with_commas, -1, "," G_FILE_ATTRIBUTE_TIME_ACCESS ","));
+ g_assert_nonnull (g_strstr_len (attrs_with_commas, -1, "," G_FILE_ATTRIBUTE_TIME_ACCESS_USEC ","));
+ }
+ else
+ {
+ g_assert_null (g_strstr_len (attrs_with_commas, -1, "," G_FILE_ATTRIBUTE_TIME_ACCESS ","));
+ g_assert_null (g_strstr_len (attrs_with_commas, -1, "," G_FILE_ATTRIBUTE_TIME_ACCESS_USEC ","));
+ }
+#endif
+ g_free (attrs_with_commas);
+ }
+
+ (void) g_file_delete (tmpfile, NULL, NULL);
+ g_clear_object (&tmpfile);
+}
+
+typedef struct
+{
+ GError *error;
+ gboolean done;
+ gboolean res;
+} MoveAsyncData;
+
+static void
+test_move_async_cb (GObject *object,
+ GAsyncResult *result,
+ gpointer user_data)
+{
+ GFile *file = G_FILE (object);
+ MoveAsyncData *data = user_data;
+ GError *error = NULL;
+
+ data->res = g_file_move_finish (file, result, &error);
+ data->error = error;
+ data->done = TRUE;
+}
+
+typedef struct
+{
+ goffset total_num_bytes;
+} MoveAsyncProgressData;
+
+static void
+test_move_async_progress_cb (goffset current_num_bytes,
+ goffset total_num_bytes,
+ gpointer user_data)
+{
+ MoveAsyncProgressData *data = user_data;
+ data->total_num_bytes = total_num_bytes;
+}
+
+/* Test that move_async() moves the file correctly */
+static void
+test_move_async (void)
+{
+ MoveAsyncData data = { 0 };
+ MoveAsyncProgressData progress_data = { 0 };
+ GFile *source;
+ GFileIOStream *iostream;
+ GOutputStream *ostream;
+ GFile *destination;
+ gchar *destination_path;
+ GError *error = NULL;
+ gboolean res;
+ const guint8 buffer[] = {1, 2, 3, 4, 5};
+
+ source = g_file_new_tmp ("g_file_move_XXXXXX", &iostream, NULL);
+
+ destination_path = g_build_path (G_DIR_SEPARATOR_S, g_get_tmp_dir (), "g_file_move_target", NULL);
+ destination = g_file_new_for_path (destination_path);
+
+ g_assert_nonnull (source);
+ g_assert_nonnull (iostream);
+
+ res = g_file_query_exists (source, NULL);
+ g_assert_true (res);
+ res = g_file_query_exists (destination, NULL);
+ g_assert_false (res);
+
+ // Write a known amount of bytes to the file, so we can test the progress callback against it
+ ostream = g_io_stream_get_output_stream (G_IO_STREAM (iostream));
+ g_output_stream_write (ostream, buffer, sizeof (buffer), NULL, &error);
+ g_assert_no_error (error);
+
+ g_file_move_async (source,
+ destination,
+ G_FILE_COPY_NONE,
+ 0,
+ NULL,
+ test_move_async_progress_cb,
+ &progress_data,
+ test_move_async_cb,
+ &data);
+
+ while (!data.done)
+ g_main_context_iteration (NULL, TRUE);
+
+ g_assert_no_error (data.error);
+ g_assert_true (data.res);
+ g_assert_cmpuint (progress_data.total_num_bytes, ==, sizeof (buffer));
+
+ res = g_file_query_exists (source, NULL);
+ g_assert_false (res);
+ res = g_file_query_exists (destination, NULL);
+ g_assert_true (res);
+
+ res = g_io_stream_close (G_IO_STREAM (iostream), NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+ g_object_unref (iostream);
+
+ res = g_file_delete (destination, NULL, &error);
+ g_assert_no_error (error);
+ g_assert_true (res);
+
+ g_object_unref (source);
+ g_object_unref (destination);
+
+ g_free (destination_path);
+}
+
+int
+main (int argc, char *argv[])
+{
+ setlocale (LC_ALL, "");
+
+ g_test_init (&argc, &argv, NULL);
+
+ g_test_add_func ("/file/basic", test_basic);
+ g_test_add_func ("/file/build-filename", test_build_filename);
+ g_test_add_func ("/file/parent", test_parent);
+ g_test_add_func ("/file/child", test_child);
+ g_test_add_func ("/file/empty-path", test_empty_path);
+ g_test_add_func ("/file/type", test_type);
+ g_test_add_func ("/file/parse-name", test_parse_name);
+ g_test_add_data_func ("/file/async-create-delete/0", GINT_TO_POINTER (0), test_create_delete);
+ g_test_add_data_func ("/file/async-create-delete/1", GINT_TO_POINTER (1), test_create_delete);
+ g_test_add_data_func ("/file/async-create-delete/10", GINT_TO_POINTER (10), test_create_delete);
+ g_test_add_data_func ("/file/async-create-delete/25", GINT_TO_POINTER (25), test_create_delete);
+ g_test_add_data_func ("/file/async-create-delete/4096", GINT_TO_POINTER (4096), test_create_delete);
+ g_test_add_func ("/file/replace-load", test_replace_load);
+ g_test_add_func ("/file/replace-cancel", test_replace_cancel);
+ g_test_add_func ("/file/replace-symlink", test_replace_symlink);
+ g_test_add_func ("/file/replace-symlink/using-etag", test_replace_symlink_using_etag);
+ g_test_add_data_func ("/file/replace/write-only", GUINT_TO_POINTER (FALSE), test_replace);
+ g_test_add_data_func ("/file/replace/read-write", GUINT_TO_POINTER (TRUE), test_replace);
+ g_test_add_func ("/file/async-delete", test_async_delete);
+ g_test_add_func ("/file/copy-preserve-mode", test_copy_preserve_mode);
g_test_add_func ("/file/measure", test_measure);
g_test_add_func ("/file/measure-async", test_measure_async);
+ g_test_add_func ("/file/load-bytes", test_load_bytes);
+ g_test_add_func ("/file/load-bytes-async", test_load_bytes_async);
+ g_test_add_func ("/file/writev", test_writev);
+ g_test_add_func ("/file/writev/no-bytes-written", test_writev_no_bytes_written);
+ g_test_add_func ("/file/writev/no-vectors", test_writev_no_vectors);
+ g_test_add_func ("/file/writev/empty-vectors", test_writev_empty_vectors);
+ g_test_add_func ("/file/writev/too-big-vectors", test_writev_too_big_vectors);
+ g_test_add_func ("/file/writev/async", test_writev_async);
+ g_test_add_func ("/file/writev/async_all", test_writev_async_all);
+ g_test_add_func ("/file/writev/async_all-empty-vectors", test_writev_async_all_empty_vectors);
+ g_test_add_func ("/file/writev/async_all-no-vectors", test_writev_async_all_no_vectors);
+ g_test_add_func ("/file/writev/async_all-to-big-vectors", test_writev_async_all_too_big_vectors);
+ g_test_add_func ("/file/writev/async_all-cancellation", test_writev_async_all_cancellation);
+ g_test_add_func ("/file/build-attribute-list-for-copy", test_build_attribute_list_for_copy);
+ g_test_add_func ("/file/move_async", test_move_async);
return g_test_run ();
}
projects / platform / upstream / glib.git / blobdiff