Method SetUp

test/anyflow/test_processor.cpp:86–117

struct ProcessorTest : public ::testing::Test {
  virtual void SetUp() override {
    {
      auto& vertex = builder.add_vertex([] {
        return ::std::unique_ptr<AddProcessor>(new AddProcessor);
      });
      vertex.named_depend("a").to("A");
      vertex.named_depend("b").to("B");
      vertex.named_depend("c").to("C");
      vertex.named_emit("x").to("D");
    }
    executor.initialize(4, 128);
    builder.set_executor(executor);
    builder.finish();
    graph = builder.build();
    a = graph->find_data("A");
    b = graph->find_data("B");
    c = graph->find_data("C");
    d = graph->find_data("D");

    MockProcessor::config_called = false;
    MockProcessor::option_append = "";
    MockProcessor::config_return = 0;

    MockProcessor::setup_called = false;
    MockProcessor::option_effect = "";
    MockProcessor::setup_return = 0;

    MockProcessor::process_called = false;
    MockProcessor::process_return = 0;

    MockProcessor::reset_called = false;
  }

  ThreadPoolGraphExecutor executor;
  GraphBuilder builder;