diff options
Diffstat (limited to 'TAO/tests/AMI/client.cpp')
| -rw-r--r-- | TAO/tests/AMI/client.cpp | 24 |
1 files changed, 21 insertions, 3 deletions
diff --git a/TAO/tests/AMI/client.cpp b/TAO/tests/AMI/client.cpp index ec583f44ee6..75f324dcf67 100644 --- a/TAO/tests/AMI/client.cpp +++ b/TAO/tests/AMI/client.cpp @@ -10,7 +10,7 @@ const char *ior = "file://test.ior"; int nthreads = 5; int niterations = 5; int debug = 0; - +int number_of_replies = 0; int parse_args (int argc, char *argv[]) @@ -91,6 +91,8 @@ public: result, out_l)); } + + number_of_replies--; }; ~Handler (void) {}; @@ -156,13 +158,29 @@ main (int argc, char *argv[]) // Main thread collects replies. It needs to collect // <nthreads*niterations> replies. - size_t number_of_replies = nthreads * niterations; + number_of_replies = nthreads * niterations; + + if (debug) + { + ACE_DEBUG ((LM_DEBUG, + "(%P|%t) : Entering perform_work loop to receive <%d> replies\n", + number_of_replies)); + } - while (orb->work_pending () && number_of_replies--) + // ORB loop. + while (orb->work_pending () && number_of_replies > 0) { orb->perform_work (); } + if (debug) + { + ACE_DEBUG ((LM_DEBUG, + "(%P|%t) : Exited perform_work loop Received <%d> replies\n", + (nthreads*niterations) - number_of_replies)); + } + + client.thr_mgr ()->wait (); ACE_DEBUG ((LM_DEBUG, "threads finished\n")); |