diff options
| author | Ossama Othman <ossama-othman@users.noreply.github.com> | 2003-02-20 17:50:09 +0000 |
|---|---|---|
| committer | Ossama Othman <ossama-othman@users.noreply.github.com> | 2003-02-20 17:50:09 +0000 |
| commit | 6960ce41e6d742387dd64136d09eb822304ef50d (patch) | |
| tree | e525bff1d716f4a9b884898cb87db5ef7d1200cb /TAO/orbsvcs/orbsvcs/LoadBalancing | |
| parent | 7910287d755f04a87eeae6e9e9614cf313da35cd (diff) | |
| download | ATCD-6960ce41e6d742387dd64136d09eb822304ef50d.tar.gz | |
ChangeLogTag:Thu Feb 20 09:07:56 2003 Ossama Othman <ossama@uci.edu>
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/LoadBalancing')
4 files changed, 13 insertions, 2 deletions
diff --git a/TAO/orbsvcs/orbsvcs/LoadBalancing/LB_CPU_Monitor.cpp b/TAO/orbsvcs/orbsvcs/LoadBalancing/LB_CPU_Monitor.cpp index 146b1fb66ca..c61a4969310 100644 --- a/TAO/orbsvcs/orbsvcs/LoadBalancing/LB_CPU_Monitor.cpp +++ b/TAO/orbsvcs/orbsvcs/LoadBalancing/LB_CPU_Monitor.cpp @@ -78,7 +78,8 @@ TAO_LB_CPU_Monitor::loads (ACE_ENV_SINGLE_ARG_DECL) // Obtain the number of processors each time a load is computed. // The idea is to take into account the processor failures that can - // on platforms that continue running with the remaining processors. + // occur on platforms that continue running with the remaining + // processors. // // @@ Is this a realistic scenario? Perhaps we should just cache // the number of processors and assume that any processor failure diff --git a/TAO/orbsvcs/orbsvcs/LoadBalancing/LB_LoadAlert.cpp b/TAO/orbsvcs/orbsvcs/LoadBalancing/LB_LoadAlert.cpp index a4374826e49..3c51e755ee5 100644 --- a/TAO/orbsvcs/orbsvcs/LoadBalancing/LB_LoadAlert.cpp +++ b/TAO/orbsvcs/orbsvcs/LoadBalancing/LB_LoadAlert.cpp @@ -10,7 +10,8 @@ ACE_RCSID (LoadBalancer, #endif /* __ACE_INLINE__ */ TAO_LB_LoadAlert::TAO_LB_LoadAlert (void) - : alerted_ (0) + : alerted_ (0), + lock_ () { } @@ -22,6 +23,8 @@ void TAO_LB_LoadAlert::enable_alert (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) ACE_THROW_SPEC ((CORBA::SystemException)) { + ACE_GUARD (TAO_SYNCH_MUTEX, monitor, this->lock_); + this->alerted_ = 1; } @@ -29,5 +32,7 @@ void TAO_LB_LoadAlert::disable_alert (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) ACE_THROW_SPEC ((CORBA::SystemException)) { + ACE_GUARD (TAO_SYNCH_MUTEX, monitor, this->lock_); + this->alerted_ = 0; } diff --git a/TAO/orbsvcs/orbsvcs/LoadBalancing/LB_LoadAlert.h b/TAO/orbsvcs/orbsvcs/LoadBalancing/LB_LoadAlert.h index b7b83230c43..8d71b76e2e7 100644 --- a/TAO/orbsvcs/orbsvcs/LoadBalancing/LB_LoadAlert.h +++ b/TAO/orbsvcs/orbsvcs/LoadBalancing/LB_LoadAlert.h @@ -71,6 +71,9 @@ private: /// by the LoadManager? CORBA::Boolean alerted_; + /// Lock used to synchronized access to the LoadAlert state. + mutable TAO_SYNCH_MUTEX lock_; + }; diff --git a/TAO/orbsvcs/orbsvcs/LoadBalancing/LB_LoadAlert.inl b/TAO/orbsvcs/orbsvcs/LoadBalancing/LB_LoadAlert.inl index 37cd8d00e4d..0f574a49206 100644 --- a/TAO/orbsvcs/orbsvcs/LoadBalancing/LB_LoadAlert.inl +++ b/TAO/orbsvcs/orbsvcs/LoadBalancing/LB_LoadAlert.inl @@ -6,5 +6,7 @@ ACE_INLINE CORBA::Boolean TAO_LB_LoadAlert::alerted (void) const { + ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, monitor, this->lock_, 0); + return this->alerted_; } |