diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/RT_Task.h')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Event/RT_Task.h | 180 |
1 files changed, 0 insertions, 180 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/RT_Task.h b/TAO/orbsvcs/orbsvcs/Event/RT_Task.h deleted file mode 100644 index be8fc01ff9e..00000000000 --- a/TAO/orbsvcs/orbsvcs/Event/RT_Task.h +++ /dev/null @@ -1,180 +0,0 @@ -/* -*- C++ -*- */ -// $Id$ - -// ============================================================================ -// -// = LIBRARY -// ace -// -// = FILENAME -// RT_Task -// -// = AUTHOR -// Tim Harrison (harrison@cs.wustl.edu) -// -// = DESCRIPTION -// Wrapper on top of ACE Task that integrates an Active Object with -// the Event Service. -// -// ============================================================================ - -#ifndef ACE_RT_TASK_H -#define ACE_RT_TASK_H - -#include "ace/Task.h" - -#if !defined (ACE_LACKS_PRAGMA_ONCE) -# pragma once -#endif /* ACE_LACKS_PRAGMA_ONCE */ - -#include "orbsvcs/RtecSchedulerC.h" - -class TAO_ORBSVCS_Export ACE_RT_Thread_Manager : public ACE_Thread_Manager - // = TITLE - // - // = DESCRIPTION -{ -public: - ACE_RT_Thread_Manager (void); - // Default construction. - - void suspend_spawns (void); - // Any threads spawned will be suspended until <unsuspend_spawns> is - // called. - - void unsuspend_spawns (void); - // Resumes all threads. - -protected: - virtual int spawn_i (ACE_THR_FUNC func, - void *args, - long flags, - ACE_thread_t * = 0, - ACE_hthread_t *t_handle = 0, - long priority = 0, - int grp_id = -1, - void *stack = 0, - size_t stack_size = 0, - ACE_Task_Base *task = 0); - - int flags_; -}; - -// ************************************************************ - -class TAO_ORBSVCS_Export ACE_RT_Task_Command : public ACE_Message_Block -// = TITLE -// -// = DESCRIPTION -{ -public: - virtual ~ACE_RT_Task_Command (void) {} - // Guarantees that derived destructors get called. - - enum { RELEASE, UNGETQ }; - - virtual int execute (u_long &command_action) = 0; - // Execute the command. Returning 1 will make the calling thread - // exit. Returning 0 will allow the thread to continue dispatching - // commands. If <command_action> returns as RELEASE, the command - // will be released. If <command_action> == UNGETQ, then the - // command will be requeued and dispatched again. -}; - -// ************************************************************ - -typedef ACE_Task<ACE_SYNCH> ACE_ES_TASK; -typedef ACE_Message_Queue<ACE_SYNCH> ACE_ES_QUEUE; - -class TAO_ORBSVCS_Export ACE_RT_Task : public ACE_ES_TASK -{ - // = TITLE - // ACE Real-Time Task - // - // = DESCRIPTION - // Real-Time Active Object that integrates with a global - // scheduler and Event Service. For now, none of the management - // methods are synchronized. If it turns out that multiple - // threads will be calling the management methods, then we can - // add synchronization. For the most part, RT_Task threads - // should be dequeueing commands from the message queue. Only - // one thread should be calling any management methods. - friend class ACE_RT_Thread_Manager; -public: - ACE_RT_Task (void); - // Default construction. - - ~ACE_RT_Task (void); - // Deactivates the queue. - - // = Management methods. - - int open_task (const char* name = 0); - // <name> is used to look up our qos info from the scheduler. If - // <name> == 0, then we create a "unique" name and ask the scheduler - // for a new qos structure. If we find an existing qos structure, - // calls this->synch_threads and returns 1. If a qos structure is not - // found, but created returns 0 and does not call synch_threads. - // Returns -1 on failure. - - int try_put (ACE_Message_Block *mb); - // Enqueue a request. Returns 0 on success, -1 on failure. If the - // task is shutdown, -1 is returned with errno == EPIPE. - - int shutdown_task (void); - // If active, shutdown all running thread. Since this is - // accomplished via queued shutdown messages, this has the effect of - // flushing the queue. Once all threads exit, threads_closed will - // be called. If this is a passive object, then the queue will be - // flushed and threads_closed will be called. - - int synch_threads (size_t threads); - // Compare <threads> with what is actually running. If there are - // any differences, update this RT_Task. This may involve spawning - // more threads or changing thread priorities, etc. This can be - // used to close all threads by sending a 0. - - RtecScheduler::handle_t rt_info (void); - // QOS accessor. The behavior of the task can be changed by setting - // this and then calling this->synch_threads. - - virtual void threads_closed (void); - // Called when every thread has exited. This hook allows - // applications to specify semantics when all threads have exited. - // For instance, the Dispatching Module uses this hook to delete - // itself when an application is shutting down. - - virtual int svc_hook (RtecScheduler::OS_Priority priority); - // This is called the first time the thread is spawned. <priority> - // is the priority of the current thread. If this returns != 1 - // (e.g., 0), the event loop will execute (calling this->svc_one). - // If this returns 1, the event loop will not execute. - - virtual int svc_one (void); - // Call this->getq once and execute the command. Returns the result - // of command->execute (). - -protected: - RtecScheduler::handle_t rt_info_; - // Scheduling characteristics of this active object. - - int closed_; - // Set to 1 when this->shutdown_threads or this->close_queue is - // called. Keeps us from enqueuing more that one shutdown message. - - virtual int svc (void); - // Run by each thread spawned. Each thread dequeues - // ACE_RT_Task_Commands and executes them. - - virtual int close (u_long flags = 0); - // Called each time a thread exits. - - void close_all_threads (void); - // Enqueues shutdown message for every thread in the task. -}; - -#if defined (__ACE_INLINE__) -#include "RT_Task.i" -#endif /* __ACE_INLINE__ */ - -#endif /* ACE_RT_TASK_H */ |