Class AddProcessor

test/anyflow/test_processor.cpp:73–140

bool MockProcessor::reset_called = false;

struct AddProcessor : public GraphProcessor {
  virtual int process() noexcept override {
    *x.emit() = ::std::to_string((a == nullptr ? 100 : *a) + *b + *c);
    return 0;
  }

  ANYFLOW_INTERFACE(ANYFLOW_DEPEND_DATA(int32_t, a, 0)
                        ANYFLOW_DEPEND_DATA(int32_t, b, 1)
                            ANYFLOW_DEPEND_DATA(int32_t, c)
                                ANYFLOW_EMIT_DATA(::std::string, x))
};

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;
  ::std::unique_ptr<Graph> graph;
  GraphData* a;
  GraphData* b;
  GraphData* c;
  GraphData* d;
};

TEST_F(ProcessorTest, config_when_finish) {
  GraphBuilder builder;
  builder