sbn_static.cxx

Go to the documentation of this file.

#include <fstream>
#include <iostream>
#include <cstdio>
#include <cstdlib>
#include <map>
#include <vector>
#include <dlfcn.h>
#include <fhiclcpp/ParameterSet.h>
#include <core/ProcessorBase.hh>
#include <core/ProcessorBlock.hh>

extern "C" {
  extern core::ProcessorBase* CreateProcessorObject();
  extern void DestroyProcessorObject(core::ProcessorBase* proc);
  extern struct core::export_table exports;
}


/** Load a Processor. */
inline core::export_table* LoadProcessor() {
  return &exports;
}


int main(int argc, char* argv[]) {
  // Parse command line arguments
  std::vector<char*> config_names;

  int c;
  while ((c=getopt(argc, argv, "c:")) != -1) {
    switch (c) {
      case 'c':
        config_names.push_back(optarg);
        break;
      case '?':
        if (optopt == 'c')
          fprintf(stderr, "Option -%c requires an argument.\n", optopt);
        else if (isprint(optopt))
          fprintf(stderr, "Unknown option `-%c'.\n", optopt);
        else
          fprintf(stderr, "Unknown option character `\\x%x'.\n", optopt);
        return 1;
      default:
        abort();
    }
  }

  if (argc - optind < 1) {
    std::cout << "Usage: " << argv[0] << " [-c [Config]] "
              << "INPUTDEF [...]" << std::endl;
    return 0;
  }

  // Process input file definition
  std::vector<std::string> filenames;
  for (int i=optind; i<argc; i++) {
    filenames.push_back(argv[i]);
  }
  assert(!filenames.empty());

  // Setup
  int n_processors = config_names.empty() ? 1 : config_names.size();
  std::vector<fhicl::ParameterSet*> configs(n_processors);
  std::vector<core::ProcessorBase*> procs(n_processors);

  std::cout << "Configuring... " << std::endl;
  for (size_t i=0; i<n_processors; i++) {
    procs[i] = LoadProcessor()->create();
    configs[i] = config_names.empty() ? NULL : core::LoadConfig(config_names[i]);
  }

  core::ProcessorBlock block;
  for (int i=0; i<procs.size(); i++) {
    block.AddProcessor(procs[i], configs[i]);
  }

  std::cout << "Running... " << std::endl;
  block.ProcessFiles(filenames);

  block.DeleteProcessors();
  std::cout << "Done!" << std::endl;

  return 0;
}