CheckpointIOTest Class Reference

Inheritance diagram for CheckpointIOTest:

Public Member Functions
	LIBMESH_CPPUNIT_TEST_SUITE (CheckpointIOTest)
	This test verifies that we can write files with the CheckpointIO object. More...
	CPPUNIT_TEST (testAsciiDistRepSplitter)
	CPPUNIT_TEST (testBinaryDistRepSplitter)
	CPPUNIT_TEST (testAsciiRepDistSplitter)
	CPPUNIT_TEST (testBinaryRepDistSplitter)
	CPPUNIT_TEST (testAsciiRepRepSplitter)
	CPPUNIT_TEST (testBinaryRepRepSplitter)
	CPPUNIT_TEST (testAsciiDistDistSplitter)
	CPPUNIT_TEST (testBinaryDistDistSplitter)
	CPPUNIT_TEST_SUITE_END ()
void	setUp ()
void	tearDown ()
template<typename MeshA , typename MeshB >
void	testSplitter (bool binary, bool using_distmesh, bool skip_partition=false)
void	testAsciiDistRepSplitter ()
void	testBinaryDistRepSplitter ()
void	testAsciiRepDistSplitter ()
void	testBinaryRepDistSplitter ()
void	testAsciiRepRepSplitter ()
void	testBinaryRepRepSplitter ()
void	testAsciiDistDistSplitter ()
void	testBinaryDistDistSplitter ()
void	testAsciiDistDistSplitterCache ()

Detailed Description

Definition at line 14 of file checkpoint.C.

Member Function Documentation

CPPUNIT_TEST() [1/8]

CheckpointIOTest::CPPUNIT_TEST

(

testAsciiDistRepSplitter

)

CPPUNIT_TEST() [2/8]

CheckpointIOTest::CPPUNIT_TEST

(

testBinaryDistRepSplitter

)

CPPUNIT_TEST() [3/8]

CheckpointIOTest::CPPUNIT_TEST

(

testAsciiRepDistSplitter

)

CPPUNIT_TEST() [4/8]

CheckpointIOTest::CPPUNIT_TEST

(

testBinaryRepDistSplitter

)

CPPUNIT_TEST() [5/8]

CheckpointIOTest::CPPUNIT_TEST

(

testAsciiRepRepSplitter

)

CPPUNIT_TEST() [6/8]

CheckpointIOTest::CPPUNIT_TEST

(

testBinaryRepRepSplitter

)

CPPUNIT_TEST() [7/8]

CheckpointIOTest::CPPUNIT_TEST

(

testAsciiDistDistSplitter

)

CPPUNIT_TEST() [8/8]

CheckpointIOTest::CPPUNIT_TEST

(

testBinaryDistDistSplitter

)

CPPUNIT_TEST_SUITE_END()

CheckpointIOTest::CPPUNIT_TEST_SUITE_END

(

)

LIBMESH_CPPUNIT_TEST_SUITE()

CheckpointIOTest::LIBMESH_CPPUNIT_TEST_SUITE

(

CheckpointIOTest

)

This test verifies that we can write files with the CheckpointIO object.

setUp()

void CheckpointIOTest::setUp ( )

inline

Definition at line 37 of file checkpoint.C.

  {
  }

tearDown()

void CheckpointIOTest::tearDown ( )

inline

Definition at line 41 of file checkpoint.C.

  {
  }

testAsciiDistDistSplitter()

void CheckpointIOTest::testAsciiDistDistSplitter ( )

inline

Definition at line 172 of file checkpoint.C.

  {
    LOG_UNIT_TEST;

    testSplitter<DistributedMesh, DistributedMesh>(false, true);
  }

testAsciiDistDistSplitterCache()

void CheckpointIOTest::testAsciiDistDistSplitterCache ( )

inline

Definition at line 186 of file checkpoint.C.

  {
    LOG_UNIT_TEST;

    testSplitter<DistributedMesh, DistributedMesh>(false, true, true);
  }

testAsciiDistRepSplitter()

void CheckpointIOTest::testAsciiDistRepSplitter ( )

inline

Definition at line 130 of file checkpoint.C.

  {
    LOG_UNIT_TEST;

    testSplitter<DistributedMesh, ReplicatedMesh>(false, true);
  }

testAsciiRepDistSplitter()

void CheckpointIOTest::testAsciiRepDistSplitter ( )

inline

Definition at line 144 of file checkpoint.C.

  {
    LOG_UNIT_TEST;

    testSplitter<ReplicatedMesh, DistributedMesh>(false, true);
  }

testAsciiRepRepSplitter()

void CheckpointIOTest::testAsciiRepRepSplitter ( )

inline

Definition at line 158 of file checkpoint.C.

  {
    LOG_UNIT_TEST;

    testSplitter<ReplicatedMesh, ReplicatedMesh>(false, false);
  }

testBinaryDistDistSplitter()

void CheckpointIOTest::testBinaryDistDistSplitter ( )

inline

