diff options
| author | levine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1997-12-02 22:33:03 +0000 |
|---|---|---|
| committer | levine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1997-12-02 22:33:03 +0000 |
| commit | 3ad25fc9bc4b51ec8d9c7b48003fc5d697e42776 (patch) | |
| tree | e001f09094ea68a54b666bfa47cbe30b759f104c /tests/Message_Queue_Test.cpp | |
| parent | bffb59df4703134a68703b163d7f1aaa254ae531 (diff) | |
| download | ATCD-3ad25fc9bc4b51ec8d9c7b48003fc5d697e42776.tar.gz | |
added check for full message queue before enqueuing
Diffstat (limited to 'tests/Message_Queue_Test.cpp')
| -rw-r--r-- | tests/Message_Queue_Test.cpp | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/tests/Message_Queue_Test.cpp b/tests/Message_Queue_Test.cpp index 9545056df11..6ea1d61b945 100644 --- a/tests/Message_Queue_Test.cpp +++ b/tests/Message_Queue_Test.cpp @@ -42,6 +42,12 @@ main (int, char *[]) ACE_Message_Block *entry; ACE_NEW_RETURN (entry, ACE_Message_Block (buffer[i], sizeof buffer[i]), -1); + if (queue.is_full ()) + ACE_ERROR_RETURN ((LM_ERROR, + "QUEUE:: the message queue is full on iteration %u!\n", + i+1), + -1); + if (queue.enqueue (entry) == -1) ACE_ERROR_RETURN ((LM_ERROR, "QUEUE::enqueue\n"), -1); } |