message_tag.C

Go to the documentation of this file.

// libMesh includes
// Using *shims* here to test backwards compatibility via those
#include <libmesh/communicator.h>
#include <libmesh/message_tag.h>

#include "test_comm.h"
#include "libmesh_cppunit.h"


using namespace libMesh;

class MessageTagTest : public CppUnit::TestCase {
public:
  LIBMESH_CPPUNIT_TEST_SUITE( MessageTagTest );

  CPPUNIT_TEST( testGetUniqueTagAuto );
  CPPUNIT_TEST( testGetUniqueTagManual );

  CPPUNIT_TEST_SUITE_END();

private:
  std::vector<std::string> _number;

public:
  void setUp()
  {}

  void tearDown()
  {}



  void testGetUniqueTagAuto()
  {
    LOG_UNIT_TEST;

    // We need to explicitly duplicate the communicator first, because
    // the original might already have tags used by other unit tests

    Parallel::Communicator newcomm;

    newcomm.duplicate(*TestCommWorld);

    const int n_vals = 5;
    const int n_vals_in_scope = 3;
    std::vector<int> vals(n_vals);

    {
      std::vector<Parallel::MessageTag> tags(n_vals_in_scope);
      for (int i=0; i != n_vals_in_scope; ++i)
        {
          tags[i] = newcomm.get_unique_tag();
          vals[i] = tags[i].value();
          for (int j=0; j != i; ++j)
            {
              CPPUNIT_ASSERT(vals[i] != vals[j]);
            }
        }
    }

    // Even after we go out of scope those values should be used up
    for (int i=n_vals_in_scope; i != n_vals; ++i)
      {
        Parallel::MessageTag another_tag = newcomm.get_unique_tag();
        vals[i] = another_tag.value();
        for (int j=0; j != i; ++j)
          {
            CPPUNIT_ASSERT(vals[i] != vals[j]);
          }
      }
  }



  void testGetUniqueTagManual()
  {
    LOG_UNIT_TEST;

    // Here we'll use the standard communicator, because even if it
    // used these tags in other contexts it should have freed them for
    // reuse later.

    const int requests[] = {2, 4, 6, 8, 8, 6, 8, 123, 3141, 3142};

    for (const int i : requests)
      {
        Parallel::MessageTag manual_tag =
          TestCommWorld->get_unique_tag(i);
        CPPUNIT_ASSERT_EQUAL(i, manual_tag.value());
      }
  }

};

CPPUNIT_TEST_SUITE_REGISTRATION( MessageTagTest );