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=8a884ab6bf68d3b5d8cbc04cfcbfdcf609f70388;hb=44cdb3a261262ebabea3fb0cae9360ac05e66f2c;hpb=8674c9bffaabd99472c684286b8da9e0d01517f7 diff --git a/tests/regression/tools/live/live_test.c b/tests/regression/tools/live/live_test.c index 8a884ab6b..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: