aboutsummaryrefslogtreecommitdiff
path: root/dep/ACE_wrappers/ace/Barrier.cpp
diff options
context:
space:
mode:
authormaximius <none@none>2009-10-17 15:35:07 -0700
committermaximius <none@none>2009-10-17 15:35:07 -0700
commit26b5e033ffde3d161382fc9addbfa99738379641 (patch)
treea344f369ca32945f787a02dee35c3dbe342bed7e /dep/ACE_wrappers/ace/Barrier.cpp
parentf21f47005dcb6b76e1abc9f35fbcd03eed191bff (diff)
*Massive cleanup (\n\n -> \n, *\n -> \n, cleanup for(...) to for (...), and some other cleanups by hand)
*Fix a possible crash in Spell::DoAllEffectOnTarget --HG-- branch : trunk
Diffstat (limited to 'dep/ACE_wrappers/ace/Barrier.cpp')
-rw-r--r--dep/ACE_wrappers/ace/Barrier.cpp36
1 files changed, 0 insertions, 36 deletions
diff --git a/dep/ACE_wrappers/ace/Barrier.cpp b/dep/ACE_wrappers/ace/Barrier.cpp
index 515a73f95a9..5597ea34c3c 100644
--- a/dep/ACE_wrappers/ace/Barrier.cpp
+++ b/dep/ACE_wrappers/ace/Barrier.cpp
@@ -1,34 +1,24 @@
// $Id: Barrier.cpp 80826 2008-03-04 14:51:23Z wotte $
-
#include "ace/Barrier.h"
-
#if defined (ACE_HAS_THREADS)
-
#if !defined (__ACE_INLINE__)
#include "ace/Barrier.inl"
#endif /* __ACE_INLINE__ */
-
#include "ace/Guard_T.h"
#include "ace/OS_NS_errno.h"
-
#if defined (ACE_HAS_DUMP)
# include "ace/Log_Msg.h"
#endif /* ACE_HAS_DUMP */
-
ACE_RCSID (ace,
Barrier,
"$Id: Barrier.cpp 80826 2008-03-04 14:51:23Z wotte $")
-
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
-
ACE_ALLOC_HOOK_DEFINE(ACE_Sub_Barrier)
-
void
ACE_Sub_Barrier::dump (void) const
{
#if defined (ACE_HAS_DUMP)
// ACE_TRACE ("ACE_Sub_Barrier::dump");
-
ACE_DEBUG ((LM_DEBUG, ACE_BEGIN_DUMP, this));
this->barrier_finished_.dump ();
ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("running_threads_ = %d"), this->running_threads_));
@@ -36,7 +26,6 @@ ACE_Sub_Barrier::dump (void) const
ACE_DEBUG ((LM_DEBUG, ACE_END_DUMP));
#endif /* ACE_HAS_DUMP */
}
-
ACE_Sub_Barrier::ACE_Sub_Barrier (unsigned int count,
ACE_Thread_Mutex &lock,
const ACE_TCHAR *name,
@@ -46,15 +35,12 @@ ACE_Sub_Barrier::ACE_Sub_Barrier (unsigned int count,
{
// ACE_TRACE ("ACE_Sub_Barrier::ACE_Sub_Barrier");
}
-
ACE_ALLOC_HOOK_DEFINE(ACE_Barrier)
-
void
ACE_Barrier::dump (void) const
{
#if defined (ACE_HAS_DUMP)
// ACE_TRACE ("ACE_Barrier::dump");
-
ACE_DEBUG ((LM_DEBUG, ACE_BEGIN_DUMP, this));
this->lock_.dump ();
ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("current_generation_ = %d"), this->current_generation_));
@@ -64,7 +50,6 @@ ACE_Barrier::dump (void) const
ACE_DEBUG ((LM_DEBUG, ACE_END_DUMP));
#endif /* ACE_HAS_DUMP */
}
-
ACE_Barrier::ACE_Barrier (unsigned int count,
const ACE_TCHAR *name,
void *arg)
@@ -78,25 +63,20 @@ ACE_Barrier::ACE_Barrier (unsigned int count,
this->sub_barrier_[0] = &this->sub_barrier_1_;
this->sub_barrier_[1] = &this->sub_barrier_2_;
}
-
int
ACE_Barrier::wait (void)
{
ACE_TRACE ("ACE_Barrier::wait");
ACE_GUARD_RETURN (ACE_Thread_Mutex, ace_mon, this->lock_, -1);
-
ACE_Sub_Barrier *sbp =
this->sub_barrier_[this->current_generation_];
-
// Check for shutdown...
if (sbp == 0)
{
errno = ESHUTDOWN;
return -1;
}
-
int retval = 0;
-
if (sbp->running_threads_ == 1)
{
// We're the last running thread, so swap generations and tell
@@ -110,11 +90,9 @@ ACE_Barrier::wait (void)
else
{
--sbp->running_threads_;
-
// Block until all the other threads wait().
while (sbp->running_threads_ != this->count_)
sbp->barrier_finished_.wait ();
-
// We're awake and the count has completed. See if it completed
// because all threads hit the barrier, or because the barrier
// was shut down.
@@ -124,45 +102,36 @@ ACE_Barrier::wait (void)
retval = -1;
}
}
-
return retval;
}
-
int
ACE_Barrier::shutdown (void)
{
ACE_TRACE ("ACE_Barrier::shutdown");
ACE_GUARD_RETURN (ACE_Thread_Mutex, ace_mon, this->lock_, -1);
-
ACE_Sub_Barrier *sbp =
this->sub_barrier_[this->current_generation_];
-
// Check for shutdown...
if (sbp == 0)
{
errno = ESHUTDOWN;
return -1;
}
-
// Flag the shutdown
this->sub_barrier_[0] = 0;
this->sub_barrier_[1] = 0;
// Tell all the threads waiting on the barrier to continue on their way.
sbp->running_threads_ = this->count_;
sbp->barrier_finished_.broadcast ();
-
return 0;
}
-
ACE_ALLOC_HOOK_DEFINE(ACE_Thread_Barrier)
-
ACE_Thread_Barrier::ACE_Thread_Barrier (unsigned int count,
const ACE_TCHAR *name)
: ACE_Barrier (count, name)
{
// ACE_TRACE ("ACE_Thread_Barrier::ACE_Thread_Barrier");
}
-
void
ACE_Thread_Barrier::dump (void) const
{
@@ -171,17 +140,14 @@ ACE_Thread_Barrier::dump (void) const
ACE_Barrier::dump ();
#endif /* ACE_HAS_DUMP */
}
-
#if 0
ACE_ALLOC_HOOK_DEFINE(ACE_Process_Barrier)
-
ACE_Process_Barrier::ACE_Process_Barrier (u_int count,
const ACE_TCHAR *name)
: ACE_Barrier (count, USYNC_PROCESS, name)
{
// ACE_TRACE ("ACE_Process_Barrier::ACE_Process_Barrier");
}
-
void
ACE_Process_Barrier::dump (void) const
{
@@ -191,8 +157,6 @@ ACE_Process_Barrier::dump (void) const
#endif /* ACE_HAS_DUMP */
}
#endif /* 0 */
-
ACE_END_VERSIONED_NAMESPACE_DECL
-
#endif /* ACE_HAS_THREADS */