summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorlevine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1997-12-02 22:17:48 +0000
committerlevine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1997-12-02 22:17:48 +0000
commitecf1d8962a38ffa86be36350514306d4a842e6f3 (patch)
tree190d9e164d8ab3c1c27f6b84c42ea4de45604e46
parentddda1f5bb98267b8789a97dad3506cb2166d74b6 (diff)
downloadATCD-ecf1d8962a38ffa86be36350514306d4a842e6f3.tar.gz
(main): increased queue size from default of 16Kb to 32Kb, so that it
runs on machines with 8Kb pagesizes.
-rw-r--r--tests/Message_Queue_Test.cpp21
1 files changed, 10 insertions, 11 deletions
diff --git a/tests/Message_Queue_Test.cpp b/tests/Message_Queue_Test.cpp
index 0b01e8067e9..9545056df11 100644
--- a/tests/Message_Queue_Test.cpp
+++ b/tests/Message_Queue_Test.cpp
@@ -32,7 +32,7 @@ main (int, char *[])
const int ITERATIONS = 5;
char buffer[ITERATIONS][BUFSIZ];
- QUEUE queue;
+ QUEUE queue (32 * 1024);
int i;
for (i = 0; i < ITERATIONS; i++)
@@ -43,7 +43,7 @@ main (int, char *[])
ACE_NEW_RETURN (entry, ACE_Message_Block (buffer[i], sizeof buffer[i]), -1);
if (queue.enqueue (entry) == -1)
- ACE_ERROR_RETURN ((LM_ERROR, "QUEUE::enqueue\n"), -1);
+ ACE_ERROR_RETURN ((LM_ERROR, "QUEUE::enqueue\n"), -1);
}
ACE_DEBUG ((LM_DEBUG, "\nForward Iterations\n"));
@@ -51,8 +51,8 @@ main (int, char *[])
ITERATOR iterator (queue);
for (ACE_Message_Block *entry = 0;
- iterator.next (entry) != 0;
- iterator.advance ())
+ iterator.next (entry) != 0;
+ iterator.advance ())
ACE_DEBUG ((LM_DEBUG, "%s\n", entry->base ()));
}
@@ -61,8 +61,8 @@ main (int, char *[])
REVERSE_ITERATOR iterator (queue);
for (ACE_Message_Block *entry = 0;
- iterator.next (entry) != 0;
- iterator.advance ())
+ iterator.next (entry) != 0;
+ iterator.advance ())
ACE_DEBUG ((LM_DEBUG, "%s\n", entry->base ()));
}
@@ -71,8 +71,8 @@ main (int, char *[])
QUEUE::ITERATOR iterator (queue);
for (ACE_Message_Block *entry = 0;
- iterator.next (entry) != 0;
- iterator.advance ())
+ iterator.next (entry) != 0;
+ iterator.advance ())
ACE_DEBUG ((LM_DEBUG, "%s\n", entry->base ()));
}
@@ -81,8 +81,8 @@ main (int, char *[])
QUEUE::REVERSE_ITERATOR iterator (queue);
for (ACE_Message_Block *entry = 0;
- iterator.next (entry) != 0;
- iterator.advance ())
+ iterator.next (entry) != 0;
+ iterator.advance ())
ACE_DEBUG ((LM_DEBUG, "%s\n", entry->base ()));
}
@@ -97,4 +97,3 @@ template class ACE_Message_Queue_Reverse_Iterator<ACE_NULL_SYNCH>;
#pragma instantiate ACE_Message_Queue_Iterator<ACE_NULL_SYNCH>
#pragma instantiate ACE_Message_Queue_Reverse_Iterator<ACE_NULL_SYNCH>
#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
-