+/*
+ * Compute the intersection of all streams in the array `streams`, write it
+ * in `range`.
+ */
+
+static
+int compute_stream_intersection(const bt_value *streams,
+ struct trace_range *range)
+{
+ unsigned int i;
+ unsigned int stream_count;
+ int ret;
+
+ BT_ASSERT(bt_value_get_type(streams) == BT_VALUE_TYPE_ARRAY);
+
+ stream_count = bt_value_array_get_length(streams);
+
+ BT_ASSERT(stream_count > 0);
+
+ range->intersection_range_begin_ns = 0;
+ range->intersection_range_end_ns = UINT64_MAX;
+
+ for (i = 0; i < stream_count; i++) {
+ int64_t begin_ns, end_ns;
+ uint64_t begin_ns_u, end_ns_u;
+ const bt_value *stream_value;
+ const bt_value *range_ns_value;
+ const bt_value *begin_value;
+ const bt_value *end_value;
+
+ stream_value = bt_value_array_borrow_element_by_index_const(streams, i);
+ if (bt_value_get_type(stream_value) != BT_VALUE_TYPE_MAP) {
+ BT_CLI_LOGE_APPEND_CAUSE("Unexpected format of `babeltrace.trace-infos` query result: "
+ "expected streams array element to be a map, got %s.",
+ bt_common_value_type_string(bt_value_get_type(stream_value)));
+ goto error;
+ }
+
+ range_ns_value = bt_value_map_borrow_entry_value_const(
+ stream_value, "range-ns");
+ if (!range_ns_value) {
+ BT_CLI_LOGE_APPEND_CAUSE("Unexpected format of `babeltrace.trace-infos` query result: "
+ "missing expected `range-ns` key in stream map.");
+ goto error;
+ }
+
+ if (bt_value_get_type(range_ns_value) != BT_VALUE_TYPE_MAP) {
+ BT_CLI_LOGE_APPEND_CAUSE("Unexpected format of `babeltrace.trace-infos` query result: "
+ "expected `range-ns` entry value of stream map to be a map, got %s.",
+ bt_common_value_type_string(bt_value_get_type(range_ns_value)));
+ goto error;
+ }
+
+ begin_value = bt_value_map_borrow_entry_value_const(range_ns_value, "begin");
+ if (!begin_value) {
+ BT_CLI_LOGE_APPEND_CAUSE("Unexpected format of `babeltrace.trace-infos` query result: "
+ "missing expected `begin` key in range-ns map.");
+ goto error;
+ }
+
+ if (bt_value_get_type(begin_value) != BT_VALUE_TYPE_SIGNED_INTEGER) {
+ BT_CLI_LOGE_APPEND_CAUSE("Unexpected format of `babeltrace.trace-infos` query result: "
+ "expected `begin` entry value of range-ns map to be a signed integer, got %s.",
+ bt_common_value_type_string(bt_value_get_type(range_ns_value)));
+ goto error;
+ }
+
+ end_value = bt_value_map_borrow_entry_value_const(range_ns_value, "end");
+ if (!end_value) {
+ BT_CLI_LOGE_APPEND_CAUSE("Unexpected format of `babeltrace.trace-infos` query result: "
+ "missing expected `end` key in range-ns map.");
+ goto error;
+ }
+
+ if (bt_value_get_type(end_value) != BT_VALUE_TYPE_SIGNED_INTEGER) {
+ BT_CLI_LOGE_APPEND_CAUSE("Unexpected format of `babeltrace.trace-infos` query result: "
+ "expected `end` entry value of range-ns map to be a signed integer, got %s.",
+ bt_common_value_type_string(bt_value_get_type(range_ns_value)));
+ goto error;
+ }
+
+ begin_ns = bt_value_integer_signed_get(begin_value);
+ end_ns = bt_value_integer_signed_get(end_value);
+
+ if (begin_ns < 0 || end_ns < 0 || end_ns < begin_ns) {
+ BT_CLI_LOGE_APPEND_CAUSE(
+ "Invalid stream range values: "
+ "range-ns:begin=%" PRId64 ", "
+ "range-ns:end=%" PRId64,
+ begin_ns, end_ns);
+ ret = -1;
+ goto error;
+ }
+
+ begin_ns_u = begin_ns;
+ end_ns_u = end_ns;
+
+ range->intersection_range_begin_ns =
+ MAX(range->intersection_range_begin_ns, begin_ns_u);
+ range->intersection_range_end_ns =
+ MIN(range->intersection_range_end_ns, end_ns_u);
+ }
+
+ ret = 0;
+ goto end;
+error:
+ ret = -1;
+
+end:
+ return ret;
+}
+