X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=tests%2Funit%2Ftest_session.c;h=cfbb52d048dd00820e6817a24dbe221a5a165716;hp=8e1da214806d105975bc5853270a68444246da03;hb=51c2fb6c453e66de5f2552569daa490a4f02a4fd;hpb=dec56f6cc894de41b312354d360b6a4c09fc199d diff --git a/tests/unit/test_session.c b/tests/unit/test_session.c index 8e1da2148..cfbb52d04 100644 --- a/tests/unit/test_session.c +++ b/tests/unit/test_session.c @@ -16,7 +16,6 @@ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. */ -#define _GNU_SOURCE #include #include #include @@ -25,11 +24,14 @@ #include #include #include +#include #include #include #include +#include +#include #include #include @@ -41,11 +43,14 @@ /* Number of TAP tests in this file */ #define NUM_TESTS 11 +struct health_app *health_sessiond; static struct ltt_session_list *session_list; +static pthread_t ht_cleanup_thread; -/* For lttngerr.h */ +/* For error.h */ int lttng_opt_quiet = 1; int lttng_opt_verbose = 0; +int lttng_opt_mi; int ust_consumerd32_fd; int ust_consumerd64_fd; @@ -108,8 +113,7 @@ static void empty_session_list(void) struct ltt_session *iter, *tmp; cds_list_for_each_entry_safe(iter, tmp, &session_list->head, list) { - cds_list_del(&iter->list); - free(iter); + session_destroy(iter); } /* Session list must be 0 */ @@ -151,15 +155,14 @@ static int create_one_session(char *name) static int destroy_one_session(struct ltt_session *session) { int ret; + char session_name[NAME_MAX]; - ret = session_destroy(session); + strncpy(session_name, session->name, sizeof(session_name)); + session_name[sizeof(session_name) - 1] = '\0'; + ret = session_destroy(session); if (ret == LTTNG_OK) { - /* Validate */ - if (session == NULL) { - return 0; - } - ret = find_session_name(session->name); + ret = find_session_name(session_name); if (ret < 0) { /* Success, -1 means that the sesion is NOT found */ return 0; @@ -280,7 +283,7 @@ void test_large_session_number(void) cds_list_for_each_entry_safe(iter, tmp, &session_list->head, list) { ret = destroy_one_session(iter); if (ret < 0) { - diag("session %d (name: %s) destroy failed", i, iter->name); + diag("session %d destroy failed", i); ++failed; } } @@ -295,8 +298,13 @@ int main(int argc, char **argv) { plan_tests(NUM_TESTS); + health_sessiond = health_app_create(NR_HEALTH_SESSIOND_TYPES); + assert(!init_ht_cleanup_thread(&ht_cleanup_thread)); + diag("Sessions unit tests"); + rcu_register_thread(); + test_session_list(); test_create_one_session(); @@ -313,5 +321,8 @@ int main(int argc, char **argv) test_large_session_number(); + rcu_unregister_thread(); + assert(!fini_ht_cleanup_thread(&ht_cleanup_thread)); + return exit_status(); }