summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Event/EC_Dispatching_Task.h
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/EC_Dispatching_Task.h')
-rw-r--r--TAO/orbsvcs/orbsvcs/Event/EC_Dispatching_Task.h123
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 */