This patch adds bt_common_abort() which, for the moment, only calls
abort().
This patch also replaces all the calls to abort() with calls to
bt_common_abort().
The purpose is to control how all the parts of Babeltrace abort,
eventually adding other actions before calling abort() for example.
Signed-off-by: Philippe Proulx <eeppeliteloop@gmail.com>
Change-Id: I2c8cd7ad760758041ef2dcaaa6b3ef84f89d80e6
Reviewed-on: https://review.lttng.org/c/babeltrace/+/2317
Tested-by: jenkins <jenkins@lttng.org>
65 files changed:
#include <glib.h>
#include "common/assert.h"
#include <glib.h>
#include "common/assert.h"
+#include "common/common.h"
parse_ret.error, i, orig_arg);
goto error;
default:
parse_ret.error, i, orig_arg);
goto error;
default:
}
if (used_next_orig_arg) {
}
if (used_next_orig_arg) {
SWIGTYPE_p_bt_trace, 0);
if (!py_trace_ptr) {
BT_LOGF_STR("Failed to create a SWIG pointer object.");
SWIGTYPE_p_bt_trace, 0);
if (!py_trace_ptr) {
BT_LOGF_STR("Failed to create a SWIG pointer object.");
}
py_res = PyObject_CallFunction(py_callable, "(O)", py_trace_ptr);
}
py_res = PyObject_CallFunction(py_callable, "(O)", py_trace_ptr);
SWIGTYPE_p_bt_trace_class, 0);
if (!py_trace_class_ptr) {
BT_LOGF_STR("Failed to create a SWIG pointer object.");
SWIGTYPE_p_bt_trace_class, 0);
if (!py_trace_class_ptr) {
BT_LOGF_STR("Failed to create a SWIG pointer object.");
}
py_res = PyObject_CallFunction(py_callable, "(O)", py_trace_class_ptr);
}
py_res = PyObject_CallFunction(py_callable, "(O)", py_trace_class_ptr);
g_ptr_array_add(cfg->cmd_data.run.sinks, cfg_comp);
break;
default:
g_ptr_array_add(cfg->cmd_data.run.sinks, cfg_comp);
break;
default:
dest = BT_CONFIG_COMPONENT_DEST_SINK;
break;
default:
dest = BT_CONFIG_COMPONENT_DEST_SINK;
break;
default:
}
BT_ASSERT(cur_base_params);
}
BT_ASSERT(cur_base_params);
sink_names = g_list_append(sink_names, name_gstr);
break;
default:
sink_names = g_list_append(sink_names, name_gstr);
break;
default:
default_log_level);
break;
default:
default_log_level);
break;
default:
default:
BT_LOGF("Unknown query status: status=%s",
bt_common_func_status_string(status));
default:
BT_LOGF("Unknown query status: status=%s",
bt_common_func_status_string(status));
comp_cls = bt_component_class_sink_as_component_class_const(find_sink_component_class(plugin_name, comp_class_name));
break;
default:
comp_cls = bt_component_class_sink_as_component_class_const(find_sink_component_class(plugin_name, comp_class_name));
break;
default:
print_cfg_print_lttng_live_sessions(cfg);
break;
default:
print_cfg_print_lttng_live_sessions(cfg);
break;
default:
cfg_comp->comp_cls_name->str);
break;
default:
cfg_comp->comp_cls_name->str);
break;
default:
(void *) &comp);
break;
default:
(void *) &comp);
break;
default:
GUINT_TO_POINTER(quark), (void *) comp);
break;
default:
GUINT_TO_POINTER(quark), (void *) comp);
break;
default:
bt_error_cause_message_iterator_actor_get_component_class_type(cause));
break;
default:
bt_error_cause_message_iterator_actor_get_component_class_type(cause));
break;
default:
}
/* Print file name and line number */
}
/* Print file name and line number */
break;
default:
BT_LOGF("Invalid/unknown command: cmd=%d", cfg->command);
break;
default:
BT_LOGF("Invalid/unknown command: cmd=%d", cfg->command);
}
BT_LOGI("Command completed: cmd=%d, command-name=\"%s\", ret=%d",
}
BT_LOGI("Command completed: cmd=%d, command-name=\"%s\", ret=%d",
bt_common_color_reset(),
bt_common_color_fg_red(),
bt_common_color_reset());
bt_common_color_reset(),
bt_common_color_fg_red(),
bt_common_color_reset());
if (page_size < 0) {
BT_LOGF("Cannot get system's page size: ret=%d",
page_size);
if (page_size < 0) {
BT_LOGF("Cannot get system's page size: ret=%d",
page_size);
BUF_STD_APPEND_SINGLE_ARG(int);
break;
default:
BUF_STD_APPEND_SINGLE_ARG(int);
break;
default:
BUF_STD_APPEND_SINGLE_ARG(wchar_t *);
break;
default:
BUF_STD_APPEND_SINGLE_ARG(wchar_t *);
break;
default:
BUF_STD_APPEND_SINGLE_ARG(size_t);
break;
default:
BUF_STD_APPEND_SINGLE_ARG(size_t);
break;
default:
BUF_STD_APPEND_SINGLE_ARG(size_t);
break;
default:
BUF_STD_APPEND_SINGLE_ARG(size_t);
break;
default:
BUF_STD_APPEND_SINGLE_ARG(long double);
break;
default:
BUF_STD_APPEND_SINGLE_ARG(long double);
break;
default:
if (length_mod == LENGTH_MOD_NONE) {
BUF_STD_APPEND_SINGLE_ARG(void *);
} else {
if (length_mod == LENGTH_MOD_NONE) {
BUF_STD_APPEND_SINGLE_ARG(void *);
} else {
g_free(buf);
return ret;
}
g_free(buf);
return ret;
}
+
+BT_HIDDEN
+void bt_common_abort(void)
+{
+ abort();
+}
BT_HIDDEN
int bt_common_append_file_content_to_g_string(GString *str, FILE *fp);
BT_HIDDEN
int bt_common_append_file_content_to_g_string(GString *str, FILE *fp);
+BT_HIDDEN
+void bt_common_abort(void) __attribute__((noreturn));
+
/*
* Wraps read() function to handle EINTR and partial reads.
* On success, it returns `count` received as parameter. On error, it returns a
/*
* Wraps read() function to handle EINTR and partial reads.
* On success, it returns `count` received as parameter. On error, it returns a
g_string_append(str, ", <CUR>");
break;
default:
g_string_append(str, ", <CUR>");
break;
default:
+#include "common/common.h"
+
#ifdef BABELTRACE_HAVE_POSIX_FALLOCATE
#include <fcntl.h>
#ifdef BABELTRACE_HAVE_POSIX_FALLOCATE
#include <fcntl.h>
/* Restore the original file pointer position */
if (!SetFilePointerEx(handle, file_pos, NULL, FILE_BEGIN)) {
/* We moved the file pointer but failed to restore it. */
/* Restore the original file pointer position */
if (!SetFilePointerEx(handle, file_pos, NULL, FILE_BEGIN)) {
/* We moved the file pointer but failed to restore it. */
#include "logging/log.h"
#include "common/macros.h"
#include "logging/log.h"
#include "common/macros.h"
+#include "common/common.h"
if (mapping) {
if (!CloseHandle(mapping->map_handle)) {
BT_LOGF_STR("Failed to close mmap map_handle.");
if (mapping) {
if (!CloseHandle(mapping->map_handle)) {
BT_LOGF_STR("Failed to close mmap map_handle.");
}
if (!CloseHandle(mapping->file_handle)) {
BT_LOGF_STR("Failed to close mmap file_handle.");
}
if (!CloseHandle(mapping->file_handle)) {
BT_LOGF_STR("Failed to close mmap file_handle.");
}
free(mapping);
mapping = NULL;
}
free(mapping);
mapping = NULL;
*/
BT_LOG_WRITE_CUR_LVL(BT_LOG_FATAL, BT_LOG_FATAL, BT_LOG_TAG,
"Failed to unmap mmap mapping.");
*/
BT_LOG_WRITE_CUR_LVL(BT_LOG_FATAL, BT_LOG_FATAL, BT_LOG_TAG,
"Failed to unmap mmap mapping.");
{
if (pthread_mutex_lock(&mmap_mutex)) {
BT_LOG_WRITE_CUR_LVL(BT_LOG_FATAL, log_level, BT_LOG_TAG, "Failed to acquire mmap_mutex.");
{
if (pthread_mutex_lock(&mmap_mutex)) {
BT_LOG_WRITE_CUR_LVL(BT_LOG_FATAL, log_level, BT_LOG_TAG, "Failed to acquire mmap_mutex.");
{
if (pthread_mutex_unlock(&mmap_mutex)) {
BT_LOG_WRITE_CUR_LVL(BT_LOG_FATAL, log_level, BT_LOG_TAG, "Failed to release mmap_mutex.");
{
if (pthread_mutex_unlock(&mmap_mutex)) {
BT_LOG_WRITE_CUR_LVL(BT_LOG_FATAL, log_level, BT_LOG_TAG, "Failed to release mmap_mutex.");
/* Remove it. */
if (!g_hash_table_remove(mmap_mappings, addr)) {
BT_LOGF_STR("Failed to remove mapping from hashtable.");
/* Remove it. */
if (!g_hash_table_remove(mmap_mappings, addr)) {
BT_LOGF_STR("Failed to remove mapping from hashtable.");
BT_CTF_ASSERT_PRE_MSG("CTF writer precondition not satisfied; error is:"); \
BT_CTF_ASSERT_PRE_MSG((_fmt), ##__VA_ARGS__); \
BT_CTF_ASSERT_PRE_MSG("Aborting..."); \
BT_CTF_ASSERT_PRE_MSG("CTF writer precondition not satisfied; error is:"); \
BT_CTF_ASSERT_PRE_MSG((_fmt), ##__VA_ARGS__); \
BT_CTF_ASSERT_PRE_MSG("Aborting..."); \
default:
BT_LOGF("Invalid enumeration field type mapping iterator type: "
"type=%d", iter->type);
default:
BT_LOGF("Invalid enumeration field type mapping iterator type: "
"type=%d", iter->type);
break;
default:
BT_LOGF("Unexpected field type ID: id=%d", ft->id);
break;
default:
BT_LOGF("Unexpected field type ID: id=%d", ft->id);
byte_order == BT_CTF_BYTE_ORDER_LITTLE_ENDIAN ?
LITTLE_ENDIAN : BIG_ENDIAN);
} else {
byte_order == BT_CTF_BYTE_ORDER_LITTLE_ENDIAN ?
LITTLE_ENDIAN : BIG_ENDIAN);
} else {
bt_ctf_field_type_common_variant_get_tag_name(type);
break;
default:
bt_ctf_field_type_common_variant_get_tag_name(type);
break;
default:
string = "native";
break;
default:
string = "native";
break;
default:
}
_bt_ctfser_incr_offset(ctfser, size_bits);
}
_bt_ctfser_incr_offset(ctfser, size_bits);
}
_bt_ctfser_incr_offset(ctfser, size_bits);
}
_bt_ctfser_incr_offset(ctfser, size_bits);
#include <stdlib.h>
#include <inttypes.h>
#include "common/macros.h"
#include <stdlib.h>
#include <inttypes.h>
#include "common/macros.h"
+#include "common/common.h"
/*
* Prints the details of an unsatisfied postcondition without
/*
* Prints the details of an unsatisfied postcondition without
BT_ASSERT_POST_MSG("Babeltrace 2 library postcondition not satisfied; error is:"); \
BT_ASSERT_POST_MSG(_fmt, ##__VA_ARGS__); \
BT_ASSERT_POST_MSG("Aborting..."); \
BT_ASSERT_POST_MSG("Babeltrace 2 library postcondition not satisfied; error is:"); \
BT_ASSERT_POST_MSG(_fmt, ##__VA_ARGS__); \
BT_ASSERT_POST_MSG("Aborting..."); \
#include <stdbool.h>
#include <stdlib.h>
#include <inttypes.h>
#include <stdbool.h>
#include <stdlib.h>
#include <inttypes.h>
+#include "common/common.h"
#include "common/macros.h"
/*
#include "common/macros.h"
/*
BT_ASSERT_PRE_MSG("Babeltrace 2 library precondition not satisfied; error is:"); \
BT_ASSERT_PRE_MSG(_fmt, ##__VA_ARGS__); \
BT_ASSERT_PRE_MSG("Aborting..."); \
BT_ASSERT_PRE_MSG("Babeltrace 2 library precondition not satisfied; error is:"); \
BT_ASSERT_PRE_MSG(_fmt, ##__VA_ARGS__); \
BT_ASSERT_PRE_MSG("Aborting..."); \
type_str = "sink";
break;
default:
type_str = "sink";
break;
default:
}
if (comp_class_id->plugin_name->len > 0) {
}
if (comp_class_id->plugin_name->len > 0) {
comp_descr_array = comp_descr_set->sinks;
break;
default:
comp_descr_array = comp_descr_set->sinks;
break;
default:
}
BT_ASSERT(comp_descr_array);
}
BT_ASSERT(comp_descr_array);
method = (method_t) src_cc->methods.output_port_connected;
break;
default:
method = (method_t) src_cc->methods.output_port_connected;
break;
default:
method = (method_t) flt_cc->methods.output_port_connected;
break;
default:
method = (method_t) flt_cc->methods.output_port_connected;
break;
default:
method = (method_t) sink_cc->methods.input_port_connected;
break;
default:
method = (method_t) sink_cc->methods.input_port_connected;
break;
default:
listeners = graph->listeners.source_output_port_added;
break;
default:
listeners = graph->listeners.source_output_port_added;
break;
default:
listeners = graph->listeners.filter_output_port_added;
break;
default:
listeners = graph->listeners.filter_output_port_added;
break;
default:
listeners = graph->listeners.sink_input_port_added;
break;
default:
listeners = graph->listeners.sink_input_port_added;
break;
default:
}
for (i = 0; i < listeners->len; i++) {
}
for (i = 0; i < listeners->len; i++) {
graph->listeners.source_sink_ports_connected;
break;
default:
graph->listeners.source_sink_ports_connected;
break;
default:
graph->listeners.filter_sink_ports_connected;
break;
default:
graph->listeners.filter_sink_ports_connected;
break;
default:
}
for (i = 0; i < listeners->len; i++) {
}
for (i = 0; i < listeners->len; i++) {
/* Finalizing */
BT_LIB_LOGF("Message iterator is already being finalized: "
"%!+i", iterator);
/* Finalizing */
BT_LIB_LOGF("Message iterator is already being finalized: "
"%!+i", iterator);
}
default:
/* Unreachable */
}
default:
/* Unreachable */
}
if (iterator->methods.seek_ns_from_origin &&
}
if (iterator->methods.seek_ns_from_origin &&
}
default:
/* Unreachable */
}
default:
/* Unreachable */
goto end;
default:
/* Unknown non-error status */
goto end;
default:
/* Unknown non-error status */
new_state = BT_SELF_COMPONENT_PORT_INPUT_MESSAGE_ITERATOR_STATE_ENDED;
break;
default:
new_state = BT_SELF_COMPONENT_PORT_INPUT_MESSAGE_ITERATOR_STATE_ENDED;
break;
default:
}
set_self_comp_port_input_msg_iterator_state(iterator, new_state);
}
set_self_comp_port_input_msg_iterator_state(iterator, new_state);
}
BT_ASSERT_DBG(clk_snapshot);
}
BT_ASSERT_DBG(clk_snapshot);
case BT_FUNC_STATUS_END:
goto end;
default:
case BT_FUNC_STATUS_END:
goto end;
default:
}
for (i = 0; i < user_count; i++) {
}
for (i = 0; i < user_count; i++) {
case BT_FUNC_STATUS_AGAIN:
goto end;
default:
case BT_FUNC_STATUS_AGAIN:
goto end;
default:
case BT_FUNC_STATUS_AGAIN:
goto end;
default:
case BT_FUNC_STATUS_AGAIN:
goto end;
default:
prefix, (_prefix2)); \
\
if (snprintf_ret < 0 || snprintf_ret >= TMP_PREFIX_LEN - 1) { \
prefix, (_prefix2)); \
\
if (snprintf_ret < 0 || snprintf_ret >= TMP_PREFIX_LEN - 1) { \
} \
\
tmp_prefix[TMP_PREFIX_LEN - 1] = '\0'; \
} \
\
tmp_prefix[TMP_PREFIX_LEN - 1] = '\0'; \
BUF_APPEND("%s", ", <CUR>");
break;
default:
BUF_APPEND("%s", ", <CUR>");
break;
default:
format_error_cause(buf_ch, extended, prefix, obj);
break;
default:
format_error_cause(buf_ch, extended, prefix, obj);
break;
default:
cur_cc_descr_attr->value.sink_get_supported_mip_versions_method;
break;
default:
cur_cc_descr_attr->value.sink_get_supported_mip_versions_method;
break;
default:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_INITIALIZE_METHOD:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_INITIALIZE_METHOD:
cur_cc_descr_attr->value.sink_initialize_method;
break;
default:
cur_cc_descr_attr->value.sink_initialize_method;
break;
default:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_FINALIZE_METHOD:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_FINALIZE_METHOD:
cur_cc_descr_attr->value.sink_finalize_method;
break;
default:
cur_cc_descr_attr->value.sink_finalize_method;
break;
default:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_QUERY_METHOD:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_QUERY_METHOD:
cur_cc_descr_attr->value.sink_query_method;
break;
default:
cur_cc_descr_attr->value.sink_query_method;
break;
default:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_INPUT_PORT_CONNECTED_METHOD:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_INPUT_PORT_CONNECTED_METHOD:
cur_cc_descr_attr->value.sink_input_port_connected_method;
break;
default:
cur_cc_descr_attr->value.sink_input_port_connected_method;
break;
default:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_OUTPUT_PORT_CONNECTED_METHOD:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_OUTPUT_PORT_CONNECTED_METHOD:
cur_cc_descr_attr->value.filter_output_port_connected_method;
break;
default:
cur_cc_descr_attr->value.filter_output_port_connected_method;
break;
default:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_GRAPH_IS_CONFIGURED_METHOD:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_GRAPH_IS_CONFIGURED_METHOD:
cur_cc_descr_attr->value.sink_graph_is_configured_method;
break;
default:
cur_cc_descr_attr->value.sink_graph_is_configured_method;
break;
default:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_MSG_ITER_INITIALIZE_METHOD:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_MSG_ITER_INITIALIZE_METHOD:
cur_cc_descr_attr->value.filter_msg_iter_initialize_method;
break;
default:
cur_cc_descr_attr->value.filter_msg_iter_initialize_method;
break;
default:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_MSG_ITER_FINALIZE_METHOD:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_MSG_ITER_FINALIZE_METHOD:
cur_cc_descr_attr->value.filter_msg_iter_finalize_method;
break;
default:
cur_cc_descr_attr->value.filter_msg_iter_finalize_method;
break;
default:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_MSG_ITER_SEEK_NS_FROM_ORIGIN_METHOD:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_MSG_ITER_SEEK_NS_FROM_ORIGIN_METHOD:
cur_cc_descr_attr->value.filter_msg_iter_seek_ns_from_origin_method;
break;
default:
cur_cc_descr_attr->value.filter_msg_iter_seek_ns_from_origin_method;
break;
default:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_MSG_ITER_SEEK_BEGINNING_METHOD:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_MSG_ITER_SEEK_BEGINNING_METHOD:
cur_cc_descr_attr->value.filter_msg_iter_seek_beginning_method;
break;
default:
cur_cc_descr_attr->value.filter_msg_iter_seek_beginning_method;
break;
default:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_MSG_ITER_CAN_SEEK_NS_FROM_ORIGIN_METHOD:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_MSG_ITER_CAN_SEEK_NS_FROM_ORIGIN_METHOD:
cur_cc_descr_attr->value.filter_msg_iter_can_seek_ns_from_origin_method;
break;
default:
cur_cc_descr_attr->value.filter_msg_iter_can_seek_ns_from_origin_method;
break;
default:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_MSG_ITER_CAN_SEEK_BEGINNING_METHOD:
}
break;
case BT_PLUGIN_COMPONENT_CLASS_DESCRIPTOR_ATTRIBUTE_TYPE_MSG_ITER_CAN_SEEK_BEGINNING_METHOD:
cur_cc_descr_attr->value.filter_msg_iter_can_seek_beginning_method;
break;
default:
cur_cc_descr_attr->value.filter_msg_iter_can_seek_beginning_method;
break;
default:
*/
#include "common/macros.h"
*/
#include "common/macros.h"
+#include "common/common.h"
#include "lib/graph/component-class.h"
#include <babeltrace2/plugin/plugin-const.h>
#include <babeltrace2/plugin/plugin-dev.h>
#include "lib/graph/component-class.h"
#include <babeltrace2/plugin/plugin-const.h>
#include <babeltrace2/plugin/plugin-dev.h>
comp_classes = plugin->sink_comp_classes;
break;
default:
comp_classes = plugin->sink_comp_classes;
break;
default:
}
/* Set component class's original plugin name */
}
/* Set component class's original plugin name */
field = create_variant_field(fc);
break;
default:
field = create_variant_field(fc);
break;
default:
destroy_variant_field(field);
break;
default:
destroy_variant_field(field);
break;
default:
case BT_FIELD_PATH_SCOPE_EVENT_PAYLOAD:
return ctx->event_payload;
default:
case BT_FIELD_PATH_SCOPE_EVENT_PAYLOAD:
return ctx->event_payload;
default:
state->expecting = INI_EXPECT_MAP_KEY;
goto success;
default:
state->expecting = INI_EXPECT_MAP_KEY;
goto success;
default:
#include <string.h>
#include "common/assert.h"
#include <string.h>
#include "common/assert.h"
+#include "common/common.h"
#include "common/macros.h"
#include "common/uuid.h"
#include "common/macros.h"
#include "common/uuid.h"
weight = 0;
break;
default:
weight = 0;
break;
default:
case BT_MESSAGE_TYPE_MESSAGE_ITERATOR_INACTIVITY:
goto end;
default:
case BT_MESSAGE_TYPE_MESSAGE_ITERATOR_INACTIVITY:
goto end;
default:
g_string_append_printf(str, "[%" PRIu64 "]", elem->array_index);
break;
default:
g_string_append_printf(str, "[%" PRIu64 "]", elem->array_index);
break;
default:
bfcr->user.data);
break;
default:
bfcr->user.data);
break;
default:
bt_bitfield_read_le(buf, uint8_t, at, field_size, v);
break;
default:
bt_bitfield_read_le(buf, uint8_t, at, field_size, v);
break;
default:
}
BT_COMP_LOGT("Read unsigned bit array: cur=%zu, size=%u, "
}
BT_COMP_LOGT("Read unsigned bit array: cur=%zu, size=%u, "
bt_bitfield_read_le(buf, uint8_t, at, field_size, v);
break;
default:
bt_bitfield_read_le(buf, uint8_t, at, field_size, v);
break;
default:
}
BT_COMP_LOGT("Read signed bit array: cur=%zu, size=%u, "
}
BT_COMP_LOGT("Read signed bit array: cur=%zu, size=%u, "
}
default:
/* Only 32-bit and 64-bit fields are supported currently */
}
default:
/* Only 32-bit and 64-bit fields are supported currently */
}
BT_COMP_LOGT("Read floating point number value: bfcr=%p, cur=%zu, val=%f",
}
BT_COMP_LOGT("Read floating point number value: bfcr=%p, cur=%zu, val=%f",
status = read_basic_string_class_and_call(bfcr, true);
break;
default:
status = read_basic_string_class_and_call(bfcr, true);
break;
default:
status = read_basic_string_class_and_call(bfcr, false);
break;
default:
status = read_basic_string_class_and_call(bfcr, false);
break;
default:
env_entry->value.str->str);
break;
default:
env_entry->value.str->str);
break;
default:
case CTF_SCOPE_EVENT_PAYLOAD:
return ctx->scopes.event_payload;
default:
case CTF_SCOPE_EVENT_PAYLOAD:
return ctx->scopes.event_payload;
default:
}
/* Skip absolute path tokens */
}
/* Skip absolute path tokens */
ir_fc = ctf_field_class_variant_to_ir(ctx, (void *) fc);
break;
default:
ir_fc = ctf_field_class_variant_to_ir(ctx, (void *) fc);
break;
default:
fc = ctx->ec->payload_fc;
break;
default:
fc = ctx->ec->payload_fc;
break;
default:
}
if (fc && ctf_field_class_struct_has_immediate_member_in_ir(
}
if (fc && ctf_field_class_struct_has_immediate_member_in_ir(
_ctf_field_class_variant_destroy((void *) fc);
break;
default:
_ctf_field_class_variant_destroy((void *) fc);
break;
default:
field_count = 1;
break;
default:
field_count = 1;
break;
default:
case CTF_SCOPE_EVENT_PAYLOAD:
return "EVENT_PAYLOAD";
default:
case CTF_SCOPE_EVENT_PAYLOAD:
return "EVENT_PAYLOAD";
default:
fc = ec->payload_fc;
break;
default:
fc = ec->payload_fc;
break;
default:
copy_fc = (void *) _ctf_field_class_variant_copy((void *) fc);
break;
default:
copy_fc = (void *) _ctf_field_class_variant_copy((void *) fc);
break;
default:
}
copy_fc->type = fc->type;
}
copy_fc->type = fc->type;
named_fc = ctf_field_class_variant_borrow_option_by_index(
var_fc, i);
} else {
named_fc = ctf_field_class_variant_borrow_option_by_index(
var_fc, i);
} else {
}
if (strcmp(named_fc->name->str, field_name) == 0) {
}
if (strcmp(named_fc->name->str, field_name) == 0) {
default:
BT_COMP_LOGF("Unknown CTF plugin message iterator state: "
"msg-it-addr=%p, state=%d", msg_it, msg_it->state);
default:
BT_COMP_LOGF("Unknown CTF plugin message iterator state: "
"msg-it-addr=%p, state=%d", msg_it, msg_it->state);
}
BT_COMP_LOGT("Handled state: msg-it-addr=%p, status=%s, "
}
BT_COMP_LOGT("Handled state: msg-it-addr=%p, status=%s, "
next_field = bt_field_variant_borrow_selected_option_field(
base_field);
} else {
next_field = bt_field_variant_borrow_selected_option_field(
base_field);
} else {
}
BT_ASSERT_DBG(next_field);
}
BT_ASSERT_DBG(next_field);
msg_it->cur_exp_packet_content_size = value;
break;
default:
msg_it->cur_exp_packet_content_size = value;
break;
default:
/* We should never get to the STATE_DONE state. */
BT_COMP_LOGF("Unexpected state: msg-it-addr=%p, state=%s",
msg_it, state_string(msg_it->state));
/* We should never get to the STATE_DONE state. */
BT_COMP_LOGF("Unexpected state: msg-it-addr=%p, state=%s",
msg_it, state_string(msg_it->state));
_fs_sink_ctf_field_class_variant_destroy((void *) fc);
break;
default:
_fs_sink_ctf_field_class_variant_destroy((void *) fc);
break;
default:
ret = write_variant_field(stream, (void *) fc, field);
break;
default:
ret = write_variant_field(stream, (void *) fc, field);
break;
default:
BT_COMP_LOGF_ERRNO("In trace destruction listener: "
"cannot open metadata file for writing",
": path=\"%s\"", trace->metadata_path->str);
BT_COMP_LOGF_ERRNO("In trace destruction listener: "
"cannot open metadata file for writing",
": path=\"%s\"", trace->metadata_path->str);
}
len = fwrite(tsdl->str, sizeof(*tsdl->str), tsdl->len, fh);
}
len = fwrite(tsdl->str, sizeof(*tsdl->str), tsdl->len, fh);
BT_COMP_LOGF_ERRNO("In trace destruction listener: "
"cannot write metadata file",
": path=\"%s\"", trace->metadata_path->str);
BT_COMP_LOGF_ERRNO("In trace destruction listener: "
"cannot write metadata file",
": path=\"%s\"", trace->metadata_path->str);
}
if (!trace->fs_sink->quiet) {
}
if (!trace->fs_sink->quiet) {
fs_sink, msg);
break;
default:
fs_sink, msg);
break;
default:
}
BT_MESSAGE_PUT_REF_AND_RESET(msgs[i]);
}
BT_MESSAGE_PUT_REF_AND_RESET(msgs[i]);
g_string_append(ctx->tsdl, "x");
break;
default:
g_string_append(ctx->tsdl, "x");
break;
default:
}
g_string_append_c(ctx->tsdl, ';');
}
g_string_append_c(ctx->tsdl, ';');
append_variant_field_class(ctx, (void *) fc);
break;
default:
append_variant_field_class(ctx, (void *) fc);
break;
default:
level = 14;
break;
default:
level = 14;
break;
default:
}
g_string_append_printf(ctx->tsdl, "%u;\n", level);
}
g_string_append_printf(ctx->tsdl, "%u;\n", level);
* This is checked in
* translate_trace_trace_ir_to_ctf_ir().
*/
* This is checked in
* translate_trace_trace_ir_to_ctf_ir().
*/
}
g_string_append(tsdl, ";\n");
}
g_string_append(tsdl, ";\n");
tgt_fc = ctx->cur_ec->payload_fc;
break;
default:
tgt_fc = ctx->cur_ec->payload_fc;
break;
default:
g_string_assign(tgt_field_ref, "event.fields");
break;
default:
g_string_assign(tgt_field_ref, "event.fields");
break;
default:
bt_field_path_item_index_get_index(fp_item));
break;
default:
bt_field_path_item_index_get_index(fp_item));
break;
default:
BT_FIELD_CLASS_TYPE_VARIANT)) {
ret = translate_variant_field_class(ctx);
} else {
BT_FIELD_CLASS_TYPE_VARIANT)) {
ret = translate_variant_field_class(ctx);
} else {
* medium-specific; there is nothing for the user to do
* and it should have been handled upstream.
*/
* medium-specific; there is nothing for the user to do
* and it should have been handled upstream.
*/
case BT_MSG_ITER_STATUS_INVAL:
case BT_MSG_ITER_STATUS_ERROR:
default:
case BT_MSG_ITER_STATUS_INVAL:
case BT_MSG_ITER_STATUS_ERROR:
default:
ds_file->msg_iter, cs);
break;
default:
ds_file->msg_iter, cs);
break;
default:
}
if (iter_status) {
ret = -1;
}
if (iter_status) {
ret = -1;
case LTTNG_LIVE_ITERATOR_STATUS_UNSUPPORTED:
return "LTTNG_LIVE_ITERATOR_STATUS_UNSUPPORTED";
default:
case LTTNG_LIVE_ITERATOR_STATUS_UNSUPPORTED:
return "LTTNG_LIVE_ITERATOR_STATUS_UNSUPPORTED";
default:
case LTTNG_LIVE_STREAM_ACTIVE_NO_DATA:
/* Invalid state. */
BT_COMP_LOGF("Unexpected stream state \"ACTIVE_NO_DATA\"");
case LTTNG_LIVE_STREAM_ACTIVE_NO_DATA:
/* Invalid state. */
BT_COMP_LOGF("Unexpected stream state \"ACTIVE_NO_DATA\"");
case LTTNG_LIVE_STREAM_QUIESCENT_NO_DATA:
/* Invalid state. */
BT_COMP_LOGF("Unexpected stream state \"QUIESCENT_NO_DATA\"");
case LTTNG_LIVE_STREAM_QUIESCENT_NO_DATA:
/* Invalid state. */
BT_COMP_LOGF("Unexpected stream state \"QUIESCENT_NO_DATA\"");
case LTTNG_LIVE_STREAM_EOF:
break;
}
case LTTNG_LIVE_STREAM_EOF:
break;
}
put_messages(msgs, *count);
break;
default:
put_messages(msgs, *count);
break;
default:
lttng_live->params.url->str);
break;
default:
lttng_live->params.url->str);
break;
default:
case LTTNG_LIVE_GET_ONE_METADATA_STATUS_ERROR:
goto error;
default:
case LTTNG_LIVE_GET_ONE_METADATA_STATUS_ERROR:
goto error;
default:
out_message = handle_discarded_packets_message(debug_it, in_message);
break;
default:
out_message = handle_discarded_packets_message(debug_it, in_message);
break;
default:
#include <stdint.h>
#include "common/assert.h"
#include <stdint.h>
#include "common/assert.h"
+#include "common/common.h"
#include "trace-ir-data-copy.h"
#include "trace-ir-data-copy.h"
out_trace, value_name,
bt_value_string_get(value));
} else {
out_trace, value_name,
bt_value_string_get(value));
} else {
}
if (set_env_status != BT_TRACE_SET_ENVIRONMENT_ENTRY_STATUS_OK) {
}
if (set_env_status != BT_TRACE_SET_ENVIRONMENT_ENTRY_STATUS_OK) {
}
BT_COMP_LOGT("Copied content of field: in-f-addr=%p, out-f-addr=%p",
}
BT_COMP_LOGT("Copied content of field: in-f-addr=%p, out-f-addr=%p",
curr_fc);
break;
} else {
curr_fc);
break;
} else {
fc_resolving_ctx->event_payload);
break;
default:
fc_resolving_ctx->event_payload);
break;
default:
status = field_class_variant_copy(md_maps,
in_field_class, out_field_class);
} else {
status = field_class_variant_copy(md_maps,
in_field_class, out_field_class);
} else {
status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR;
break;
default:
status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR;
break;
default:
}
details_comp = create_details_comp(comp);
}
details_comp = create_details_comp(comp);
ret = BT_COMPONENT_CLASS_SINK_CONSUME_METHOD_STATUS_MEMORY_ERROR;
goto end;
default:
ret = BT_COMPONENT_CLASS_SINK_CONSUME_METHOD_STATUS_MEMORY_ERROR;
goto end;
default:
}
sprintf(buf_start, spec, value);
}
sprintf(buf_start, spec, value);
}
sprintf(buf_start, spec, abs_value);
}
sprintf(buf_start, spec, abs_value);
}
g_ptr_array_free(keys, TRUE);
}
g_ptr_array_free(keys, TRUE);
write_uint_prop_value(ctx, 16);
break;
default:
write_uint_prop_value(ctx, 16);
break;
default:
write_str_prop_value(ctx, "Event payload");
break;
default:
write_str_prop_value(ctx, "Event payload");
break;
default:
}
g_string_append(ctx->str, ": ");
}
g_string_append(ctx->str, ": ");
write_str_prop_value(ctx, "<current>");
break;
default:
write_str_prop_value(ctx, "<current>");
break;
default:
type = "Variant (signed integer selector)";
break;
default:
type = "Variant (signed integer selector)";
break;
default:
}
g_string_append_printf(ctx->str, "%s%s%s",
}
g_string_append_printf(ctx->str, "%s%s%s",
ll_str = "Debug";
break;
default:
ll_str = "Debug";
break;
default:
}
write_str_prop_line(ctx, "Log level", ll_str);
}
write_str_prop_line(ctx, "Log level", ll_str);
fmt_base = 16;
break;
default:
fmt_base = 16;
break;
default:
}
if (bt_field_class_type_is(fc_type,
}
if (bt_field_class_type_is(fc_type,
bt_field_variant_borrow_selected_option_field_const(
field), NULL);
} else {
bt_field_variant_borrow_selected_option_field_const(
field), NULL);
} else {
write_str_prop_value(ctx,
bt_value_string_get(value));
} else {
write_str_prop_value(ctx,
bt_value_string_get(value));
} else {
ret = write_discarded_packets_message(&ctx, msg);
break;
default:
ret = write_discarded_packets_message(&ctx, msg);
break;
default:
status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR;
break;
default:
status = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR;
break;
default:
pretty->options.print_scope_field_names = false;
break;
default:
pretty->options.print_scope_field_names = false;
break;
default:
}
apply_one_bool_if_specified("name-payload", params,
}
apply_one_bool_if_specified("name-payload", params,
pretty->options.print_callsite_field = false;
break;
default:
pretty->options.print_callsite_field = false;
break;
default:
}
apply_one_bool_if_specified("field-trace", params,
}
apply_one_bool_if_specified("field-trace", params,
&label_array, &label_count);
break;
default:
&label_array, &label_count);
break;
default:
elem_type = "packet";
break;
default:
elem_type = "packet";
break;
default:
}
print_discarded_elements_msg(pretty, stream, begin, end,
}
print_discarded_elements_msg(pretty, stream, begin, end,
BT_COMP_LOGF("Unexpected clock class expectation: "
"expectation-code=%d",
muxer_msg_iter->clock_class_expectation);
BT_COMP_LOGF("Unexpected clock class expectation: "
"expectation-code=%d",
muxer_msg_iter->clock_class_expectation);
status = BT_COMPONENT_CLASS_MESSAGE_ITERATOR_NEXT_METHOD_STATUS_END;
break;
default:
status = BT_COMPONENT_CLASS_MESSAGE_ITERATOR_NEXT_METHOD_STATUS_END;
break;
default:
ret = BT_FUNC_STATUS_ERROR;
goto end;
default:
ret = BT_FUNC_STATUS_ERROR;
goto end;
default:
$(top_builddir)/src/param-parse/libbabeltrace2-param-parse.la \
$(top_builddir)/src/plugins/common/param-validation/libbabeltrace2-param-validation.la \
$(top_builddir)/src/lib/libbabeltrace2.la \
$(top_builddir)/src/param-parse/libbabeltrace2-param-parse.la \
$(top_builddir)/src/plugins/common/param-validation/libbabeltrace2-param-validation.la \
$(top_builddir)/src/lib/libbabeltrace2.la \
+ $(top_builddir)/src/common/libbabeltrace2-common.la \
+ $(top_builddir)/src/logging/libbabeltrace2-logging.la \
$(top_builddir)/tests/utils/tap/libtap.la
$(top_builddir)/tests/utils/tap/libtap.la