message_tag_unit.C File Reference

Go to the source code of this file.

Functions
void	testGetUniqueTagAuto ()
void	testGetUniqueTagManual ()
void	testGetUniqueTagOverlap ()
int	main (int argc, const char *const *argv)

Variables
Communicator *	TestCommWorld

Function Documentation

main()

int main	(	int	argc,
		const char *const *	argv
	)

Definition at line 104 of file message_tag_unit.C.

References TIMPI::TIMPIInit::comm(), TestCommWorld, testGetUniqueTagAuto(), testGetUniqueTagManual(), and testGetUniqueTagOverlap().

{
  TIMPI::TIMPIInit init(argc, argv);
  TestCommWorld = &init.comm();

  testGetUniqueTagAuto();
  testGetUniqueTagManual();
  testGetUniqueTagOverlap();

  return 0;
}

testGetUniqueTagAuto()

void testGetUniqueTagAuto

(

)

Definition at line 13 of file message_tag_unit.C.

References TIMPI::Communicator::duplicate(), TIMPI::Communicator::get_unique_tag(), TestCommWorld, and TIMPI::MessageTag::value().

Referenced by main().

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

    TIMPI::Communicator newcomm;

    TestCommWorld->duplicate(newcomm);

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

    {
      std::vector<TIMPI::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)
            {
              TIMPI_UNIT_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)
      {
        TIMPI::MessageTag another_tag = newcomm.get_unique_tag();
        vals[i] = another_tag.value();
        for (int j=0; j != i; ++j)
          {
            TIMPI_UNIT_ASSERT(vals[i] != vals[j]);
          }
      }
  }

testGetUniqueTagManual()

void testGetUniqueTagManual

(

)

Definition at line 53 of file message_tag_unit.C.

References TIMPI::Communicator::get_unique_tag(), TestCommWorld, and TIMPI::MessageTag::value().

Referenced by main().

  {
    // 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)
      {
        TIMPI::MessageTag manual_tag =
          TestCommWorld->get_unique_tag(i);
        TIMPI_UNIT_ASSERT(i == manual_tag.value());

        TIMPI::MessageTag tag_copy = manual_tag;
        TIMPI_UNIT_ASSERT(i == tag_copy.value());

        TIMPI::MessageTag tag_move = std::move(tag_copy);
        TIMPI_UNIT_ASSERT(i == tag_move.value());

        TIMPI::MessageTag stupidly_manual_tag(i);
        TIMPI_UNIT_ASSERT(i == stupidly_manual_tag.value());
      }
  }

testGetUniqueTagOverlap()

void testGetUniqueTagOverlap

(

)

Definition at line 79 of file message_tag_unit.C.

References TIMPI::Communicator::get_unique_tag(), TestCommWorld, and TIMPI::MessageTag::value().

Referenced by main().

  {
    // Try to request the same tag twice, make sure we don't get it
    // the second time.

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

    for (const int i : requests)
      {
        TIMPI::MessageTag manual_tag =
          TestCommWorld->get_unique_tag(i);
        TIMPI_UNIT_ASSERT(i == manual_tag.value());

        TIMPI::MessageTag dup_manual_tag =
          TestCommWorld->get_unique_tag(i);
        TIMPI_UNIT_ASSERT(i != dup_manual_tag.value());

        TIMPI::MessageTag tag_copy = manual_tag;
        TIMPI_UNIT_ASSERT(i == tag_copy.value());

        TIMPI::MessageTag tag_move = std::move(tag_copy);
        TIMPI_UNIT_ASSERT(i == tag_move.value());
      }
  }

Variable Documentation

TestCommWorld

Communicator* TestCommWorld

Definition at line 11 of file message_tag_unit.C.

Referenced by main(), testGetUniqueTagAuto(), testGetUniqueTagManual(), and testGetUniqueTagOverlap().