X-Git-Url: http://git.efficios.com/?p=lttng-tools.git;a=blobdiff_plain;f=tests%2Fregression%2Ftools%2Flive%2Flive_test.c;h=151e23fb6eb60089df712efcc51eacba017283af;hp=9f4532cfd6078c71e6e4ad0e3a547cb570ccf872;hb=44cdb3a261262ebabea3fb0cae9360ac05e66f2c;hpb=a7333da73c2083281c5ec833d041b7acf0d10d0b diff --git a/tests/regression/tools/live/live_test.c b/tests/regression/tools/live/live_test.c index 9f4532cfd..151e23fb6 100644 --- a/tests/regression/tools/live/live_test.c +++ b/tests/regression/tools/live/live_test.c @@ -51,9 +51,6 @@ #define NUM_TESTS 11 #define mmap_size 524288 -int ust_consumerd32_fd; -int ust_consumerd64_fd; - static int control_sock; struct live_session *session; @@ -399,6 +396,7 @@ int get_metadata(void) rq.stream_id = htobe64(session->streams[metadata_stream_id].id); +retry: ret_len = lttng_live_send(control_sock, &cmd, sizeof(cmd)); if (ret_len < 0) { diag("Error sending cmd"); @@ -423,8 +421,8 @@ int get_metadata(void) break; case LTTNG_VIEWER_NO_NEW_METADATA: diag("Got LTTNG_VIEWER_NO_NEW_METADATA:"); - ret = 0; - goto end; + usleep(50); + goto retry; case LTTNG_VIEWER_METADATA_ERR: diag("Got LTTNG_VIEWER_METADATA_ERR:"); goto error; @@ -454,7 +452,7 @@ int get_metadata(void) } free(data); ret = len; -end: + return ret; error_free_data: @@ -693,6 +691,9 @@ int main(int argc, char **argv) ret = list_sessions(&session_id); ok(ret > 0, "List sessions : %d session(s)", ret); + if (ret < 0) { + goto end; + } ret = create_viewer_session(); ok(ret == 0, "Create viewer session"); @@ -721,6 +722,6 @@ int main(int argc, char **argv) ret = attach_session(session_id); ok(ret > 0, "Attach to session, %d streams received", ret); - +end: return exit_status(); }