1 files changed, 81 insertions, 0 deletions
diff --git a/TAO/examples/PluggableUDP/tests/Performance/UDP_i.h b/TAO/examples/PluggableUDP/tests/Performance/UDP_i.h
new file mode 100644
index 00000000000..9754f100c19
--- /dev/null
+++ b/TAO/examples/PluggableUDP/tests/Performance/UDP_i.h
@@ -0,0 +1,81 @@
+// -*- C++ -*-
+// $Id$
+
+// ============================================================================
+//
+// = LIBRARY
+//    TAO/examples/PluggableUDP/tests/Performance
+//
+// = FILENAME
+//    UDP_i.h
+//
+// = DESCRIPTION
+//    This class implements the server functionality of the UDP test.
+//
+// = AUTHOR
+//    Michael Kircher <Michael.Kircher@mchp.siemens.de>
+//
+// ============================================================================
+
+#ifndef UDP_I_H
+#define UDP_I_H
+
+#include "UDPS.h"
+#include "ace/Hash_Map_Manager_T.h"
+#include "ace/Null_Mutex.h"
+
+class UDP_i: public POA_UDP
+{
+  // = TITLE
+  //    UDP Object Implementation
+  //
+  // = DESCRIPTION
+  //
+public:
+  // = Initialization and termination methods.
+  UDP_i (void);
+  // Constructor
+
+  ~UDP_i (void);
+  // Destructor
+
+  virtual void setResponseHandler (UDP_ptr udpHandler);
+
+  virtual void invoke (const char *client_name,
+                       CORBA::Long request_id);
+
+  virtual void reset (const char * client_name);
+
+
+  virtual void shutdown (void);
+
+  // Shutdown the server.
+
+  void orb (CORBA::ORB_ptr o);
+  // Set the ORB pointer.
+
+  ACE_UINT32 getMessagesCount ();
+  // Return the number of lost messages
+
+  ACE_UINT32 getWrongMessagesCount ();
+  // Return the number of lost messages
+
+
+private:
+  CORBA::ORB_var orb_;
+  // ORB pointer.
+
+  ACE_Hash_Map_Manager_Ex < CORBA::String_var,
+                            CORBA::Long,
+                            ACE_Hash < const char * >,
+                            ACE_Equal_To < const char * >,
+                            ACE_Null_Mutex > request_id_table_;
+
+  ACE_UINT32 messages_count_;
+
+  ACE_UINT32 wrong_messages_count_;
+
+  UDP_var responseHandler_;
+};
+
+#endif /* UDP_I_H */