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 <IceUtil/PushDisableWarnings.h>
25 #include <Ice/ProxyF.h>
26 #include <Ice/ObjectF.h>
27 #include <Ice/ValueF.h>
28 #include <Ice/Exception.h>
29 #include <Ice/LocalObject.h>
30 #include <Ice/StreamHelpers.h>
31 #include <Ice/Comparable.h>
32 #include <Ice/Proxy.h>
33 #include <Ice/Object.h>
34 #include <Ice/GCObject.h>
35 #include <Ice/Value.h>
36 #include <Ice/Incoming.h>
37 #include <Ice/FactoryTableInit.h>
38 #include <IceUtil/ScopedArray.h>
39 #include <Ice/Optional.h>
40 #include <Ice/ExceptionHelpers.h>
41 #include <Ice/Instrumentation.h>
42 #include <IceStorm/IceStorm.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 }
68 
69 
70 
72 {
73 
74  enum class SubscriberState : unsigned char
75  {
79  };
80 
81 }
82 
83 
84 
86 {
87 
88  class TopicObserver : public virtual ::Ice::Instrumentation::Observer
89  {
90  public:
91 
92  virtual ~TopicObserver();
93 
94  virtual void published() = 0;
95 
96  virtual void forwarded() = 0;
97  };
98 
99  class SubscriberObserver : public virtual ::Ice::Instrumentation::Observer
100  {
101  public:
102 
103  virtual ~SubscriberObserver();
104 
105  virtual void queued(int) = 0;
106 
107  virtual void outstanding(int) = 0;
108 
109  virtual void delivered(int) = 0;
110  };
111 
112  class ObserverUpdater
113  {
114  public:
115 
116  virtual ~ObserverUpdater();
117 
118  virtual void updateTopicObservers() = 0;
119 
120  virtual void updateSubscriberObservers() = 0;
121  };
122 
123  class TopicManagerObserver
124  {
125  public:
126 
127  virtual ~TopicManagerObserver();
128 
129  virtual ::std::shared_ptr<::IceStorm::Instrumentation::TopicObserver> getTopicObserver(const ::std::string&, const ::std::string&, const ::std::shared_ptr<::IceStorm::Instrumentation::TopicObserver>&) = 0;
130 
131  virtual ::std::shared_ptr<::IceStorm::Instrumentation::SubscriberObserver> getSubscriberObserver(const ::std::string&, const ::std::string&, const ::std::shared_ptr<::Ice::ObjectPrx>&, const ::IceStorm::QoS&, const ::std::shared_ptr<::IceStorm::TopicPrx>&, ::IceStorm::Instrumentation::SubscriberState, const ::std::shared_ptr<::IceStorm::Instrumentation::SubscriberObserver>&) = 0;
132 
133  virtual void setObserverUpdater(const ::std::shared_ptr<::IceStorm::Instrumentation::ObserverUpdater>&) = 0;
134  };
135 
136 }
137 
138 
139 
140 namespace Ice
141 {
142 
143  template<>
144  struct StreamableTraits< ::IceStorm::Instrumentation::SubscriberState>
145  {
146  static const StreamHelperCategory helper = StreamHelperCategoryEnum;
147  static const int minValue = 0;
148  static const int maxValue = 2;
149  static const int minWireSize = 1;
150  static const bool fixedLength = false;
151  };
152 
153 }
154 
156 {
157 
158  using TopicObserverPtr = ::std::shared_ptr<TopicObserver>;
159 
160  using SubscriberObserverPtr = ::std::shared_ptr<SubscriberObserver>;
161 
162  using ObserverUpdaterPtr = ::std::shared_ptr<ObserverUpdater>;
163 
164  using TopicManagerObserverPtr = ::std::shared_ptr<TopicManagerObserver>;
165 
166 }
167 
168 
169 
170 #else // C++98 mapping
171 
172 namespace IceProxy
173 {
174 
175 }
176 
178 {
179 
180  class TopicObserver;
181  ::Ice::LocalObject* upCast(::IceStorm::Instrumentation::TopicObserver*);
182  typedef ::IceInternal::Handle< ::IceStorm::Instrumentation::TopicObserver> TopicObserverPtr;
183 
184  class SubscriberObserver;
186  typedef ::IceInternal::Handle< ::IceStorm::Instrumentation::SubscriberObserver> SubscriberObserverPtr;
187 
188  class ObserverUpdater;
189  ::Ice::LocalObject* upCast(::IceStorm::Instrumentation::ObserverUpdater*);
190  typedef ::IceInternal::Handle< ::IceStorm::Instrumentation::ObserverUpdater> ObserverUpdaterPtr;
191 
192  class TopicManagerObserver;
194  typedef ::IceInternal::Handle< ::IceStorm::Instrumentation::TopicManagerObserver> TopicManagerObserverPtr;
195 
196 }
197 
198 
199 
201 {
202 
204  {
208  };
209 
210 }
211 
212 
213 
214 namespace IceProxy
215 {
216 
217 }
218 
220 {
221 
222  class TopicObserver : virtual public ::Ice::Instrumentation::Observer
223  {
224  public:
225 
227 
228  virtual ~TopicObserver();
229 
230  virtual void published() = 0;
231 
232  virtual void forwarded() = 0;
233  };
234 
235  inline bool operator==(const TopicObserver& lhs, const TopicObserver& rhs)
236  {
237  return static_cast<const ::Ice::LocalObject&>(lhs) == static_cast<const ::Ice::LocalObject&>(rhs);
238  }
239 
240  inline bool operator<(const TopicObserver& lhs, const TopicObserver& rhs)
241  {
242  return static_cast<const ::Ice::LocalObject&>(lhs) < static_cast<const ::Ice::LocalObject&>(rhs);
243  }
244 
245  class SubscriberObserver : virtual public ::Ice::Instrumentation::Observer
246  {
247  public:
248 
250 
251  virtual ~SubscriberObserver();
252 
253  virtual void queued(::Ice::Int) = 0;
254 
255  virtual void outstanding(::Ice::Int) = 0;
256 
257  virtual void delivered(::Ice::Int) = 0;
258  };
259 
260  inline bool operator==(const SubscriberObserver& lhs, const SubscriberObserver& rhs)
261  {
262  return static_cast<const ::Ice::LocalObject&>(lhs) == static_cast<const ::Ice::LocalObject&>(rhs);
263  }
264 
265  inline bool operator<(const SubscriberObserver& lhs, const SubscriberObserver& rhs)
266  {
267  return static_cast<const ::Ice::LocalObject&>(lhs) < static_cast<const ::Ice::LocalObject&>(rhs);
268  }
269 
270  class ObserverUpdater : public virtual ::Ice::LocalObject
271  {
272  public:
273 
275 
276  virtual ~ObserverUpdater();
277 
278  virtual void updateTopicObservers() = 0;
279 
280  virtual void updateSubscriberObservers() = 0;
281  };
282 
283  inline bool operator==(const ObserverUpdater& lhs, const ObserverUpdater& rhs)
284  {
285  return static_cast<const ::Ice::LocalObject&>(lhs) == static_cast<const ::Ice::LocalObject&>(rhs);
286  }
287 
288  inline bool operator<(const ObserverUpdater& lhs, const ObserverUpdater& rhs)
289  {
290  return static_cast<const ::Ice::LocalObject&>(lhs) < static_cast<const ::Ice::LocalObject&>(rhs);
291  }
292 
293  class TopicManagerObserver : public virtual ::Ice::LocalObject
294  {
295  public:
296 
298 
299  virtual ~TopicManagerObserver();
300 
302 
304 
306  };
307 
308  inline bool operator==(const TopicManagerObserver& lhs, const TopicManagerObserver& rhs)
309  {
310  return static_cast<const ::Ice::LocalObject&>(lhs) == static_cast<const ::Ice::LocalObject&>(rhs);
311  }
312 
313  inline bool operator<(const TopicManagerObserver& lhs, const TopicManagerObserver& rhs)
314  {
315  return static_cast<const ::Ice::LocalObject&>(lhs) < static_cast<const ::Ice::LocalObject&>(rhs);
316  }
317 
318 }
319 
320 
321 
322 namespace Ice
323 {
324 
325  template<>
326  struct StreamableTraits< ::IceStorm::Instrumentation::SubscriberState>
327  {
328  static const StreamHelperCategory helper = StreamHelperCategoryEnum;
329  static const int minValue = 0;
330  static const int maxValue = 2;
331  static const int minWireSize = 1;
332  static const bool fixedLength = false;
333  };
334 
335 }
336 
337 #endif
338 
339 #include <IceUtil/PopDisableWarnings.h>
340 #endif
IceStorm::Instrumentation::operator<
bool operator<(const TopicObserver &lhs, const TopicObserver &rhs)
Definition: Instrumentation.h:240
IceStorm::Instrumentation::TopicObserverPtr
::IceInternal::Handle< ::IceStorm::Instrumentation::TopicObserver > TopicObserverPtr
Definition: Instrumentation.h:182
IceProxy
Definition: DBTypes.h:115
IceStorm::Instrumentation::SubscriberObserver::PointerType
SubscriberObserverPtr PointerType
Definition: Instrumentation.h:249
IceStorm::Instrumentation::TopicManagerObserver::PointerType
TopicManagerObserverPtr PointerType
Definition: Instrumentation.h:297
IceStorm::Instrumentation::TopicObserver::PointerType
TopicObserverPtr PointerType
Definition: Instrumentation.h:226
IceStorm::Instrumentation::TopicManagerObserver::~TopicManagerObserver
virtual ~TopicManagerObserver()
Definition: Instrumentation.cpp:103
IceStorm::Instrumentation::operator==
bool operator==(const TopicObserver &lhs, const TopicObserver &rhs)
Definition: Instrumentation.h:235
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:270
IceStorm::Instrumentation::TopicObserver
Definition: Instrumentation.h:222
IceStorm::Instrumentation::SubscriberState
SubscriberState
Definition: Instrumentation.h:203
IceStorm::Instrumentation::SubscriberObserver
Definition: Instrumentation.h:245
IceStorm::Instrumentation
Definition: Instrumentation.h:177
IceStorm::Instrumentation::ObserverUpdater::updateTopicObservers
virtual void updateTopicObservers()=0
IceInternal::Handle
Definition: forward_declarations.h:8
IceStorm::Instrumentation::ObserverUpdaterPtr
::IceInternal::Handle< ::IceStorm::Instrumentation::ObserverUpdater > ObserverUpdaterPtr
Definition: Instrumentation.h:190
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:293
IceStorm::Instrumentation::SubscriberStateOffline
@ SubscriberStateOffline
Offline, retrying.
Definition: Instrumentation.h:206
IceStorm::TopicPrx
::IceInternal::ProxyHandle< ::IceProxy::IceStorm::Topic > TopicPrx
Definition: IceManager.h:70
IceStorm::Instrumentation::TopicManagerObserverPtr
::IceInternal::Handle< ::IceStorm::Instrumentation::TopicManagerObserver > TopicManagerObserverPtr
Definition: Instrumentation.h:194
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:64
IceStorm::Instrumentation::SubscriberObserver::delivered
virtual void delivered(::Ice::Int)=0
IceStorm::Instrumentation::ObserverUpdater::PointerType
ObserverUpdaterPtr PointerType
Definition: Instrumentation.h:274
IceStorm::Instrumentation::ObserverUpdater::~ObserverUpdater
virtual ~ObserverUpdater()
Definition: Instrumentation.cpp:94
armarx::VariantType::Int
const VariantTypeId Int
Definition: Variant.h:916
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:76
IceStorm::Instrumentation::SubscriberObserverPtr
::IceInternal::Handle< ::IceStorm::Instrumentation::SubscriberObserver > SubscriberObserverPtr
Definition: Instrumentation.h:186
IceStorm::Instrumentation::SubscriberObserver::outstanding
virtual void outstanding(::Ice::Int)=0
IceStorm::Instrumentation::SubscriberStateError
@ SubscriberStateError
Error state, awaiting to be destroyed.
Definition: Instrumentation.h:207
IceStorm::Instrumentation::SubscriberStateOnline
@ SubscriberStateOnline
Online waiting to send events.
Definition: Instrumentation.h:205