src/plugins/ctf/common/metadata/ctf-meta-update-default-clock-classes.cpp

   1 /*
   2  * SPDX-License-Identifier: MIT
   3  *
   4  * Copyright 2018 Philippe Proulx <pproulx@efficios.com>
   5  */
   6
   7 #include <inttypes.h>
   8 #include <string.h>
   9
  10 #define BT_COMP_LOG_SELF_COMP       (log_cfg->self_comp)
  11 #define BT_COMP_LOG_SELF_COMP_CLASS (log_cfg->self_comp_class)
  12 #define BT_LOG_OUTPUT_LEVEL         (log_cfg->log_level)
  13 #define BT_LOG_TAG                  "PLUGIN/CTF/META/UPDATE-DEF-CC"
  14 #include "logging.hpp"
  15
  16 #include "ctf-meta-visitors.hpp"
  17
  18 static inline int find_mapped_clock_class(struct ctf_field_class *fc,
  19                                           struct ctf_clock_class **clock_class,
  20                                           struct meta_log_config *log_cfg)
  21 {
  22     int ret = 0;
  23     uint64_t i;
  24
  25     if (!fc) {
  26         goto end;
  27     }
  28
  29     switch (fc->type) {
  30     case CTF_FIELD_CLASS_TYPE_INT:
  31     case CTF_FIELD_CLASS_TYPE_ENUM:
  32     {
  33         struct ctf_field_class_int *int_fc = ctf_field_class_as_int(fc);
  34
  35         if (int_fc->mapped_clock_class) {
  36             if (*clock_class && *clock_class != int_fc->mapped_clock_class) {
  37                 _BT_COMP_OR_COMP_CLASS_LOGE_APPEND_CAUSE("Stream class contains more than one "
  38                                                          "clock class: expected-cc-name=\"%s\", "
  39                                                          "other-cc-name=\"%s\"",
  40                                                          (*clock_class)->name->str,
  41                                                          int_fc->mapped_clock_class->name->str);
  42                 ret = -1;
  43                 goto end;
  44             }
  45
  46             *clock_class = int_fc->mapped_clock_class;
  47         }
  48
  49         break;
  50     }
  51     case CTF_FIELD_CLASS_TYPE_STRUCT:
  52     {
  53         struct ctf_field_class_struct *struct_fc = ctf_field_class_as_struct(fc);
  54
  55         for (i = 0; i < struct_fc->members->len; i++) {
  56             struct ctf_named_field_class *named_fc =
  57                 ctf_field_class_struct_borrow_member_by_index(struct_fc, i);
  58
  59             ret = find_mapped_clock_class(named_fc->fc, clock_class, log_cfg);
  60             if (ret) {
  61                 goto end;
  62             }
  63         }
  64
  65         break;
  66     }
  67     case CTF_FIELD_CLASS_TYPE_VARIANT:
  68     {
  69         struct ctf_field_class_variant *var_fc = ctf_field_class_as_variant(fc);
  70
  71         for (i = 0; i < var_fc->options->len; i++) {
  72             struct ctf_named_field_class *named_fc =
  73                 ctf_field_class_variant_borrow_option_by_index(var_fc, i);
  74
  75             ret = find_mapped_clock_class(named_fc->fc, clock_class, log_cfg);
  76             if (ret) {
  77                 goto end;
  78             }
  79         }
  80
  81         break;
  82     }
  83     case CTF_FIELD_CLASS_TYPE_ARRAY:
  84     case CTF_FIELD_CLASS_TYPE_SEQUENCE:
  85     {
  86         struct ctf_field_class_array_base *array_fc = ctf_field_class_as_array_base(fc);
  87
  88         ret = find_mapped_clock_class(array_fc->elem_fc, clock_class, log_cfg);
  89         if (ret) {
  90             goto end;
  91         }
  92
  93         break;
  94     }
  95     default:
  96         break;
  97     }
  98
  99 end:
 100     return ret;
 101 }
 102
 103 static inline int update_stream_class_default_clock_class(struct ctf_stream_class *stream_class,
 104                                                           struct meta_log_config *log_cfg)
 105 {
 106     int ret = 0;
 107     struct ctf_clock_class *clock_class = stream_class->default_clock_class;
 108     uint64_t i;
 109
 110     ret = find_mapped_clock_class(stream_class->packet_context_fc, &clock_class, log_cfg);
 111     if (ret) {
 112         goto end;
 113     }
 114
 115     ret = find_mapped_clock_class(stream_class->event_header_fc, &clock_class, log_cfg);
 116     if (ret) {
 117         goto end;
 118     }
 119
 120     ret = find_mapped_clock_class(stream_class->event_common_context_fc, &clock_class, log_cfg);
 121     if (ret) {
 122         goto end;
 123     }
 124
 125     for (i = 0; i < stream_class->event_classes->len; i++) {
 126         struct ctf_event_class *event_class =
 127             (ctf_event_class *) stream_class->event_classes->pdata[i];
 128
 129         ret = find_mapped_clock_class(event_class->spec_context_fc, &clock_class, log_cfg);
 130         if (ret) {
 131             goto end;
 132         }
 133
 134         ret = find_mapped_clock_class(event_class->payload_fc, &clock_class, log_cfg);
 135         if (ret) {
 136             goto end;
 137         }
 138     }
 139
 140     if (!stream_class->default_clock_class) {
 141         stream_class->default_clock_class = clock_class;
 142     }
 143
 144 end:
 145     return ret;
 146 }
 147
 148 int ctf_trace_class_update_default_clock_classes(struct ctf_trace_class *ctf_tc,
 149                                                  struct meta_log_config *log_cfg)
 150 {
 151     uint64_t i;
 152     int ret = 0;
 153     struct ctf_clock_class *clock_class = NULL;
 154
 155     ret = find_mapped_clock_class(ctf_tc->packet_header_fc, &clock_class, log_cfg);
 156     if (ret) {
 157         goto end;
 158     }
 159
 160     if (clock_class) {
 161         ret = -1;
 162         goto end;
 163     }
 164
 165     for (i = 0; i < ctf_tc->stream_classes->len; i++) {
 166         struct ctf_stream_class *sc = (ctf_stream_class *) ctf_tc->stream_classes->pdata[i];
 167
 168         ret = update_stream_class_default_clock_class(
 169             (ctf_stream_class *) ctf_tc->stream_classes->pdata[i], log_cfg);
 170         if (ret) {
 171             _BT_COMP_OR_COMP_CLASS_LOGE_APPEND_CAUSE("Stream class contains more than one "
 172                                                      "clock class: stream-class-id=%" PRIu64,
 173                                                      sc->id);
 174             goto end;
 175         }
 176     }
 177
 178 end:
 179     return ret;
 180 }