Function ACE_TMAIN

tests/DCPS/ConfigFile/ConfigFile.cpp:34–261

using namespace OpenDDS::DCPS;

int
ACE_TMAIN(int argc, ACE_TCHAR* argv[])
{
  try
  {
    DDS::DomainParticipantFactory_var dpf =
      TheParticipantFactoryWithArgs(argc, argv);
    TEST_CHECK(dpf.in() != 0);

    // From commandline
    TEST_CHECK(TheServiceParticipant->config_store()->get("MY_CONFIG_KEY1", "") == "value1");
    // From environment variable
    TEST_CHECK(TheServiceParticipant->config_store()->get("MY_CONFIG_KEY2", "") == "value2");
    TEST_CHECK(OpenDDS::DCPS::DCPS_debug_level == 1);
    TEST_CHECK(TheServiceParticipant->n_chunks() == 10);
    TEST_CHECK(TheServiceParticipant->association_chunk_multiplier() == 5);
    TEST_CHECK(TheServiceParticipant->liveliness_factor() == 70);
    TEST_CHECK(TheServiceParticipant->bit_transport_port() == 1234);
    TEST_CHECK(TheServiceParticipant->bit_lookup_duration_msec() == 1000);
    TEST_CHECK(TheServiceParticipant->get_BIT() == false);
    TEST_CHECK(OpenDDS::DCPS::Transport_debug_level == 1);
    TEST_CHECK(TheServiceParticipant->pending_timeout() == TimeDuration(10));
    TEST_CHECK(TheServiceParticipant->publisher_content_filter() == false);
    TEST_CHECK(TheServiceParticipant->get_default_discovery() == "MyDefaultDiscovery");
    TEST_CHECK(TheServiceParticipant->default_address() == NetworkAddress(u_short(0), "127.0.0.1"));
    TEST_CHECK(TheServiceParticipant->event_dispatcher_thread_count() == 4);
    TEST_CHECK(TheServiceParticipant->federation_recovery_duration() == 800);
    TEST_CHECK(TheServiceParticipant->federation_initial_backoff_seconds() == 2);
    TEST_CHECK(TheServiceParticipant->federation_backoff_multiplier() == 3);
    TEST_CHECK(TheServiceParticipant->federation_liveliness() == 70);

    TransportInst_rch inst = TransportRegistry::instance()->get_inst("mytcp");
    TEST_CHECK(inst);

    TcpInst_rch tcp_inst = dynamic_rchandle_cast<TcpInst>(inst);
    TEST_CHECK(tcp_inst);

    // tcp_inst->dump(std::cout);

    TEST_CHECK(tcp_inst->name() == "mytcp");
    TEST_CHECK(tcp_inst->max_packet_size() == 2000000000);
    TEST_CHECK(tcp_inst->max_samples_per_packet() == 3);
    TEST_CHECK(tcp_inst->optimum_packet_size() == 2048);
    TEST_CHECK(tcp_inst->thread_per_connection() == true);
    TEST_CHECK(tcp_inst->event_dispatcher_threads() == 3);
    TEST_CHECK(tcp_inst->datalink_release_delay() == 5000);
    TEST_CHECK(tcp_inst->datalink_control_chunks() == 16);
    TEST_CHECK(tcp_inst->local_address() == "localhost:");
    TEST_CHECK(tcp_inst->enable_nagle_algorithm() == true);
    TEST_CHECK(tcp_inst->send_buffer_size() == 131072);
    TEST_CHECK(tcp_inst->rcv_buffer_size() == 262144);
    TEST_CHECK(tcp_inst->conn_retry_initial_delay() == 1000);
    TEST_CHECK(tcp_inst->conn_retry_backoff_multiplier() == 4);
    TEST_CHECK(tcp_inst->conn_retry_attempts() == 4);
    TEST_CHECK(tcp_inst->passive_reconnect_duration() == 4000);
    TEST_CHECK(tcp_inst->max_output_pause_period() == 1000);

    TransportInst_rch inst2 = TransportRegistry::instance()->get_inst("anothertcp");