luc14n0/glib
1
0
Fork 0
mirror of https://gitlab.gnome.org/GNOME/glib.git synced 2025-01-26 22:16:16 +01:00
Code Issues Packages Projects Releases Wiki Activity

tests: Add a test for progress callbacks from g_file_copy()

Browse Source 
This wasn’t previously tested.

Signed-off-by: Philip Withnall <pwithnall@endlessos.org>

Helps: #2863
This commit is contained in:
Philip Withnall 2023-04-27 22:42:13 +01:00
parent 0da948a5d1
commit aafa19fc0d
1 changed files with 76 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

76
gio/tests/file.c
View File

@ -2513,6 +2513,80 @@ test_copy_preserve_mode (void)
#endif #endif
} }
typedef struct
{
goffset current_num_bytes;
goffset total_num_bytes;
} CopyProgressData;
static void
file_copy_progress_cb (goffset current_num_bytes,
goffset total_num_bytes,
gpointer user_data)
{
CopyProgressData *prev_data = user_data;
g_assert_cmpuint (total_num_bytes, ==, prev_data->total_num_bytes);
g_assert_cmpuint (current_num_bytes, >=, prev_data->current_num_bytes);
/* Update it for the next callback. */
prev_data->current_num_bytes = current_num_bytes;
}
static void
test_copy_progress (void)
{
GFile *src_tmpfile = NULL;
GFile *dest_tmpfile = NULL;
GFileIOStream *iostream;
GOutputStream *ostream;
GError *local_error = NULL;
const guint8 buffer[] = { 1, 2, 3, 4, 5 };
CopyProgressData progress_data;
src_tmpfile = g_file_new_tmp ("tmp-copy-progressXXXXXX",
&iostream, &local_error);
g_assert_no_error (local_error);
/* Write some content to the file for testing. */
ostream = g_io_stream_get_output_stream (G_IO_STREAM (iostream));
g_output_stream_write (ostream, buffer, sizeof (buffer), NULL, &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);
/* Grab a unique destination filename. */
dest_tmpfile = g_file_new_tmp ("tmp-copy-progressXXXXXX",
&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);
/* Set the progress data to an initial offset of zero. The callback will
* assert that progress is non-decreasing and reaches the total length of
* the file. */
progress_data.current_num_bytes = 0;
progress_data.total_num_bytes = sizeof (buffer);
/* Copy the file with progress reporting. */
g_file_copy (src_tmpfile, dest_tmpfile, G_FILE_COPY_OVERWRITE,
NULL, file_copy_progress_cb, &progress_data, &local_error);
g_assert_no_error (local_error);
g_assert_cmpuint (progress_data.current_num_bytes, ==, progress_data.total_num_bytes);
g_assert_cmpuint (progress_data.total_num_bytes, ==, sizeof (buffer));
/* Clean up. */
(void) g_file_delete (src_tmpfile, NULL, NULL);
(void) g_file_delete (dest_tmpfile, NULL, NULL);
g_clear_object (&src_tmpfile);
g_clear_object (&dest_tmpfile);
}
static void static void
test_measure (void) test_measure (void)
{ {
@ -3844,6 +3918,7 @@ main (int argc, char *argv[])
g_test_add_func ("/file/async-delete", test_async_delete); g_test_add_func ("/file/async-delete", test_async_delete);
g_test_add_func ("/file/async-make-symlink", test_async_make_symlink); g_test_add_func ("/file/async-make-symlink", test_async_make_symlink);
g_test_add_func ("/file/copy-preserve-mode", test_copy_preserve_mode); g_test_add_func ("/file/copy-preserve-mode", test_copy_preserve_mode);
g_test_add_func ("/file/copy/progress", test_copy_progress);
g_test_add_func ("/file/measure", test_measure); g_test_add_func ("/file/measure", test_measure);
g_test_add_func ("/file/measure-async", test_measure_async); 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", test_load_bytes);
@ -3869,3 +3944,4 @@ main (int argc, char *argv[])
return g_test_run (); return g_test_run ();
} }