Method read_record

LatencyMap.py:182–228

(self)

                return

    def read_record(self) -> None:
        while True:
            line = self._read_non_empty_line_lower_stripped()
            split_line = [x.strip() for x in line.split(",")]

            # End-of-record
            if len(split_line) == 1 and split_line[0] == g_params.end_tag:
                return

            # Header / meta lines
            if len(split_line) == 4 and split_line[0] == 'timestamp' and split_line[1] == 'microsec':
                self.data['timestamp'] = int(split_line[2])
                self.date = split_line[3]
                continue

            if len(split_line) == 2 and split_line[0] == g_params.label_tag:
                self.label = split_line[1]
                continue

            if len(split_line) == 2 and split_line[0] == g_params.label_data_source:
                self.data_source = split_line[1]
                continue

            if len(split_line) == 2 and split_line[0] == g_params.latencyunit_tag:
                unit = split_line[1]
                if unit not in ('millisec', 'microsec', 'nanosec'):
                    raise ValueError(f"Cannot understand latency unit in line: {line!r}")
                g_params.latency_unit = unit
                continue

            # Data lines: <power_of_two_value>,<count>
            if len(split_line) != 2:
                raise ValueError(f"Cannot process record line: {line!r}")

            try:
                power_of_two_val = int(split_line[0])
                count = int(split_line[1])
                bucket = math.log(power_of_two_val, 2.0)
            except Exception as exc:
                raise ValueError(f"Cannot parse data line: {line!r} ({exc})") from exc

            if abs(int(bucket) - bucket) > 1e-6:
                raise ValueError(f"Bucket value must be a power of 2: {line!r}")
            bucket = int(bucket)

            # Keep cumulative count for this exponent bucket
            self.data[bucket] = self.data.get(bucket, 0) + count

    # ----------------------- Computations & autotune ----------------------- #