FederatorConfig.cpp File Reference

#include "DcpsInfo_pch.h"
#include "dds/DCPS/debug.h"
#include "FederatorConfig.h"
#include "FederatorC.h"
#include "ace/Configuration.h"
#include "ace/Configuration_Import_Export.h"
#include "ace/Log_Priority.h"
#include "ace/Log_Msg.h"
#include "ace/OS_NS_stdlib.h"
#include "ace/OS_NS_strings.h"
#include "ace/OS_NS_sys_time.h"
#include <algorithm>
#include "FederatorConfig.inl"

Include dependency graph for FederatorConfig.cpp:

Go to the source code of this file.

Namespaces
namespace	OpenDDS
namespace	OpenDDS::Federator
Functions
int	random_id ()
void	hash_endpoint (::CORBA::Long &hash, const char *const endpoint, const size_t len)
void	hash_endpoints (::CORBA::Long &hash, const ACE_TCHAR *const endpoints_str)
::CORBA::Long	hash_endpoints (int argc, ACE_TCHAR **argv)
Variables
const ACE_TCHAR	FEDERATION_DOMAIN_KEY [] = ACE_TEXT("FederationDomain")
const ACE_TCHAR	FEDERATION_ID_KEY [] = ACE_TEXT("FederationId")
const ACE_TCHAR	FEDERATION_PORT_KEY [] = ACE_TEXT("FederationPort")
OpenDDS::Federator::Config *	config_
	The configuration object.
Action	action_
	How to treat the next argument.

---

Function Documentation

void @101::hash_endpoint	(	::CORBA::Long &	hash,
		const char *const	endpoint,
		const size_t	len
	)			[static]

Definition at line 119 of file FederatorConfig.cpp.

Referenced by hash_endpoints().

{
  std::string toprint(endpoint, len);
  if (len > 0)
  {
    for (size_t i = 0; i < len; i++)
    {
      hash = 31 * hash + endpoint[i];
    }
  }
}

::CORBA::Long @101::hash_endpoints	(	int	argc,
		ACE_TCHAR **	argv
	)			[static]

Definition at line 153 of file FederatorConfig.cpp.

References hash_endpoints(), and random_id().

{
  ::CORBA::Long hash = 0;
  bool found = false;
  for (int i = 0; i < argc - 1; ++i) {
    if (ACE_OS::strncasecmp(argv[i], ACE_TEXT("-ORB"), ACE_OS::strlen(ACE_TEXT("-ORB"))) == 0 &&
        (ACE_OS::strcasecmp(ACE_TEXT("-ORBEndpoint"), argv[i]) == 0 ||
         ACE_OS::strcasecmp(ACE_TEXT("-ORBListenEndpoints"), argv[i]) == 0 ||
         ACE_OS::strcasecmp(ACE_TEXT("-ORBLaneEndpoint"), argv[i]) == 0 ||
         ACE_OS::strcasecmp(ACE_TEXT("-ORBLaneListenEndpoints"), argv[i]) == 0)) {
      const ACE_TCHAR* enpoints = argv[++i];
      hash_endpoints(hash, enpoints);
      found = true;
    }
  }
  if (!found) {
    hash = random_id();
  }
  return hash;
}

void @101::hash_endpoints	(	::CORBA::Long &	hash,
		const ACE_TCHAR *const	endpoints_str
	)			[static]

Definition at line 139 of file FederatorConfig.cpp.

References hash_endpoint().

Referenced by hash_endpoints().

{
  const ACE_TCHAR* delim = ACE_TEXT(";");
  const size_t len = ACE_OS::strlen(endpoints_str);
  const ACE_TCHAR* curr = endpoints_str;
  while (curr < endpoints_str + len) {
    const ACE_TCHAR* next = ACE_OS::strstr(curr, delim);
    if (next == 0)
      next = endpoints_str + len;
    hash_endpoint(hash, curr, (next - curr));
    curr = next + 1;
  }
}

int @101::random_id

(

)

[static]

Definition at line 110 of file FederatorConfig.cpp.

Referenced by hash_endpoints().

{
  ACE_UINT64 msec;
  ACE_OS::gettimeofday().msec(msec);
  ACE_OS::srand((unsigned int)msec);
  const int r = ACE_OS::rand();
  return r;
}

---

Variable Documentation

Action action_

How to treat the next argument.

Definition at line 54 of file FederatorConfig.cpp.

OpenDDS::Federator::Config* config_

The configuration object.

Definition at line 51 of file FederatorConfig.cpp.

const ACE_TCHAR FEDERATION_DOMAIN_KEY[] = ACE_TEXT("FederationDomain") [static]

Definition at line 29 of file FederatorConfig.cpp.

const ACE_TCHAR FEDERATION_ID_KEY[] = ACE_TEXT("FederationId") [static]

Definition at line 32 of file FederatorConfig.cpp.

const ACE_TCHAR FEDERATION_PORT_KEY[] = ACE_TEXT("FederationPort") [static]

Definition at line 35 of file FederatorConfig.cpp.

---