diff options
author | coryan <coryan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1999-06-09 15:46:57 +0000 |
---|---|---|
committer | coryan <coryan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1999-06-09 15:46:57 +0000 |
commit | ec637f77004c9371ddaac067f6d64281218f85bf (patch) | |
tree | ce8df235d4b152aa0ff9744eb43369b0a8c79873 /ace/Svc_Handler.cpp | |
parent | 97efe565744c1a45e39ec150e8c6a3b3c7a71bb0 (diff) | |
download | ATCD-ec637f77004c9371ddaac067f6d64281218f85bf.tar.gz |
ChangeLogTag:Wed Jun 9 10:46:07 1999 Carlos O'Ryan <coryan@cs.wustl.edu>
Diffstat (limited to 'ace/Svc_Handler.cpp')
-rw-r--r-- | ace/Svc_Handler.cpp | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/ace/Svc_Handler.cpp b/ace/Svc_Handler.cpp index 2bbee9ef56d..4aa7b10f018 100644 --- a/ace/Svc_Handler.cpp +++ b/ace/Svc_Handler.cpp @@ -191,12 +191,12 @@ ACE_Svc_Handler<PR_ST_2, ACE_SYNCH_USE>::put (ACE_Message_Block *mb, // Enqueue <mb> onto the message queue. if (this->putq (mb, tv) == -1) return -1; - else + else { // Flush the buffer when the number of bytes exceeds the maximum // buffer size or when the timeout period has elapsed. if (mb->total_size () >= this->maximum_buffer_size_ - || (this->timeoutp_ != 0 + || (this->timeoutp_ != 0 && this->timeout_ > ACE_OS::gettimeofday ())) return this->flush (); @@ -217,7 +217,7 @@ ACE_Svc_Handler<PR_ST_2, ACE_SYNCH_USE>::flush (void) // Iterate over all the <ACE_Message_Block>s in the // <ACE_Message_Queue> and prepare them to be written out. - for (ACE_Message_Queue_Iterator<ACE_NULL_SYNCH> iterator (*this->msg_queue ()); + for (ACE_Message_Queue_Iterator<ACE_SYNCH_USE> iterator (*this->msg_queue ()); iterator.next (entry) != 0 && result == 0; iterator.advance ()) @@ -225,11 +225,11 @@ ACE_Svc_Handler<PR_ST_2, ACE_SYNCH_USE>::flush (void) // Iterate over all the <Message_Block>s in a chain, including // continuations. for (ACE_Message_Block *temp = entry; - entry != 0; - entry = entry->cont ()) + temp != 0; + temp = entry->cont ()) { - iov[i].iov_len = entry->length (); - iov[i].iov_base = entry->rd_ptr (); + iov[i].iov_len = temp->length (); + iov[i].iov_base = temp->rd_ptr (); i++; @@ -263,7 +263,7 @@ ACE_Svc_Handler<PR_ST_2, ACE_SYNCH_USE>::flush (void) ACE_DEBUG ((LM_DEBUG, "sending data (final flush, i = %d)\n", i)); -#endif (ACE_DEBUGGING) +#endif /* ACE_DEBUGGING */ } // Remove all the <ACE_Message_Block>s in the <ACE_Message_Queue> |