process_journal_pair.cpp

Go to the documentation of this file.

#include "joedb/ui/process_journal_pair.h"
#include "joedb/journal/File.h"
 
#include <iostream>
 
namespace joedb
{
 ////////////////////////////////////////////////////////////////////////////
 int process_journal_pair
 ////////////////////////////////////////////////////////////////////////////
 (
  Arguments &arguments,
  void (*process)(Readonly_Journal &, Writable_Journal &, int64_t checkpoint)
 )
 {
  const bool ignore_header = arguments.has_flag("ignore_header");
  const int64_t until = arguments.get_option<int64_t>
  (
   "until",
   "checkpoint",
   0
  );
  const std::string_view input = arguments.get_next("input.joedb");
  const std::string_view output = arguments.get_next("output.joedb");
 
  if (arguments.missing())
  {
   arguments.print_help(std::cerr);
   return 1;
  }
 
  File input_file(input.data(), Open_Mode::read_existing);
 
  Readonly_Journal input_journal
  (
   Journal_Construction_Lock
   (
    input_file,
    ignore_header ? Recovery::ignore_header : Recovery::none
   )
  );
 
  File output_file(output.data(), Open_Mode::create_new);
  Writable_Journal output_journal(output_file);
 
  process(input_journal, output_journal, until);
 
  return 0;
 }
}