summaryrefslogtreecommitdiff
path: root/TAO/examples/AMI/FL_Callback/Peer_i.h
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/examples/AMI/FL_Callback/Peer_i.h')
-rw-r--r--TAO/examples/AMI/FL_Callback/Peer_i.h135
1 files changed, 0 insertions, 135 deletions
diff --git a/TAO/examples/AMI/FL_Callback/Peer_i.h b/TAO/examples/AMI/FL_Callback/Peer_i.h
deleted file mode 100644
index bc2e1e799b9..00000000000
--- a/TAO/examples/AMI/FL_Callback/Peer_i.h
+++ /dev/null
@@ -1,135 +0,0 @@
-// $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_PeerHandler
-{
-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 request_excep (AMI_PeerExceptionHolder * excep_holder,
- 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_PeerHandler_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_PeerHandler_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 */