Function ACE_TMAIN

tests/security/ConcurrentAuthLimit/ConcurrentAuthLimit.cpp:211–348

}

int ACE_TMAIN(int argc, ACE_TCHAR* argv[])
{
  DDS::DomainParticipantFactory_var dpf = TheServiceParticipant->get_domain_participant_factory(argc, argv);

  // Parse options.
  OpenDDS::DCPS::String DDS_ROOT;
  bool no_limit = false;

  const char* value = ACE_OS::getenv("DDS_ROOT");
  if (value) {
    DDS_ROOT = value;
  }

  value = ACE_OS::getenv("no_limit");
  if (value && strcmp(value, "true") == 0) {
    no_limit = true;
  }

  ACE_DEBUG((LM_DEBUG, "DDS_ROOT = %C\n", DDS_ROOT.c_str()));
  ACE_DEBUG((LM_DEBUG, "no_limit = %d\n", no_limit));

  const DDS::DomainId_t domain = 4;
  const RcHandle<RtpsDiscovery> disc = make_rch<RtpsDiscovery>("RtpsDiscovery");

  if (!no_limit) {
    disc->config()->max_participants_in_authentication(1);
  }

  // Create sockets for the SPDP writers.
  GuidGenerator guid_generator;

  GUID_t writer1_guid;
  guid_generator.populate(writer1_guid);
  writer1_guid.entityId = ENTITYID_SPDP_BUILTIN_PARTICIPANT_WRITER;
  ACE_DEBUG((LM_DEBUG, "Writer1 guid is %C\n", LogGuid(writer1_guid).c_str()));
  SequenceNumber writer1_sequence;

  const ACE_INET_Addr writer1_addr(u_short(7575), "0.0.0.0");
  ACE_SOCK_Dgram writer1_socket;
  if (writer1_socket.open(writer1_addr)) {
    ACE_ERROR((LM_ERROR, ACE_TEXT("ERROR: failed to open writer1 socket\n")));
    return EXIT_FAILURE;
  }

  GUID_t writer2_guid;
  guid_generator.populate(writer2_guid);
  writer2_guid.entityId = ENTITYID_SPDP_BUILTIN_PARTICIPANT_WRITER;
  ACE_DEBUG((LM_DEBUG, "Writer2 guid is %C\n", LogGuid(writer2_guid).c_str()));
  SequenceNumber writer2_sequence;

  const ACE_INET_Addr writer2_addr(u_short(7576), "0.0.0.0");
  ACE_SOCK_Dgram writer2_socket;
  if (writer2_socket.open(writer2_addr)) {
    ACE_ERROR((LM_ERROR, ACE_TEXT("ERROR: failed to open writer2 socket\n")));
    return EXIT_FAILURE;
  }

  NetworkAddress multicast_address;