diff options
| author | hillj <hillj@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2008-07-11 08:12:09 +0000 |
|---|---|---|
| committer | hillj <hillj@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2008-07-11 08:12:09 +0000 |
| commit | f04b476461912e5eebed9f73249ac92b63901c19 (patch) | |
| tree | c4bc7e90acd4591b621169992432a6b61824cb20 /ACE/ace/Message_Queue_T.cpp | |
| parent | f60ca919974ce56cec2183b315d2e64ae2fc69e5 (diff) | |
| download | ATCD-f04b476461912e5eebed9f73249ac92b63901c19.tar.gz | |
Fri Jul 11 08:06:40 UTC 2008 James H. Hill <hillj@isis.vanderbilt.edu>
Diffstat (limited to 'ACE/ace/Message_Queue_T.cpp')
| -rw-r--r-- | ACE/ace/Message_Queue_T.cpp | 81 |
1 files changed, 81 insertions, 0 deletions
diff --git a/ACE/ace/Message_Queue_T.cpp b/ACE/ace/Message_Queue_T.cpp index bb61f06d6ed..adbc80b6856 100644 --- a/ACE/ace/Message_Queue_T.cpp +++ b/ACE/ace/Message_Queue_T.cpp @@ -338,6 +338,87 @@ ACE_Message_Queue_Ex<ACE_MESSAGE_TYPE, ACE_SYNCH_USE>::notify (void) return this->queue_.notify (); } +template <class ACE_MESSAGE_TYPE, ACE_SYNCH_DECL> +ACE_Message_Queue_Ex_Iterator<ACE_MESSAGE_TYPE, ACE_SYNCH_USE>:: +ACE_Message_Queue_Ex_Iterator (ACE_Message_Queue_Ex <ACE_MESSAGE_TYPE, ACE_SYNCH_USE> & queue) +: iter_ (queue.queue_) +{ + +} + +template <class ACE_MESSAGE_TYPE, ACE_SYNCH_DECL> int +ACE_Message_Queue_Ex_Iterator<ACE_MESSAGE_TYPE, ACE_SYNCH_USE>:: +next (ACE_MESSAGE_TYPE *&entry) +{ + ACE_Message_Block * mb = 0; + int retval = this->iter_.next (mb); + + if (retval == 1) + entry = reinterpret_cast<ACE_MESSAGE_TYPE *> (mb->base ()); + + return retval; +} + +template <class ACE_MESSAGE_TYPE, ACE_SYNCH_DECL> int +ACE_Message_Queue_Ex_Iterator<ACE_MESSAGE_TYPE, ACE_SYNCH_USE>::done (void) const +{ + return this->iter_.done (); +} + +template <class ACE_MESSAGE_TYPE, ACE_SYNCH_DECL> int +ACE_Message_Queue_Ex_Iterator<ACE_MESSAGE_TYPE, ACE_SYNCH_USE>::advance (void) +{ + return this->iter_.advance (); +} + +template <class ACE_MESSAGE_TYPE, ACE_SYNCH_DECL> void +ACE_Message_Queue_Ex_Iterator<ACE_MESSAGE_TYPE, ACE_SYNCH_USE>::dump (void) const +{ + return this->iter_.dump (); +} + +ACE_ALLOC_HOOK_DEFINE(ACE_Message_Queue_Ex_Iterator) + +template <class ACE_MESSAGE_TYPE, ACE_SYNCH_DECL> +ACE_Message_Queue_Ex_Reverse_Iterator<ACE_MESSAGE_TYPE, ACE_SYNCH_USE>:: +ACE_Message_Queue_Ex_Reverse_Iterator (ACE_Message_Queue_Ex <ACE_MESSAGE_TYPE, ACE_SYNCH_USE> & queue) +: iter_ (queue.queue_) +{ + +} + +template <class ACE_MESSAGE_TYPE, ACE_SYNCH_DECL> int +ACE_Message_Queue_Ex_Reverse_Iterator<ACE_MESSAGE_TYPE, ACE_SYNCH_USE>:: +next (ACE_MESSAGE_TYPE *&entry) +{ + ACE_Message_Block * mb = 0; + int retval = this->iter_.next (mb); + + if (retval == 1) + entry = reinterpret_cast<ACE_MESSAGE_TYPE *> (mb->base ()); + + return retval; +} + +template <class ACE_MESSAGE_TYPE, ACE_SYNCH_DECL> int +ACE_Message_Queue_Ex_Reverse_Iterator<ACE_MESSAGE_TYPE, ACE_SYNCH_USE>::done (void) const +{ + return this->iter_.done (); +} + +template <class ACE_MESSAGE_TYPE, ACE_SYNCH_DECL> int +ACE_Message_Queue_Ex_Reverse_Iterator<ACE_MESSAGE_TYPE, ACE_SYNCH_USE>::advance (void) +{ + return this->iter_.advance (); +} + +template <class ACE_MESSAGE_TYPE, ACE_SYNCH_DECL> void +ACE_Message_Queue_Ex_Reverse_Iterator<ACE_MESSAGE_TYPE, ACE_SYNCH_USE>::dump (void) const +{ + return this->iter_.dump (); +} + +ACE_ALLOC_HOOK_DEFINE(ACE_Message_Queue_Ex_Reverse_Iterator) template <class ACE_MESSAGE_TYPE, ACE_SYNCH_DECL> ACE_Message_Queue_Ex_N<ACE_MESSAGE_TYPE, ACE_SYNCH_USE>::ACE_Message_Queue_Ex_N |