summaryrefslogtreecommitdiff
path: root/ace/Message_Queue_T.cpp
diff options
context:
space:
mode:
authorJohnny Willemsen <jwillemsen@remedy.nl>2005-10-21 12:31:39 +0000
committerJohnny Willemsen <jwillemsen@remedy.nl>2005-10-21 12:31:39 +0000
commitf7b43e3293d267fbbb122170fb2ee30f4b8d318a (patch)
tree81ab2120dc96a2492de6e1a4a31e51d8bb8db36d /ace/Message_Queue_T.cpp
parentb07e10e8af7e460f977e308b3bfe6614b4fa15eb (diff)
downloadATCD-f7b43e3293d267fbbb122170fb2ee30f4b8d318a.tar.gz
ChangeLogTag: Fri Oct 21 11:03:12 UTC 2005 Johnny Willemsen <jwillemsen@remedy.nl>
Diffstat (limited to 'ace/Message_Queue_T.cpp')
-rw-r--r--ace/Message_Queue_T.cpp26
1 files changed, 13 insertions, 13 deletions
diff --git a/ace/Message_Queue_T.cpp b/ace/Message_Queue_T.cpp
index 9fc5ad5ec92..6d60aa90ad4 100644
--- a/ace/Message_Queue_T.cpp
+++ b/ace/Message_Queue_T.cpp
@@ -845,7 +845,7 @@ ACE_Message_Queue<ACE_SYNCH_USE>::flush_i (void)
// and <release> their memory.
for (this->tail_ = 0; this->head_ != 0; )
{
- number_flushed++;
+ ++number_flushed;
size_t mb_bytes = 0;
size_t mb_length = 0;
@@ -854,7 +854,7 @@ ACE_Message_Queue<ACE_SYNCH_USE>::flush_i (void)
// Subtract off all of the bytes associated with this message.
this->cur_bytes_ -= mb_bytes;
this->cur_length_ -= mb_length;
- this->cur_count_--;
+ --this->cur_count_;
ACE_Message_Block *temp = this->head_;
this->head_ = this->head_->next ();
@@ -995,7 +995,7 @@ ACE_Message_Queue<ACE_SYNCH_USE>::enqueue_tail_i (ACE_Message_Block *new_item)
// Make sure to count all the bytes in a composite message!!!
new_item->total_size_and_length (this->cur_bytes_,
this->cur_length_);
- this->cur_count_++;
+ ++this->cur_count_;
if (this->signal_dequeue_waiters () == -1)
return -1;
@@ -1026,7 +1026,7 @@ ACE_Message_Queue<ACE_SYNCH_USE>::enqueue_head_i (ACE_Message_Block *new_item)
// Make sure to count all the bytes in a composite message!!!
new_item->total_size_and_length (this->cur_bytes_,
this->cur_length_);
- this->cur_count_++;
+ ++this->cur_count_;
if (this->signal_dequeue_waiters () == -1)
return -1;
@@ -1091,7 +1091,7 @@ ACE_Message_Queue<ACE_SYNCH_USE>::enqueue_i (ACE_Message_Block *new_item)
// Make sure to count all the bytes in a composite message!!!
new_item->total_size_and_length (this->cur_bytes_,
this->cur_length_);
- this->cur_count_++;
+ ++this->cur_count_;
if (this->signal_dequeue_waiters () == -1)
return -1;
@@ -1152,7 +1152,7 @@ ACE_Message_Queue<ACE_SYNCH_USE>::enqueue_deadline_i (ACE_Message_Block *new_ite
// Make sure to count all the bytes in a composite message!!!
new_item->total_size_and_length (this->cur_bytes_,
this->cur_length_);
- this->cur_count_++;
+ ++this->cur_count_;
if (this->signal_dequeue_waiters () == -1)
return -1;
@@ -1191,7 +1191,7 @@ ACE_Message_Queue<ACE_SYNCH_USE>::dequeue_head_i (ACE_Message_Block *&first_item
// Subtract off all of the bytes associated with this message.
this->cur_bytes_ -= mb_bytes;
this->cur_length_ -= mb_length;
- this->cur_count_--;
+ --this->cur_count_;
if (this->cur_count_ == 0 && this->head_ == this->tail_)
this->head_ = this->tail_ = 0;
@@ -1267,7 +1267,7 @@ ACE_Message_Queue<ACE_SYNCH_USE>::dequeue_prio_i (ACE_Message_Block *&dequeued)
// Subtract off all of the bytes associated with this message.
this->cur_bytes_ -= mb_bytes;
this->cur_length_ -= mb_length;
- this->cur_count_--;
+ --this->cur_count_;
if (this->cur_count_ == 0 && this->head_ == this->tail_)
this->head_ = this->tail_ = 0;
@@ -1316,7 +1316,7 @@ ACE_Message_Queue<ACE_SYNCH_USE>::dequeue_tail_i (ACE_Message_Block *&dequeued)
// Subtract off all of the bytes associated with this message.
this->cur_bytes_ -= mb_bytes;
this->cur_length_ -= mb_length;
- this->cur_count_--;
+ --this->cur_count_;
if (this->cur_count_ == 0 && this->head_ == this->tail_)
this->head_ = this->tail_ = 0;
@@ -1385,7 +1385,7 @@ ACE_Message_Queue<ACE_SYNCH_USE>::dequeue_deadline_i (ACE_Message_Block *&dequeu
// Subtract off all of the bytes associated with this message.
this->cur_bytes_ -= mb_bytes;
this->cur_length_ -= mb_length;
- this->cur_count_--;
+ --this->cur_count_;
if (this->cur_count_ == 0 && this->head_ == this->tail_)
this->head_ = this->tail_ = 0;
@@ -1869,7 +1869,7 @@ ACE_Dynamic_Message_Queue<ACE_SYNCH_USE>::remove_messages (ACE_Message_Block *&l
temp1 != 0;
temp1 = temp1->next ())
{
- this->cur_count_--;
+ --this->cur_count_;
size_t mb_bytes = 0;
size_t mb_length = 0;
@@ -2089,7 +2089,7 @@ ACE_Dynamic_Message_Queue<ACE_SYNCH_USE>::enqueue_i (ACE_Message_Block *new_item
mb_length);
this->cur_bytes_ += mb_bytes;
this->cur_length_ += mb_length;
- this->cur_count_++;
+ ++this->cur_count_;
if (this->signal_dequeue_waiters () == -1)
return -1;
@@ -2278,7 +2278,7 @@ ACE_Dynamic_Message_Queue<ACE_SYNCH_USE>::dequeue_head_i (ACE_Message_Block *&fi
// Subtract off all of the bytes associated with this message.
this->cur_bytes_ -= mb_bytes;
this->cur_length_ -= mb_length;
- this->cur_count_--;
+ --this->cur_count_;
// Only signal enqueueing threads if we've fallen below the low
// water mark.