summaryrefslogtreecommitdiff
path: root/ace/Message_Queue.cpp
diff options
context:
space:
mode:
authorschmidt <douglascraigschmidt@users.noreply.github.com>1998-06-07 03:28:31 +0000
committerschmidt <douglascraigschmidt@users.noreply.github.com>1998-06-07 03:28:31 +0000
commit64d52b548d159b8efc70acc6431f2319d1576189 (patch)
tree2988a618113408b9d2dd4fd5da19e34425c63c10 /ace/Message_Queue.cpp
parent4e66acff840358012086fe00c7b2c950d3e14531 (diff)
downloadATCD-64d52b548d159b8efc70acc6431f2319d1576189.tar.gz
*** empty log message ***
Diffstat (limited to 'ace/Message_Queue.cpp')
-rw-r--r--ace/Message_Queue.cpp6
1 files changed, 4 insertions, 2 deletions
diff --git a/ace/Message_Queue.cpp b/ace/Message_Queue.cpp
index ad7235a982b..120676ceca8 100644
--- a/ace/Message_Queue.cpp
+++ b/ace/Message_Queue.cpp
@@ -47,7 +47,8 @@ ACE_Message_Queue_Iterator<ACE_SYNCH_USE>::advance (void)
{
ACE_Read_Guard<ACE_SYNCH_MUTEX_T> m (this->queue_.lock_);
- this->curr_ = this->curr_->next ();
+ if (this->curr_)
+ this->curr_ = this->curr_->next ();
return this->curr_ != 0;
}
@@ -92,7 +93,8 @@ ACE_Message_Queue_Reverse_Iterator<ACE_SYNCH_USE>::advance (void)
{
ACE_Read_Guard<ACE_SYNCH_MUTEX_T> m (this->queue_.lock_);
- this->curr_ = this->curr_->prev ();
+ if (this->curr_)
+ this->curr_ = this->curr_->prev ();
return this->curr_ != 0;
}