X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=blobdiff_plain;f=lib%2Fctf-ir%2Fclock-class.c;h=e4d5341925c0fa8e9b0f7dc822f4049affdfe053;hp=730f8f34dab53f98f2d677a112ec89d37b79ee8f;hb=44c440bc5fe8219cc17d1b786d91fd83c4c9860a;hpb=93dda9014cf4c4f5365a6af73594a543ec642cb9 diff --git a/lib/ctf-ir/clock-class.c b/lib/ctf-ir/clock-class.c index 730f8f34..e4d53419 100644 --- a/lib/ctf-ir/clock-class.c +++ b/lib/ctf-ir/clock-class.c @@ -29,101 +29,89 @@ #define BT_LOG_TAG "CLOCK-CLASS" #include +#include #include #include #include -#include +#include #include #include #include #include #include #include +#include -static -void bt_clock_class_destroy(struct bt_object *obj); - -BT_HIDDEN -bt_bool bt_clock_class_is_valid(struct bt_clock_class *clock_class) -{ - return clock_class && clock_class->name; -} +#define BT_ASSERT_PRE_CLOCK_CLASS_HOT(_cc) \ + BT_ASSERT_PRE_HOT((_cc), "Clock class", ": %!+K", (_cc)) -int bt_clock_class_set_name(struct bt_clock_class *clock_class, - const char *name) +static +void destroy_clock_class(struct bt_object *obj) { - int ret = 0; - - if (!clock_class) { - BT_LOGW_STR("Invalid parameter: clock class is NULL."); - ret = -1; - goto end; - } + struct bt_clock_class *clock_class = (void *) obj; - if (clock_class->frozen) { - BT_LOGW("Invalid parameter: clock class is frozen: addr=%p, name=\"%s\"", - clock_class, bt_clock_class_get_name(clock_class)); - ret = -1; - goto end; - } + BT_LIB_LOGD("Destroying clock class: %!+K", clock_class); - if (!bt_identifier_is_valid(name)) { - BT_LOGE("Clock class's name is not a valid CTF identifier: " - "addr=%p, name=\"%s\"", - clock_class, name); - ret = -1; - goto end; + if (clock_class->name.str) { + g_string_free(clock_class->name.str, TRUE); } - if (clock_class->name) { - g_string_assign(clock_class->name, name); - } else { - clock_class->name = g_string_new(name); - if (!clock_class->name) { - BT_LOGE_STR("Failed to allocate a GString."); - ret = -1; - goto end; - } + if (clock_class->description.str) { + g_string_free(clock_class->description.str, TRUE); } - BT_LOGV("Set clock class's name: addr=%p, name=\"%s\"", - clock_class, name); - -end: - return ret; + bt_object_pool_finalize(&clock_class->cv_pool); + g_free(clock_class); } static -bool validate_freq(struct bt_clock_class *clock_class, - const char *name, uint64_t freq) +void free_clock_value(struct bt_clock_value *clock_value, + struct bt_clock_class *clock_class) { - bool is_valid = true; + bt_clock_value_destroy(clock_value); +} - if (freq == -1ULL || freq == 0) { - BT_LOGW("Invalid parameter: frequency is invalid: " - "addr=%p, name=\"%s\", freq=%" PRIu64, - clock_class, name, freq); - is_valid = false; +static inline +void set_base_offset(struct bt_clock_class *clock_class) +{ + uint64_t offset_cycles_ns; + + /* Initialize nanosecond timestamp to clock's offset in seconds */ + if (clock_class->offset_seconds <= (INT64_MIN / INT64_C(1000000000) - 1) || + clock_class->offset_seconds >= (INT64_MAX / INT64_C(1000000000)) - 1) { + /* + * Overflow: offset in seconds converted to nanoseconds + * is outside the int64_t range. We also subtract 1 here + * to leave "space" for the offset in cycles converted + * to nanoseconds (which is always less than 1 second by + * contract). + */ + clock_class->base_offset.overflows = true; goto end; } + /* Offset (seconds) to nanoseconds */ + clock_class->base_offset.value_ns = clock_class->offset_seconds * + INT64_C(1000000000); + + /* Add offset in cycles */ + BT_ASSERT(clock_class->offset_cycles < clock_class->frequency); + offset_cycles_ns = bt_util_ns_from_value(clock_class->frequency, + clock_class->offset_cycles); + BT_ASSERT(offset_cycles_ns < 1000000000); + clock_class->base_offset.value_ns += (int64_t) offset_cycles_ns; + clock_class->base_offset.overflows = false; + end: - return is_valid; + return; } -struct bt_clock_class *bt_clock_class_create(const char *name, - uint64_t freq) +struct bt_clock_class *bt_clock_class_create(void) { int ret; struct bt_clock_class *clock_class = NULL; - BT_LOGD("Creating default clock class object: name=\"%s\"", - name); - - if (!validate_freq(NULL, name, freq)) { - /* validate_freq() logs errors */ - goto error; - } + BT_LOGD_STR("Creating default clock class object"); clock_class = g_new0(struct bt_clock_class, 1); if (!clock_class) { @@ -131,879 +119,211 @@ struct bt_clock_class *bt_clock_class_create(const char *name, goto error; } - clock_class->precision = 1; - clock_class->frequency = freq; - bt_object_init(clock_class, bt_clock_class_destroy); - - if (name) { - ret = bt_clock_class_set_name(clock_class, name); - if (ret) { - BT_LOGE("Cannot set clock class's name: " - "addr=%p, name=\"%s\"", - clock_class, name); - goto error; - } + bt_object_init_shared(&clock_class->base, destroy_clock_class); + clock_class->name.str = g_string_new(NULL); + if (!clock_class->name.str) { + BT_LOGE_STR("Failed to allocate a GString."); + goto error; } - BT_LOGD("Created clock class object: addr=%p, name=\"%s\"", - clock_class, name); - return clock_class; -error: - BT_PUT(clock_class); - return clock_class; -} - -const char *bt_clock_class_get_name(struct bt_clock_class *clock_class) -{ - const char *ret = NULL; - - if (!clock_class) { - BT_LOGW_STR("Invalid parameter: clock class is NULL."); - goto end; + clock_class->description.str = g_string_new(NULL); + if (!clock_class->description.str) { + BT_LOGE_STR("Failed to allocate a GString."); + goto error; } - if (clock_class->name) { - ret = clock_class->name->str; + clock_class->frequency = UINT64_C(1000000000); + clock_class->is_absolute = BT_TRUE; + set_base_offset(clock_class); + ret = bt_object_pool_initialize(&clock_class->cv_pool, + (bt_object_pool_new_object_func) bt_clock_value_new, + (bt_object_pool_destroy_object_func) + free_clock_value, + clock_class); + if (ret) { + BT_LOGE("Failed to initialize clock value pool: ret=%d", + ret); + goto error; } + BT_LIB_LOGD("Created clock class object: %!+K", clock_class); + goto end; + +error: + BT_PUT(clock_class); + end: - return ret; + return clock_class; } -const char *bt_clock_class_get_description( +const char *bt_clock_class_get_name( struct bt_clock_class *clock_class) { - const char *ret = NULL; + BT_ASSERT_PRE_NON_NULL(clock_class, "Clock class"); + return clock_class->name.value; +} - if (!clock_class) { - BT_LOGW_STR("Invalid parameter: clock class is NULL."); - goto end; - } +int bt_clock_class_set_name(struct bt_clock_class *clock_class, + const char *name) +{ + BT_ASSERT_PRE_NON_NULL(clock_class, "Clock class"); + BT_ASSERT_PRE_NON_NULL(name, "Name"); + BT_ASSERT_PRE_CLOCK_CLASS_HOT(clock_class); + g_string_assign(clock_class->name.str, name); + clock_class->name.value = clock_class->name.str->str; + BT_LIB_LOGV("Set clock class's name: %!+K", clock_class); + return 0; +} - if (clock_class->description) { - ret = clock_class->description->str; - } -end: - return ret; +const char *bt_clock_class_get_description(struct bt_clock_class *clock_class) +{ + BT_ASSERT_PRE_NON_NULL(clock_class, "Clock class"); + return clock_class->description.value; } int bt_clock_class_set_description(struct bt_clock_class *clock_class, - const char *desc) + const char *descr) { - int ret = 0; - - if (!clock_class || !desc) { - BT_LOGW("Invalid parameter: clock class or description is NULL: " - "clock-class-addr=%p, name=\"%s\", desc-addr=%p", - clock_class, bt_clock_class_get_name(clock_class), - desc); - ret = -1; - goto end; - } - - if (clock_class->frozen) { - BT_LOGW("Invalid parameter: clock class is frozen: addr=%p, name=\"%s\"", - clock_class, bt_clock_class_get_name(clock_class)); - ret = -1; - goto end; - } - - clock_class->description = g_string_new(desc); - ret = clock_class->description ? 0 : -1; - BT_LOGV("Set clock class's description: addr=%p, " - "name=\"%s\", desc=\"%s\"", - clock_class, bt_clock_class_get_name(clock_class), desc); -end: - return ret; + BT_ASSERT_PRE_NON_NULL(clock_class, "Clock class"); + BT_ASSERT_PRE_NON_NULL(descr, "Description"); + BT_ASSERT_PRE_CLOCK_CLASS_HOT(clock_class); + g_string_assign(clock_class->description.str, descr); + clock_class->description.value = clock_class->description.str->str; + BT_LIB_LOGV("Set clock class's description: %!+K", + clock_class); + return 0; } -uint64_t bt_clock_class_get_frequency( - struct bt_clock_class *clock_class) +uint64_t bt_clock_class_get_frequency(struct bt_clock_class *clock_class) { - uint64_t ret = -1ULL; - - if (!clock_class) { - BT_LOGW_STR("Invalid parameter: clock class is NULL."); - goto end; - } - - ret = clock_class->frequency; -end: - return ret; + BT_ASSERT_PRE_NON_NULL(clock_class, "Clock class"); + return clock_class->frequency; } int bt_clock_class_set_frequency(struct bt_clock_class *clock_class, - uint64_t freq) + uint64_t frequency) { - int ret = 0; - - if (!clock_class) { - BT_LOGW("Invalid parameter: clock class is NULL or frequency is invalid: " - "addr=%p, name=\"%s\"", - clock_class, bt_clock_class_get_name(clock_class)); - ret = -1; - goto end; - } - - if (!validate_freq(clock_class, bt_clock_class_get_name(clock_class), - freq)) { - /* validate_freq() logs errors */ - goto end; - } - - if (clock_class->frozen) { - BT_LOGW("Invalid parameter: clock class is frozen: addr=%p, name=\"%s\"", - clock_class, bt_clock_class_get_name(clock_class)); - ret = -1; - goto end; - } - - clock_class->frequency = freq; - BT_LOGV("Set clock class's frequency: addr=%p, name=\"%s\", freq=%" PRIu64, - clock_class, bt_clock_class_get_name(clock_class), freq); -end: - return ret; + BT_ASSERT_PRE_NON_NULL(clock_class, "Clock class"); + BT_ASSERT_PRE_CLOCK_CLASS_HOT(clock_class); + BT_ASSERT_PRE(frequency != UINT64_C(-1) && frequency != 0, + "Invalid frequency: %![cc-]+K, new-freq=%" PRIu64, + clock_class, frequency); + BT_ASSERT_PRE(clock_class->offset_cycles < frequency, + "Offset (cycles) is greater than clock class's frequency: " + "%![cc-]+K, new-freq=%" PRIu64, clock_class, frequency); + clock_class->frequency = frequency; + set_base_offset(clock_class); + BT_LIB_LOGV("Set clock class's frequency: %!+K", clock_class); + return 0; } uint64_t bt_clock_class_get_precision(struct bt_clock_class *clock_class) { - uint64_t ret = -1ULL; - - if (!clock_class) { - BT_LOGW_STR("Invalid parameter: clock class is NULL."); - goto end; - } - - ret = clock_class->precision; -end: - return ret; + BT_ASSERT_PRE_NON_NULL(clock_class, "Clock class"); + return clock_class->precision; } int bt_clock_class_set_precision(struct bt_clock_class *clock_class, uint64_t precision) { - int ret = 0; - - if (!clock_class || precision == -1ULL) { - BT_LOGW("Invalid parameter: clock class is NULL or precision is invalid: " - "addr=%p, name=\"%s\", precision=%" PRIu64, - clock_class, bt_clock_class_get_name(clock_class), - precision); - ret = -1; - goto end; - } - - if (clock_class->frozen) { - BT_LOGW("Invalid parameter: clock class is frozen: addr=%p, name=\"%s\"", - clock_class, bt_clock_class_get_name(clock_class)); - ret = -1; - goto end; - } - + BT_ASSERT_PRE_NON_NULL(clock_class, "Clock class"); + BT_ASSERT_PRE_CLOCK_CLASS_HOT(clock_class); + BT_ASSERT_PRE(precision != UINT64_C(-1), + "Invalid precision: %![cc-]+K, new-precision=%" PRIu64, + clock_class, precision); clock_class->precision = precision; - BT_LOGV("Set clock class's precision: addr=%p, name=\"%s\", precision=%" PRIu64, - clock_class, bt_clock_class_get_name(clock_class), - precision); -end: - return ret; + BT_LIB_LOGV("Set clock class's precision: %!+K", clock_class); + return 0; } -int bt_clock_class_get_offset_s(struct bt_clock_class *clock_class, - int64_t *offset_s) +void bt_clock_class_get_offset(struct bt_clock_class *clock_class, + int64_t *seconds, uint64_t *cycles) { - int ret = 0; - - if (!clock_class || !offset_s) { - BT_LOGW("Invalid parameter: clock class or offset pointer is NULL: " - "clock-class-addr=%p, name=\"%s\", offset-addr=%p", - clock_class, bt_clock_class_get_name(clock_class), - offset_s); - ret = -1; - goto end; - } - - *offset_s = clock_class->offset_s; -end: - return ret; + BT_ASSERT_PRE_NON_NULL(clock_class, "Clock class"); + BT_ASSERT_PRE_NON_NULL(seconds, "Seconds (output)"); + BT_ASSERT_PRE_NON_NULL(cycles, "Cycles (output)"); + *seconds = clock_class->offset_seconds; + *cycles = clock_class->offset_cycles; } -int bt_clock_class_set_offset_s(struct bt_clock_class *clock_class, - int64_t offset_s) +int bt_clock_class_set_offset(struct bt_clock_class *clock_class, + int64_t seconds, uint64_t cycles) { - int ret = 0; - - if (!clock_class) { - BT_LOGW_STR("Invalid parameter: clock class is NULL."); - ret = -1; - goto end; - } - - if (clock_class->frozen) { - BT_LOGW("Invalid parameter: clock class is frozen: addr=%p, name=\"%s\"", - clock_class, bt_clock_class_get_name(clock_class)); - ret = -1; - goto end; - } - - clock_class->offset_s = offset_s; - BT_LOGV("Set clock class's offset (seconds): " - "addr=%p, name=\"%s\", offset-s=%" PRId64, - clock_class, bt_clock_class_get_name(clock_class), - offset_s); -end: - return ret; -} - -int bt_clock_class_get_offset_cycles(struct bt_clock_class *clock_class, - int64_t *offset) -{ - int ret = 0; - - if (!clock_class || !offset) { - BT_LOGW("Invalid parameter: clock class or offset pointer is NULL: " - "clock-class-addr=%p, name=\"%s\", offset-addr=%p", - clock_class, bt_clock_class_get_name(clock_class), - offset); - ret = -1; - goto end; - } - - *offset = clock_class->offset; -end: - return ret; -} - -int bt_clock_class_set_offset_cycles(struct bt_clock_class *clock_class, - int64_t offset) -{ - int ret = 0; - - if (!clock_class) { - BT_LOGW_STR("Invalid parameter: clock class is NULL."); - ret = -1; - goto end; - } - - if (clock_class->frozen) { - BT_LOGW("Invalid parameter: clock class is frozen: addr=%p, name=\"%s\"", - clock_class, bt_clock_class_get_name(clock_class)); - ret = -1; - goto end; - } - - clock_class->offset = offset; - BT_LOGV("Set clock class's offset (cycles): addr=%p, name=\"%s\", offset-cycles=%" PRId64, - clock_class, bt_clock_class_get_name(clock_class), offset); -end: - return ret; + BT_ASSERT_PRE_NON_NULL(clock_class, "Clock class"); + BT_ASSERT_PRE_CLOCK_CLASS_HOT(clock_class); + BT_ASSERT_PRE(cycles < clock_class->frequency, + "Offset (cycles) is greater than clock class's frequency: " + "%![cc-]+K, new-offset-cycles=%" PRIu64, clock_class, cycles); + clock_class->offset_seconds = seconds; + clock_class->offset_cycles = cycles; + set_base_offset(clock_class); + BT_LIB_LOGV("Set clock class's offset: %!+K", clock_class); + return 0; } bt_bool bt_clock_class_is_absolute(struct bt_clock_class *clock_class) { - int ret = -1; - - if (!clock_class) { - BT_LOGW_STR("Invalid parameter: clock class is NULL."); - goto end; - } - - ret = clock_class->absolute; -end: - return ret; + BT_ASSERT_PRE_NON_NULL(clock_class, "Clock class"); + return (bool) clock_class->is_absolute; } int bt_clock_class_set_is_absolute(struct bt_clock_class *clock_class, bt_bool is_absolute) { - int ret = 0; - - if (!clock_class) { - BT_LOGW_STR("Invalid parameter: clock class is NULL."); - ret = -1; - goto end; - } - - if (clock_class->frozen) { - BT_LOGW("Invalid parameter: clock class is frozen: addr=%p, name=\"%s\"", - clock_class, bt_clock_class_get_name(clock_class)); - ret = -1; - goto end; - } - - clock_class->absolute = !!is_absolute; - BT_LOGV("Set clock class's absolute flag: addr=%p, name=\"%s\", is-absolute=%d", - clock_class, bt_clock_class_get_name(clock_class), - is_absolute); -end: - return ret; + BT_ASSERT_PRE_NON_NULL(clock_class, "Clock class"); + BT_ASSERT_PRE_CLOCK_CLASS_HOT(clock_class); + clock_class->is_absolute = (bool) is_absolute; + BT_LIB_LOGV("Set clock class's absolute property: %!+K", + clock_class); + return 0; } -const unsigned char *bt_clock_class_get_uuid( - struct bt_clock_class *clock_class) +bt_uuid bt_clock_class_get_uuid(struct bt_clock_class *clock_class) { - const unsigned char *ret; - - if (!clock_class) { - BT_LOGW_STR("Invalid parameter: clock class is NULL."); - ret = NULL; - goto end; - } - - if (!clock_class->uuid_set) { - BT_LOGV("Clock class's UUID is not set: addr=%p, name=\"%s\"", - clock_class, bt_clock_class_get_name(clock_class)); - ret = NULL; - goto end; - } - - ret = clock_class->uuid; -end: - return ret; + BT_ASSERT_PRE_NON_NULL(clock_class, "Clock class"); + return clock_class->uuid.value; } int bt_clock_class_set_uuid(struct bt_clock_class *clock_class, - const unsigned char *uuid) -{ - int ret = 0; - - if (!clock_class || !uuid) { - BT_LOGW("Invalid parameter: clock class or UUID is NULL: " - "clock-class-addr=%p, name=\"%s\", uuid-addr=%p", - clock_class, bt_clock_class_get_name(clock_class), - uuid); - ret = -1; - goto end; - } - - if (clock_class->frozen) { - BT_LOGW("Invalid parameter: clock class is frozen: addr=%p, name=\"%s\"", - clock_class, bt_clock_class_get_name(clock_class)); - ret = -1; - goto end; - } - - memcpy(clock_class->uuid, uuid, BABELTRACE_UUID_LEN); - clock_class->uuid_set = 1; - BT_LOGV("Set clock class's UUID: addr=%p, name=\"%s\", " - "uuid=\"%02x%02x%02x%02x-%02x%02x-%02x%02x-%02x%02x-%02x%02x%02x%02x%02x%02x\"", - clock_class, bt_clock_class_get_name(clock_class), - (unsigned int) uuid[0], - (unsigned int) uuid[1], - (unsigned int) uuid[2], - (unsigned int) uuid[3], - (unsigned int) uuid[4], - (unsigned int) uuid[5], - (unsigned int) uuid[6], - (unsigned int) uuid[7], - (unsigned int) uuid[8], - (unsigned int) uuid[9], - (unsigned int) uuid[10], - (unsigned int) uuid[11], - (unsigned int) uuid[12], - (unsigned int) uuid[13], - (unsigned int) uuid[14], - (unsigned int) uuid[15]); -end: - return ret; -} - -static uint64_t ns_from_value(uint64_t frequency, uint64_t value) + bt_uuid uuid) { - uint64_t ns; - - if (frequency == 1000000000) { - ns = value; - } else { - double dblres = ((1e9 * (double) value) / (double) frequency); - - if (dblres >= (double) UINT64_MAX) { - /* Overflows uint64_t */ - ns = -1ULL; - } else { - ns = (uint64_t) dblres; - } - } - - return ns; + BT_ASSERT_PRE_NON_NULL(clock_class, "Clock class"); + BT_ASSERT_PRE_NON_NULL(uuid, "UUID"); + BT_ASSERT_PRE_CLOCK_CLASS_HOT(clock_class); + memcpy(clock_class->uuid.uuid, uuid, BABELTRACE_UUID_LEN); + clock_class->uuid.value = clock_class->uuid.uuid; + BT_LIB_LOGV("Set clock class's UUID: %!+K", clock_class); + return 0; } BT_HIDDEN -void bt_clock_class_freeze(struct bt_clock_class *clock_class) -{ - if (!clock_class) { - BT_LOGW_STR("Invalid parameter: clock class is NULL."); - return; - } - - if (!clock_class->frozen) { - BT_LOGD("Freezing clock class: addr=%p, name=\"%s\"", - clock_class, bt_clock_class_get_name(clock_class)); - clock_class->frozen = 1; - } -} - -BT_HIDDEN -void bt_clock_class_serialize(struct bt_clock_class *clock_class, - struct metadata_context *context) -{ - unsigned char *uuid; - - BT_LOGD("Serializing clock class's metadata: clock-class-addr=%p, " - "name=\"%s\", metadata-context-addr=%p", clock_class, - bt_clock_class_get_name(clock_class), context); - - if (!clock_class || !context) { - BT_LOGW("Invalid parameter: clock class or metadata context is NULL: " - "clock-class-addr=%p, name=\"%s\", metadata-context-addr=%p", - clock_class, bt_clock_class_get_name(clock_class), - context); - return; - } - - uuid = clock_class->uuid; - g_string_append(context->string, "clock {\n"); - g_string_append_printf(context->string, "\tname = %s;\n", - clock_class->name->str); - - if (clock_class->uuid_set) { - g_string_append_printf(context->string, - "\tuuid = \"%02x%02x%02x%02x-%02x%02x-%02x%02x-%02x%02x-%02x%02x%02x%02x%02x%02x\";\n", - uuid[0], uuid[1], uuid[2], uuid[3], - uuid[4], uuid[5], uuid[6], uuid[7], - uuid[8], uuid[9], uuid[10], uuid[11], - uuid[12], uuid[13], uuid[14], uuid[15]); - } - - if (clock_class->description) { - g_string_append_printf(context->string, "\tdescription = \"%s\";\n", - clock_class->description->str); - } - - g_string_append_printf(context->string, "\tfreq = %" PRIu64 ";\n", - clock_class->frequency); - g_string_append_printf(context->string, "\tprecision = %" PRIu64 ";\n", - clock_class->precision); - g_string_append_printf(context->string, "\toffset_s = %" PRIu64 ";\n", - clock_class->offset_s); - g_string_append_printf(context->string, "\toffset = %" PRIu64 ";\n", - clock_class->offset); - g_string_append_printf(context->string, "\tabsolute = %s;\n", - clock_class->absolute ? "true" : "false"); - g_string_append(context->string, "};\n\n"); -} - -static -void bt_clock_class_destroy(struct bt_object *obj) +void _bt_clock_class_freeze(struct bt_clock_class *clock_class) { - struct bt_clock_class *clock_class; - - clock_class = container_of(obj, struct bt_clock_class, base); - BT_LOGD("Destroying clock class: addr=%p, name=\"%s\"", - obj, bt_clock_class_get_name(clock_class)); - if (clock_class->name) { - g_string_free(clock_class->name, TRUE); - } - if (clock_class->description) { - g_string_free(clock_class->description, TRUE); - } + BT_ASSERT(clock_class); - g_free(clock_class); -} - -static -void bt_clock_value_destroy(struct bt_object *obj) -{ - struct bt_clock_value *value; - - if (!obj) { + if (clock_class->frozen) { return; } - value = container_of(obj, struct bt_clock_value, base); - BT_LOGD("Destroying clock value: addr=%p, clock-class-addr=%p, " - "clock-class-name=\"%s\"", obj, value->clock_class, - bt_clock_class_get_name(value->clock_class)); - bt_put(value->clock_class); - g_free(value); + BT_LIB_LOGD("Freezing clock class: %!+K", clock_class); + clock_class->frozen = 1; } -static -void set_ns_from_epoch(struct bt_clock_value *clock_value) +int bt_clock_class_cycles_to_ns_from_origin(struct bt_clock_class *clock_class, + uint64_t cycles, int64_t *ns) { - struct bt_clock_class *clock_class = clock_value->clock_class; - int64_t diff; - int64_t s_ns; - uint64_t u_ns; - uint64_t cycles; - - /* Initialize nanosecond timestamp to clock's offset in seconds */ - if (clock_class->offset_s <= (INT64_MIN / 1000000000) || - clock_class->offset_s >= (INT64_MAX / 1000000000)) { - /* - * Overflow: offset in seconds converted to nanoseconds - * is outside the int64_t range. - */ - clock_value->ns_from_epoch_overflows = true; - goto end; - } - - clock_value->ns_from_epoch = clock_class->offset_s * (int64_t) 1000000000; - - /* Add offset in cycles */ - if (clock_class->offset < 0) { - cycles = (uint64_t) (-clock_class->offset); - } else { - cycles = (uint64_t) clock_class->offset; - } - - u_ns = ns_from_value(clock_class->frequency, cycles); - - if (u_ns == -1ULL || u_ns >= INT64_MAX) { - /* - * Overflow: offset in cycles converted to nanoseconds - * is outside the int64_t range. - */ - clock_value->ns_from_epoch_overflows = true; - goto end; - } - - s_ns = (int64_t) u_ns; - assert(s_ns >= 0); - - if (clock_class->offset < 0) { - if (clock_value->ns_from_epoch >= 0) { - /* - * Offset in cycles is negative so it must also - * be negative once converted to nanoseconds. - */ - s_ns = -s_ns; - goto offset_ok; - } - - diff = clock_value->ns_from_epoch - INT64_MIN; - - if (s_ns >= diff) { - /* - * Overflow: current timestamp in nanoseconds - * plus the offset in cycles converted to - * nanoseconds is outside the int64_t range. - */ - clock_value->ns_from_epoch_overflows = true; - goto end; - } - - /* - * Offset in cycles is negative so it must also be - * negative once converted to nanoseconds. - */ - s_ns = -s_ns; - } else { - if (clock_value->ns_from_epoch <= 0) { - goto offset_ok; - } - - diff = INT64_MAX - clock_value->ns_from_epoch; - - if (s_ns >= diff) { - /* - * Overflow: current timestamp in nanoseconds - * plus the offset in cycles converted to - * nanoseconds is outside the int64_t range. - */ - clock_value->ns_from_epoch_overflows = true; - goto end; - } - } - -offset_ok: - clock_value->ns_from_epoch += s_ns; - - /* Add clock value (cycles) */ - u_ns = ns_from_value(clock_class->frequency, clock_value->value); - - if (u_ns == -1ULL || u_ns >= INT64_MAX) { - /* - * Overflow: value converted to nanoseconds is outside - * the int64_t range. - */ - clock_value->ns_from_epoch_overflows = true; - goto end; - } - - s_ns = (int64_t) u_ns; - assert(s_ns >= 0); - - /* Clock value (cycles) is always positive */ - if (clock_value->ns_from_epoch <= 0) { - goto value_ok; - } - - diff = INT64_MAX - clock_value->ns_from_epoch; - - if (s_ns >= diff) { - /* - * Overflow: current timestamp in nanoseconds plus the - * clock value converted to nanoseconds is outside the - * int64_t range. - */ - clock_value->ns_from_epoch_overflows = true; - goto end; - } - -value_ok: - clock_value->ns_from_epoch += s_ns; - -end: - if (clock_value->ns_from_epoch_overflows) { - clock_value->ns_from_epoch = 0; - } -} - -struct bt_clock_value *bt_clock_value_create( - struct bt_clock_class *clock_class, uint64_t value) -{ - struct bt_clock_value *ret = NULL; - - BT_LOGD("Creating clock value object: clock-class-addr=%p, " - "clock-class-name=\"%s\", value=%" PRIu64, clock_class, - bt_clock_class_get_name(clock_class), value); - - if (!clock_class) { - BT_LOGW_STR("Invalid parameter: clock class is NULL."); - goto end; - } - - ret = g_new0(struct bt_clock_value, 1); - if (!ret) { - BT_LOGE_STR("Failed to allocate one clock value."); - goto end; - } - - bt_object_init(ret, bt_clock_value_destroy); - ret->clock_class = bt_get(clock_class); - ret->value = value; - set_ns_from_epoch(ret); - bt_clock_class_freeze(clock_class); - BT_LOGD("Created clock value object: clock-value-addr=%p, " - "clock-class-addr=%p, clock-class-name=\"%s\", " - "ns-from-epoch=%" PRId64 ", ns-from-epoch-overflows=%d", - ret, clock_class, bt_clock_class_get_name(clock_class), - ret->ns_from_epoch, ret->ns_from_epoch_overflows); - -end: - return ret; -} - -int bt_clock_value_get_value( - struct bt_clock_value *clock_value, uint64_t *raw_value) -{ - int ret = 0; - - if (!clock_value || !raw_value) { - BT_LOGW("Invalid parameter: clock value or raw value is NULL: " - "clock-value-addr=%p, raw-value-addr=%p", - clock_value, raw_value); - ret = -1; - goto end; - } - - *raw_value = clock_value->value; -end: - return ret; -} - -int bt_clock_value_get_value_ns_from_epoch(struct bt_clock_value *value, - int64_t *ret_value_ns) -{ - int ret = 0; - - if (!value || !ret_value_ns) { - BT_LOGW("Invalid parameter: clock value or return value pointer is NULL: " - "clock-value-addr=%p, ret-value-addr=%p", - value, ret_value_ns); - ret = -1; - goto end; - } - - if (value->ns_from_epoch_overflows) { - BT_LOGW("Clock value converted to nanoseconds from Epoch overflows the signed 64-bit integer range: " - "clock-value-addr=%p, " - "clock-class-offset-s=%" PRId64 ", " - "clock-class-offset-cycles=%" PRId64 ", " - "value=%" PRIu64, - value, value->clock_class->offset_s, - value->clock_class->offset, - value->value); - ret = -1; - goto end; - } - - *ret_value_ns = value->ns_from_epoch; - -end: - return ret; -} - -struct bt_clock_class *bt_clock_value_get_class( - struct bt_clock_value *clock_value) -{ - struct bt_clock_class *clock_class = NULL; - - if (!clock_value) { - BT_LOGW_STR("Invalid parameter: clock value is NULL."); - goto end; - } - - clock_class = bt_get(clock_value->clock_class); - -end: - return clock_class; -} - -BT_HIDDEN -int bt_clock_class_compare(struct bt_clock_class *clock_class_a, - struct bt_clock_class *clock_class_b) -{ - int ret = 1; - assert(clock_class_a); - assert(clock_class_b); - - /* Name */ - if (strcmp(clock_class_a->name->str, clock_class_b->name->str) != 0) { - BT_LOGV("Clock classes differ: different names: " - "cc-a-name=\"%s\", cc-b-name=\"%s\"", - clock_class_a->name->str, - clock_class_b->name->str); - goto end; - } - - /* Description */ - if (clock_class_a->description) { - if (!clock_class_b->description) { - BT_LOGV_STR("Clock classes differ: clock class A has a " - "description, but clock class B does not."); - goto end; - } - - if (strcmp(clock_class_a->name->str, clock_class_b->name->str) - != 0) { - BT_LOGV("Clock classes differ: different descriptions: " - "cc-a-descr=\"%s\", cc-b-descr=\"%s\"", - clock_class_a->description->str, - clock_class_b->description->str); - goto end; - } - } else { - if (clock_class_b->description) { - BT_LOGV_STR("Clock classes differ: clock class A has " - "no description, but clock class B has one."); - goto end; - } - } - - /* Frequency */ - if (clock_class_a->frequency != clock_class_b->frequency) { - BT_LOGV("Clock classes differ: different frequencies: " - "cc-a-freq=%" PRIu64 ", cc-b-freq=%" PRIu64, - clock_class_a->frequency, - clock_class_b->frequency); - goto end; - } - - /* Precision */ - if (clock_class_a->precision != clock_class_b->precision) { - BT_LOGV("Clock classes differ: different precisions: " - "cc-a-freq=%" PRIu64 ", cc-b-freq=%" PRIu64, - clock_class_a->precision, - clock_class_b->precision); - goto end; - } - - /* Offset (seconds) */ - if (clock_class_a->offset_s != clock_class_b->offset_s) { - BT_LOGV("Clock classes differ: different offsets (seconds): " - "cc-a-offset-s=%" PRId64 ", cc-b-offset-s=%" PRId64, - clock_class_a->offset_s, - clock_class_b->offset_s); - goto end; - } - - /* Offset (cycles) */ - if (clock_class_a->offset != clock_class_b->offset) { - BT_LOGV("Clock classes differ: different offsets (cycles): " - "cc-a-offset-s=%" PRId64 ", cc-b-offset-s=%" PRId64, - clock_class_a->offset, - clock_class_b->offset); - goto end; - } - - /* UUIDs */ - if (clock_class_a->uuid_set) { - if (!clock_class_b->uuid_set) { - BT_LOGV_STR("Clock classes differ: clock class A has a " - "UUID, but clock class B does not."); - goto end; - } - - if (memcmp(clock_class_a->uuid, clock_class_b->uuid, - BABELTRACE_UUID_LEN) != 0) { - BT_LOGV("Clock classes differ: different UUIDs: " - "cc-a-uuid=\"%02x%02x%02x%02x-%02x%02x-%02x%02x-%02x%02x-%02x%02x%02x%02x%02x%02x\", " - "cc-b-uuid=\"%02x%02x%02x%02x-%02x%02x-%02x%02x-%02x%02x-%02x%02x%02x%02x%02x%02x\"", - (unsigned int) clock_class_a->uuid[0], - (unsigned int) clock_class_a->uuid[1], - (unsigned int) clock_class_a->uuid[2], - (unsigned int) clock_class_a->uuid[3], - (unsigned int) clock_class_a->uuid[4], - (unsigned int) clock_class_a->uuid[5], - (unsigned int) clock_class_a->uuid[6], - (unsigned int) clock_class_a->uuid[7], - (unsigned int) clock_class_a->uuid[8], - (unsigned int) clock_class_a->uuid[9], - (unsigned int) clock_class_a->uuid[10], - (unsigned int) clock_class_a->uuid[11], - (unsigned int) clock_class_a->uuid[12], - (unsigned int) clock_class_a->uuid[13], - (unsigned int) clock_class_a->uuid[14], - (unsigned int) clock_class_a->uuid[15], - (unsigned int) clock_class_b->uuid[0], - (unsigned int) clock_class_b->uuid[1], - (unsigned int) clock_class_b->uuid[2], - (unsigned int) clock_class_b->uuid[3], - (unsigned int) clock_class_b->uuid[4], - (unsigned int) clock_class_b->uuid[5], - (unsigned int) clock_class_b->uuid[6], - (unsigned int) clock_class_b->uuid[7], - (unsigned int) clock_class_b->uuid[8], - (unsigned int) clock_class_b->uuid[9], - (unsigned int) clock_class_b->uuid[10], - (unsigned int) clock_class_b->uuid[11], - (unsigned int) clock_class_b->uuid[12], - (unsigned int) clock_class_b->uuid[13], - (unsigned int) clock_class_b->uuid[14], - (unsigned int) clock_class_b->uuid[15]); - goto end; - } - } else { - if (clock_class_b->uuid_set) { - BT_LOGV_STR("Clock classes differ: clock class A has " - "no UUID, but clock class B has one."); - goto end; - } - } + int ret; - /* Absolute */ - if (!!clock_class_a->absolute != !!clock_class_b->absolute) { - BT_LOGV("Clock classes differ: one is absolute, the other " - "is not: cc-a-is-absolute=%d, cc-b-is-absolute=%d", - !!clock_class_a->absolute, - !!clock_class_b->absolute); - goto end; + BT_ASSERT_PRE_NON_NULL(clock_class, "Clock class"); + BT_ASSERT_PRE_NON_NULL(ns, "Nanoseconds (output)"); + ret = bt_util_ns_from_origin(clock_class, cycles, ns); + if (ret) { + BT_LIB_LOGW("Cannot convert cycles to nanoseconds " + "from origin for given clock class: " + "value overflows the signed 64-bit integer range: " + "%![cc-]+K, cycles=%" PRIu64, + clock_class, cycles); } - /* Equal */ - ret = 0; - -end: return ret; }