1 files changed, 94 insertions, 0 deletions
diff --git a/ACE/TAO/tao/RTCORBA/RT_Mutex.cpp b/ACE/TAO/tao/RTCORBA/RT_Mutex.cpp
new file mode 100644
index 00000000000..d0c7b4c22ff
--- /dev/null
+++ b/ACE/TAO/tao/RTCORBA/RT_Mutex.cpp
@@ -0,0 +1,94 @@
+// $Id$
+#include "tao/RTCORBA/RT_Mutex.h"
+
+#if defined (TAO_HAS_CORBA_MESSAGING) && TAO_HAS_CORBA_MESSAGING != 0
+
+#include "tao/RTCORBA/RT_ORB.h"
+#include "tao/SystemException.h"
+#include "ace/OS_NS_sys_time.h"
+
+ACE_RCSID(RTCORBA,
+          RT_Mutex,
+          "$Id$")
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+TAO_RT_Mutex::~TAO_RT_Mutex (void)
+{
+}
+
+void
+TAO_RT_Mutex::lock (void)
+{
+  if (this->mu_.acquire () != 0)
+    throw ::CORBA::INTERNAL ();
+}
+
+void
+TAO_RT_Mutex::unlock (void)
+{
+  if (this->mu_.release () != 0)
+    throw ::CORBA::INTERNAL ();
+}
+
+CORBA::Boolean
+TAO_RT_Mutex::try_lock (TimeBase::TimeT wait_time)
+{
+  int result;
+
+  if (wait_time == 0)
+    // No wait.
+    result = this->mu_.tryacquire ();
+  else
+    {
+      // Wait for the specified amount of time before giving up.
+      // (wait_time units are 100ns.  See TimeBase.pidl)
+      TimeBase::TimeT seconds = wait_time / 10000000u;
+      TimeBase::TimeT microseconds = (wait_time % 10000000u) / 10;
+
+      ACE_Time_Value relative_time (ACE_U64_TO_U32 (seconds),
+                                    ACE_U64_TO_U32 (microseconds));
+
+      ACE_Time_Value absolute_time =
+        relative_time +
+        ACE_OS::gettimeofday ();
+
+      result = this->mu_.acquire (absolute_time);
+    }
+
+  if (result == 0)
+    return 1;
+  else if (result == -1 &&
+           (errno == ETIME ||
+            errno == EBUSY))
+    return 0;
+  else
+    // Some really bad error.
+    throw ::CORBA::INTERNAL ();
+}
+
+const char *
+TAO_RT_Mutex::name (void) const
+{
+  return 0;
+}
+
+///////////////////////////////////////////////////////////////////////////////
+#if (TAO_HAS_NAMED_RT_MUTEXES == 1)
+TAO_Named_RT_Mutex::TAO_Named_RT_Mutex (const char *name)
+  : name_ (name)
+{
+}
+
+const char *
+TAO_Named_RT_Mutex::name (void) const
+{
+  return this->name_.c_str ();
+}
+#endif /* TAO_HAS_NAMED_RT_MUTEXES == 1 */
+
+///////////////////////////////////////////////////////////////////////////////
+
+TAO_END_VERSIONED_NAMESPACE_DECL
+
+#endif /* TAO_HAS_CORBA_MESSAGING && TAO_HAS_CORBA_MESSAGING != 0 */