X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=gio%2Ftests%2Fwin32-streams.c;h=b9d95f9aea6e553698faff250424837d90f13212;hb=b5ba22f163f884f14724b54d001bd044308f9f63;hp=e482852a306240188033552fcd1d239d8ec189c7;hpb=b9b2cf6a666af907d775a871d76b5b6871b4a6bd;p=platform%2Fupstream%2Fglib.git

diff --git a/gio/tests/win32-streams.c b/gio/tests/win32-streams.c
index e482852..b9d95f9 100644
--- a/gio/tests/win32-streams.c
+++ b/gio/tests/win32-streams.c
@@ -466,14 +466,68 @@ test_pipe_io_concurrent (void)
   close (writer_pipe[1]);
 }
 
+static void
+readable_cancel (GObject *source, GAsyncResult *res, gpointer user_data)
+{
+  GInputStream *in = G_INPUT_STREAM (source);
+  GError *err = NULL;
+  gssize len;
+
+  len = g_input_stream_read_finish (in, res, &err);
+  g_assert_cmpint (len, ==, -1);
+  g_assert_error (err, G_IO_ERROR, G_IO_ERROR_CANCELLED);
+  g_error_free (err);
+
+  g_main_loop_quit (loop);
+}
+
+static void
+test_pipe_io_cancel (void)
+{
+  GInputStream *in;
+  GOutputStream *out;
+  HANDLE in_handle, out_handle;
+  gchar name[256];
+
+  g_snprintf (name, sizeof (name),
+              "\\\\.\\pipe\\gtest-io-cancel-%u", (guint) getpid ());
+
+  in_handle = CreateNamedPipe (name,
+                               PIPE_ACCESS_INBOUND | FILE_FLAG_OVERLAPPED,
+                               PIPE_READMODE_BYTE | PIPE_WAIT,
+                               1, 0, 0, 0, NULL);
+  g_assert (in_handle != INVALID_HANDLE_VALUE);
+
+  out_handle = CreateFile (name, GENERIC_WRITE, 0, NULL, OPEN_EXISTING, 0, NULL);
+  g_assert (out_handle != INVALID_HANDLE_VALUE);
+
+  in = g_win32_input_stream_new (in_handle, TRUE);
+  out = g_win32_output_stream_new (out_handle, TRUE);
+
+  reader_cancel = g_cancellable_new ();
+  g_input_stream_read_async (in, main_buf, sizeof (main_buf),
+                             G_PRIORITY_DEFAULT, reader_cancel,
+                             readable_cancel, out);
+
+  g_timeout_add (500, timeout, reader_cancel);
+
+  loop = g_main_loop_new (NULL, TRUE);
+  g_main_loop_run (loop);
+  g_main_loop_unref (loop);
+
+  g_object_unref (reader_cancel);
+  g_object_unref (in);
+  g_object_unref (out);
+}
+
 int
 main (int   argc,
       char *argv[])
 {
-  g_type_init ();
   g_test_init (&argc, &argv, NULL);
 
   g_test_add_func ("/win32-streams/pipe-io-test", test_pipe_io);
+  g_test_add_func ("/win32-streams/pipe-io-cancel-test", test_pipe_io_cancel);
   g_test_add_func ("/win32-streams/pipe-io-overlap-test", test_pipe_io_overlap);
   g_test_add_func ("/win32-streams/pipe-io-concurrent-test", test_pipe_io_concurrent);