diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/EC_Dispatching_Task.h')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Event/EC_Dispatching_Task.h | 123 |
1 files changed, 0 insertions, 123 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_Dispatching_Task.h b/TAO/orbsvcs/orbsvcs/Event/EC_Dispatching_Task.h deleted file mode 100644 index 3133fcdf1c4..00000000000 --- a/TAO/orbsvcs/orbsvcs/Event/EC_Dispatching_Task.h +++ /dev/null @@ -1,123 +0,0 @@ -/* -*- C++ -*- */ -// $Id$ -// -// ============================================================================ -// -// = LIBRARY -// ORBSVCS Real-time Event Channel -// -// = FILENAME -// EC_Dispatching_Task -// -// = AUTHOR -// Carlos O'Ryan (coryan@cs.wustl.edu) -// -// = CREDITS -// Based on previous work by Tim Harrison (harrison@cs.wustl.edu) -// and other members of the DOC group. -// More details can be found in: -// http://www.cs.wustl.edu/~schmidt/oopsla.ps.gz -// http://www.cs.wustl.edu/~schmidt/JSAC-98.ps.gz -// -// -// ============================================================================ - -#ifndef TAO_EC_DISPATCHING_TASK_H -#define TAO_EC_DISPATCHING_TASK_H - -#include "ace/Task.h" -#include "ace/Message_Block.h" - -#if !defined (ACE_LACKS_PRAGMA_ONCE) -# pragma once -#endif /* ACE_LACKS_PRAGMA_ONCE */ - -#include "orbsvcs/RtecEventCommC.h" - -class TAO_EC_ProxyPushSupplier; - -class TAO_ORBSVCS_Export TAO_EC_Dispatching_Task : public ACE_Task<ACE_SYNCH> -{ - // = TITLE - // Implement the dispatching queues for FIFO and Priority - // dispatching. - // - // = DESCRIPTION - // -public: - TAO_EC_Dispatching_Task (ACE_Thread_Manager* thr_manager = 0); - // Constructor - - virtual int svc (void); - // Process the events in the queue. - - virtual void push (TAO_EC_ProxyPushSupplier *proxy, - RtecEventComm::EventSet& event, - CORBA::Environment &env); - -private: - ACE_Allocator *allocator_; - // An per-task allocator - - ACE_Locked_Data_Block<ACE_Lock_Adapter<ACE_SYNCH_MUTEX> > data_block_; - // Helper data structure to minimize memory allocations... -}; - -// **************************************************************** - -class TAO_ORBSVCS_Export TAO_EC_Dispatch_Command : public ACE_Message_Block -{ -public: - TAO_EC_Dispatch_Command (ACE_Allocator *mb_allocator = 0); - // Constructor, it will allocate its own data block - - TAO_EC_Dispatch_Command (ACE_Data_Block*, - ACE_Allocator *mb_allocator = 0); - // Constructor, it assumes ownership of the data block - - virtual ~TAO_EC_Dispatch_Command (void); - // Destructor - - virtual int execute (CORBA::Environment&) = 0; - // Command callback -}; - -// **************************************************************** - -class TAO_ORBSVCS_Export TAO_EC_Shutdown_Command : public TAO_EC_Dispatch_Command -{ -public: - TAO_EC_Shutdown_Command (ACE_Allocator *mb_allocator = 0); - // Constructor - - virtual int execute (CORBA::Environment&); - // Command callback -}; - -// **************************************************************** - -class TAO_ORBSVCS_Export TAO_EC_Push_Command : public TAO_EC_Dispatch_Command -{ -public: - TAO_EC_Push_Command (TAO_EC_ProxyPushSupplier* proxy, - RtecEventComm::EventSet& event, - ACE_Data_Block* data_block, - ACE_Allocator *mb_allocator); - // Constructor - - virtual int execute (CORBA::Environment&); - // Command callback - -private: - TAO_EC_ProxyPushSupplier* proxy_; - // The proxy - - RtecEventComm::EventSet event_; - // The event -}; - -#if defined (__ACE_INLINE__) -#include "EC_Dispatching_Task.i" -#endif /* __ACE_INLINE__ */ - -#endif /* TAO_EC_DISPATCHING_TASK_H */ |