diff options
author | Johnny Willemsen <jwillemsen@remedy.nl> | 2016-02-12 15:37:31 +0100 |
---|---|---|
committer | Johnny Willemsen <jwillemsen@remedy.nl> | 2016-02-12 15:37:31 +0100 |
commit | b61579224c35cbefe2a34a6315bea999cf6ff67e (patch) | |
tree | 18d6fc34d7ab8b27f62c8b3945a97eaad021f42b /ACE/ace/Service_Repository.cpp | |
parent | ae65ab947f05f6ef56abfbb2fc2fae6f5b19fe2b (diff) | |
download | ATCD-b61579224c35cbefe2a34a6315bea999cf6ff67e.tar.gz |
Added a lock accessor to the ACE Service Repository which is now of
type ACE_SYNCH_RECURSIVE_MUTEX so that user code that iterates the
service repository can lock its content during iteration to make sure
it doesn't get a corrupted state when another thread tries to change
its state
* ACE/ace/Service_Repository.cpp:
* ACE/ace/Service_Repository.h:
* ACE/ace/Service_Repository.inl:
* ACE/tests/Service_Config_Test.cpp:
Diffstat (limited to 'ACE/ace/Service_Repository.cpp')
-rw-r--r-- | ACE/ace/Service_Repository.cpp | 18 |
1 files changed, 8 insertions, 10 deletions
diff --git a/ACE/ace/Service_Repository.cpp b/ACE/ace/Service_Repository.cpp index 4850cc63131..6c5fb03df59 100644 --- a/ACE/ace/Service_Repository.cpp +++ b/ACE/ace/Service_Repository.cpp @@ -114,7 +114,7 @@ int ACE_Service_Repository::fini (void) { ACE_TRACE ("ACE_Service_Repository::fini"); - ACE_MT (ACE_GUARD_RETURN (ACE_Recursive_Thread_Mutex, ace_mon, this->lock_, -1)); + ACE_GUARD_RETURN (ACE_SYNCH_RECURSIVE_MUTEX, ace_mon, this->lock_, -1); int retval = 0; // Do not be tempted to use the prefix decrement operator. Use @@ -209,7 +209,7 @@ int ACE_Service_Repository::close (void) { ACE_TRACE ("ACE_Service_Repository::close"); - ACE_MT (ACE_GUARD_RETURN (ACE_Recursive_Thread_Mutex, ace_mon, this->lock_, -1)); + ACE_GUARD_RETURN (ACE_SYNCH_RECURSIVE_MUTEX, ace_mon, this->lock_, -1); #ifndef ACE_NLOGGING if(ACE::debug ()) @@ -384,7 +384,7 @@ ACE_Service_Repository::find (const ACE_TCHAR name[], bool ignore_suspended) const { ACE_TRACE ("ACE_Service_Repository::find"); - ACE_MT (ACE_GUARD_RETURN (ACE_Recursive_Thread_Mutex, ace_mon, this->lock_, -1)); + ACE_GUARD_RETURN (ACE_SYNCH_RECURSIVE_MUTEX, ace_mon, this->lock_, -1); size_t ignore_location = 0; return this->find_i (name, ignore_location, srp, ignore_suspended); } @@ -406,10 +406,8 @@ ACE_Service_Repository::insert (const ACE_Service_Type *sr) // storage { // @TODO: Do we need a recursive mutex here? - ACE_MT (ACE_GUARD_RETURN (ACE_Recursive_Thread_Mutex, - ace_mon, - this->lock_, - -1)); + ACE_GUARD_RETURN (ACE_SYNCH_RECURSIVE_MUTEX, + ace_mon, this->lock_, -1); return_value = find_i (sr->name (), i, &s, false); @@ -463,7 +461,7 @@ ACE_Service_Repository::resume (const ACE_TCHAR name[], const ACE_Service_Type **srp) { ACE_TRACE ("ACE_Service_Repository::resume"); - ACE_MT (ACE_GUARD_RETURN (ACE_Recursive_Thread_Mutex, ace_mon, this->lock_, -1)); + ACE_GUARD_RETURN (ACE_SYNCH_RECURSIVE_MUTEX, ace_mon, this->lock_, -1); size_t i = 0; if (-1 == this->find_i (name, i, srp, 0)) @@ -479,7 +477,7 @@ ACE_Service_Repository::suspend (const ACE_TCHAR name[], const ACE_Service_Type **srp) { ACE_TRACE ("ACE_Service_Repository::suspend"); - ACE_MT (ACE_GUARD_RETURN (ACE_Recursive_Thread_Mutex, ace_mon, this->lock_, -1)); + ACE_GUARD_RETURN (ACE_SYNCH_RECURSIVE_MUTEX, ace_mon, this->lock_, -1); size_t i = 0; if (-1 == this->find_i (name, i, srp, 0)) return -1; @@ -497,7 +495,7 @@ ACE_Service_Repository::remove (const ACE_TCHAR name[], ACE_Service_Type **ps) ACE_TRACE ("ACE_Service_Repository::remove"); ACE_Service_Type *s = 0; { - ACE_MT (ACE_GUARD_RETURN (ACE_Recursive_Thread_Mutex, ace_mon, this->lock_, -1)); + ACE_GUARD_RETURN (ACE_SYNCH_RECURSIVE_MUTEX, ace_mon, this->lock_, -1); // Not found!? if (this->remove_i (name, &s) == -1) |