diff options
Diffstat (limited to 'TAO/examples/AMI/FL_Callback/Peer_i.h')
-rw-r--r-- | TAO/examples/AMI/FL_Callback/Peer_i.h | 128 |
1 files changed, 0 insertions, 128 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 c8d7fba80f9..00000000000 --- a/TAO/examples/AMI/FL_Callback/Peer_i.h +++ /dev/null @@ -1,128 +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_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 */ |