iterate_binary_log.h

Go to the documentation of this file.

#pragma once
 
/*
 * Copyright 2019-2023 CNRS-UM LIRMM, CNRS-AIST JRL
 */
 
#include <mc_rtc/MessagePackBuilder.h>
#include <mc_rtc/log/FlatLog.h>
 
namespace mc_rtc::log
{
 
using copy_callback = std::function<void(mc_rtc::MessagePackBuilder &, const std::vector<std::string> &)>;
 
struct MC_RTC_UTILS_DLLAPI IterateBinaryLogData
{
  const std::vector<std::string> & keys;
  std::vector<FlatLog::record> & records;
  std::vector<Logger::GUIEvent> & gui_events;
  std::optional<double> time;
  const copy_callback & copy_cb;
  const char * raw_data;
  size_t raw_data_size;
  const std::optional<Logger::Meta> & meta;
};
 
using iterate_binary_log_callback = std::function<bool(IterateBinaryLogData)>;
 
using binary_log_callback =
    std::function<bool(const std::vector<std::string> &, std::vector<FlatLog::record> &, double)>;
 
using binary_log_copy_callback = std::function<bool(const std::vector<std::string> &,
                                                    std::vector<FlatLog::record> &,
                                                    double,
                                                    const copy_callback &,
                                                    const char *,
                                                    uint64_t)>;
 
bool MC_RTC_UTILS_DLLAPI iterate_binary_log(const std::string & fpath,
                                            const iterate_binary_log_callback & callback,
                                            bool extract,
                                            const std::string & time = "t");
 
inline bool iterate_binary_log(const std::string & fpath,
                               const binary_log_copy_callback & callback,
                               bool extract,
                               const std::string & time = "t")
{
  return iterate_binary_log(
      fpath,
      [&callback](IterateBinaryLogData data) {
        return callback(data.keys, data.records, data.time.value_or(-1), data.copy_cb, data.raw_data,
                        data.raw_data_size);
      },
      extract, time);
}
 
inline bool iterate_binary_log(const std::string & fpath,
                               const binary_log_callback & callback,
                               bool extract,
                               const std::string & time = "t")
{
  return iterate_binary_log(
      fpath, [&callback](IterateBinaryLogData data)
      { return callback(data.keys, data.records, data.time.value_or(-1)); }, extract, time);
}
 
} // namespace mc_rtc::log