X-Git-Url: https://git.efficios.com/?a=blobdiff_plain;f=src%2Fplugins%2Fctf%2Flttng-live%2Flttng-live.cpp;h=63fc173f689cd20f956ba2ba6810cf3e6bc7fa8e;hb=10265ebe457aa6633556c604e27e865e66d14f0b;hp=3a882b88070ad574552325650c047152d5f11bce;hpb=4164020e790fa6c0700715936b40a3fa46df479e;p=babeltrace.git diff --git a/src/plugins/ctf/lttng-live/lttng-live.cpp b/src/plugins/ctf/lttng-live/lttng-live.cpp index 3a882b88..63fc173f 100644 --- a/src/plugins/ctf/lttng-live/lttng-live.cpp +++ b/src/plugins/ctf/lttng-live/lttng-live.cpp @@ -607,9 +607,7 @@ lttng_live_iterator_handle_new_streams_and_metadata(struct lttng_live_msg_iter * status = lttng_live_get_session(lttng_live_msg_iter, session); switch (status) { case LTTNG_LIVE_ITERATOR_STATUS_OK: - break; case LTTNG_LIVE_ITERATOR_STATUS_END: - status = LTTNG_LIVE_ITERATOR_STATUS_OK; break; default: goto end; @@ -1799,8 +1797,8 @@ lttng_live_msg_iter_init(bt_self_message_iterator *self_msg_it, lttng_live_msg_iter = lttng_live_msg_iter_create(lttng_live, self_msg_it); if (!lttng_live_msg_iter) { - status = BT_MESSAGE_ITERATOR_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR; BT_COMP_LOGE_APPEND_CAUSE(self_comp, "Failed to create lttng_live_msg_iter"); + status = BT_MESSAGE_ITERATOR_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR; goto error; } @@ -1817,6 +1815,8 @@ lttng_live_msg_iter_init(bt_self_message_iterator *self_msg_it, */ BT_COMP_LOGE_APPEND_CAUSE(self_comp, "Interrupted while creating viewer connection"); } + + status = BT_MESSAGE_ITERATOR_CLASS_INITIALIZE_METHOD_STATUS_ERROR; goto error; } @@ -1831,6 +1831,8 @@ lttng_live_msg_iter_init(bt_self_message_iterator *self_msg_it, */ BT_COMP_LOGE_APPEND_CAUSE(self_comp, "Interrupted when creating viewer session"); } + + status = BT_MESSAGE_ITERATOR_CLASS_INITIALIZE_METHOD_STATUS_ERROR; goto error; } @@ -1850,6 +1852,7 @@ lttng_live_msg_iter_init(bt_self_message_iterator *self_msg_it, "component parameter: url =\"%s\"", SESS_NOT_FOUND_ACTION_PARAM, SESS_NOT_FOUND_ACTION_FAIL_STR, lttng_live->params.url->str); + status = BT_MESSAGE_ITERATOR_CLASS_INITIALIZE_METHOD_STATUS_ERROR; goto error; case SESSION_NOT_FOUND_ACTION_END: BT_COMP_LOGI( @@ -1869,16 +1872,14 @@ lttng_live_msg_iter_init(bt_self_message_iterator *self_msg_it, goto end; error: - status = BT_MESSAGE_ITERATOR_CLASS_INITIALIZE_METHOD_STATUS_ERROR; lttng_live_msg_iter_destroy(lttng_live_msg_iter); end: return status; } static struct bt_param_validation_map_value_entry_descr list_sessions_params[] = { - {URL_PARAM, - BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_MANDATORY, - {bt_param_validation_value_descr::string_t}}, + {URL_PARAM, BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_MANDATORY, + bt_param_validation_value_descr::makeString()}, BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_END}; static bt_component_class_query_method_status @@ -2086,9 +2087,8 @@ parse_session_not_found_action_param(const bt_value *no_session_param) return action; } -static bt_param_validation_value_descr inputs_elem_descr { - bt_param_validation_value_descr::string_t, -}; +static bt_param_validation_value_descr inputs_elem_descr = + bt_param_validation_value_descr::makeString(); static const char *sess_not_found_action_choices[] = { SESS_NOT_FOUND_ACTION_CONTINUE_STR, @@ -2097,12 +2097,10 @@ static const char *sess_not_found_action_choices[] = { }; static struct bt_param_validation_map_value_entry_descr params_descr[] = { - {INPUTS_PARAM, - BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_MANDATORY, - {bt_param_validation_value_descr::array_t, 1, 1, inputs_elem_descr}}, - {SESS_NOT_FOUND_ACTION_PARAM, - BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, - {bt_param_validation_value_descr::string_t, sess_not_found_action_choices}}, + {INPUTS_PARAM, BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_MANDATORY, + bt_param_validation_value_descr::makeArray(1, 1, inputs_elem_descr)}, + {SESS_NOT_FOUND_ACTION_PARAM, BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL, + bt_param_validation_value_descr::makeString(sess_not_found_action_choices)}, BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_END}; static bt_component_class_initialize_method_status