FutureDAGTest.cpp File Reference

#include <folly/experimental/FutureDAG.h>
#include <boost/thread/barrier.hpp>
#include <folly/portability/GTest.h>

Go to the source code of this file.

Classes
struct	FutureDAGTest
struct	FutureDAGTest::TestNode

Functions
	TEST_F (FutureDAGTest, SingleNode)
	TEST_F (FutureDAGTest, RemoveSingleNode)
	TEST_F (FutureDAGTest, RemoveNodeComplex)
	TEST_F (FutureDAGTest, ResetDAG)
	TEST_F (FutureDAGTest, FanOut)
	TEST_F (FutureDAGTest, FanIn)
	TEST_F (FutureDAGTest, FanOutFanIn)
	TEST_F (FutureDAGTest, Complex)
	TEST_F (FutureDAGTest, ThrowBegin)
	TEST_F (FutureDAGTest, ThrowEnd)
	TEST_F (FutureDAGTest, Cycle1)
	TEST_F (FutureDAGTest, Cycle2)
	TEST_F (FutureDAGTest, Cycle3)
	TEST_F (FutureDAGTest, DestroyBeforeComplete)

Variables
FutureDAG::FutureFunc	makeFutureFunc = [] { return makeFuture(); }
FutureDAG::FutureFunc	throwFunc

Function Documentation

TEST_F	(	FutureDAGTest	,
		SingleNode
	)

Definition at line 101 of file FutureDAGTest.cpp.

References add, and ASSERT_NO_THROW.

                                  {
  add();
  ASSERT_NO_THROW(dag->go().get());
  checkOrder();
}

TEST_F	(	FutureDAGTest	,
		RemoveSingleNode
	)

Definition at line 107 of file FutureDAGTest.cpp.

References add, and ASSERT_NO_THROW.

                                        {
  auto h1 = add();
  auto h2 = add();
  (void)h1;
  remove(h2);
  ASSERT_NO_THROW(dag->go().get());
  checkOrder();
}

TEST_F	(	FutureDAGTest	,
		RemoveNodeComplex
	)

Definition at line 116 of file FutureDAGTest.cpp.

References add, and ASSERT_NO_THROW.

                                         {
  auto h1 = add();
  auto h2 = add();
  auto h3 = add();
  dependency(h1, h3);
  dependency(h2, h1);
  remove(h3);
  remove(h2);
  remove(h1);
  ASSERT_NO_THROW(dag->go().get());
  checkOrder();
}

TEST_F	(	FutureDAGTest	,
		ResetDAG
	)

Definition at line 129 of file FutureDAGTest.cpp.

References add, and ASSERT_NO_THROW.

                                {
  auto h1 = add();
  auto h2 = add();
  auto h3 = add();
  dependency(h3, h1);
  dependency(h2, h3);

  reset();
  ASSERT_NO_THROW(dag->go().get());
  checkOrder();
}

TEST_F	(	FutureDAGTest	,
		FanOut
	)

Definition at line 141 of file FutureDAGTest.cpp.

References add, and ASSERT_NO_THROW.

                              {
  auto h1 = add();
  auto h2 = add();
  auto h3 = add();
  dependency(h1, h2);
  dependency(h1, h3);
  ASSERT_NO_THROW(dag->go().get());
  checkOrder();
}

TEST_F	(	FutureDAGTest	,
		FanIn
	)

Definition at line 151 of file FutureDAGTest.cpp.

References add, and ASSERT_NO_THROW.

                             {
  auto h1 = add();
  auto h2 = add();
  auto h3 = add();
  dependency(h1, h3);
  dependency(h2, h3);
  ASSERT_NO_THROW(dag->go().get());
  checkOrder();
}

TEST_F	(	FutureDAGTest	,
		FanOutFanIn
	)

Definition at line 161 of file FutureDAGTest.cpp.

References add, and ASSERT_NO_THROW.

                                   {
  auto h1 = add();
  auto h2 = add();
  auto h3 = add();
  auto h4 = add();
  dependency(h1, h3);
  dependency(h1, h2);
  dependency(h2, h4);
  dependency(h3, h4);
  ASSERT_NO_THROW(dag->go().get());
  checkOrder();
}

TEST_F	(	FutureDAGTest	,
		Complex
	)

