Instrumentation.h
Go to the documentation of this file.
1 // **********************************************************************
2 //
3 // Copyright (c) 2003-2017 ZeroC, Inc. All rights reserved.
4 //
5 // This copy of Ice is licensed to you under the terms described in the
6 // ICE_LICENSE file included in this distribution.
7 //
8 // **********************************************************************
9 //
10 // Ice version 3.7.0
11 //
12 // <auto-generated>
13 //
14 // Generated from file `Instrumentation.ice'
15 //
16 // Warning: do not edit this file.
17 //
18 // </auto-generated>
19 //
20 
21 #ifndef __IceStorm_Instrumentation_h__
22 #define __IceStorm_Instrumentation_h__
23 
24 #include <Ice/Comparable.h>
25 #include <Ice/Exception.h>
26 #include <Ice/ExceptionHelpers.h>
27 #include <Ice/FactoryTableInit.h>
28 #include <Ice/GCObject.h>
29 #include <Ice/Incoming.h>
30 #include <Ice/Instrumentation.h>
31 #include <Ice/LocalObject.h>
32 #include <Ice/Object.h>
33 #include <Ice/ObjectF.h>
34 #include <Ice/Optional.h>
35 #include <Ice/Proxy.h>
36 #include <Ice/ProxyF.h>
37 #include <Ice/StreamHelpers.h>
38 #include <Ice/Value.h>
39 #include <Ice/ValueF.h>
40 #include <IceStorm/IceStorm.h>
41 #include <IceUtil/PushDisableWarnings.h>
42 #include <IceUtil/ScopedArray.h>
43 #include <IceUtil/UndefSysMacros.h>
44 
45 #ifndef ICE_IGNORE_VERSION
46 #if ICE_INT_VERSION / 100 != 307
47 #error Ice version mismatch!
48 #endif
49 #if ICE_INT_VERSION % 100 > 50
50 #error Beta header file detected
51 #endif
52 #if ICE_INT_VERSION % 100 < 0
53 #error Ice patch level mismatch!
54 #endif
55 #endif
56 
57 #ifdef ICE_CPP11_MAPPING // C++11 mapping
58 
60 {
61 
62  class TopicObserver;
63  class SubscriberObserver;
64  class ObserverUpdater;
65  class TopicManagerObserver;
66 
67 } // namespace IceStorm::Instrumentation
68 
70 {
71 
72  enum class SubscriberState : unsigned char
73  {
77  };
78 
79 } // namespace IceStorm::Instrumentation
80 
82 {
83 
84  class TopicObserver : public virtual ::Ice::Instrumentation::Observer
85  {
86  public:
87  virtual ~TopicObserver();
88 
89  virtual void published() = 0;
90 
91  virtual void forwarded() = 0;
92  };
93 
94  class SubscriberObserver : public virtual ::Ice::Instrumentation::Observer
95  {
96  public:
97  virtual ~SubscriberObserver();
98 
99  virtual void queued(int) = 0;
100 
101  virtual void outstanding(int) = 0;
102 
103  virtual void delivered(int) = 0;
104  };
105 
106  class ObserverUpdater
107  {
108  public:
109  virtual ~ObserverUpdater();
110 
111  virtual void updateTopicObservers() = 0;
112 
113  virtual void updateSubscriberObservers() = 0;
114  };
115 
116  class TopicManagerObserver
117  {
118  public:
119  virtual ~TopicManagerObserver();
120 
121  virtual ::std::shared_ptr<::IceStorm::Instrumentation::TopicObserver>
122  getTopicObserver(const ::std::string&,
123  const ::std::string&,
124  const ::std::shared_ptr<::IceStorm::Instrumentation::TopicObserver>&) = 0;
125 
126  virtual ::std::shared_ptr<::IceStorm::Instrumentation::SubscriberObserver>
128  const ::std::string&,
129  const ::std::string&,
130  const ::std::shared_ptr<::Ice::ObjectPrx>&,
131  const ::IceStorm::QoS&,
132  const ::std::shared_ptr<::IceStorm::TopicPrx>&,
134  const ::std::shared_ptr<::IceStorm::Instrumentation::SubscriberObserver>&) = 0;
135 
136  virtual void setObserverUpdater(
137  const ::std::shared_ptr<::IceStorm::Instrumentation::ObserverUpdater>&) = 0;
138  };
139 
140 } // namespace IceStorm::Instrumentation
141 
142 namespace Ice
143 {
144 
145  template <>
146  struct StreamableTraits<::IceStorm::Instrumentation::SubscriberState>
147  {
148  static const StreamHelperCategory helper = StreamHelperCategoryEnum;
149  static const int minValue = 0;
150  static const int maxValue = 2;
151  static const int minWireSize = 1;
152  static const bool fixedLength = false;
153  };
154 
155 } // namespace Ice
156 
158 {
159 
160  using TopicObserverPtr = ::std::shared_ptr<TopicObserver>;
161 
162  using SubscriberObserverPtr = ::std::shared_ptr<SubscriberObserver>;
163 
164  using ObserverUpdaterPtr = ::std::shared_ptr<ObserverUpdater>;
165 
166  using TopicManagerObserverPtr = ::std::shared_ptr<TopicManagerObserver>;
167 
168 } // namespace IceStorm::Instrumentation
169 
170 
171 #else // C++98 mapping
172 
173 namespace IceProxy
174 {
175 
176 }
177 
179 {
180 
181  class TopicObserver;
182  ::Ice::LocalObject* upCast(::IceStorm::Instrumentation::TopicObserver*);
183  typedef ::IceInternal::Handle<::IceStorm::Instrumentation::TopicObserver> TopicObserverPtr;
184 
185  class SubscriberObserver;
187  typedef ::IceInternal::Handle<::IceStorm::Instrumentation::SubscriberObserver>
189 
190  class ObserverUpdater;
191  ::Ice::LocalObject* upCast(::IceStorm::Instrumentation::ObserverUpdater*);
192  typedef ::IceInternal::Handle<::IceStorm::Instrumentation::ObserverUpdater> ObserverUpdaterPtr;
193 
194  class TopicManagerObserver;
196  typedef ::IceInternal::Handle<::IceStorm::Instrumentation::TopicManagerObserver>
198 
199 } // namespace IceStorm::Instrumentation
200 
202 {
203 
205  {
209  };
210 
211 } // namespace IceStorm::Instrumentation
212 
213 namespace IceProxy
214 {
215 
216 }
217 
219 {
220 
221  class TopicObserver : virtual public ::Ice::Instrumentation::Observer
222  {
223  public:
225 
226  virtual ~TopicObserver();
227 
228  virtual void published() = 0;
229 
230  virtual void forwarded() = 0;
231  };
232 
233  inline bool
234  operator==(const TopicObserver& lhs, const TopicObserver& rhs)
235  {
236  return static_cast<const ::Ice::LocalObject&>(lhs) ==
237  static_cast<const ::Ice::LocalObject&>(rhs);
238  }
239 
240  inline bool
241  operator<(const TopicObserver& lhs, const TopicObserver& rhs)
242  {
243  return static_cast<const ::Ice::LocalObject&>(lhs) <
244  static_cast<const ::Ice::LocalObject&>(rhs);
245  }
246 
247  class SubscriberObserver : virtual public ::Ice::Instrumentation::Observer
248  {
249  public:
251 
252  virtual ~SubscriberObserver();
253 
254  virtual void queued(::Ice::Int) = 0;
255 
256  virtual void outstanding(::Ice::Int) = 0;
257 
258  virtual void delivered(::Ice::Int) = 0;
259  };
260 
261  inline bool
263  {
264  return static_cast<const ::Ice::LocalObject&>(lhs) ==
265  static_cast<const ::Ice::LocalObject&>(rhs);
266  }
267 
268  inline bool
270  {
271  return static_cast<const ::Ice::LocalObject&>(lhs) <
272  static_cast<const ::Ice::LocalObject&>(rhs);
273  }
274 
275  class ObserverUpdater : public virtual ::Ice::LocalObject
276  {
277  public:
279 
280  virtual ~ObserverUpdater();
281 
282  virtual void updateTopicObservers() = 0;
283 
284  virtual void updateSubscriberObservers() = 0;
285  };
286 
287  inline bool
289  {
290  return static_cast<const ::Ice::LocalObject&>(lhs) ==
291  static_cast<const ::Ice::LocalObject&>(rhs);
292  }
293 
294  inline bool
295  operator<(const ObserverUpdater& lhs, const ObserverUpdater& rhs)
296  {
297  return static_cast<const ::Ice::LocalObject&>(lhs) <
298  static_cast<const ::Ice::LocalObject&>(rhs);
299  }
300 
301  class TopicManagerObserver : public virtual ::Ice::LocalObject
302  {
303  public:
305 
306  virtual ~TopicManagerObserver();
307 
309  getTopicObserver(const ::std::string&,
310  const ::std::string&,
312 
314  getSubscriberObserver(const ::std::string&,
315  const ::std::string&,
316  const ::Ice::ObjectPrx&,
317  const ::IceStorm::QoS&,
321 
323  };
324 
325  inline bool
327  {
328  return static_cast<const ::Ice::LocalObject&>(lhs) ==
329  static_cast<const ::Ice::LocalObject&>(rhs);
330  }
331 
332  inline bool
334  {
335  return static_cast<const ::Ice::LocalObject&>(lhs) <
336  static_cast<const ::Ice::LocalObject&>(rhs);
337  }
338 
339 } // namespace IceStorm::Instrumentation
340 
341 namespace Ice
342 {
343 
344  template <>
346  {
347  static const StreamHelperCategory helper = StreamHelperCategoryEnum;
348  static const int minValue = 0;
349  static const int maxValue = 2;
350  static const int minWireSize = 1;
351  static const bool fixedLength = false;
352  };
353 
354 } // namespace Ice
355 
356 #endif
357 
358 #include <IceUtil/PopDisableWarnings.h>
359 #endif
IceStorm::Instrumentation::ObserverUpdaterPtr
::IceInternal::Handle<::IceStorm::Instrumentation::ObserverUpdater > ObserverUpdaterPtr
Definition: Instrumentation.h:192
IceStorm::Instrumentation::operator<
bool operator<(const TopicObserver &lhs, const TopicObserver &rhs)
Definition: Instrumentation.h:241
IceProxy
Definition: DBTypes.h:119
IceStorm::Instrumentation::SubscriberObserverPtr
::IceInternal::Handle<::IceStorm::Instrumentation::SubscriberObserver > SubscriberObserverPtr
Definition: Instrumentation.h:188
IceStorm::Instrumentation::SubscriberObserver::PointerType
SubscriberObserverPtr PointerType
Definition: Instrumentation.h:250
IceStorm::Instrumentation::TopicManagerObserver::PointerType
TopicManagerObserverPtr PointerType
Definition: Instrumentation.h:304
IceStorm::Instrumentation::TopicObserver::PointerType
TopicObserverPtr PointerType
Definition: Instrumentation.h:224
IceStorm::Instrumentation::TopicManagerObserver::~TopicManagerObserver
virtual ~TopicManagerObserver()
Definition: Instrumentation.cpp:105
IceStorm::Instrumentation::operator==
bool operator==(const TopicObserver &lhs, const TopicObserver &rhs)
Definition: Instrumentation.h:234
IceStorm::Instrumentation::TopicManagerObserver::getSubscriberObserver
virtual ::IceStorm::Instrumentation::SubscriberObserverPtr getSubscriberObserver(const ::std::string &, const ::std::string &, const ::Ice::ObjectPrx &, const ::IceStorm::QoS &, const ::IceStorm::TopicPrx &, ::IceStorm::Instrumentation::SubscriberState, const ::IceStorm::Instrumentation::SubscriberObserverPtr &)=0
IceStorm::Instrumentation::ObserverUpdater
The ObserverUpdater interface is implemented by IceStorm and an instance of this interface is provide...
Definition: Instrumentation.h:275
IceStorm::Instrumentation::TopicObserver
Definition: Instrumentation.h:221
IceStorm::Instrumentation::SubscriberState
SubscriberState
Definition: Instrumentation.h:204
IceStorm::Instrumentation::SubscriberObserver
Definition: Instrumentation.h:247
IceStorm::Instrumentation
Definition: Instrumentation.h:178
IceStorm::Instrumentation::ObserverUpdater::updateTopicObservers
virtual void updateTopicObservers()=0
IceInternal::Handle
Definition: forward_declarations.h:8
IceStorm::Instrumentation::ObserverUpdater::updateSubscriberObservers
virtual void updateSubscriberObservers()=0
IceStorm::Instrumentation::TopicManagerObserver::getTopicObserver
virtual ::IceStorm::Instrumentation::TopicObserverPtr getTopicObserver(const ::std::string &, const ::std::string &, const ::IceStorm::Instrumentation::TopicObserverPtr &)=0
IceStorm::Instrumentation::TopicManagerObserver::setObserverUpdater
virtual void setObserverUpdater(const ::IceStorm::Instrumentation::ObserverUpdaterPtr &)=0
IceStorm::Instrumentation::TopicManagerObserver
The topic manager observer interface used by the Ice run-time to obtain and update observers for its ...
Definition: Instrumentation.h:301
IceStorm::TopicPrx
::IceInternal::ProxyHandle<::IceProxy::IceStorm::Topic > TopicPrx
Definition: IceManager.h:70
IceStorm::Instrumentation::SubscriberStateOffline
@ SubscriberStateOffline
Offline, retrying.
Definition: Instrumentation.h:207
IceStorm::Instrumentation::TopicManagerObserverPtr
::IceInternal::Handle<::IceStorm::Instrumentation::TopicManagerObserver > TopicManagerObserverPtr
Definition: Instrumentation.h:197
IceStorm::Instrumentation::TopicObserverPtr
::IceInternal::Handle<::IceStorm::Instrumentation::TopicObserver > TopicObserverPtr
Definition: Instrumentation.h:183
IceStorm::Instrumentation::TopicObserver::published
virtual void published()=0
IceStorm::Instrumentation::upCast
::Ice::LocalObject * upCast(::IceStorm::Instrumentation::TopicObserver *)
Definition: Instrumentation.cpp:80
Ice
Definition: DBTypes.cpp:63
IceStorm::Instrumentation::SubscriberObserver::delivered
virtual void delivered(::Ice::Int)=0
IceStorm::Instrumentation::ObserverUpdater::PointerType
ObserverUpdaterPtr PointerType
Definition: Instrumentation.h:278
IceStorm::Instrumentation::ObserverUpdater::~ObserverUpdater
virtual ~ObserverUpdater()
Definition: Instrumentation.cpp:95
armarx::VariantType::Int
const VariantTypeId Int
Definition: Variant.h:917
IceStorm::Instrumentation::SubscriberObserver::queued
virtual void queued(::Ice::Int)=0
IceStorm::Instrumentation::SubscriberObserver::~SubscriberObserver
virtual ~SubscriberObserver()
Definition: Instrumentation.cpp:85
IceStorm::Instrumentation::TopicObserver::forwarded
virtual void forwarded()=0
IceStorm::Instrumentation::TopicObserver::~TopicObserver
virtual ~TopicObserver()
Definition: Instrumentation.cpp:75
IceStorm::Instrumentation::SubscriberObserver::outstanding
virtual void outstanding(::Ice::Int)=0
IceStorm::Instrumentation::SubscriberStateError
@ SubscriberStateError
Error state, awaiting to be destroyed.
Definition: Instrumentation.h:208
IceStorm::Instrumentation::SubscriberStateOnline
@ SubscriberStateOnline
Online waiting to send events.
Definition: Instrumentation.h:206