diff options
Diffstat (limited to 'ACE/ace/UUID.cpp')
| -rw-r--r-- | ACE/ace/UUID.cpp | 554 |
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 |