1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
/* -*- C++ -*- */
/**
* @file EC_Kokyu_Filter.h
*
* $Id$
*
* @author Carlos O'Ryan (coryan@cs.wustl.edu)
*
* 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://doc.ece.uci.edu/~coryan/EC/index.html
*/
#ifndef TAO_EC_KOKYU_FILTER_H
#define TAO_EC_KOKYU_FILTER_H
#include /**/ "ace/pre.h"
#include "EC_Filter.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "orbsvcs/RtecSchedulerC.h"
#include "rtkokyu_event_export.h"
#include "ace/SString.h"
//#define EC_KOKYU_LOGGING
/**
* @class TAO_EC_Kokyu_Filter
*
* @brief Decorate a filter with scheduling information
*
* This filter decorates a regular filter with scheduling
* information. It creates a new RT_Info entry for the filter and
* it adds the dependencies between the filter and any childrens
* it may have.
*
* <H2>Memory Management</H2>
* It assumes ownership of the children.
*/
class TAO_RTKokyuEvent_Export TAO_EC_Kokyu_Filter : public TAO_EC_Filter
{
public:
/**
* Constructor.
* It assumes ownership of the @a body, makes a copy of the other
* parameters
*/
TAO_EC_Kokyu_Filter (const char* name,
RtecScheduler::handle_t rt_info,
RtecScheduler::Scheduler_ptr scheduler,
TAO_EC_Filter* body,
RtecScheduler::handle_t body_info,
RtecScheduler::handle_t parent_info,
RtecScheduler::Info_Type_t info_type);
/// Destructor
virtual ~TAO_EC_Kokyu_Filter (void);
// = The TAO_EC_Filter methods, please check the documentation in
// TAO_EC_Filter.
virtual ChildrenIterator begin (void) const;
virtual ChildrenIterator end (void) const;
virtual int size (void) const;
virtual int filter (const RtecEventComm::EventSet& event,
TAO_EC_QOS_Info& qos_info
ACE_ENV_ARG_DECL);
virtual int filter_nocopy (RtecEventComm::EventSet& event,
TAO_EC_QOS_Info& qos_info
ACE_ENV_ARG_DECL);
virtual void push (const RtecEventComm::EventSet& event,
TAO_EC_QOS_Info& qos_info
ACE_ENV_ARG_DECL);
virtual void push_nocopy (RtecEventComm::EventSet& event,
TAO_EC_QOS_Info& qos_info
ACE_ENV_ARG_DECL);
virtual void clear (void);
virtual CORBA::ULong max_event_size (void) const;
virtual int can_match (const RtecEventComm::EventHeader& header) const;
virtual int add_dependencies (const RtecEventComm::EventHeader& header,
const TAO_EC_QOS_Info &qos_info
ACE_ENV_ARG_DECL);
virtual void get_qos_info (TAO_EC_QOS_Info& qos_info
ACE_ENV_ARG_DECL);
private:
ACE_UNIMPLEMENTED_FUNC (TAO_EC_Kokyu_Filter
(const TAO_EC_Kokyu_Filter&))
ACE_UNIMPLEMENTED_FUNC (TAO_EC_Kokyu_Filter& operator=
(const TAO_EC_Kokyu_Filter&))
/// Initialize our RT_Info handle and dependencies
void init_rt_info (ACE_ENV_SINGLE_ARG_DECL);
/// Compute a new qos_info to push up.
void compute_qos_info (TAO_EC_QOS_Info& qos_info
ACE_ENV_ARG_DECL);
private:
/// The RT_Info handle for this object
RtecScheduler::handle_t rt_info_;
/// Has the Scheduler been updated?
int rt_info_computed_;
/// Our operation name
ACE_CString name_;
/// The scheduler we are going to use
RtecScheduler::Scheduler_var scheduler_;
/// The implementation
TAO_EC_Filter* body_;
/// The RT_Info handle for the body
RtecScheduler::handle_t body_info_;
/// The RT_Info handle for the parent
RtecScheduler::handle_t parent_info_;
/// Required for the scheduling service
RtecScheduler::Info_Type_t info_type_;
};
#if defined (__ACE_INLINE__)
#include "EC_Kokyu_Filter.i"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* TAO_EC_KOKYU_FILTER_H */
|
