rendered paste bodyIndex: ../../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)