undoing accidental deletion

1 files changed, 554 insertions, 0 deletions

diff --git a/ACE/ace/UUID.cpp b/ACE/ace/UUID.cpp
new file mode 100644
index 00000000000..f65475b3cf8
--- /dev/null
+++ b/ACE/ace/UUID.cpp
@@ -0,0 +1,554 @@
+//$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