All pastes #811469 Raw Edit

Mine

public text v1 · immutable
·published 2007-12-10 23:11 UTC
rendered paste body
Index: ../../tests/client-tests/check_client.c
===================================================================
--- ../../tests/client-tests/check_client.c     (revision 2938)
+++ ../../tests/client-tests/check_client.c     (working copy)
@@ -152,8 +152,9 @@
           counterpart to close the queue.
        */
 
+       osync_queue_disconnect(read2, NULL); // HACK HACK HACK - this closes one end of the pipe to emit HUP signal to avoid blocking
+
 
-       /*
        OSyncError *locerror = NULL;
        osync_error_set(&locerror, OSYNC_ERROR_GENERIC, "test");
        fail_unless(osync_client_run(client, &error), NULL);
@@ -161,13 +162,12 @@
        osync_client_error_shutdown(client, locerror);
        osync_error_unref(&locerror);
 
+       printf("Yiiiiiiipe client shutdown.. but i block here since i try to get messages from a closed queue....\n");
        message = osync_queue_get_message(read2);
        osync_assert(osync_message_get_command(message) == OSYNC_MESSAGE_ERROR);
        osync_message_unref(message);
-       */
 
 
-
        osync_assert(osync_queue_disconnect(read1, &error));
        osync_assert(error == NULL);
 
@@ -203,13 +203,13 @@
 Suite *client_suite(void)
 {
        Suite *s = suite_create("Client");
-//     Suite *s2 = suite_create("Client");
+       Suite *s2 = suite_create("Client");
 
        create_case(s, "client_new", client_new);
        create_case(s, "client_pipes", client_pipes);
-       create_case(s, "client_run", client_run);
+       create_case(s2, "client_run", client_run);
 
-       return s;
+       return s2;
 }
 
 int main(void)