Definition at line 179 of file checkpoint.C.

  {
    LOG_UNIT_TEST;

    testSplitter<DistributedMesh, DistributedMesh>(true, true);
  }

testBinaryDistRepSplitter()

void CheckpointIOTest::testBinaryDistRepSplitter ( )

inline

Definition at line 137 of file checkpoint.C.

  {
    LOG_UNIT_TEST;

    testSplitter<DistributedMesh, ReplicatedMesh>(true, true);
  }

testBinaryRepDistSplitter()

void CheckpointIOTest::testBinaryRepDistSplitter ( )

inline

Definition at line 151 of file checkpoint.C.

  {
    LOG_UNIT_TEST;

    testSplitter<ReplicatedMesh, DistributedMesh>(true, true);
  }

testBinaryRepRepSplitter()

void CheckpointIOTest::testBinaryRepRepSplitter ( )

inline

Definition at line 165 of file checkpoint.C.

  {
    LOG_UNIT_TEST;

    testSplitter<ReplicatedMesh, ReplicatedMesh>(true, false);
  }

testSplitter()

template<typename MeshA , typename MeshB >

void CheckpointIOTest::testSplitter ( bool  binary, bool  using_distmesh, bool  skip_partition = false  )

inline

Definition at line 47 of file checkpoint.C.

References TIMPI::Communicator::barrier(), libMesh::CheckpointIO::binary(), libMesh::MeshTools::Generation::build_square(), libMesh::ParallelObject::comm(), libMesh::CheckpointIO::current_n_processors(), libMesh::CheckpointIO::current_processor_ids(), distance(), mesh, libMesh::MeshBase::n_elem(), libMesh::MeshBase::n_partitions(), libMesh::ParallelObject::n_processors(), libMesh::CheckpointIO::parallel(), libMesh::MeshBase::partition(), libMesh::ParallelObject::processor_id(), libMesh::QUAD4, libMesh::CheckpointIO::read(), TIMPI::Communicator::size(), libMesh::MeshBase::skip_partitioning(), TIMPI::Communicator::sum(), TestCommWorld, and libMesh::CheckpointIO::write().

  {
    // The CheckpointIO-based splitter requires XDR.
#ifdef LIBMESH_HAVE_XDR

    // In this test, we partition the mesh into n_procs parts.  Don't
    // try to partition a DistributedMesh into more parts than we have
    // processors, though.
    const unsigned int n_procs = using_distmesh ?
      std::min(static_cast<processor_id_type>(2), TestCommWorld->size()) :
      2;

    // The number of elements in the original mesh.  For verification
    // later.
    dof_id_type original_n_elem = 0;

    const std::string filename =
      std::string("checkpoint_splitter.cp") + (binary ? "r" : "a");

    {
      MeshA mesh(*TestCommWorld);

      MeshTools::Generation::build_square(mesh,
                                          4,  4,
                                          0., 1.,
                                          0., 1.,
                                          QUAD4);

      // Store the number of elements that were in the original mesh.
      original_n_elem = mesh.n_elem();

      // Partition the mesh into n_procs pieces
      mesh.partition(n_procs);

      // Write out checkpoint files for each piece.  Since on a
      // ReplicatedMesh we might have more pieces than we do
      // processors, some processors may have to write out more than
      // one piece.
      CheckpointIO cpr(mesh);
      cpr.current_processor_ids().clear();
      for (processor_id_type pid = mesh.processor_id(); pid < n_procs; pid += mesh.n_processors())
        cpr.current_processor_ids().push_back(pid);
      cpr.current_n_processors() = n_procs;
      cpr.binary() = binary;
      cpr.parallel() = true;
      cpr.write(filename);
    }

    TestCommWorld->barrier();

    // Test that we can read in the files we wrote and sum up to the
    // same total number of elements.
    {
      MeshB mesh(*TestCommWorld);
      if (skip_partition)
        mesh.skip_partitioning(true);

      CheckpointIO cpr(mesh);
      cpr.current_n_processors() = n_procs;
      cpr.binary() = binary;
      cpr.read(filename);

      // If we decided to skip partitioning, then we shouldn't be
      // waiting for a partition() call to get our n_partitions()
      // cache in order
      if (skip_partition)
        CPPUNIT_ASSERT_EQUAL(mesh.n_partitions(), n_procs);

      std::size_t read_in_elements = 0;

      for (unsigned pid=mesh.processor_id(); pid<n_procs; pid += mesh.n_processors())
        {
          read_in_elements += std::distance(mesh.pid_elements_begin(pid),
                                            mesh.pid_elements_end(pid));
        }
      mesh.comm().sum(read_in_elements);

      // Verify that we read in exactly as many elements as we started with.
      CPPUNIT_ASSERT_EQUAL(static_cast<dof_id_type>(read_in_elements), original_n_elem);
    }
#endif // LIBMESH_HAVE_XDR
  }

---

The documentation for this class was generated from the following file:

• tests/mesh/checkpoint.C