summaryrefslogtreecommitdiff
path: root/ACE/ace/UUID.cpp
diff options
context:
space:
mode:
authorWilliam R. Otte <wotte@dre.vanderbilt.edu>2008-03-04 13:56:48 +0000
committerWilliam R. Otte <wotte@dre.vanderbilt.edu>2008-03-04 13:56:48 +0000
commitc4078c377d74290ebe4e66da0b4975da91732376 (patch)
tree1816ef391e42a07929304908ac0e21f4c2f6cb7b /ACE/ace/UUID.cpp
parent700d1c1a6be348c6c70a2085e559baeb8f4a62ea (diff)
downloadATCD-c4078c377d74290ebe4e66da0b4975da91732376.tar.gz
swap in externals for ACE and TAO
Diffstat (limited to 'ACE/ace/UUID.cpp')
-rw-r--r--ACE/ace/UUID.cpp554
1 files changed, 0 insertions, 554 deletions
diff --git a/ACE/ace/UUID.cpp b/ACE/ace/UUID.cpp
deleted file mode 100644
index f65475b3cf8..00000000000
--- a/ACE/ace/UUID.cpp
+++ /dev/null
@@ -1,554 +0,0 @@
-//$Id$
-
-#include "ace/UUID.h"
-#include "ace/Guard_T.h"
-
-#if !defined (__ACE_INLINE__)
-#include "ace/UUID.inl"
-#endif /* __ACE_INLINE__ */
-
-#include "ace/Log_Msg.h"
-#include "ace/OS_NS_stdio.h"
-#include "ace/OS_NS_string.h"
-#include "ace/OS_NS_sys_time.h"
-#include "ace/OS_NS_netdb.h"
-#include "ace/OS_NS_unistd.h"
-#include "ace/ACE.h"
-
-ACE_RCSID (ace,
- UUID,
- "$Id$")
-
-
-ACE_BEGIN_VERSIONED_NAMESPACE_DECL
-
-namespace ACE_Utils
-{
- UUID_Node::UUID_Node (void)
- {
- for (int i = 0; i < UUID_Node::NODE_ID_SIZE; ++i)
- node_ID_[i] = 0;
- }
-
- UUID_Node::Node_ID&
- UUID_Node::node_ID (void)
- {
- return node_ID_;
- }
-
- void
- UUID_Node::node_ID (Node_ID& node_ID)
- {
- for (int i = 0; i < UUID_Node::NODE_ID_SIZE; ++i)
- node_ID_[i] = node_ID[i];
- }
-
- UUID UUID::NIL_UUID;
-
- /// Construct a nil UUID. Such a UUID has every one of it's data
- /// elements set to zero.
- UUID::UUID (void)
- : time_low_ (0),
- time_mid_ (0),
- time_hi_and_version_ (0),
- clock_seq_hi_and_reserved_ (0),
- clock_seq_low_ (0),
- node_ (0),
- node_release_ (true),
- as_string_ (0)
- {
- ACE_NEW (node_,
- UUID_Node);
- }
-
- /// Construct a UUID from a string representation of an UUID.
- UUID::UUID (const ACE_CString& uuid_string)
- : time_low_ (0),
- time_mid_ (0),
- time_hi_and_version_ (0),
- clock_seq_hi_and_reserved_ (0),
- clock_seq_low_ (0),
- node_ (0),
- node_release_ (true),
- as_string_ (0)
- {
- ACE_NEW (node_,
- UUID_Node);
-
- this->from_string_i (uuid_string);
- }
-
- UUID::UUID (const UUID &right)
- : time_low_ (right.time_low_),
- time_mid_ (right.time_mid_),
- time_hi_and_version_ (right.time_hi_and_version_),
- clock_seq_hi_and_reserved_ (right.clock_seq_hi_and_reserved_),
- clock_seq_low_ (right.clock_seq_low_),
- as_string_ (0)
- {
- ACE_NEW (node_,
- UUID_Node (*right.node_));
- }
-
- UUID::~UUID (void)
- {
- if (node_release_)
- delete node_;
-
- if (as_string_ != 0)
- delete as_string_;
- }
-
- const ACE_CString*
- UUID::to_string (void)
- {
- /// Only compute the string representation once.
- if (as_string_ == 0)
- {
- // Get a buffer exactly the correct size. Use the nil UUID as a
- // gauge. Don't forget the trailing nul.
- size_t UUID_STRING_LENGTH = 36 + thr_id_.length () + pid_.length ();
- char *buf = 0;
-
- if ((thr_id_.length () != 0) && (pid_.length () != 0))
- {
- UUID_STRING_LENGTH += 2; //for '-'
- ACE_NEW_RETURN (buf,
- char[UUID_STRING_LENGTH + 1],
- 0);
-
- ACE_OS::sprintf (buf,
- "%8.8x-%4.4x-%4.4x-%2.2x%2.2x-%2.2x%2.2x%2.2x%2.2x%2.2x%2.2x-%s-%s",
- this->time_low_,
- this->time_mid_,
- this->time_hi_and_version_,
- this->clock_seq_hi_and_reserved_,
- this->clock_seq_low_,
- (this->node_->node_ID ()) [0],
- (this->node_->node_ID ()) [1],
- (this->node_->node_ID ()) [2],
- (this->node_->node_ID ()) [3],
- (this->node_->node_ID ()) [4],
- (this->node_->node_ID ()) [5],
- thr_id_.c_str (),
- pid_.c_str ()
- );
- }
- else
- {
- ACE_NEW_RETURN (buf,
- char[UUID_STRING_LENGTH + 1],
- 0);
-
- ACE_OS::sprintf (buf,
- "%8.8x-%4.4x-%4.4x-%2.2x%2.2x-%2.2x%2.2x%2.2x%2.2x%2.2x%2.2x",
- this->time_low_,
- this->time_mid_,
- this->time_hi_and_version_,
- this->clock_seq_hi_and_reserved_,
- this->clock_seq_low_,
- (this->node_->node_ID ()) [0],
- (this->node_->node_ID ()) [1],
- (this->node_->node_ID ()) [2],
- (this->node_->node_ID ()) [3],
- (this->node_->node_ID ()) [4],
- (this->node_->node_ID ()) [5]
- );
- }
-
- // We allocated 'buf' above dynamically, so we shouldn't use
- // ACE_NEW_RETURN here to avoid a possible memory leak.
- ACE_NEW_NORETURN (this->as_string_,
- ACE_CString (buf, UUID_STRING_LENGTH));
-
- // we first free the dynamically allocated 'buf'.
- delete [] buf;
-
- // then we test that ACE_NEW succeded for 'as_string_'
- // if not, we return 0 (NULL) to indicate failure.
- if (this->as_string_ == 0 )
- return 0;
- }
-
- return as_string_;
- }
-
- void
- UUID::from_string_i (const ACE_CString& uuid_string)
- {
- if (uuid_string.length () < NIL_UUID.to_string ()->length ())
- {
- ACE_ERROR ((LM_ERROR,
- "%N ACE_UUID::from_string_i - "
- "IllegalArgument (incorrect string length)\n"));
- return;
- }
-
- /// Special case for the nil UUID.
- if (uuid_string == *NIL_UUID.to_string ())
- {
- bool copy_constructor_not_supported = false;
- ACE_ASSERT (copy_constructor_not_supported);
- //*this = NIL_UUID;
- ACE_UNUSED_ARG (copy_constructor_not_supported);
- return;
- }
-
- unsigned int time_low;
- unsigned int time_mid;
- unsigned int time_hi_and_version;
- unsigned int clock_seq_hi_and_reserved;
- unsigned int clock_seq_low;
- unsigned int node [UUID_Node::NODE_ID_SIZE];
- char thr_pid_buf [BUFSIZ];
-
- if (uuid_string.length () == NIL_UUID.to_string ()->length ())
- {
- // This might seem quite strange this being in ACE, but it
- // seems to be a bit difficult to write a facade for ::sscanf
- // because some compilers dont support vsscanf, including
- // MSVC. It appears that most platforms support sscanf though
- // so we need to use it directly.
- const int nScanned =
-#if defined (ACE_HAS_TR24731_2005_CRT)
- sscanf_s (
-#else
- ::sscanf (
-#endif /* ACE_HAS_TR24731_2005_CRT */
- uuid_string.c_str (),
- "%8x-%4x-%4x-%2x%2x-%2x%2x%2x%2x%2x%2x",
- &time_low,
- &time_mid,
- &time_hi_and_version,
- &clock_seq_hi_and_reserved,
- &clock_seq_low,
- &node[0],
- &node[1],
- &node[2],
- &node[3],
- &node[4],
- &node[5]
- );
-
- if (nScanned != 11)
- {
- ACE_DEBUG ((LM_DEBUG,
- "UUID::from_string_i - "
- "IllegalArgument (invalid string representation)\n"));
- return;
- }
- }
- else
- {
- const int nScanned =
-#if defined (ACE_HAS_TR24731_2005_CRT)
- sscanf_s (uuid_string.c_str (),
- "%8x-%4x-%4x-%2x%2x-%2x%2x%2x%2x%2x%2x-%s",
- &time_low,
- &time_mid,
- &time_hi_and_version,
- &clock_seq_hi_and_reserved,
- &clock_seq_low,
- &node[0],
- &node[1],
- &node[2],
- &node[3],
- &node[4],
- &node[5],
- thr_pid_buf,
- BUFSIZ
- );
-#else
- ::sscanf (uuid_string.c_str (),
- "%8x-%4x-%4x-%2x%2x-%2x%2x%2x%2x%2x%2x-%s",
- &time_low,
- &time_mid,
- &time_hi_and_version,
- &clock_seq_hi_and_reserved,
- &clock_seq_low,
- &node[0],
- &node[1],
- &node[2],
- &node[3],
- &node[4],
- &node[5],
- thr_pid_buf
- );
-#endif /* ACE_HAS_TR24731_2005_CRT */
-
- if (nScanned != 12)
- {
- ACE_DEBUG ((LM_DEBUG,
- "ACE_UUID::from_string_i - "
- "IllegalArgument (invalid string representation)\n"));
- return;
- }
- }
-
- this->time_low_ = static_cast<ACE_UINT32> (time_low);
- this->time_mid_ = static_cast<ACE_UINT16> (time_mid);
- this->time_hi_and_version_ = static_cast<ACE_UINT16> (time_hi_and_version);
- this->clock_seq_hi_and_reserved_ = static_cast<u_char> (clock_seq_hi_and_reserved);
- this->clock_seq_low_ = static_cast<u_char> (clock_seq_low);
-
- UUID_Node::Node_ID node_id;
- for (int i = 0; i < UUID_Node::NODE_ID_SIZE; ++i)
- node_id [i] = static_cast<u_char> (node[i]);
-
- this->node_->node_ID (node_id);
-
- // Support varient 10- only
- if ((this->clock_seq_hi_and_reserved_ & 0xc0) != 0x80 && (this->clock_seq_hi_and_reserved_ & 0xc0) != 0xc0)
- {
- ACE_DEBUG ((LM_DEBUG,
- "ACE_UUID::from_string_i - "
- "IllegalArgument (unsupported variant)\n"));
- return;
- }
-
- /// Support versions 1, 3, and 4 only
- ACE_UINT16 V1 = this->time_hi_and_version_;
-
- if ((V1 & 0xF000) != 0x1000 &&
- (V1 & 0xF000) != 0x3000 &&
- (V1 & 0xF000) != 0x4000)
- {
- ACE_DEBUG ((LM_DEBUG,
- "ACE_UUID::from_string_i - "
- "IllegalArgument (unsupported version)\n"));
- return;
- }
-
- if ((this->clock_seq_hi_and_reserved_ & 0xc0) == 0xc0)
- {
- if (uuid_string.length () == NIL_UUID.to_string ()->length ())
- {
- ACE_DEBUG ((LM_DEBUG,
- "ACE_UUID::from_string_i - "
- "IllegalArgument (Missing Thread and Process Id)\n"));
- return;
- }
- ACE_CString thr_pid_str (thr_pid_buf);
- ssize_t pos = static_cast<ssize_t> (thr_pid_str.find ('-'));
- if (pos == -1)
- ACE_DEBUG ((LM_DEBUG,
- "ACE_UUID::from_string_i - "
- "IllegalArgument (Thread and Process Id format incorrect)\n"));
-
- this->thr_id_ = thr_pid_str.substr (0, pos);
- this->pid_ = thr_pid_str.substr (pos+1, thr_pid_str.length ()-pos-1);
- }
- }
-
- UUID_Generator::UUID_Generator ()
- : time_last_ (0),
- destroy_lock_ (true)
- {
- ACE_NEW (lock_,
- ACE_SYNCH_MUTEX);
- }
-
- UUID_Generator::~UUID_Generator ()
- {
- if (destroy_lock_)
- delete lock_;
- }
-
- void
- UUID_Generator::init (void)
- {
- ACE_OS::macaddr_node_t macaddress;
- int result = ACE_OS::getmacaddress (&macaddress);
-
- UUID_Node::Node_ID node_id;
- if (result != -1)
- {
-// ACE_DEBUG ((LM_DEBUG,
-// "%02X-%02X-%02X-%02X-%02X-%02X\n",
-// macaddress.node [0],
-// macaddress.node [1],
-// macaddress.node [2],
-// macaddress.node [3],
-// macaddress.node [4],
-// macaddress.node [5]));
-
- ACE_OS::memcpy (&node_id,
- macaddress.node,
- sizeof (node_id));
- }
- else
- {
- node_id [0] = static_cast<u_char> (ACE_OS::rand ());
- node_id [1] = static_cast<u_char> (ACE_OS::rand ());
- node_id [2] = static_cast<u_char> (ACE_OS::rand ());
- node_id [3] = static_cast<u_char> (ACE_OS::rand ());
- node_id [4] = static_cast<u_char> (ACE_OS::rand ());
- node_id [5] = static_cast<u_char> (ACE_OS::rand ());
- }
-
- this->get_timestamp (time_last_);
-
- {
- ACE_GUARD (ACE_SYNCH_MUTEX, ace_mon, *lock_);
- uuid_state_.timestamp = time_last_;
- uuid_state_.node.node_ID (node_id);
- }
- }
-
- void
- UUID_Generator::generate_UUID (UUID& uuid,ACE_UINT16 version,
- u_char variant)
- {
- UUID_Time timestamp;
- ACE_UINT16 clock_sequence;
-
- this->get_timestamp_and_clocksequence (timestamp,
- clock_sequence);
-
- // Construct a Version 1 UUID with the information in the arguements.
- uuid.time_low (static_cast<ACE_UINT32> (timestamp & 0xFFFFFFFF));
- uuid.time_mid (static_cast<ACE_UINT16> ((timestamp >> 32) & 0xFFFF));
-
- ACE_UINT16 tHAV = static_cast<ACE_UINT16> ((timestamp >> 48) & 0xFFFF);
- tHAV |= (version << 12);
- uuid.time_hi_and_version (tHAV);
-
- u_char cseqHAV;
- uuid.clock_seq_low (static_cast<u_char> (clock_sequence & 0xFF));
- cseqHAV = static_cast<u_char> ((clock_sequence & 0x3f00) >> 8);
- uuid_state_.timestamp = timestamp;
-
- cseqHAV |= variant;
- uuid.clock_seq_hi_and_reserved (cseqHAV);
- uuid.node (& (uuid_state_.node));
-
- if (variant == 0xc0)
- {
- ACE_Thread_ID thread_id;
- char buf [BUFSIZ];
- thread_id.to_string (buf);
- uuid.thr_id (buf);
-
- ACE_OS::sprintf (buf,
- "%d",
- static_cast<int> (ACE_OS::getpid ()));
- uuid.pid (buf);
- }
- }
-
- UUID*
- UUID_Generator::generate_UUID (ACE_UINT16 version, u_char variant)
- {
- UUID* uuid;
- ACE_NEW_RETURN (uuid,
- UUID,
- 0);
-
- this->generate_UUID (*uuid, version, variant);
- return uuid;
- }
-
- /// Obtain a new timestamp. If UUID's are being generated too quickly
- /// the clock sequence will be incremented
- void
- UUID_Generator::get_timestamp (UUID_Time& timestamp)
- {
- ACE_GUARD (ACE_SYNCH_MUTEX, mon, *lock_);
-
- this->get_systemtime (timestamp);
-
- // Account for the clock being set back. Increment the clock /
- // sequence.
- if (timestamp <= time_last_)
- {
- uuid_state_.clock_sequence = static_cast<ACE_UINT16>
- ((uuid_state_.clock_sequence + 1) & ACE_UUID_CLOCK_SEQ_MASK);
- }
- // If the system time ticked since the last UUID was
- // generated. Set / the clock sequence back.
- else if (timestamp > time_last_)
- {
- uuid_state_.clock_sequence = 0;
- }
-
- time_last_ = timestamp;
- }
-
- void
- UUID_Generator::get_timestamp_and_clocksequence (UUID_Time& timestamp,
- ACE_UINT16& clock_sequence)
- {
- ACE_GUARD (ACE_SYNCH_MUTEX, mon, *lock_);
-
- this->get_systemtime (timestamp);
-
- // Account for the clock being set back. Increment the clock /
- // sequence.
- if (timestamp <= time_last_)
- uuid_state_.clock_sequence = static_cast<u_char> ((uuid_state_.clock_sequence + 1) & ACE_UUID_CLOCK_SEQ_MASK);
-
- // If the system time ticked since the last UUID was
- // generated. Set / the clock sequence back.
- else if (timestamp > time_last_)
- uuid_state_.clock_sequence = 0;
-
- time_last_ = timestamp;
- clock_sequence = uuid_state_.clock_sequence;
- }
-
- /**
- * ACE_Time_Value is in POSIX time, seconds since Jan 1, 1970. UUIDs use
- * time in 100ns ticks since 15 October 1582. The difference is:
- * 15 Oct 1582 - 1 Jan 1600: 17 days in Oct, 30 in Nov, 31 in Dec +
- * 17 years and 4 leap days (1584, 88, 92 and 96)
- * 1 Jan 1600 - 1 Jan 1900: 3 centuries + 73 leap days ( 25 in 17th cent.
- * and 24 each in 18th and 19th centuries)
- * 1 Jan 1900 - 1 Jan 1970: 70 years + 17 leap days.
- * This adds up, in days: (17+30+31+365*17+4)+ (365*300+73)+ (365*70+17) or
- * 122192928000000000U (0x1B21DD213814000) 100 ns ticks.
- */
- void
- UUID_Generator::get_systemtime (UUID_Time & timestamp)
- {
- const UUID_Time timeOffset =
-#if defined (ACE_LACKS_UNSIGNEDLONGLONG_T)
- ACE_U_LongLong (ACE_INT64_LITERAL (0x1B21DD213814000));
-#elif defined (ACE_LACKS_LONGLONG_T)
- ACE_U_LongLong (0x13814000u, 0x1B21DD2u);
-#else
- ACE_UINT64_LITERAL (0x1B21DD213814000);
-#endif /* ACE_LACKS_UNSIGNEDLONGLONG_T */
-
- /// Get the time of day, convert to 100ns ticks then add the offset.
- ACE_Time_Value now = ACE_OS::gettimeofday ();
- ACE_UINT64 time;
- now.to_usec (time);
- time = time * 10;
- timestamp = time + timeOffset;
-}
-
- ACE_SYNCH_MUTEX*
- UUID_Generator::lock (void)
- {
- return this->lock_;
- }
-
- void
- UUID_Generator::lock (ACE_SYNCH_MUTEX* lock,
- bool release_lock)
- {
- if (this->destroy_lock_)
- delete this->lock_;
-
- this->lock_ = lock;
- this->destroy_lock_ = release_lock;
- }
-
-}
-
-#if defined (ACE_HAS_EXPLICIT_STATIC_TEMPLATE_MEMBER_INSTANTIATION)
-template ACE_Singleton<ACE_Utils::UUID_Generator, ACE_SYNCH_MUTEX> *
- ACE_Singleton<ACE_Utils::UUID_Generator, ACE_SYNCH_MUTEX>::singleton_;
-#endif /* ACE_HAS_EXPLICIT_STATIC_TEMPLATE_MEMBER_INSTANTIATION */
-
-ACE_END_VERSIONED_NAMESPACE_DECL