summaryrefslogtreecommitdiff
path: root/TAO/tests/MT_NoUpcall_Client_Leader/chatter.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tests/MT_NoUpcall_Client_Leader/chatter.cpp')
-rw-r--r--TAO/tests/MT_NoUpcall_Client_Leader/chatter.cpp15
1 files changed, 11 insertions, 4 deletions
diff --git a/TAO/tests/MT_NoUpcall_Client_Leader/chatter.cpp b/TAO/tests/MT_NoUpcall_Client_Leader/chatter.cpp
index 6a9248bda6f..b29c1e9bfc1 100644
--- a/TAO/tests/MT_NoUpcall_Client_Leader/chatter.cpp
+++ b/TAO/tests/MT_NoUpcall_Client_Leader/chatter.cpp
@@ -28,7 +28,7 @@ Chatter::nrequests (void)
int
Chatter::svc (void)
{
- long nrq = nrequests ();
+ long nrq = -1;
try
{
//sleep(1);
@@ -43,12 +43,19 @@ Chatter::svc (void)
ACE_ERROR_RETURN ((LM_ERROR, "Nil reference <%s>\n", ior_), -1);
// make call on server
+ {
+ ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, guard, request_reply_count_mutex_, -1);
+ nrq= nrequests ();
+ nrequests_++;
+ }
ACE_DEBUG((LM_INFO,"(%P|%t) Chatter[%d] started for %s\n", nrq, ior_));
- nrequests_++;
intf_var->ping();
- nreplies_++;
+ {
+ ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, guard, request_reply_count_mutex_, -1);
+ nreplies_++;
+ }
- ACE_DEBUG((LM_INFO,"(%P|%t) Chatter[%d] completed for %s\n", nrq, ior_));
+ ACE_DEBUG((LM_INFO,"(%P|%t) Chatter[%d,%d,%d] completed for %s\n", nrq, nrequests_, nreplies_, ior_));
cond_.signal();
return 0;
}