Service_Participant.cpp File Reference

#include "DCPS/DdsDcps_pch.h"
#include "debug.h"
#include "Service_Participant.h"
#include "BuiltInTopicUtils.h"
#include "DataDurabilityCache.h"
#include "GuidConverter.h"
#include "MonitorFactory.h"
#include "ConfigUtils.h"
#include "dds/DCPS/transport/framework/TransportRegistry.h"
#include "tao/ORB_Core.h"
#include "ace/Singleton.h"
#include "ace/Arg_Shifter.h"
#include "ace/Reactor.h"
#include "ace/Select_Reactor.h"
#include "ace/Configuration_Import_Export.h"
#include "ace/Service_Config.h"
#include "ace/Argv_Type_Converter.h"
#include "ace/Auto_Ptr.h"
#include "ace/Sched_Params.h"
#include "ace/Malloc_Allocator.h"
#include "RecorderImpl.h"
#include "ReplayerImpl.h"
#include "StaticDiscovery.h"
#include <fstream>
#include "Service_Participant.inl"

Include dependency graph for Service_Participant.cpp:

Go to the source code of this file.

Namespaces
namespace	OpenDDS
namespace	OpenDDS::DCPS
Defines
#define	DDS_DEFAULT_DISCOVERY_METHOD   Discovery::DEFAULT_REPO
Functions
void	set_log_file_name (const char *fname)
void	set_log_verbose (unsigned long verbose_logging)
static ACE_TString	OpenDDS::DCPS::config_fname (ACE_TEXT(""))
Variables
const size_t	OpenDDS::DCPS::DEFAULT_NUM_CHUNKS = 20
const size_t	OpenDDS::DCPS::DEFAULT_CHUNK_MULTIPLIER = 10
const int	OpenDDS::DCPS::DEFAULT_FEDERATION_RECOVERY_DURATION = 900
const int	OpenDDS::DCPS::DEFAULT_FEDERATION_INITIAL_BACKOFF_SECONDS = 1
const int	OpenDDS::DCPS::DEFAULT_FEDERATION_BACKOFF_MULTIPLIER = 2
const int	OpenDDS::DCPS::DEFAULT_FEDERATION_LIVELINESS = 60
const int	OpenDDS::DCPS::BIT_LOOKUP_DURATION_MSEC = 2000
static const ACE_TCHAR	OpenDDS::DCPS::DEFAULT_REPO_IOR [] = ACE_TEXT("file://repo.ior")
static const ACE_CString	OpenDDS::DCPS::DEFAULT_PERSISTENT_DATA_DIR = "OpenDDS-durable-data-dir"
static const ACE_TCHAR	OpenDDS::DCPS::COMMON_SECTION_NAME [] = ACE_TEXT("common")
static const ACE_TCHAR	OpenDDS::DCPS::DOMAIN_SECTION_NAME [] = ACE_TEXT("domain")
static const ACE_TCHAR	OpenDDS::DCPS::REPO_SECTION_NAME [] = ACE_TEXT("repository")
static const ACE_TCHAR	OpenDDS::DCPS::RTPS_SECTION_NAME [] = ACE_TEXT("rtps_discovery")
static bool	OpenDDS::DCPS::got_debug_level = false
static bool	OpenDDS::DCPS::got_use_rti_serialization = false
static bool	OpenDDS::DCPS::got_info = false
static bool	OpenDDS::DCPS::got_chunks = false
static bool	OpenDDS::DCPS::got_chunk_association_multiplier = false
static bool	OpenDDS::DCPS::got_liveliness_factor = false
static bool	OpenDDS::DCPS::got_bit_transport_port = false
static bool	OpenDDS::DCPS::got_bit_transport_ip = false
static bool	OpenDDS::DCPS::got_bit_lookup_duration_msec = false
static bool	OpenDDS::DCPS::got_global_transport_config = false
static bool	OpenDDS::DCPS::got_bit_flag = false
static bool	OpenDDS::DCPS::got_publisher_content_filter = false
static bool	OpenDDS::DCPS::got_transport_debug_level = false
static bool	OpenDDS::DCPS::got_pending_timeout = false
static bool	OpenDDS::DCPS::got_persistent_data_dir = false
static bool	OpenDDS::DCPS::got_default_discovery = false
static bool	OpenDDS::DCPS::got_log_fname = false
static bool	OpenDDS::DCPS::got_log_verbose = false
static bool	OpenDDS::DCPS::got_default_address = false

---

Define Documentation

#define DDS_DEFAULT_DISCOVERY_METHOD   Discovery::DEFAULT_REPO

Definition at line 142 of file Service_Participant.cpp.

---

Function Documentation

void @39::set_log_file_name

(

const char *

fname

)

[static]

Definition at line 48 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

{
#ifdef OPENDDS_SAFETY_PROFILE
  ACE_LOG_MSG->msg_ostream(fopen(fname, "a"), true);
#else
  std::ofstream* output_stream = new std::ofstream(fname, ios::app);
  if (output_stream->bad()) {
    delete output_stream;
  } else {
    ACE_LOG_MSG->msg_ostream(output_stream, true);
  }
#endif
  ACE_LOG_MSG->clr_flags(ACE_Log_Msg::STDERR | ACE_Log_Msg::LOGGER);
  ACE_LOG_MSG->set_flags(ACE_Log_Msg::OSTREAM);
}

void @39::set_log_verbose

(

unsigned long

verbose_logging

)

[static]

Definition at line 65 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

{
  // Code copied from TAO_ORB_Core::init() in
  // TAO version 1.6a_p13.

  typedef void (ACE_Log_Msg::*PTMF)(u_long);
  PTMF flagop = &ACE_Log_Msg::set_flags;
  u_long value;

  switch (verbose_logging)
    {
    case 0:
      flagop = &ACE_Log_Msg::clr_flags;
      value = ACE_Log_Msg::VERBOSE | ACE_Log_Msg::VERBOSE_LITE;
      break;
    case 1:
      value = ACE_Log_Msg::VERBOSE_LITE; break;
    default:
      value = ACE_Log_Msg::VERBOSE; break;
    }

  (ACE_LOG_MSG->*flagop)(value);

}

---