diff options
Diffstat (limited to 'TAO/tests/AMI_Buffering/client.cpp')
| -rw-r--r-- | TAO/tests/AMI_Buffering/client.cpp | 30 |
1 files changed, 23 insertions, 7 deletions
diff --git a/TAO/tests/AMI_Buffering/client.cpp b/TAO/tests/AMI_Buffering/client.cpp index eb5819492ca..2e05c13f86e 100644 --- a/TAO/tests/AMI_Buffering/client.cpp +++ b/TAO/tests/AMI_Buffering/client.cpp @@ -12,7 +12,7 @@ ACE_RCSID(AMI_Buffering, client, "$Id$") const char *server_ior = "file://server.ior"; const char *admin_ior = "file://admin.ior"; -int iterations = 200; +int iterations = 20; int run_message_count_test = 0; int run_timeout_test = 0; @@ -20,12 +20,12 @@ int run_timeout_reactive_test = 0; int run_buffer_size_test = 0; const int PAYLOAD_LENGTH = 1024; -const int BUFFERED_MESSAGES_COUNT = 50; -const unsigned int TIMEOUT_MILLISECONDS = 25; -const int BUFFER_SIZE = 64 * PAYLOAD_LENGTH; +const int BUFFERED_MESSAGES_COUNT = 10; +const unsigned int TIMEOUT_MILLISECONDS = 50; +const int BUFFER_SIZE = 10 * PAYLOAD_LENGTH; /// Allow a larger timeout to occur due to scheduler differences -const unsigned int TIMEOUT_TOLERANCE = 20 * TIMEOUT_MILLISECONDS; +const unsigned int TIMEOUT_TOLERANCE = 4 * TIMEOUT_MILLISECONDS; /// Check that no more than 10% of the messages are not sent. const double LIVENESS_TOLERANCE = 0.9; @@ -393,6 +393,10 @@ run_liveness_test (CORBA::ORB_ptr orb, ami_buffering_admin->request_count (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK_RETURN (-1); + ACE_Time_Value tv (0, 10 * 1000); + orb->run (tv ACE_ENV_ARG_PARAMETER); + ACE_CHECK_RETURN (-1); + // Once the system has sent enough messages we don't // expect it to fall too far behind, i.e. at least 90% of the // messages should be delivered.... @@ -491,6 +495,10 @@ run_message_count (CORBA::ORB_ptr orb, ami_buffering_admin->request_count (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK_RETURN (-1); + ACE_Time_Value tv (0, 10 * 1000); + orb->run (tv ACE_ENV_ARG_PARAMETER); + ACE_CHECK_RETURN (-1); + CORBA::ULong iteration_count = send_count - initial_receive_count; if (receive_count != initial_receive_count) @@ -605,6 +613,10 @@ run_timeout (CORBA::ORB_ptr orb, ami_buffering_admin->request_count (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK_RETURN (-1); + ACE_Time_Value tv (0, 10 * 1000); + orb->run (tv ACE_ENV_ARG_PARAMETER); + ACE_CHECK_RETURN (-1); + ACE_Time_Value elapsed = ACE_OS::gettimeofday () - start; if (receive_count != initial_receive_count) { @@ -720,8 +732,8 @@ run_timeout_reactive (CORBA::ORB_ptr orb, ami_buffering_admin->request_count (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK_RETURN (-1); - ACE_Time_Value sleep (0, 10000); - orb->run (sleep ACE_ENV_ARG_PARAMETER); + ACE_Time_Value tv (0, 10 * 1000); + orb->run (tv ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (-1); ACE_Time_Value elapsed = ACE_OS::gettimeofday () - start; @@ -838,6 +850,10 @@ run_buffer_size (CORBA::ORB_ptr orb, ami_buffering_admin->bytes_received_count (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK_RETURN (-1); + ACE_Time_Value tv (0, 10 * 1000); + orb->run (tv ACE_ENV_ARG_PARAMETER); + ACE_CHECK_RETURN (-1); + CORBA::ULong payload_delta = bytes_sent - initial_bytes_received; if (bytes_received != initial_bytes_received) |