#define BT_LOG_TAG "CLOCK-CLASS"
#include <babeltrace/lib-logging-internal.h>
+#include <babeltrace/assert-pre-internal.h>
#include <babeltrace/compat/uuid-internal.h>
#include <babeltrace/ctf-ir/clock-class-internal.h>
#include <babeltrace/ctf-ir/clock-value-internal.h>
-#include <babeltrace/ctf-ir/utils.h>
+#include <babeltrace/ctf-ir/utils-internal.h>
#include <babeltrace/ref.h>
#include <babeltrace/compiler-internal.h>
#include <babeltrace/types.h>
#include <babeltrace/object-internal.h>
#include <babeltrace/assert-internal.h>
-static
-void bt_clock_class_destroy(struct bt_object *obj);
+#define BT_ASSERT_PRE_CLOCK_CLASS_HOT(_cc) \
+ BT_ASSERT_PRE_HOT((_cc), "Clock class", ": %!+K", (_cc))
-BT_HIDDEN
-bt_bool bt_clock_class_is_valid(struct bt_clock_class *clock_class)
+static
+void destroy_clock_class(struct bt_object *obj)
{
- return clock_class && clock_class->name;
-}
+ struct bt_clock_class *clock_class = (void *) obj;
-int bt_clock_class_set_name(struct bt_clock_class *clock_class,
- const char *name)
-{
- int ret = 0;
+ BT_LIB_LOGD("Destroying clock class: %!+K", clock_class);
- if (!clock_class) {
- BT_LOGW_STR("Invalid parameter: clock class is NULL.");
- ret = -1;
- goto end;
+ if (clock_class->name.str) {
+ g_string_free(clock_class->name.str, TRUE);
}
- 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;
+ if (clock_class->description.str) {
+ g_string_free(clock_class->description.str, TRUE);
}
- if (!bt_identifier_is_valid(name)) {
- BT_LOGW("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) {
- 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;
- }
- }
-
- 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);
+}
+
+static inline
+void set_base_offset(struct bt_clock_class *clock_class)
+{
+ uint64_t offset_cycles_ns;
- 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;
+ /* 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) {
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_clock_class_set_name() logs errors */
- 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;
-}
-
-int bt_clock_class_get_offset_s(struct bt_clock_class *clock_class,
- int64_t *offset_s)
-{
- 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;
-}
-
-int bt_clock_class_set_offset_s(struct bt_clock_class *clock_class,
- int64_t offset_s)
-{
- 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;
+ BT_LIB_LOGV("Set clock class's precision: %!+K", clock_class);
+ return 0;
}
-int bt_clock_class_get_offset_cycles(struct bt_clock_class *clock_class,
- int64_t *offset)
+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) {
- 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;
+ 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_cycles(struct bt_clock_class *clock_class,
- int64_t offset)
+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 = 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)
+void _bt_clock_class_freeze(struct bt_clock_class *clock_class)
{
- if (!clock_class || clock_class->frozen) {
- return;
- }
+ BT_ASSERT(clock_class);
- BT_LOGD("Freezing clock class: addr=%p, name=\"%s\"",
- clock_class, bt_clock_class_get_name(clock_class));
- clock_class->frozen = 1;
-}
-
-static
-void bt_clock_class_destroy(struct bt_object *obj)
-{
- 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);
- }
-
- 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);
-}
-
-static
-void set_ns_from_epoch(struct bt_clock_value *clock_value)
-{
- 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;
- BT_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;
- BT_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_LIB_LOGD("Freezing clock class: %!+K", clock_class);
+ clock_class->frozen = 1;
}
-BT_HIDDEN
-int bt_clock_class_compare(struct bt_clock_class *clock_class_a,
- struct bt_clock_class *clock_class_b)
+int bt_clock_class_cycles_to_ns_from_origin(struct bt_clock_class *clock_class,
+ uint64_t cycles, int64_t *ns)
{
- int ret = 1;
- BT_ASSERT(clock_class_a);
- BT_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;
}
projects / babeltrace.git / blobdiff