summaryrefslogtreecommitdiff
path: root/TAO/tests/LongWrites/Receiver.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tests/LongWrites/Receiver.cpp')
-rw-r--r--TAO/tests/LongWrites/Receiver.cpp29
1 files changed, 28 insertions, 1 deletions
diff --git a/TAO/tests/LongWrites/Receiver.cpp b/TAO/tests/LongWrites/Receiver.cpp
index 6425de4a18a..7d7f23ea44c 100644
--- a/TAO/tests/LongWrites/Receiver.cpp
+++ b/TAO/tests/LongWrites/Receiver.cpp
@@ -11,6 +11,13 @@ Receiver::Receiver (void)
{
}
+CORBA::ULong
+Receiver::message_count (void)
+{
+ ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, ace_mon, this->mutex_, 0);
+ return this->message_count_;
+}
+
void
Receiver::dump_results ()
{
@@ -31,5 +38,25 @@ Receiver::receive_data (const Test::Payload &payload,
this->message_count_++;
this->byte_count_ += payload.length ();
- ACE_DEBUG ((LM_DEBUG, "Receiver::receive_data\n"));
+ if (this->message_count_ % 100 == 0)
+ {
+ ACE_DEBUG ((LM_DEBUG, "(%P|%t) Receiver::receive_data %d\n",
+ this->message_count_));
+ }
+}
+
+void
+Receiver::receive_data_oneway (const Test::Payload &payload,
+ CORBA::Environment &ACE_TRY_ENV)
+ ACE_THROW_SPEC ((CORBA::SystemException))
+{
+ this->receive_data (payload, ACE_TRY_ENV);
+}
+
+Test::Payload *
+Receiver::return_data (const Test::Payload &payload,
+ CORBA::Environment &)
+ ACE_THROW_SPEC ((CORBA::SystemException))
+{
+ return new Test::Payload (payload);
}