diff options
author | William R. Otte <wotte@dre.vanderbilt.edu> | 2008-03-04 14:51:23 +0000 |
---|---|---|
committer | William R. Otte <wotte@dre.vanderbilt.edu> | 2008-03-04 14:51:23 +0000 |
commit | 99aa8c60282c7b8072eb35eb9ac815702f5bf586 (patch) | |
tree | bda96bf8c3a4c2875a083d7b16720533c8ffeaf4 /ACE/apps/JAWS2/JAWS/Pipeline_Tasks.h | |
parent | c4078c377d74290ebe4e66da0b4975da91732376 (diff) | |
download | ATCD-99aa8c60282c7b8072eb35eb9ac815702f5bf586.tar.gz |
undoing accidental deletion
Diffstat (limited to 'ACE/apps/JAWS2/JAWS/Pipeline_Tasks.h')
-rw-r--r-- | ACE/apps/JAWS2/JAWS/Pipeline_Tasks.h | 56 |
1 files changed, 56 insertions, 0 deletions
diff --git a/ACE/apps/JAWS2/JAWS/Pipeline_Tasks.h b/ACE/apps/JAWS2/JAWS/Pipeline_Tasks.h new file mode 100644 index 00000000000..3bbb5080593 --- /dev/null +++ b/ACE/apps/JAWS2/JAWS/Pipeline_Tasks.h @@ -0,0 +1,56 @@ +/* -*- c++ -*- */ +// $Id$ + +#ifndef JAWS_PIPELINE_TASKS_H +#define JAWS_PIPELINE_TASKS_H + +#include "ace/Singleton.h" + +#if !defined (ACE_LACKS_PRAGMA_ONCE) +# pragma once +#endif /* ACE_LACKS_PRAGMA_ONCE */ + +#include "JAWS/Export.h" +#include "JAWS/Pipeline.h" +#include "JAWS/Pipeline_Handler_T.h" +#include "JAWS/Data_Block.h" + +class JAWS_Export JAWS_Pipeline_Handler + : public JAWS_Pipeline_Abstract_Handler<JAWS_Data_Block> +{ +public: + JAWS_Pipeline_Handler (void); + virtual ~JAWS_Pipeline_Handler (void); + virtual int put (ACE_Message_Block *mb, ACE_Time_Value *tv = 0); + virtual int handle_put (JAWS_Data_Block *data, ACE_Time_Value *tv) = 0; + + virtual JAWS_Dispatch_Policy * policy (void); + virtual void policy (JAWS_Dispatch_Policy *); + +private: + JAWS_Dispatch_Policy *policy_; +}; + +class JAWS_Pipeline_Accept_Task : public JAWS_Pipeline_Handler +{ +public: + virtual int put (ACE_Message_Block *mb, ACE_Time_Value *tv = 0); + virtual int handle_put (JAWS_Data_Block *data, ACE_Time_Value *tv); + + virtual JAWS_IO_Handler * new_handler (JAWS_Data_Block *data); +}; + +class JAWS_Pipeline_Done_Task : public JAWS_Pipeline_Handler +{ +public: + virtual int put (ACE_Message_Block *mb, ACE_Time_Value *tv = 0); + virtual int handle_put (JAWS_Data_Block *data, ACE_Time_Value *tv); +}; + +typedef ACE_Singleton<JAWS_Pipeline_Accept_Task, ACE_SYNCH_MUTEX> + JAWS_Pipeline_Accept_Task_Singleton; + +typedef ACE_Singleton<JAWS_Pipeline_Done_Task, ACE_SYNCH_NULL_MUTEX> + JAWS_Pipeline_Done_Task_Singleton; + +#endif /* !defined (JAWS_PIPELINE_TASKS_H) */ |