summaryrefslogtreecommitdiff
path: root/ace/Message_Queue_T.cpp
diff options
context:
space:
mode:
authorOssama Othman <ossama-othman@users.noreply.github.com>2000-09-14 19:30:17 +0000
committerOssama Othman <ossama-othman@users.noreply.github.com>2000-09-14 19:30:17 +0000
commit3667d4f180f689755ece1bf014fcb59e596fddfe (patch)
tree912fb00ba74a738e14b8aba80d721c84ee2179ab /ace/Message_Queue_T.cpp
parenta01e90f4beecf3bc80fd43204bc220f27f785fd5 (diff)
downloadATCD-3667d4f180f689755ece1bf014fcb59e596fddfe.tar.gz
ChangeLogTag:Thu Sep 14 11:59:48 2000 Ossama Othman <ossama@uci.edu>
Diffstat (limited to 'ace/Message_Queue_T.cpp')
-rw-r--r--ace/Message_Queue_T.cpp32
1 files changed, 13 insertions, 19 deletions
diff --git a/ace/Message_Queue_T.cpp b/ace/Message_Queue_T.cpp
index b9c23dc1ea5..0aa4cd749b3 100644
--- a/ace/Message_Queue_T.cpp
+++ b/ace/Message_Queue_T.cpp
@@ -40,8 +40,8 @@ ACE_Message_Queue_Iterator<ACE_SYNCH_USE>::next (ACE_Message_Block *&entry)
entry = this->curr_;
return 1;
}
- else
- return 0;
+
+ return 0;
}
template <ACE_SYNCH_DECL> int
@@ -86,8 +86,8 @@ ACE_Message_Queue_Reverse_Iterator<ACE_SYNCH_USE>::next (ACE_Message_Block *&ent
entry = this->curr_;
return 1;
}
- else
- return 0;
+
+ return 0;
}
template <ACE_SYNCH_DECL> int
@@ -623,11 +623,9 @@ ACE_Message_Queue<ACE_SYNCH_USE>::enqueue_head (ACE_Message_Block *new_item,
if (queue_count == -1)
return -1;
- else
- {
- this->notify ();
- return queue_count;
- }
+
+ this->notify ();
+ return queue_count;
}
// Enqueue an <ACE_Message_Block *> into the <Message_Queue> in
@@ -654,11 +652,9 @@ ACE_Message_Queue<ACE_SYNCH_USE>::enqueue_prio (ACE_Message_Block *new_item,
if (queue_count == -1)
return -1;
- else
- {
- this->notify ();
- return queue_count;
- }
+
+ this->notify ();
+ return queue_count;
}
template <ACE_SYNCH_DECL> int
@@ -692,11 +688,9 @@ ACE_Message_Queue<ACE_SYNCH_USE>::enqueue_tail (ACE_Message_Block *new_item,
if (queue_count == -1)
return -1;
- else
- {
- this->notify ();
- return queue_count;
- }
+
+ this->notify ();
+ return queue_count;
}
// Remove an item from the front of the queue. If timeout == 0 block