1 files changed, 128 insertions, 0 deletions
diff --git a/TAO/examples/AMI/FL_Callback/Peer_i.h b/TAO/examples/AMI/FL_Callback/Peer_i.h
new file mode 100644
index 00000000000..c8d7fba80f9
--- /dev/null
+++ b/TAO/examples/AMI/FL_Callback/Peer_i.h
@@ -0,0 +1,128 @@
+// $Id$
+
+// ============================================================================
+//
+// = LIBRARY
+//   TAO/examples/AMI/FL_Callback
+//
+// = FILENAME
+//   Peer_i.h
+//
+// = AUTHOR
+//   Carlos O'Ryan
+//
+// ============================================================================
+
+#ifndef PEER_I_H
+#define PEER_I_H
+
+#include "testS.h"
+#include "ace/Task.h"
+
+class Peer_i;
+
+class Peer_Handler_i : public POA_AMI_Peer_Handler
+{
+public:
+  Peer_Handler_i (Peer_i *peer);
+  // The peer
+
+  virtual void request (CORBA::Long retval, 
+                         CORBA::Environment &ACE_TRY_ENV)
+    ACE_THROW_SPEC ((CORBA::SystemException));
+  virtual void start (CORBA::Environment &ACE_TRY_ENV)
+    ACE_THROW_SPEC ((CORBA::SystemException));
+  virtual void shutdown (CORBA::Environment &ACE_TRY_ENV)
+    ACE_THROW_SPEC ((CORBA::SystemException));
+
+private:
+  Peer_i *peer_;
+  // The real implementation
+};
+
+class Peer_i : public POA_Peer
+{
+public:
+  Peer_i (void);
+  // Constructor
+
+  virtual ~Peer_i (void);
+  // Destructor
+
+  void init (CORBA::ORB_ptr orb,
+             Progress_ptr progress,
+             const ACE_Time_Value &delay,
+             CORBA::Environment &ACE_TRY_ENV)
+    ACE_THROW_SPEC ((CORBA::SystemException));
+
+  void reply (CORBA::Long result,
+              CORBA::Environment &ACE_TRY_ENV)
+    ACE_THROW_SPEC ((CORBA::SystemException));
+  // Used by the Reply_Handler to indicate that a reply has been
+  // received.
+
+  // = See test.idl for an explanation of these methods.
+  CORBA::Long request (CORBA::Long id,
+                       CORBA::Environment& ACE_TRY_ENV)
+    ACE_THROW_SPEC ((CORBA::SystemException));
+  void start (const PeerSet& the_peers,
+              CORBA::Long iterations,
+              CORBA::Environment& ACE_TRY_ENV)
+    ACE_THROW_SPEC ((CORBA::SystemException));
+
+  void shutdown (CORBA::Environment& ACE_TRY_ENV)
+    ACE_THROW_SPEC ((CORBA::SystemException));
+
+private:
+  Peer_Handler_i reply_handler_;
+  // The reply_handler
+
+  CORBA::ORB_var orb_;
+  // The orb
+
+  Progress_var progress_;
+  // The interface to report back progress.
+
+  ACE_Time_Value delay_;
+  // The delay on each request
+
+  CORBA::Long id_;
+  // The id assigned by the progress interface
+};
+
+class Peer_Task : public ACE_Task_Base
+{
+  // = DESCRIPTION
+  //   Run a "start" request on a separate thread.
+public:
+  Peer_Task (const PeerSet& the_peers,
+             CORBA::Long iterations,
+             Progress_ptr progress,
+             AMI_Peer_Handler_ptr handler,
+             CORBA::Long id);
+
+  virtual int svc (void);
+  // The thread entry point
+
+private:
+  PeerSet the_peers_;
+  // The peers
+
+  CORBA::Long iterations_;
+  // The number of iterations
+
+  Progress_var progress_;
+  // To report progress
+
+  AMI_Peer_Handler_var handler_;
+  // To issue async requests
+
+  CORBA::Long id_;
+  // Our id
+};
+
+#if defined(__ACE_INLINE__)
+#include "Peer_i.i"
+#endif /* __ACE_INLINE__ */
+
+#endif /* PEER_I_H */