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)