blob: c53a847ca51340b6a256d19ecc6a5a04baf18f24 (
plain)
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
134
135
136
137
138
139
140
|
/* -*- C++ -*- */
// $Id$
// ==========================================================================
//
// = LIBRARY
// orbsvcs
//
// = FILENAME
// Notify_QoSAdmin_i.h
//
// = DESCRIPTION
// Implements get/set methods for QoS properties.
//
// = AUTHOR
// Pradeep Gore <pradeep@cs.wustl.edu>
//
// ==========================================================================
#ifndef TAO_NOTIFY_QOSADMIN_I_H
#define TAO_NOTIFY_QOSADMIN_I_H
#include "ace/pre.h"
#include "orbsvcs/CosNotificationC.h"
#include "orbsvcs/TimeBaseC.h"
#include "notify_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
class TAO_Notify_Export TAO_Notify_QoSAdmin_i
{
// = TITLE
// TAO_Notify_QoSAdmin_i
//
// = DESCRIPTION
//
//
public:
TAO_Notify_QoSAdmin_i (void);
// Constructor
virtual ~TAO_Notify_QoSAdmin_i (void);
// Destructor
virtual CosNotification::QoSProperties * get_qos (
ACE_ENV_SINGLE_ARG_DECL
)
ACE_THROW_SPEC ((
CORBA::SystemException
));
virtual void set_qos (
const CosNotification::QoSProperties & qos
ACE_ENV_ARG_DECL
)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosNotification::UnsupportedQoS
));
virtual void validate_qos (
const CosNotification::QoSProperties & required_qos,
CosNotification::NamedPropertyRangeSeq_out available_qos
ACE_ENV_ARG_DECL
)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosNotification::UnsupportedQoS
));
// Accessors
CORBA::Long maximum_batch_size (void) const;
TimeBase::TimeT pacing_interval (void) const;
protected:
// = QoS Properties
CORBA::Short event_reliability_;
CORBA::Boolean event_reliability_set_;
CORBA::Short connection_reliability_;
CORBA::Boolean connection_reliability_set_;
// Reliability properties (to be implemented "later").
CORBA::Short priority_;
CORBA::Boolean priority_set_;
// Priority for the event
/*
TimeBase::UtcT start_time_;
// Earliest delivery time
TimeBase::UtcT stop_time_;
*/
TimeBase::TimeT timeout_;
CORBA::Boolean timeout_set_;
// Expiry time
CORBA::Boolean start_time_supported_;
CORBA::Boolean start_time_supported_set_;
CORBA::Boolean stop_time_supported_;
CORBA::Boolean stop_time_supported_set_;
// Are start/stop times supported
CORBA::Long max_events_per_consumer_;
CORBA::Boolean max_events_per_consumer_set_;
// Max events allowed to be queued on behalf of a consumer
CORBA::Short order_policy_;
CORBA::Boolean order_policy_set_;
// Order of events in internal buffers.
CORBA::Short discard_policy_;
CORBA::Boolean discard_policy_set_;
// Policy to discard when buffers are full.
CORBA::Long maximum_batch_size_;
CORBA::Boolean maximum_batch_size_set_;
// Batch size for sequences of structured events.
TimeBase::TimeT pacing_interval_;
CORBA::Boolean pacing_interval_set_;
// Max. period of time that events are collected before delivering
// them as a sequence of structured events.
// TAO Specific QoS Properties
TimeBase::TimeT blocking_timeout_;
CORBA::Boolean blocking_timeout_set_;
//
};
#if defined (__ACE_INLINE__)
#include "Notify_QoSAdmin_i.inl"
#endif /* __ACE_INLINE__ */
#include "ace/post.h"
#endif /* TAO_NOTIFY_QOSADMIN_I_H */
|