Definition at line 174 of file FutureDAGTest.cpp.

References add, ASSERT_NO_THROW, C, D, and M.

                               {
  auto A = add();
  auto B = add();
  auto C = add();
  auto D = add();
  auto E = add();
  auto F = add();
  auto G = add();
  auto H = add();
  auto I = add();
  auto J = add();
  auto K = add();
  auto L = add();
  auto M = add();
  auto N = add();

  dependency(A, B);
  dependency(A, C);
  dependency(A, D);
  dependency(A, J);
  dependency(C, H);
  dependency(D, E);
  dependency(E, F);
  dependency(E, G);
  dependency(F, H);
  dependency(G, H);
  dependency(H, I);
  dependency(J, K);
  dependency(K, L);
  dependency(K, M);
  dependency(L, N);
  dependency(I, N);

  ASSERT_NO_THROW(dag->go().get());
  checkOrder();
}

TEST_F	(	FutureDAGTest	,
		ThrowBegin
	)

Definition at line 217 of file FutureDAGTest.cpp.

References EXPECT_THROW, makeFutureFunc, and throwFunc.

                                  {
  auto h1 = dag->add(throwFunc);
  auto h2 = dag->add(makeFutureFunc);
  dag->dependency(h1, h2);
  EXPECT_THROW(dag->go().get(), std::runtime_error);
}

TEST_F	(	FutureDAGTest	,
		ThrowEnd
	)

Definition at line 224 of file FutureDAGTest.cpp.

References EXPECT_THROW, makeFutureFunc, and throwFunc.

                                {
  auto h1 = dag->add(makeFutureFunc);
  auto h2 = dag->add(throwFunc);
  dag->dependency(h1, h2);
  EXPECT_THROW(dag->go().get(), std::runtime_error);
}

TEST_F	(	FutureDAGTest	,
		Cycle1
	)

Definition at line 231 of file FutureDAGTest.cpp.

References add, and EXPECT_THROW.

                              {
  auto h1 = add();
  dependency(h1, h1);
  EXPECT_THROW(dag->go().get(), std::runtime_error);
}

TEST_F	(	FutureDAGTest	,
		Cycle2
	)

Definition at line 237 of file FutureDAGTest.cpp.

References add, and EXPECT_THROW.

                              {
  auto h1 = add();
  auto h2 = add();
  dependency(h1, h2);
  dependency(h2, h1);
  EXPECT_THROW(dag->go().get(), std::runtime_error);
}

TEST_F	(	FutureDAGTest	,
		Cycle3
	)

Definition at line 245 of file FutureDAGTest.cpp.

References add, and EXPECT_THROW.

                              {
  auto h1 = add();
  auto h2 = add();
  auto h3 = add();
  dependency(h1, h2);
  dependency(h2, h3);
  dependency(h3, h1);
  EXPECT_THROW(dag->go().get(), std::runtime_error);
}

TEST_F	(	FutureDAGTest	,
		DestroyBeforeComplete
	)

Definition at line 255 of file FutureDAGTest.cpp.

References ASSERT_NO_THROW, folly::FutureDAG::create(), f, makeFutureFunc, folly::gen::move, and folly::pushmi::detail::t.

                                             {
  auto barrier = std::make_shared<boost::barrier>(2);
  Future<Unit> f;
  {
    auto localDag = FutureDAG::create();
    auto h1 = localDag->add([barrier] {
      auto p = std::make_shared<Promise<Unit>>();
      std::thread t([p, barrier] {
        barrier->wait();
        p->setValue();
      });
      t.detach();
      return p->getFuture();
    });
    auto h2 = localDag->add(makeFutureFunc);
    localDag->dependency(h1, h2);
    f = localDag->go();
  }
  barrier->wait();
  ASSERT_NO_THROW(std::move(f).get());
}

Variable Documentation

FutureDAG::FutureFunc makeFutureFunc = [] { return makeFuture(); }

Definition at line 211 of file FutureDAGTest.cpp.

Referenced by TEST_F().

FutureDAG::FutureFunc throwFunc

Initial value:

= [] {
  return makeFuture<Unit>(std::runtime_error("oops"));
}

Definition at line 213 of file FutureDAGTest.cpp.

Referenced by TEST_F().