summaryrefslogtreecommitdiff
path: root/TAO/performance-tests/Throughput/Receiver.h
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/performance-tests/Throughput/Receiver.h')
-rw-r--r--TAO/performance-tests/Throughput/Receiver.h52
1 files changed, 52 insertions, 0 deletions
diff --git a/TAO/performance-tests/Throughput/Receiver.h b/TAO/performance-tests/Throughput/Receiver.h
new file mode 100644
index 00000000000..10b4b65544b
--- /dev/null
+++ b/TAO/performance-tests/Throughput/Receiver.h
@@ -0,0 +1,52 @@
+//
+// $Id$
+//
+
+#ifndef THROUGHPUT_RECEIVER_H
+#define THROUGHPUT_RECEIVER_H
+#include /**/ "ace/pre.h"
+
+#include "TestS.h"
+#include "ace/OS_NS_time.h"
+
+#if defined (_MSC_VER)
+# pragma warning(push)
+# pragma warning (disable:4250)
+#endif /* _MSC_VER */
+
+/// Implement the Test::Receiver interface
+class Receiver
+ : public virtual POA_Test::Receiver
+{
+public:
+ /// Constructor
+ Receiver (void);
+
+ // = The skeleton methods
+ virtual void receive_data (const Test::Message &message);
+
+ virtual void done (void);
+
+private:
+ /// The timestamp for the first message
+ ACE_hrtime_t start_time_;
+
+ /// The number of messages received
+ size_t message_count_;
+
+ /// The number of bytes received
+ size_t byte_count_;
+
+ /// The timestamp for the last message
+ ACE_hrtime_t last_message_time_;
+
+ /// The id for the last message
+ CORBA::ULong last_message_id_;
+};
+
+#if defined(_MSC_VER)
+# pragma warning(pop)
+#endif /* _MSC_VER */
+
+#include /**/ "ace/post.h"
+#endif /* THROUGHPUT_RECEIVER_H */