* SOFTWARE.
*/
+#define BT_LOG_TAG "CC-PRIO-MAP"
+#include <babeltrace/lib-logging-internal.h>
+
#include <babeltrace/graph/clock-class-priority-map.h>
#include <babeltrace/graph/clock-class-priority-map-internal.h>
#include <babeltrace/ctf-ir/clock-class.h>
#include <babeltrace/babeltrace-internal.h>
#include <babeltrace/compiler-internal.h>
#include <babeltrace/ref.h>
+#include <stdint.h>
+#include <inttypes.h>
#include <glib.h>
static
return;
}
+ BT_LOGD("Destroying component class priority map object: addr=%p",
+ cc_prio_map);
+
if (cc_prio_map->entries) {
+ BT_LOGD("Putting clock classes.");
g_ptr_array_free(cc_prio_map->entries, TRUE);
}
{
struct bt_clock_class_priority_map *cc_prio_map = NULL;
+ BT_LOGD_STR("Creating clock class priority map object.");
+
cc_prio_map = g_new0(struct bt_clock_class_priority_map, 1);
if (!cc_prio_map) {
+ BT_LOGE_STR("Failed to allocate one clock class priority map.");
goto error;
}
cc_prio_map->entries = g_ptr_array_new_with_free_func(
(GDestroyNotify) bt_put);
if (!cc_prio_map->entries) {
+ BT_LOGE_STR("Failed to allocate a GPtrArray.");
goto error;
}
cc_prio_map->prios = g_hash_table_new_full(g_direct_hash,
g_direct_equal, NULL, (GDestroyNotify) g_free);
if (!cc_prio_map->entries) {
+ BT_LOGE_STR("Failed to allocate a GHashTable.");
goto error;
}
+ BT_LOGD("Created clock class priority map object: addr=%p",
+ cc_prio_map);
goto end;
error:
return cc_prio_map;
}
-int bt_clock_class_priority_map_get_clock_class_count(
+int64_t bt_clock_class_priority_map_get_clock_class_count(
struct bt_clock_class_priority_map *cc_prio_map)
{
- int ret = -1;
+ int64_t ret = (int64_t) -1;
if (!cc_prio_map) {
+ BT_LOGW_STR("Invalid parameter: clock class priority map is NULL.");
goto end;
}
- ret = (int) cc_prio_map->entries->len;
+ ret = (int64_t) cc_prio_map->entries->len;
end:
return ret;
}
-struct bt_ctf_clock_class *bt_clock_class_priority_map_get_clock_class(
+struct bt_ctf_clock_class *bt_clock_class_priority_map_get_clock_class_by_index(
struct bt_clock_class_priority_map *cc_prio_map,
- unsigned int index)
+ uint64_t index)
{
struct bt_ctf_clock_class *clock_class = NULL;
- if (!cc_prio_map || index >= cc_prio_map->entries->len) {
+ if (!cc_prio_map) {
+ BT_LOGW_STR("Invalid parameter: clock class priority map is NULL.");
+ goto end;
+ }
+
+ if (index >= cc_prio_map->entries->len) {
+ BT_LOGW("Invalid parameter: index is out of bounds: "
+ "addr=%p, index=%" PRIu64 ", count=%u",
+ cc_prio_map, index, cc_prio_map->entries->len);
goto end;
}
size_t i;
struct bt_ctf_clock_class *clock_class = NULL;
- if (!cc_prio_map || !name) {
+ if (!cc_prio_map) {
+ BT_LOGW_STR("Invalid parameter: clock class priority map is NULL.");
+ goto end;
+ }
+
+ if (!name) {
+ BT_LOGW_STR("Invalid parameter: name is NULL.");
goto end;
}
for (i = 0; i < cc_prio_map->entries->len; i++) {
struct bt_ctf_clock_class *cur_cc =
g_ptr_array_index(cc_prio_map->entries, i);
- // FIXME when available: use bt_ctf_clock_class_get_name()
const char *cur_cc_name =
- cur_cc->name ? cur_cc->name->str : NULL;
+ bt_ctf_clock_class_get_name(cur_cc);
- if (!cur_cc_name) {
- goto end;
- }
+ assert(cur_cc_name);
if (strcmp(cur_cc_name, name) == 0) {
clock_class = bt_get(cur_cc);
struct bt_ctf_clock_class *clock_class = NULL;
if (!cc_prio_map) {
+ BT_LOGW_STR("Invalid parameter: clock class priority map is NULL.");
goto end;
}
int ret = 0;
uint64_t *prio;
- if (!cc_prio_map || !clock_class || !priority) {
+ if (!cc_prio_map) {
+ BT_LOGW_STR("Invalid parameter: clock class priority map is NULL.");
+ ret = -1;
+ goto end;
+ }
+
+ if (!clock_class) {
+ BT_LOGW_STR("Invalid parameter: clock class is NULL.");
+ ret = -1;
+ goto end;
+ }
+
+ if (!priority) {
+ BT_LOGW_STR("Invalid parameter: priority is NULL.");
ret = -1;
goto end;
}
prio = g_hash_table_lookup(cc_prio_map->prios, clock_class);
if (!prio) {
+ BT_LOGV("Clock class does not exist in clock class priority map: "
+ "cc-prio-map-addr=%p, clock-class-addr=%p, "
+ "clock-class-name=\"%s\"",
+ cc_prio_map, clock_class,
+ bt_ctf_clock_class_get_name(clock_class));
ret = -1;
goto end;
}
// FIXME when available: check
// bt_ctf_clock_class_is_valid(clock_class)
- if (!cc_prio_map || !clock_class || cc_prio_map->frozen) {
+ if (!cc_prio_map) {
+ BT_LOGW_STR("Invalid parameter: clock class priority map is NULL.");
+ ret = -1;
+ goto end;
+ }
+
+ if (!clock_class) {
+ BT_LOGW_STR("Invalid parameter: clock class is NULL.");
ret = -1;
goto end;
}
- /* Check for duplicate clock classes */
+ if (cc_prio_map->frozen) {
+ BT_LOGW("Invalid parameter: clock class priority map is frozen: "
+ "addr=%p", cc_prio_map);
+ ret = -1;
+ goto end;
+ }
+
+ /* Check for existing clock class */
prio_ptr = g_hash_table_lookup(cc_prio_map->prios, clock_class);
if (prio_ptr) {
+ *prio_ptr = priority;
prio_ptr = NULL;
- ret = -1;
- goto end;
+ goto set_highest_prio;
}
prio_ptr = g_new(uint64_t, 1);
if (!prio_ptr) {
+ BT_LOGE_STR("Failed to allocate a uint64_t.");
ret = -1;
goto end;
}
g_ptr_array_add(cc_prio_map->entries, clock_class);
g_hash_table_insert(cc_prio_map->prios, clock_class, prio_ptr);
prio_ptr = NULL;
+
+set_highest_prio:
cc_prio = bt_ctf_clock_class_priority_map_current_highest_prio(
cc_prio_map);
assert(cc_prio.clock_class);
cc_prio_map->highest_prio_cc = cc_prio.clock_class;
+ BT_LOGV("Added clock class to clock class priority map: "
+ "cc-prio-map-addr=%p, added-clock-class-addr=%p, "
+ "added-clock-class-name=\"%s\", "
+ "highest-prio-clock-class-addr=%p, "
+ "highest-prio-clock-class-name=\"%s\"",
+ cc_prio_map, clock_class,
+ bt_ctf_clock_class_get_name(clock_class),
+ cc_prio.clock_class,
+ bt_ctf_clock_class_get_name(cc_prio.clock_class));
end:
- if (prio_ptr) {
- g_free(prio_ptr);
- }
+ g_free(prio_ptr);
return ret;
}
+
+struct bt_clock_class_priority_map *bt_clock_class_priority_map_copy(
+ struct bt_clock_class_priority_map *orig_cc_prio_map)
+{
+ struct bt_clock_class_priority_map *cc_prio_map;
+ size_t i;
+
+ cc_prio_map = bt_clock_class_priority_map_create();
+ if (!cc_prio_map) {
+ BT_LOGW_STR("Invalid parameter: clock class priority map is NULL.");
+ goto error;
+ }
+
+ for (i = 0; i < orig_cc_prio_map->entries->len; i++) {
+ struct bt_ctf_clock_class *clock_class =
+ g_ptr_array_index(orig_cc_prio_map->entries, i);
+ uint64_t *prio = g_hash_table_lookup(orig_cc_prio_map->prios,
+ clock_class);
+ int ret = bt_clock_class_priority_map_add_clock_class(
+ cc_prio_map, clock_class, *prio);
+
+ if (ret) {
+ BT_LOGE("Cannot add clock class to clock class priority map copy: "
+ "cc-prio-map-copy-addr=%p, clock-class-addr=%p, "
+ "clock-class-name=\"%s\"",
+ cc_prio_map, clock_class,
+ bt_ctf_clock_class_get_name(clock_class));
+ goto error;
+ }
+ }
+
+ cc_prio_map->highest_prio_cc = orig_cc_prio_map->highest_prio_cc;
+ BT_LOGD("Copied clock class priority map: "
+ "original-addr=%p, copy-addr=%p",
+ orig_cc_prio_map, cc_prio_map);
+ goto end;
+
+error:
+ BT_PUT(cc_prio_map);
+
+end:
+ return cc_prio_map;
+}