Election.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 `Election.ice'
15 //
16 // Warning: do not edit this file.
17 //
18 // </auto-generated>
19 //
20 
21 #ifndef __IceStorm_Election_h__
22 #define __IceStorm_Election_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/Identity.h>
42 #include <Ice/BuiltinSequences.h>
44 #include <IceStorm/LLURecord.h>
45 #include <IceUtil/UndefSysMacros.h>
46 
47 #ifndef ICE_IGNORE_VERSION
48 # if ICE_INT_VERSION / 100 != 307
49 # error Ice version mismatch!
50 # endif
51 # if ICE_INT_VERSION % 100 > 50
52 # error Beta header file detected
53 # endif
54 # if ICE_INT_VERSION % 100 < 0
55 # error Ice patch level mismatch!
56 # endif
57 #endif
58 
59 #ifdef ICE_CPP11_MAPPING // C++11 mapping
60 
61 namespace IceStormElection
62 {
63 
64  class ReplicaObserver;
65  class ReplicaObserverPrx;
66  class TopicManagerSync;
67  class TopicManagerSyncPrx;
68  class Node;
69  class NodePrx;
70 
71 }
72 
73 namespace IceStormElection
74 {
75 
76  struct TopicContent
77  {
80 
81  std::tuple<const ::Ice::Identity&, const ::IceStorm::SubscriberRecordSeq&> ice_tuple() const
82  {
83  return std::tie(id, records);
84  }
85  };
86 
87  using TopicContentSeq = ::std::vector<::IceStormElection::TopicContent>;
88 
89  class ObserverInconsistencyException : public ::Ice::UserExceptionHelper<ObserverInconsistencyException, ::Ice::UserException>
90  {
91  public:
92 
94 
96 
98 
99  ObserverInconsistencyException(const ::std::string& iceP_reason) :
100  reason(::std::move(iceP_reason))
101  {
102  }
103 
104  std::tuple<const ::std::string&> ice_tuple() const
105  {
106  return std::tie(reason);
107  }
108 
109  static const ::std::string& ice_staticId();
110 
111  ::std::string reason;
112  };
113 
114  static ObserverInconsistencyException _iceS_ObserverInconsistencyException_init;
115 
116  enum class NodeState : unsigned char
117  {
122  };
123 
124  struct NodeInfo
125  {
126  int id;
127  ::std::shared_ptr<::IceStormElection::NodePrx> n;
128 
129  std::tuple<const int&, const ::std::shared_ptr<::IceStormElection::NodePrx>&> ice_tuple() const
130  {
131  return std::tie(id, n);
132  }
133  };
134 
135  using NodeInfoSeq = ::std::vector<::IceStormElection::NodeInfo>;
136 
137  struct GroupInfo
138  {
139  int id;
141 
142  std::tuple<const int&, const ::IceStormElection::LogUpdate&> ice_tuple() const
143  {
144  return std::tie(id, llu);
145  }
146  };
147 
148  using GroupInfoSeq = ::std::vector<::IceStormElection::GroupInfo>;
149 
150  struct QueryInfo
151  {
152  int id;
153  int coord;
154  ::std::string group;
155  ::std::shared_ptr<::Ice::ObjectPrx> replica;
158  int max;
159 
160  std::tuple<const int&, const int&, const ::std::string&, const ::std::shared_ptr<::Ice::ObjectPrx>&, const ::IceStormElection::NodeState&, const ::IceStormElection::GroupInfoSeq&, const int&> ice_tuple() const
161  {
162  return std::tie(id, coord, group, replica, state, up, max);
163  }
164  };
165 
166  using Ice::operator<;
167  using Ice::operator<=;
168  using Ice::operator>;
169  using Ice::operator>=;
170  using Ice::operator==;
171  using Ice::operator!=;
172 
173 }
174 
175 namespace IceStormElection
176 {
177 
178  class ReplicaObserver : public virtual ::Ice::Object
179  {
180  public:
181 
183 
184  virtual bool ice_isA(::std::string, const ::Ice::Current&) const override;
185  virtual ::std::vector<::std::string> ice_ids(const ::Ice::Current&) const override;
186  virtual ::std::string ice_id(const ::Ice::Current&) const override;
187 
188  static const ::std::string& ice_staticId();
189 
190  virtual void init(::IceStormElection::LogUpdate, ::IceStormElection::TopicContentSeq, const ::Ice::Current&) = 0;
191  bool _iceD_init(::IceInternal::Incoming&, const ::Ice::Current&);
192 
193  virtual void createTopic(::IceStormElection::LogUpdate, ::std::string, const ::Ice::Current&) = 0;
194  bool _iceD_createTopic(::IceInternal::Incoming&, const ::Ice::Current&);
195 
196  virtual void destroyTopic(::IceStormElection::LogUpdate, ::std::string, const ::Ice::Current&) = 0;
197  bool _iceD_destroyTopic(::IceInternal::Incoming&, const ::Ice::Current&);
198 
199  virtual void addSubscriber(::IceStormElection::LogUpdate, ::std::string, ::IceStorm::SubscriberRecord, const ::Ice::Current&) = 0;
200  bool _iceD_addSubscriber(::IceInternal::Incoming&, const ::Ice::Current&);
201 
202  virtual void removeSubscriber(::IceStormElection::LogUpdate, ::std::string, ::Ice::IdentitySeq, const ::Ice::Current&) = 0;
203  bool _iceD_removeSubscriber(::IceInternal::Incoming&, const ::Ice::Current&);
204 
205  virtual bool _iceDispatch(::IceInternal::Incoming&, const ::Ice::Current&) override;
206  };
207 
208  class TopicManagerSync : public virtual ::Ice::Object
209  {
210  public:
211 
213 
214  virtual bool ice_isA(::std::string, const ::Ice::Current&) const override;
215  virtual ::std::vector<::std::string> ice_ids(const ::Ice::Current&) const override;
216  virtual ::std::string ice_id(const ::Ice::Current&) const override;
217 
218  static const ::std::string& ice_staticId();
219 
220  struct GetContentResult
221  {
224  };
225 
226  virtual void getContent(::IceStormElection::LogUpdate&, ::IceStormElection::TopicContentSeq&, const ::Ice::Current&) = 0;
227  bool _iceD_getContent(::IceInternal::Incoming&, const ::Ice::Current&);
228 
229  virtual bool _iceDispatch(::IceInternal::Incoming&, const ::Ice::Current&) override;
230  };
231 
232  class Node : public virtual ::Ice::Object
233  {
234  public:
235 
236  using ProxyType = NodePrx;
237 
238  virtual bool ice_isA(::std::string, const ::Ice::Current&) const override;
239  virtual ::std::vector<::std::string> ice_ids(const ::Ice::Current&) const override;
240  virtual ::std::string ice_id(const ::Ice::Current&) const override;
241 
242  static const ::std::string& ice_staticId();
243 
244  virtual void invitation(int, ::std::string, const ::Ice::Current&) = 0;
245  bool _iceD_invitation(::IceInternal::Incoming&, const ::Ice::Current&);
246 
247  virtual void ready(int, ::std::string, ::std::shared_ptr<::Ice::ObjectPrx>, int, long long int, const ::Ice::Current&) = 0;
248  bool _iceD_ready(::IceInternal::Incoming&, const ::Ice::Current&);
249 
250  virtual void accept(int, ::std::string, ::Ice::IntSeq, ::std::shared_ptr<::Ice::ObjectPrx>, ::IceStormElection::LogUpdate, int, const ::Ice::Current&) = 0;
251  bool _iceD_accept(::IceInternal::Incoming&, const ::Ice::Current&);
252 
253  virtual bool areYouCoordinator(const ::Ice::Current&) const = 0;
254  bool _iceD_areYouCoordinator(::IceInternal::Incoming&, const ::Ice::Current&) const;
255 
256  virtual bool areYouThere(::std::string, int, const ::Ice::Current&) const = 0;
257  bool _iceD_areYouThere(::IceInternal::Incoming&, const ::Ice::Current&) const;
258 
259  virtual ::std::shared_ptr<::Ice::ObjectPrx> sync(const ::Ice::Current&) const = 0;
260  bool _iceD_sync(::IceInternal::Incoming&, const ::Ice::Current&) const;
261 
262  virtual ::IceStormElection::NodeInfoSeq nodes(const ::Ice::Current&) const = 0;
263  bool _iceD_nodes(::IceInternal::Incoming&, const ::Ice::Current&) const;
264 
265  virtual ::IceStormElection::QueryInfo query(const ::Ice::Current&) const = 0;
266  bool _iceD_query(::IceInternal::Incoming&, const ::Ice::Current&) const;
267 
268  virtual bool _iceDispatch(::IceInternal::Incoming&, const ::Ice::Current&) override;
269  };
270 
271 }
272 
273 namespace IceStormElection
274 {
275 
276  class ReplicaObserverPrx : public virtual ::Ice::Proxy<ReplicaObserverPrx, ::Ice::ObjectPrx>
277  {
278  public:
279 
280  void init(const ::IceStormElection::LogUpdate& iceP_llu, const ::IceStormElection::TopicContentSeq& iceP_content, const ::Ice::Context& context = Ice::noExplicitContext)
281  {
282  _makePromiseOutgoing<void>(true, this, &IceStormElection::ReplicaObserverPrx::_iceI_init, iceP_llu, iceP_content, context).get();
283  }
284 
285  template<template<typename> class P = ::std::promise>
286  auto initAsync(const ::IceStormElection::LogUpdate& iceP_llu, const ::IceStormElection::TopicContentSeq& iceP_content, const ::Ice::Context& context = Ice::noExplicitContext)
287  -> decltype(::std::declval<P<void>>().get_future())
288  {
289  return _makePromiseOutgoing<void, P>(false, this, &IceStormElection::ReplicaObserverPrx::_iceI_init, iceP_llu, iceP_content, context);
290  }
291 
292  ::std::function<void()>
293  initAsync(const ::IceStormElection::LogUpdate& iceP_llu, const ::IceStormElection::TopicContentSeq& iceP_content,
294  ::std::function<void()> response,
295  ::std::function<void(::std::exception_ptr)> ex = nullptr,
296  ::std::function<void(bool)> sent = nullptr,
297  const ::Ice::Context& context = Ice::noExplicitContext)
298  {
299  return _makeLamdaOutgoing<void>(response, ex, sent, this, &IceStormElection::ReplicaObserverPrx::_iceI_init, iceP_llu, iceP_content, context);
300  }
301 
302  void _iceI_init(const ::std::shared_ptr<::IceInternal::OutgoingAsyncT<void>>&, const ::IceStormElection::LogUpdate&, const ::IceStormElection::TopicContentSeq&, const ::Ice::Context&);
303 
304  void createTopic(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name, const ::Ice::Context& context = Ice::noExplicitContext)
305  {
306  _makePromiseOutgoing<void>(true, this, &IceStormElection::ReplicaObserverPrx::_iceI_createTopic, iceP_llu, iceP_name, context).get();
307  }
308 
309  template<template<typename> class P = ::std::promise>
310  auto createTopicAsync(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name, const ::Ice::Context& context = Ice::noExplicitContext)
311  -> decltype(::std::declval<P<void>>().get_future())
312  {
313  return _makePromiseOutgoing<void, P>(false, this, &IceStormElection::ReplicaObserverPrx::_iceI_createTopic, iceP_llu, iceP_name, context);
314  }
315 
316  ::std::function<void()>
317  createTopicAsync(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name,
318  ::std::function<void()> response,
319  ::std::function<void(::std::exception_ptr)> ex = nullptr,
320  ::std::function<void(bool)> sent = nullptr,
321  const ::Ice::Context& context = Ice::noExplicitContext)
322  {
323  return _makeLamdaOutgoing<void>(response, ex, sent, this, &IceStormElection::ReplicaObserverPrx::_iceI_createTopic, iceP_llu, iceP_name, context);
324  }
325 
326  void _iceI_createTopic(const ::std::shared_ptr<::IceInternal::OutgoingAsyncT<void>>&, const ::IceStormElection::LogUpdate&, const ::std::string&, const ::Ice::Context&);
327 
328  void destroyTopic(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name, const ::Ice::Context& context = Ice::noExplicitContext)
329  {
330  _makePromiseOutgoing<void>(true, this, &IceStormElection::ReplicaObserverPrx::_iceI_destroyTopic, iceP_llu, iceP_name, context).get();
331  }
332 
333  template<template<typename> class P = ::std::promise>
334  auto destroyTopicAsync(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name, const ::Ice::Context& context = Ice::noExplicitContext)
335  -> decltype(::std::declval<P<void>>().get_future())
336  {
337  return _makePromiseOutgoing<void, P>(false, this, &IceStormElection::ReplicaObserverPrx::_iceI_destroyTopic, iceP_llu, iceP_name, context);
338  }
339 
340  ::std::function<void()>
341  destroyTopicAsync(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name,
342  ::std::function<void()> response,
343  ::std::function<void(::std::exception_ptr)> ex = nullptr,
344  ::std::function<void(bool)> sent = nullptr,
345  const ::Ice::Context& context = Ice::noExplicitContext)
346  {
347  return _makeLamdaOutgoing<void>(response, ex, sent, this, &IceStormElection::ReplicaObserverPrx::_iceI_destroyTopic, iceP_llu, iceP_name, context);
348  }
349 
350  void _iceI_destroyTopic(const ::std::shared_ptr<::IceInternal::OutgoingAsyncT<void>>&, const ::IceStormElection::LogUpdate&, const ::std::string&, const ::Ice::Context&);
351 
352  void addSubscriber(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::IceStorm::SubscriberRecord& iceP_record, const ::Ice::Context& context = Ice::noExplicitContext)
353  {
354  _makePromiseOutgoing<void>(true, this, &IceStormElection::ReplicaObserverPrx::_iceI_addSubscriber, iceP_llu, iceP_topic, iceP_record, context).get();
355  }
356 
357  template<template<typename> class P = ::std::promise>
358  auto addSubscriberAsync(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::IceStorm::SubscriberRecord& iceP_record, const ::Ice::Context& context = Ice::noExplicitContext)
359  -> decltype(::std::declval<P<void>>().get_future())
360  {
361  return _makePromiseOutgoing<void, P>(false, this, &IceStormElection::ReplicaObserverPrx::_iceI_addSubscriber, iceP_llu, iceP_topic, iceP_record, context);
362  }
363 
364  ::std::function<void()>
365  addSubscriberAsync(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::IceStorm::SubscriberRecord& iceP_record,
366  ::std::function<void()> response,
367  ::std::function<void(::std::exception_ptr)> ex = nullptr,
368  ::std::function<void(bool)> sent = nullptr,
369  const ::Ice::Context& context = Ice::noExplicitContext)
370  {
371  return _makeLamdaOutgoing<void>(response, ex, sent, this, &IceStormElection::ReplicaObserverPrx::_iceI_addSubscriber, iceP_llu, iceP_topic, iceP_record, context);
372  }
373 
374  void _iceI_addSubscriber(const ::std::shared_ptr<::IceInternal::OutgoingAsyncT<void>>&, const ::IceStormElection::LogUpdate&, const ::std::string&, const ::IceStorm::SubscriberRecord&, const ::Ice::Context&);
375 
376  void removeSubscriber(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::Ice::IdentitySeq& iceP_subscribers, const ::Ice::Context& context = Ice::noExplicitContext)
377  {
378  _makePromiseOutgoing<void>(true, this, &IceStormElection::ReplicaObserverPrx::_iceI_removeSubscriber, iceP_llu, iceP_topic, iceP_subscribers, context).get();
379  }
380 
381  template<template<typename> class P = ::std::promise>
382  auto removeSubscriberAsync(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::Ice::IdentitySeq& iceP_subscribers, const ::Ice::Context& context = Ice::noExplicitContext)
383  -> decltype(::std::declval<P<void>>().get_future())
384  {
385  return _makePromiseOutgoing<void, P>(false, this, &IceStormElection::ReplicaObserverPrx::_iceI_removeSubscriber, iceP_llu, iceP_topic, iceP_subscribers, context);
386  }
387 
388  ::std::function<void()>
389  removeSubscriberAsync(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::Ice::IdentitySeq& iceP_subscribers,
390  ::std::function<void()> response,
391  ::std::function<void(::std::exception_ptr)> ex = nullptr,
392  ::std::function<void(bool)> sent = nullptr,
393  const ::Ice::Context& context = Ice::noExplicitContext)
394  {
395  return _makeLamdaOutgoing<void>(response, ex, sent, this, &IceStormElection::ReplicaObserverPrx::_iceI_removeSubscriber, iceP_llu, iceP_topic, iceP_subscribers, context);
396  }
397 
398  void _iceI_removeSubscriber(const ::std::shared_ptr<::IceInternal::OutgoingAsyncT<void>>&, const ::IceStormElection::LogUpdate&, const ::std::string&, const ::Ice::IdentitySeq&, const ::Ice::Context&);
399 
400  static const ::std::string& ice_staticId();
401 
402  protected:
403 
404  ReplicaObserverPrx() = default;
405  friend ::std::shared_ptr<ReplicaObserverPrx> IceInternal::createProxy<ReplicaObserverPrx>();
406 
407  virtual ::std::shared_ptr<::Ice::ObjectPrx> _newInstance() const override;
408  };
409 
410  class TopicManagerSyncPrx : public virtual ::Ice::Proxy<TopicManagerSyncPrx, ::Ice::ObjectPrx>
411  {
412  public:
413 
414  void getContent(::IceStormElection::LogUpdate& iceP_llu, ::IceStormElection::TopicContentSeq& iceP_content, const ::Ice::Context& context = Ice::noExplicitContext)
415  {
416  auto result = _makePromiseOutgoing<::IceStormElection::TopicManagerSync::GetContentResult>(true, this, &IceStormElection::TopicManagerSyncPrx::_iceI_getContent, context).get();
417  iceP_llu = ::std::move(result.llu);
418  iceP_content = ::std::move(result.content);
419  }
420 
421  template<template<typename> class P = ::std::promise>
422  auto getContentAsync(const ::Ice::Context& context = Ice::noExplicitContext)
423  -> decltype(::std::declval<P<::IceStormElection::TopicManagerSync::GetContentResult>>().get_future())
424  {
425  return _makePromiseOutgoing<::IceStormElection::TopicManagerSync::GetContentResult, P>(false, this, &IceStormElection::TopicManagerSyncPrx::_iceI_getContent, context);
426  }
427 
428  ::std::function<void()>
429  getContentAsync(::std::function<void(::IceStormElection::LogUpdate, ::IceStormElection::TopicContentSeq)> response,
430  ::std::function<void(::std::exception_ptr)> ex = nullptr,
431  ::std::function<void(bool)> sent = nullptr,
432  const ::Ice::Context& context = Ice::noExplicitContext)
433  {
434  auto responseCb = [response](::IceStormElection::TopicManagerSync::GetContentResult && result)
435  {
436  response(::std::move(result.llu), ::std::move(result.content));
437  };
438  return _makeLamdaOutgoing<::IceStormElection::TopicManagerSync::GetContentResult>(responseCb, ex, sent, this, &IceStormElection::TopicManagerSyncPrx::_iceI_getContent, context);
439  }
440 
441  void _iceI_getContent(const ::std::shared_ptr<::IceInternal::OutgoingAsyncT<::IceStormElection::TopicManagerSync::GetContentResult>>&, const ::Ice::Context&);
442 
443  static const ::std::string& ice_staticId();
444 
445  protected:
446 
447  TopicManagerSyncPrx() = default;
448  friend ::std::shared_ptr<TopicManagerSyncPrx> IceInternal::createProxy<TopicManagerSyncPrx>();
449 
450  virtual ::std::shared_ptr<::Ice::ObjectPrx> _newInstance() const override;
451  };
452 
453  class NodePrx : public virtual ::Ice::Proxy<NodePrx, ::Ice::ObjectPrx>
454  {
455  public:
456 
457  void invitation(int iceP_j, const ::std::string& iceP_gn, const ::Ice::Context& context = Ice::noExplicitContext)
458  {
459  _makePromiseOutgoing<void>(true, this, &IceStormElection::NodePrx::_iceI_invitation, iceP_j, iceP_gn, context).get();
460  }
461 
462  template<template<typename> class P = ::std::promise>
463  auto invitationAsync(int iceP_j, const ::std::string& iceP_gn, const ::Ice::Context& context = Ice::noExplicitContext)
464  -> decltype(::std::declval<P<void>>().get_future())
465  {
466  return _makePromiseOutgoing<void, P>(false, this, &IceStormElection::NodePrx::_iceI_invitation, iceP_j, iceP_gn, context);
467  }
468 
469  ::std::function<void()>
470  invitationAsync(int iceP_j, const ::std::string& iceP_gn,
471  ::std::function<void()> response,
472  ::std::function<void(::std::exception_ptr)> ex = nullptr,
473  ::std::function<void(bool)> sent = nullptr,
474  const ::Ice::Context& context = Ice::noExplicitContext)
475  {
476  return _makeLamdaOutgoing<void>(response, ex, sent, this, &IceStormElection::NodePrx::_iceI_invitation, iceP_j, iceP_gn, context);
477  }
478 
479  void _iceI_invitation(const ::std::shared_ptr<::IceInternal::OutgoingAsyncT<void>>&, int, const ::std::string&, const ::Ice::Context&);
480 
481  void ready(int iceP_j, const ::std::string& iceP_gn, const ::std::shared_ptr<::Ice::ObjectPrx>& iceP_coordinator, int iceP_max, long long int iceP_generation, const ::Ice::Context& context = Ice::noExplicitContext)
482  {
483  _makePromiseOutgoing<void>(true, this, &IceStormElection::NodePrx::_iceI_ready, iceP_j, iceP_gn, iceP_coordinator, iceP_max, iceP_generation, context).get();
484  }
485 
486  template<template<typename> class P = ::std::promise>
487  auto readyAsync(int iceP_j, const ::std::string& iceP_gn, const ::std::shared_ptr<::Ice::ObjectPrx>& iceP_coordinator, int iceP_max, long long int iceP_generation, const ::Ice::Context& context = Ice::noExplicitContext)
488  -> decltype(::std::declval<P<void>>().get_future())
489  {
490  return _makePromiseOutgoing<void, P>(false, this, &IceStormElection::NodePrx::_iceI_ready, iceP_j, iceP_gn, iceP_coordinator, iceP_max, iceP_generation, context);
491  }
492 
493  ::std::function<void()>
494  readyAsync(int iceP_j, const ::std::string& iceP_gn, const ::std::shared_ptr<::Ice::ObjectPrx>& iceP_coordinator, int iceP_max, long long int iceP_generation,
495  ::std::function<void()> response,
496  ::std::function<void(::std::exception_ptr)> ex = nullptr,
497  ::std::function<void(bool)> sent = nullptr,
498  const ::Ice::Context& context = Ice::noExplicitContext)
499  {
500  return _makeLamdaOutgoing<void>(response, ex, sent, this, &IceStormElection::NodePrx::_iceI_ready, iceP_j, iceP_gn, iceP_coordinator, iceP_max, iceP_generation, context);
501  }
502 
503  void _iceI_ready(const ::std::shared_ptr<::IceInternal::OutgoingAsyncT<void>>&, int, const ::std::string&, const ::std::shared_ptr<::Ice::ObjectPrx>&, int, long long int, const ::Ice::Context&);
504 
505  void accept(int iceP_j, const ::std::string& iceP_gn, const ::Ice::IntSeq& iceP_forwardedInvites, const ::std::shared_ptr<::Ice::ObjectPrx>& iceP_observer, const ::IceStormElection::LogUpdate& iceP_llu, int iceP_max, const ::Ice::Context& context = Ice::noExplicitContext)
506  {
507  _makePromiseOutgoing<void>(true, this, &IceStormElection::NodePrx::_iceI_accept, iceP_j, iceP_gn, iceP_forwardedInvites, iceP_observer, iceP_llu, iceP_max, context).get();
508  }
509 
510  template<template<typename> class P = ::std::promise>
511  auto acceptAsync(int iceP_j, const ::std::string& iceP_gn, const ::Ice::IntSeq& iceP_forwardedInvites, const ::std::shared_ptr<::Ice::ObjectPrx>& iceP_observer, const ::IceStormElection::LogUpdate& iceP_llu, int iceP_max, const ::Ice::Context& context = Ice::noExplicitContext)
512  -> decltype(::std::declval<P<void>>().get_future())
513  {
514  return _makePromiseOutgoing<void, P>(false, this, &IceStormElection::NodePrx::_iceI_accept, iceP_j, iceP_gn, iceP_forwardedInvites, iceP_observer, iceP_llu, iceP_max, context);
515  }
516 
517  ::std::function<void()>
518  acceptAsync(int iceP_j, const ::std::string& iceP_gn, const ::Ice::IntSeq& iceP_forwardedInvites, const ::std::shared_ptr<::Ice::ObjectPrx>& iceP_observer, const ::IceStormElection::LogUpdate& iceP_llu, int iceP_max,
519  ::std::function<void()> response,
520  ::std::function<void(::std::exception_ptr)> ex = nullptr,
521  ::std::function<void(bool)> sent = nullptr,
522  const ::Ice::Context& context = Ice::noExplicitContext)
523  {
524  return _makeLamdaOutgoing<void>(response, ex, sent, this, &IceStormElection::NodePrx::_iceI_accept, iceP_j, iceP_gn, iceP_forwardedInvites, iceP_observer, iceP_llu, iceP_max, context);
525  }
526 
527  void _iceI_accept(const ::std::shared_ptr<::IceInternal::OutgoingAsyncT<void>>&, int, const ::std::string&, const ::Ice::IntSeq&, const ::std::shared_ptr<::Ice::ObjectPrx>&, const ::IceStormElection::LogUpdate&, int, const ::Ice::Context&);
528 
529  bool areYouCoordinator(const ::Ice::Context& context = Ice::noExplicitContext)
530  {
531  return _makePromiseOutgoing<bool>(true, this, &IceStormElection::NodePrx::_iceI_areYouCoordinator, context).get();
532  }
533 
534  template<template<typename> class P = ::std::promise>
535  auto areYouCoordinatorAsync(const ::Ice::Context& context = Ice::noExplicitContext)
536  -> decltype(::std::declval<P<bool>>().get_future())
537  {
538  return _makePromiseOutgoing<bool, P>(false, this, &IceStormElection::NodePrx::_iceI_areYouCoordinator, context);
539  }
540 
541  ::std::function<void()>
542  areYouCoordinatorAsync(::std::function<void(bool)> response,
543  ::std::function<void(::std::exception_ptr)> ex = nullptr,
544  ::std::function<void(bool)> sent = nullptr,
545  const ::Ice::Context& context = Ice::noExplicitContext)
546  {
547  return _makeLamdaOutgoing<bool>(response, ex, sent, this, &IceStormElection::NodePrx::_iceI_areYouCoordinator, context);
548  }
549 
550  void _iceI_areYouCoordinator(const ::std::shared_ptr<::IceInternal::OutgoingAsyncT<bool>>&, const ::Ice::Context&);
551 
552  bool areYouThere(const ::std::string& iceP_gn, int iceP_j, const ::Ice::Context& context = Ice::noExplicitContext)
553  {
554  return _makePromiseOutgoing<bool>(true, this, &IceStormElection::NodePrx::_iceI_areYouThere, iceP_gn, iceP_j, context).get();
555  }
556 
557  template<template<typename> class P = ::std::promise>
558  auto areYouThereAsync(const ::std::string& iceP_gn, int iceP_j, const ::Ice::Context& context = Ice::noExplicitContext)
559  -> decltype(::std::declval<P<bool>>().get_future())
560  {
561  return _makePromiseOutgoing<bool, P>(false, this, &IceStormElection::NodePrx::_iceI_areYouThere, iceP_gn, iceP_j, context);
562  }
563 
564  ::std::function<void()>
565  areYouThereAsync(const ::std::string& iceP_gn, int iceP_j,
566  ::std::function<void(bool)> response,
567  ::std::function<void(::std::exception_ptr)> ex = nullptr,
568  ::std::function<void(bool)> sent = nullptr,
569  const ::Ice::Context& context = Ice::noExplicitContext)
570  {
571  return _makeLamdaOutgoing<bool>(response, ex, sent, this, &IceStormElection::NodePrx::_iceI_areYouThere, iceP_gn, iceP_j, context);
572  }
573 
574  void _iceI_areYouThere(const ::std::shared_ptr<::IceInternal::OutgoingAsyncT<bool>>&, const ::std::string&, int, const ::Ice::Context&);
575 
576  ::std::shared_ptr<::Ice::ObjectPrx> sync(const ::Ice::Context& context = Ice::noExplicitContext)
577  {
578  return _makePromiseOutgoing<::std::shared_ptr<::Ice::ObjectPrx>>(true, this, &IceStormElection::NodePrx::_iceI_sync, context).get();
579  }
580 
581  template<template<typename> class P = ::std::promise>
582  auto syncAsync(const ::Ice::Context& context = Ice::noExplicitContext)
583  -> decltype(::std::declval<P<::std::shared_ptr<::Ice::ObjectPrx>>>().get_future())
584  {
585  return _makePromiseOutgoing<::std::shared_ptr<::Ice::ObjectPrx>, P>(false, this, &IceStormElection::NodePrx::_iceI_sync, context);
586  }
587 
588  ::std::function<void()>
589  syncAsync(::std::function<void(::std::shared_ptr<::Ice::ObjectPrx>)> response,
590  ::std::function<void(::std::exception_ptr)> ex = nullptr,
591  ::std::function<void(bool)> sent = nullptr,
592  const ::Ice::Context& context = Ice::noExplicitContext)
593  {
594  return _makeLamdaOutgoing<::std::shared_ptr<::Ice::ObjectPrx>>(response, ex, sent, this, &IceStormElection::NodePrx::_iceI_sync, context);
595  }
596 
597  void _iceI_sync(const ::std::shared_ptr<::IceInternal::OutgoingAsyncT<::std::shared_ptr<::Ice::ObjectPrx>>>&, const ::Ice::Context&);
598 
599  ::IceStormElection::NodeInfoSeq nodes(const ::Ice::Context& context = Ice::noExplicitContext)
600  {
601  return _makePromiseOutgoing<::IceStormElection::NodeInfoSeq>(true, this, &IceStormElection::NodePrx::_iceI_nodes, context).get();
602  }
603 
604  template<template<typename> class P = ::std::promise>
605  auto nodesAsync(const ::Ice::Context& context = Ice::noExplicitContext)
606  -> decltype(::std::declval<P<::IceStormElection::NodeInfoSeq>>().get_future())
607  {
608  return _makePromiseOutgoing<::IceStormElection::NodeInfoSeq, P>(false, this, &IceStormElection::NodePrx::_iceI_nodes, context);
609  }
610 
611  ::std::function<void()>
612  nodesAsync(::std::function<void(::IceStormElection::NodeInfoSeq)> response,
613  ::std::function<void(::std::exception_ptr)> ex = nullptr,
614  ::std::function<void(bool)> sent = nullptr,
615  const ::Ice::Context& context = Ice::noExplicitContext)
616  {
617  return _makeLamdaOutgoing<::IceStormElection::NodeInfoSeq>(response, ex, sent, this, &IceStormElection::NodePrx::_iceI_nodes, context);
618  }
619 
620  void _iceI_nodes(const ::std::shared_ptr<::IceInternal::OutgoingAsyncT<::IceStormElection::NodeInfoSeq>>&, const ::Ice::Context&);
621 
622  ::IceStormElection::QueryInfo query(const ::Ice::Context& context = Ice::noExplicitContext)
623  {
624  return _makePromiseOutgoing<::IceStormElection::QueryInfo>(true, this, &IceStormElection::NodePrx::_iceI_query, context).get();
625  }
626 
627  template<template<typename> class P = ::std::promise>
628  auto queryAsync(const ::Ice::Context& context = Ice::noExplicitContext)
629  -> decltype(::std::declval<P<::IceStormElection::QueryInfo>>().get_future())
630  {
631  return _makePromiseOutgoing<::IceStormElection::QueryInfo, P>(false, this, &IceStormElection::NodePrx::_iceI_query, context);
632  }
633 
634  ::std::function<void()>
635  queryAsync(::std::function<void(::IceStormElection::QueryInfo)> response,
636  ::std::function<void(::std::exception_ptr)> ex = nullptr,
637  ::std::function<void(bool)> sent = nullptr,
638  const ::Ice::Context& context = Ice::noExplicitContext)
639  {
640  return _makeLamdaOutgoing<::IceStormElection::QueryInfo>(response, ex, sent, this, &IceStormElection::NodePrx::_iceI_query, context);
641  }
642 
643  void _iceI_query(const ::std::shared_ptr<::IceInternal::OutgoingAsyncT<::IceStormElection::QueryInfo>>&, const ::Ice::Context&);
644 
645  static const ::std::string& ice_staticId();
646 
647  protected:
648 
649  NodePrx() = default;
650  friend ::std::shared_ptr<NodePrx> IceInternal::createProxy<NodePrx>();
651 
652  virtual ::std::shared_ptr<::Ice::ObjectPrx> _newInstance() const override;
653  };
654 
655 }
656 
657 namespace Ice
658 {
659 
660  template<>
661  struct StreamableTraits<::IceStormElection::TopicContent>
662  {
663  static const StreamHelperCategory helper = StreamHelperCategoryStruct;
664  static const int minWireSize = 3;
665  static const bool fixedLength = false;
666  };
667 
668  template<typename S>
669  struct StreamReader<::IceStormElection::TopicContent, S>
670  {
671  static void read(S* istr, ::IceStormElection::TopicContent& v)
672  {
673  istr->readAll(v.id, v.records);
674  }
675  };
676 
677  template<typename S>
678  struct StreamReader<::IceStormElection::ObserverInconsistencyException, S>
679  {
681  {
682  istr->readAll(v.reason);
683  }
684  };
685 
686  template<>
687  struct StreamableTraits< ::IceStormElection::NodeState>
688  {
689  static const StreamHelperCategory helper = StreamHelperCategoryEnum;
690  static const int minValue = 0;
691  static const int maxValue = 3;
692  static const int minWireSize = 1;
693  static const bool fixedLength = false;
694  };
695 
696  template<>
697  struct StreamableTraits<::IceStormElection::NodeInfo>
698  {
699  static const StreamHelperCategory helper = StreamHelperCategoryStruct;
700  static const int minWireSize = 6;
701  static const bool fixedLength = false;
702  };
703 
704  template<typename S>
705  struct StreamReader<::IceStormElection::NodeInfo, S>
706  {
707  static void read(S* istr, ::IceStormElection::NodeInfo& v)
708  {
709  istr->readAll(v.id, v.n);
710  }
711  };
712 
713  template<>
714  struct StreamableTraits<::IceStormElection::GroupInfo>
715  {
716  static const StreamHelperCategory helper = StreamHelperCategoryStruct;
717  static const int minWireSize = 20;
718  static const bool fixedLength = true;
719  };
720 
721  template<typename S>
722  struct StreamReader<::IceStormElection::GroupInfo, S>
723  {
724  static void read(S* istr, ::IceStormElection::GroupInfo& v)
725  {
726  istr->readAll(v.id, v.llu);
727  }
728  };
729 
730  template<>
731  struct StreamableTraits<::IceStormElection::QueryInfo>
732  {
733  static const StreamHelperCategory helper = StreamHelperCategoryStruct;
734  static const int minWireSize = 17;
735  static const bool fixedLength = false;
736  };
737 
738  template<typename S>
739  struct StreamReader<::IceStormElection::QueryInfo, S>
740  {
741  static void read(S* istr, ::IceStormElection::QueryInfo& v)
742  {
743  istr->readAll(v.id, v.coord, v.group, v.replica, v.state, v.up, v.max);
744  }
745  };
746 
747 }
748 
749 namespace IceStormElection
750 {
751 
752  using ReplicaObserverPtr = ::std::shared_ptr<ReplicaObserver>;
753  using ReplicaObserverPrxPtr = ::std::shared_ptr<ReplicaObserverPrx>;
754 
755  using TopicManagerSyncPtr = ::std::shared_ptr<TopicManagerSync>;
756  using TopicManagerSyncPrxPtr = ::std::shared_ptr<TopicManagerSyncPrx>;
757 
758  using NodePtr = ::std::shared_ptr<Node>;
759  using NodePrxPtr = ::std::shared_ptr<NodePrx>;
760 
761 }
762 
763 #else // C++98 mapping
764 
766 {
767 
768  class ReplicaObserver;
769  void _readProxy(::Ice::InputStream*, ::IceInternal::ProxyHandle< ::IceProxy::IceStormElection::ReplicaObserver>&);
770  ::IceProxy::Ice::Object* upCast(::IceProxy::IceStormElection::ReplicaObserver*);
771 
772  class TopicManagerSync;
773  void _readProxy(::Ice::InputStream*, ::IceInternal::ProxyHandle< ::IceProxy::IceStormElection::TopicManagerSync>&);
774  ::IceProxy::Ice::Object* upCast(::IceProxy::IceStormElection::TopicManagerSync*);
775 
776  class Node;
777  void _readProxy(::Ice::InputStream*, ::IceInternal::ProxyHandle< ::IceProxy::IceStormElection::Node>&);
778  ::IceProxy::Ice::Object* upCast(::IceProxy::IceStormElection::Node*);
779 
780 }
781 
782 
783 
784 namespace IceStormElection
785 {
786 
787  class ReplicaObserver;
788  ::Ice::Object* upCast(::IceStormElection::ReplicaObserver*);
789  typedef ::IceInternal::Handle< ::IceStormElection::ReplicaObserver> ReplicaObserverPtr;
790  typedef ::IceInternal::ProxyHandle< ::IceProxy::IceStormElection::ReplicaObserver> ReplicaObserverPrx;
793 
794  class TopicManagerSync;
795  ::Ice::Object* upCast(::IceStormElection::TopicManagerSync*);
796  typedef ::IceInternal::Handle< ::IceStormElection::TopicManagerSync> TopicManagerSyncPtr;
797  typedef ::IceInternal::ProxyHandle< ::IceProxy::IceStormElection::TopicManagerSync> TopicManagerSyncPrx;
800 
801  class Node;
802  ::Ice::Object* upCast(::IceStormElection::Node*);
803  typedef ::IceInternal::Handle< ::IceStormElection::Node> NodePtr;
804  typedef ::IceInternal::ProxyHandle< ::IceProxy::IceStormElection::Node> NodePrx;
807 
808 }
809 
810 namespace IceStormElection
811 {
812 
813  struct TopicContent
814  {
817  };
818 
819  typedef ::std::vector< ::IceStormElection::TopicContent> TopicContentSeq;
820 
821  class ObserverInconsistencyException : public ::Ice::UserException
822  {
823  public:
824 
826  explicit ObserverInconsistencyException(const ::std::string&);
827  virtual ~ObserverInconsistencyException() throw();
828 
829  virtual ::std::string ice_id() const;
830  virtual ObserverInconsistencyException* ice_clone() const;
831  virtual void ice_throw() const;
832 
833  ::std::string reason;
834 
835  protected:
836 
837  virtual void _writeImpl(::Ice::OutputStream*) const;
838  virtual void _readImpl(::Ice::InputStream*);
839  };
840 
841  static ObserverInconsistencyException _iceS_ObserverInconsistencyException_init;
842 
844  {
849  };
850 
851  struct NodeInfo
852  {
855  };
856 
857  typedef ::std::vector< ::IceStormElection::NodeInfo> NodeInfoSeq;
858 
859  struct GroupInfo
860  {
863 
864  bool operator==(const GroupInfo& rhs_) const
865  {
866  if (this == &rhs_)
867  {
868  return true;
869  }
870  if (id != rhs_.id)
871  {
872  return false;
873  }
874  if (llu != rhs_.llu)
875  {
876  return false;
877  }
878  return true;
879  }
880 
881  bool operator<(const GroupInfo& rhs_) const
882  {
883  if (this == &rhs_)
884  {
885  return false;
886  }
887  if (id < rhs_.id)
888  {
889  return true;
890  }
891  else if (rhs_.id < id)
892  {
893  return false;
894  }
895  if (llu < rhs_.llu)
896  {
897  return true;
898  }
899  else if (rhs_.llu < llu)
900  {
901  return false;
902  }
903  return false;
904  }
905 
906  bool operator!=(const GroupInfo& rhs_) const
907  {
908  return !operator==(rhs_);
909  }
910  bool operator<=(const GroupInfo& rhs_) const
911  {
912  return operator<(rhs_) || operator==(rhs_);
913  }
914  bool operator>(const GroupInfo& rhs_) const
915  {
916  return !operator<(rhs_) && !operator==(rhs_);
917  }
918  bool operator>=(const GroupInfo& rhs_) const
919  {
920  return !operator<(rhs_);
921  }
922  };
923 
924  typedef ::std::vector< ::IceStormElection::GroupInfo> GroupInfoSeq;
925 
926  struct QueryInfo
927  {
930  ::std::string group;
931  ::Ice::ObjectPrx replica;
935  };
936 
937 }
938 
939 namespace IceStormElection
940 {
941 
942  class Callback_ReplicaObserver_init_Base : public virtual ::IceInternal::CallbackBase { };
943  typedef ::IceUtil::Handle< Callback_ReplicaObserver_init_Base> Callback_ReplicaObserver_initPtr;
944 
945  class Callback_ReplicaObserver_createTopic_Base : public virtual ::IceInternal::CallbackBase { };
946  typedef ::IceUtil::Handle< Callback_ReplicaObserver_createTopic_Base> Callback_ReplicaObserver_createTopicPtr;
947 
948  class Callback_ReplicaObserver_destroyTopic_Base : public virtual ::IceInternal::CallbackBase { };
949  typedef ::IceUtil::Handle< Callback_ReplicaObserver_destroyTopic_Base> Callback_ReplicaObserver_destroyTopicPtr;
950 
951  class Callback_ReplicaObserver_addSubscriber_Base : public virtual ::IceInternal::CallbackBase { };
952  typedef ::IceUtil::Handle< Callback_ReplicaObserver_addSubscriber_Base> Callback_ReplicaObserver_addSubscriberPtr;
953 
954  class Callback_ReplicaObserver_removeSubscriber_Base : public virtual ::IceInternal::CallbackBase { };
955  typedef ::IceUtil::Handle< Callback_ReplicaObserver_removeSubscriber_Base> Callback_ReplicaObserver_removeSubscriberPtr;
956 
957  class Callback_TopicManagerSync_getContent_Base : public virtual ::IceInternal::CallbackBase { };
958  typedef ::IceUtil::Handle< Callback_TopicManagerSync_getContent_Base> Callback_TopicManagerSync_getContentPtr;
959 
960  class Callback_Node_invitation_Base : public virtual ::IceInternal::CallbackBase { };
961  typedef ::IceUtil::Handle< Callback_Node_invitation_Base> Callback_Node_invitationPtr;
962 
963  class Callback_Node_ready_Base : public virtual ::IceInternal::CallbackBase { };
964  typedef ::IceUtil::Handle< Callback_Node_ready_Base> Callback_Node_readyPtr;
965 
966  class Callback_Node_accept_Base : public virtual ::IceInternal::CallbackBase { };
967  typedef ::IceUtil::Handle< Callback_Node_accept_Base> Callback_Node_acceptPtr;
968 
969  class Callback_Node_areYouCoordinator_Base : public virtual ::IceInternal::CallbackBase { };
970  typedef ::IceUtil::Handle< Callback_Node_areYouCoordinator_Base> Callback_Node_areYouCoordinatorPtr;
971 
972  class Callback_Node_areYouThere_Base : public virtual ::IceInternal::CallbackBase { };
973  typedef ::IceUtil::Handle< Callback_Node_areYouThere_Base> Callback_Node_areYouTherePtr;
974 
975  class Callback_Node_sync_Base : public virtual ::IceInternal::CallbackBase { };
976  typedef ::IceUtil::Handle< Callback_Node_sync_Base> Callback_Node_syncPtr;
977 
978  class Callback_Node_nodes_Base : public virtual ::IceInternal::CallbackBase { };
979  typedef ::IceUtil::Handle< Callback_Node_nodes_Base> Callback_Node_nodesPtr;
980 
981  class Callback_Node_query_Base : public virtual ::IceInternal::CallbackBase { };
982  typedef ::IceUtil::Handle< Callback_Node_query_Base> Callback_Node_queryPtr;
983 
984 }
985 
987 {
988 
989  class ReplicaObserver : public virtual ::Ice::Proxy<ReplicaObserver, ::IceProxy::Ice::Object>
990  {
991  public:
992 
993  void init(const ::IceStormElection::LogUpdate& iceP_llu, const ::IceStormElection::TopicContentSeq& iceP_content, const ::Ice::Context& context = ::Ice::noExplicitContext)
994  {
995  end_init(_iceI_begin_init(iceP_llu, iceP_content, context, ::IceInternal::dummyCallback, 0, true));
996  }
997 
998  ::Ice::AsyncResultPtr begin_init(const ::IceStormElection::LogUpdate& iceP_llu, const ::IceStormElection::TopicContentSeq& iceP_content, const ::Ice::Context& context = ::Ice::noExplicitContext)
999  {
1000  return _iceI_begin_init(iceP_llu, iceP_content, context, ::IceInternal::dummyCallback, 0);
1001  }
1002 
1003  ::Ice::AsyncResultPtr begin_init(const ::IceStormElection::LogUpdate& iceP_llu, const ::IceStormElection::TopicContentSeq& iceP_content, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1004  {
1005  return _iceI_begin_init(iceP_llu, iceP_content, ::Ice::noExplicitContext, del, cookie);
1006  }
1007 
1008  ::Ice::AsyncResultPtr begin_init(const ::IceStormElection::LogUpdate& iceP_llu, const ::IceStormElection::TopicContentSeq& iceP_content, const ::Ice::Context& context, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1009  {
1010  return _iceI_begin_init(iceP_llu, iceP_content, context, del, cookie);
1011  }
1012 
1013  ::Ice::AsyncResultPtr begin_init(const ::IceStormElection::LogUpdate& iceP_llu, const ::IceStormElection::TopicContentSeq& iceP_content, const ::IceStormElection::Callback_ReplicaObserver_initPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1014  {
1015  return _iceI_begin_init(iceP_llu, iceP_content, ::Ice::noExplicitContext, del, cookie);
1016  }
1017 
1018  ::Ice::AsyncResultPtr begin_init(const ::IceStormElection::LogUpdate& iceP_llu, const ::IceStormElection::TopicContentSeq& iceP_content, const ::Ice::Context& context, const ::IceStormElection::Callback_ReplicaObserver_initPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1019  {
1020  return _iceI_begin_init(iceP_llu, iceP_content, context, del, cookie);
1021  }
1022 
1023  void end_init(const ::Ice::AsyncResultPtr&);
1024 
1025  private:
1026 
1027  ::Ice::AsyncResultPtr _iceI_begin_init(const ::IceStormElection::LogUpdate&, const ::IceStormElection::TopicContentSeq&, const ::Ice::Context&, const ::IceInternal::CallbackBasePtr&, const ::Ice::LocalObjectPtr& cookie = 0, bool sync = false);
1028 
1029  public:
1030 
1031  void createTopic(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name, const ::Ice::Context& context = ::Ice::noExplicitContext)
1032  {
1033  end_createTopic(_iceI_begin_createTopic(iceP_llu, iceP_name, context, ::IceInternal::dummyCallback, 0, true));
1034  }
1035 
1036  ::Ice::AsyncResultPtr begin_createTopic(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name, const ::Ice::Context& context = ::Ice::noExplicitContext)
1037  {
1038  return _iceI_begin_createTopic(iceP_llu, iceP_name, context, ::IceInternal::dummyCallback, 0);
1039  }
1040 
1041  ::Ice::AsyncResultPtr begin_createTopic(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1042  {
1043  return _iceI_begin_createTopic(iceP_llu, iceP_name, ::Ice::noExplicitContext, del, cookie);
1044  }
1045 
1046  ::Ice::AsyncResultPtr begin_createTopic(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name, const ::Ice::Context& context, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1047  {
1048  return _iceI_begin_createTopic(iceP_llu, iceP_name, context, del, cookie);
1049  }
1050 
1051  ::Ice::AsyncResultPtr begin_createTopic(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name, const ::IceStormElection::Callback_ReplicaObserver_createTopicPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1052  {
1053  return _iceI_begin_createTopic(iceP_llu, iceP_name, ::Ice::noExplicitContext, del, cookie);
1054  }
1055 
1056  ::Ice::AsyncResultPtr begin_createTopic(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name, const ::Ice::Context& context, const ::IceStormElection::Callback_ReplicaObserver_createTopicPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1057  {
1058  return _iceI_begin_createTopic(iceP_llu, iceP_name, context, del, cookie);
1059  }
1060 
1061  void end_createTopic(const ::Ice::AsyncResultPtr&);
1062 
1063  private:
1064 
1065  ::Ice::AsyncResultPtr _iceI_begin_createTopic(const ::IceStormElection::LogUpdate&, const ::std::string&, const ::Ice::Context&, const ::IceInternal::CallbackBasePtr&, const ::Ice::LocalObjectPtr& cookie = 0, bool sync = false);
1066 
1067  public:
1068 
1069  void destroyTopic(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name, const ::Ice::Context& context = ::Ice::noExplicitContext)
1070  {
1071  end_destroyTopic(_iceI_begin_destroyTopic(iceP_llu, iceP_name, context, ::IceInternal::dummyCallback, 0, true));
1072  }
1073 
1074  ::Ice::AsyncResultPtr begin_destroyTopic(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name, const ::Ice::Context& context = ::Ice::noExplicitContext)
1075  {
1076  return _iceI_begin_destroyTopic(iceP_llu, iceP_name, context, ::IceInternal::dummyCallback, 0);
1077  }
1078 
1079  ::Ice::AsyncResultPtr begin_destroyTopic(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1080  {
1081  return _iceI_begin_destroyTopic(iceP_llu, iceP_name, ::Ice::noExplicitContext, del, cookie);
1082  }
1083 
1084  ::Ice::AsyncResultPtr begin_destroyTopic(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name, const ::Ice::Context& context, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1085  {
1086  return _iceI_begin_destroyTopic(iceP_llu, iceP_name, context, del, cookie);
1087  }
1088 
1089  ::Ice::AsyncResultPtr begin_destroyTopic(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name, const ::IceStormElection::Callback_ReplicaObserver_destroyTopicPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1090  {
1091  return _iceI_begin_destroyTopic(iceP_llu, iceP_name, ::Ice::noExplicitContext, del, cookie);
1092  }
1093 
1094  ::Ice::AsyncResultPtr begin_destroyTopic(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_name, const ::Ice::Context& context, const ::IceStormElection::Callback_ReplicaObserver_destroyTopicPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1095  {
1096  return _iceI_begin_destroyTopic(iceP_llu, iceP_name, context, del, cookie);
1097  }
1098 
1099  void end_destroyTopic(const ::Ice::AsyncResultPtr&);
1100 
1101  private:
1102 
1103  ::Ice::AsyncResultPtr _iceI_begin_destroyTopic(const ::IceStormElection::LogUpdate&, const ::std::string&, const ::Ice::Context&, const ::IceInternal::CallbackBasePtr&, const ::Ice::LocalObjectPtr& cookie = 0, bool sync = false);
1104 
1105  public:
1106 
1107  void addSubscriber(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::IceStorm::SubscriberRecord& iceP_record, const ::Ice::Context& context = ::Ice::noExplicitContext)
1108  {
1109  end_addSubscriber(_iceI_begin_addSubscriber(iceP_llu, iceP_topic, iceP_record, context, ::IceInternal::dummyCallback, 0, true));
1110  }
1111 
1112  ::Ice::AsyncResultPtr begin_addSubscriber(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::IceStorm::SubscriberRecord& iceP_record, const ::Ice::Context& context = ::Ice::noExplicitContext)
1113  {
1114  return _iceI_begin_addSubscriber(iceP_llu, iceP_topic, iceP_record, context, ::IceInternal::dummyCallback, 0);
1115  }
1116 
1117  ::Ice::AsyncResultPtr begin_addSubscriber(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::IceStorm::SubscriberRecord& iceP_record, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1118  {
1119  return _iceI_begin_addSubscriber(iceP_llu, iceP_topic, iceP_record, ::Ice::noExplicitContext, del, cookie);
1120  }
1121 
1122  ::Ice::AsyncResultPtr begin_addSubscriber(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::IceStorm::SubscriberRecord& iceP_record, const ::Ice::Context& context, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1123  {
1124  return _iceI_begin_addSubscriber(iceP_llu, iceP_topic, iceP_record, context, del, cookie);
1125  }
1126 
1127  ::Ice::AsyncResultPtr begin_addSubscriber(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::IceStorm::SubscriberRecord& iceP_record, const ::IceStormElection::Callback_ReplicaObserver_addSubscriberPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1128  {
1129  return _iceI_begin_addSubscriber(iceP_llu, iceP_topic, iceP_record, ::Ice::noExplicitContext, del, cookie);
1130  }
1131 
1132  ::Ice::AsyncResultPtr begin_addSubscriber(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::IceStorm::SubscriberRecord& iceP_record, const ::Ice::Context& context, const ::IceStormElection::Callback_ReplicaObserver_addSubscriberPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1133  {
1134  return _iceI_begin_addSubscriber(iceP_llu, iceP_topic, iceP_record, context, del, cookie);
1135  }
1136 
1137  void end_addSubscriber(const ::Ice::AsyncResultPtr&);
1138 
1139  private:
1140 
1141  ::Ice::AsyncResultPtr _iceI_begin_addSubscriber(const ::IceStormElection::LogUpdate&, const ::std::string&, const ::IceStorm::SubscriberRecord&, const ::Ice::Context&, const ::IceInternal::CallbackBasePtr&, const ::Ice::LocalObjectPtr& cookie = 0, bool sync = false);
1142 
1143  public:
1144 
1145  void removeSubscriber(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::Ice::IdentitySeq& iceP_subscribers, const ::Ice::Context& context = ::Ice::noExplicitContext)
1146  {
1147  end_removeSubscriber(_iceI_begin_removeSubscriber(iceP_llu, iceP_topic, iceP_subscribers, context, ::IceInternal::dummyCallback, 0, true));
1148  }
1149 
1150  ::Ice::AsyncResultPtr begin_removeSubscriber(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::Ice::IdentitySeq& iceP_subscribers, const ::Ice::Context& context = ::Ice::noExplicitContext)
1151  {
1152  return _iceI_begin_removeSubscriber(iceP_llu, iceP_topic, iceP_subscribers, context, ::IceInternal::dummyCallback, 0);
1153  }
1154 
1155  ::Ice::AsyncResultPtr begin_removeSubscriber(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::Ice::IdentitySeq& iceP_subscribers, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1156  {
1157  return _iceI_begin_removeSubscriber(iceP_llu, iceP_topic, iceP_subscribers, ::Ice::noExplicitContext, del, cookie);
1158  }
1159 
1160  ::Ice::AsyncResultPtr begin_removeSubscriber(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::Ice::IdentitySeq& iceP_subscribers, const ::Ice::Context& context, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1161  {
1162  return _iceI_begin_removeSubscriber(iceP_llu, iceP_topic, iceP_subscribers, context, del, cookie);
1163  }
1164 
1165  ::Ice::AsyncResultPtr begin_removeSubscriber(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::Ice::IdentitySeq& iceP_subscribers, const ::IceStormElection::Callback_ReplicaObserver_removeSubscriberPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1166  {
1167  return _iceI_begin_removeSubscriber(iceP_llu, iceP_topic, iceP_subscribers, ::Ice::noExplicitContext, del, cookie);
1168  }
1169 
1170  ::Ice::AsyncResultPtr begin_removeSubscriber(const ::IceStormElection::LogUpdate& iceP_llu, const ::std::string& iceP_topic, const ::Ice::IdentitySeq& iceP_subscribers, const ::Ice::Context& context, const ::IceStormElection::Callback_ReplicaObserver_removeSubscriberPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1171  {
1172  return _iceI_begin_removeSubscriber(iceP_llu, iceP_topic, iceP_subscribers, context, del, cookie);
1173  }
1174 
1175  void end_removeSubscriber(const ::Ice::AsyncResultPtr&);
1176 
1177  private:
1178 
1179  ::Ice::AsyncResultPtr _iceI_begin_removeSubscriber(const ::IceStormElection::LogUpdate&, const ::std::string&, const ::Ice::IdentitySeq&, const ::Ice::Context&, const ::IceInternal::CallbackBasePtr&, const ::Ice::LocalObjectPtr& cookie = 0, bool sync = false);
1180 
1181  public:
1182 
1183  static const ::std::string& ice_staticId();
1184 
1185  protected:
1186 
1187  virtual ::IceProxy::Ice::Object* _newInstance() const;
1188  };
1189 
1190  class TopicManagerSync : public virtual ::Ice::Proxy<TopicManagerSync, ::IceProxy::Ice::Object>
1191  {
1192  public:
1193 
1194  void getContent(::IceStormElection::LogUpdate& iceP_llu, ::IceStormElection::TopicContentSeq& iceP_content, const ::Ice::Context& context = ::Ice::noExplicitContext)
1195  {
1196  end_getContent(iceP_llu, iceP_content, _iceI_begin_getContent(context, ::IceInternal::dummyCallback, 0, true));
1197  }
1198 
1199  ::Ice::AsyncResultPtr begin_getContent(const ::Ice::Context& context = ::Ice::noExplicitContext)
1200  {
1201  return _iceI_begin_getContent(context, ::IceInternal::dummyCallback, 0);
1202  }
1203 
1204  ::Ice::AsyncResultPtr begin_getContent(const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1205  {
1206  return _iceI_begin_getContent(::Ice::noExplicitContext, del, cookie);
1207  }
1208 
1209  ::Ice::AsyncResultPtr begin_getContent(const ::Ice::Context& context, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1210  {
1211  return _iceI_begin_getContent(context, del, cookie);
1212  }
1213 
1214  ::Ice::AsyncResultPtr begin_getContent(const ::IceStormElection::Callback_TopicManagerSync_getContentPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1215  {
1216  return _iceI_begin_getContent(::Ice::noExplicitContext, del, cookie);
1217  }
1218 
1219  ::Ice::AsyncResultPtr begin_getContent(const ::Ice::Context& context, const ::IceStormElection::Callback_TopicManagerSync_getContentPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1220  {
1221  return _iceI_begin_getContent(context, del, cookie);
1222  }
1223 
1224  void end_getContent(::IceStormElection::LogUpdate& iceP_llu, ::IceStormElection::TopicContentSeq& iceP_content, const ::Ice::AsyncResultPtr&);
1225 
1226  private:
1227 
1228  ::Ice::AsyncResultPtr _iceI_begin_getContent(const ::Ice::Context&, const ::IceInternal::CallbackBasePtr&, const ::Ice::LocalObjectPtr& cookie = 0, bool sync = false);
1229 
1230  public:
1231 
1232  static const ::std::string& ice_staticId();
1233 
1234  protected:
1235 
1236  virtual ::IceProxy::Ice::Object* _newInstance() const;
1237  };
1238 
1239  class Node : public virtual ::Ice::Proxy<Node, ::IceProxy::Ice::Object>
1240  {
1241  public:
1242 
1243  void invitation(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::Context& context = ::Ice::noExplicitContext)
1244  {
1245  end_invitation(_iceI_begin_invitation(iceP_j, iceP_gn, context, ::IceInternal::dummyCallback, 0, true));
1246  }
1247 
1248  ::Ice::AsyncResultPtr begin_invitation(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::Context& context = ::Ice::noExplicitContext)
1249  {
1250  return _iceI_begin_invitation(iceP_j, iceP_gn, context, ::IceInternal::dummyCallback, 0);
1251  }
1252 
1253  ::Ice::AsyncResultPtr begin_invitation(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1254  {
1255  return _iceI_begin_invitation(iceP_j, iceP_gn, ::Ice::noExplicitContext, del, cookie);
1256  }
1257 
1258  ::Ice::AsyncResultPtr begin_invitation(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::Context& context, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1259  {
1260  return _iceI_begin_invitation(iceP_j, iceP_gn, context, del, cookie);
1261  }
1262 
1263  ::Ice::AsyncResultPtr begin_invitation(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::IceStormElection::Callback_Node_invitationPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1264  {
1265  return _iceI_begin_invitation(iceP_j, iceP_gn, ::Ice::noExplicitContext, del, cookie);
1266  }
1267 
1268  ::Ice::AsyncResultPtr begin_invitation(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::Context& context, const ::IceStormElection::Callback_Node_invitationPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1269  {
1270  return _iceI_begin_invitation(iceP_j, iceP_gn, context, del, cookie);
1271  }
1272 
1273  void end_invitation(const ::Ice::AsyncResultPtr&);
1274 
1275  private:
1276 
1277  ::Ice::AsyncResultPtr _iceI_begin_invitation(::Ice::Int, const ::std::string&, const ::Ice::Context&, const ::IceInternal::CallbackBasePtr&, const ::Ice::LocalObjectPtr& cookie = 0, bool sync = false);
1278 
1279  public:
1280 
1281  void ready(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::ObjectPrx& iceP_coordinator, ::Ice::Int iceP_max, ::Ice::Long iceP_generation, const ::Ice::Context& context = ::Ice::noExplicitContext)
1282  {
1283  end_ready(_iceI_begin_ready(iceP_j, iceP_gn, iceP_coordinator, iceP_max, iceP_generation, context, ::IceInternal::dummyCallback, 0, true));
1284  }
1285 
1286  ::Ice::AsyncResultPtr begin_ready(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::ObjectPrx& iceP_coordinator, ::Ice::Int iceP_max, ::Ice::Long iceP_generation, const ::Ice::Context& context = ::Ice::noExplicitContext)
1287  {
1288  return _iceI_begin_ready(iceP_j, iceP_gn, iceP_coordinator, iceP_max, iceP_generation, context, ::IceInternal::dummyCallback, 0);
1289  }
1290 
1291  ::Ice::AsyncResultPtr begin_ready(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::ObjectPrx& iceP_coordinator, ::Ice::Int iceP_max, ::Ice::Long iceP_generation, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1292  {
1293  return _iceI_begin_ready(iceP_j, iceP_gn, iceP_coordinator, iceP_max, iceP_generation, ::Ice::noExplicitContext, del, cookie);
1294  }
1295 
1296  ::Ice::AsyncResultPtr begin_ready(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::ObjectPrx& iceP_coordinator, ::Ice::Int iceP_max, ::Ice::Long iceP_generation, const ::Ice::Context& context, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1297  {
1298  return _iceI_begin_ready(iceP_j, iceP_gn, iceP_coordinator, iceP_max, iceP_generation, context, del, cookie);
1299  }
1300 
1301  ::Ice::AsyncResultPtr begin_ready(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::ObjectPrx& iceP_coordinator, ::Ice::Int iceP_max, ::Ice::Long iceP_generation, const ::IceStormElection::Callback_Node_readyPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1302  {
1303  return _iceI_begin_ready(iceP_j, iceP_gn, iceP_coordinator, iceP_max, iceP_generation, ::Ice::noExplicitContext, del, cookie);
1304  }
1305 
1306  ::Ice::AsyncResultPtr begin_ready(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::ObjectPrx& iceP_coordinator, ::Ice::Int iceP_max, ::Ice::Long iceP_generation, const ::Ice::Context& context, const ::IceStormElection::Callback_Node_readyPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1307  {
1308  return _iceI_begin_ready(iceP_j, iceP_gn, iceP_coordinator, iceP_max, iceP_generation, context, del, cookie);
1309  }
1310 
1311  void end_ready(const ::Ice::AsyncResultPtr&);
1312 
1313  private:
1314 
1315  ::Ice::AsyncResultPtr _iceI_begin_ready(::Ice::Int, const ::std::string&, const ::Ice::ObjectPrx&, ::Ice::Int, ::Ice::Long, const ::Ice::Context&, const ::IceInternal::CallbackBasePtr&, const ::Ice::LocalObjectPtr& cookie = 0, bool sync = false);
1316 
1317  public:
1318 
1319  void accept(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::IntSeq& iceP_forwardedInvites, const ::Ice::ObjectPrx& iceP_observer, const ::IceStormElection::LogUpdate& iceP_llu, ::Ice::Int iceP_max, const ::Ice::Context& context = ::Ice::noExplicitContext)
1320  {
1321  end_accept(_iceI_begin_accept(iceP_j, iceP_gn, iceP_forwardedInvites, iceP_observer, iceP_llu, iceP_max, context, ::IceInternal::dummyCallback, 0, true));
1322  }
1323 
1324  ::Ice::AsyncResultPtr begin_accept(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::IntSeq& iceP_forwardedInvites, const ::Ice::ObjectPrx& iceP_observer, const ::IceStormElection::LogUpdate& iceP_llu, ::Ice::Int iceP_max, const ::Ice::Context& context = ::Ice::noExplicitContext)
1325  {
1326  return _iceI_begin_accept(iceP_j, iceP_gn, iceP_forwardedInvites, iceP_observer, iceP_llu, iceP_max, context, ::IceInternal::dummyCallback, 0);
1327  }
1328 
1329  ::Ice::AsyncResultPtr begin_accept(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::IntSeq& iceP_forwardedInvites, const ::Ice::ObjectPrx& iceP_observer, const ::IceStormElection::LogUpdate& iceP_llu, ::Ice::Int iceP_max, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1330  {
1331  return _iceI_begin_accept(iceP_j, iceP_gn, iceP_forwardedInvites, iceP_observer, iceP_llu, iceP_max, ::Ice::noExplicitContext, del, cookie);
1332  }
1333 
1334  ::Ice::AsyncResultPtr begin_accept(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::IntSeq& iceP_forwardedInvites, const ::Ice::ObjectPrx& iceP_observer, const ::IceStormElection::LogUpdate& iceP_llu, ::Ice::Int iceP_max, const ::Ice::Context& context, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1335  {
1336  return _iceI_begin_accept(iceP_j, iceP_gn, iceP_forwardedInvites, iceP_observer, iceP_llu, iceP_max, context, del, cookie);
1337  }
1338 
1339  ::Ice::AsyncResultPtr begin_accept(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::IntSeq& iceP_forwardedInvites, const ::Ice::ObjectPrx& iceP_observer, const ::IceStormElection::LogUpdate& iceP_llu, ::Ice::Int iceP_max, const ::IceStormElection::Callback_Node_acceptPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1340  {
1341  return _iceI_begin_accept(iceP_j, iceP_gn, iceP_forwardedInvites, iceP_observer, iceP_llu, iceP_max, ::Ice::noExplicitContext, del, cookie);
1342  }
1343 
1344  ::Ice::AsyncResultPtr begin_accept(::Ice::Int iceP_j, const ::std::string& iceP_gn, const ::Ice::IntSeq& iceP_forwardedInvites, const ::Ice::ObjectPrx& iceP_observer, const ::IceStormElection::LogUpdate& iceP_llu, ::Ice::Int iceP_max, const ::Ice::Context& context, const ::IceStormElection::Callback_Node_acceptPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1345  {
1346  return _iceI_begin_accept(iceP_j, iceP_gn, iceP_forwardedInvites, iceP_observer, iceP_llu, iceP_max, context, del, cookie);
1347  }
1348 
1349  void end_accept(const ::Ice::AsyncResultPtr&);
1350 
1351  private:
1352 
1353  ::Ice::AsyncResultPtr _iceI_begin_accept(::Ice::Int, const ::std::string&, const ::Ice::IntSeq&, const ::Ice::ObjectPrx&, const ::IceStormElection::LogUpdate&, ::Ice::Int, const ::Ice::Context&, const ::IceInternal::CallbackBasePtr&, const ::Ice::LocalObjectPtr& cookie = 0, bool sync = false);
1354 
1355  public:
1356 
1357  bool areYouCoordinator(const ::Ice::Context& context = ::Ice::noExplicitContext)
1358  {
1359  return end_areYouCoordinator(_iceI_begin_areYouCoordinator(context, ::IceInternal::dummyCallback, 0, true));
1360  }
1361 
1362  ::Ice::AsyncResultPtr begin_areYouCoordinator(const ::Ice::Context& context = ::Ice::noExplicitContext)
1363  {
1364  return _iceI_begin_areYouCoordinator(context, ::IceInternal::dummyCallback, 0);
1365  }
1366 
1367  ::Ice::AsyncResultPtr begin_areYouCoordinator(const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1368  {
1369  return _iceI_begin_areYouCoordinator(::Ice::noExplicitContext, del, cookie);
1370  }
1371 
1372  ::Ice::AsyncResultPtr begin_areYouCoordinator(const ::Ice::Context& context, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1373  {
1374  return _iceI_begin_areYouCoordinator(context, del, cookie);
1375  }
1376 
1377  ::Ice::AsyncResultPtr begin_areYouCoordinator(const ::IceStormElection::Callback_Node_areYouCoordinatorPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1378  {
1379  return _iceI_begin_areYouCoordinator(::Ice::noExplicitContext, del, cookie);
1380  }
1381 
1382  ::Ice::AsyncResultPtr begin_areYouCoordinator(const ::Ice::Context& context, const ::IceStormElection::Callback_Node_areYouCoordinatorPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1383  {
1384  return _iceI_begin_areYouCoordinator(context, del, cookie);
1385  }
1386 
1387  bool end_areYouCoordinator(const ::Ice::AsyncResultPtr&);
1388 
1389  private:
1390 
1391  ::Ice::AsyncResultPtr _iceI_begin_areYouCoordinator(const ::Ice::Context&, const ::IceInternal::CallbackBasePtr&, const ::Ice::LocalObjectPtr& cookie = 0, bool sync = false);
1392 
1393  public:
1394 
1395  bool areYouThere(const ::std::string& iceP_gn, ::Ice::Int iceP_j, const ::Ice::Context& context = ::Ice::noExplicitContext)
1396  {
1397  return end_areYouThere(_iceI_begin_areYouThere(iceP_gn, iceP_j, context, ::IceInternal::dummyCallback, 0, true));
1398  }
1399 
1400  ::Ice::AsyncResultPtr begin_areYouThere(const ::std::string& iceP_gn, ::Ice::Int iceP_j, const ::Ice::Context& context = ::Ice::noExplicitContext)
1401  {
1402  return _iceI_begin_areYouThere(iceP_gn, iceP_j, context, ::IceInternal::dummyCallback, 0);
1403  }
1404 
1405  ::Ice::AsyncResultPtr begin_areYouThere(const ::std::string& iceP_gn, ::Ice::Int iceP_j, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1406  {
1407  return _iceI_begin_areYouThere(iceP_gn, iceP_j, ::Ice::noExplicitContext, del, cookie);
1408  }
1409 
1410  ::Ice::AsyncResultPtr begin_areYouThere(const ::std::string& iceP_gn, ::Ice::Int iceP_j, const ::Ice::Context& context, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1411  {
1412  return _iceI_begin_areYouThere(iceP_gn, iceP_j, context, del, cookie);
1413  }
1414 
1415  ::Ice::AsyncResultPtr begin_areYouThere(const ::std::string& iceP_gn, ::Ice::Int iceP_j, const ::IceStormElection::Callback_Node_areYouTherePtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1416  {
1417  return _iceI_begin_areYouThere(iceP_gn, iceP_j, ::Ice::noExplicitContext, del, cookie);
1418  }
1419 
1420  ::Ice::AsyncResultPtr begin_areYouThere(const ::std::string& iceP_gn, ::Ice::Int iceP_j, const ::Ice::Context& context, const ::IceStormElection::Callback_Node_areYouTherePtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1421  {
1422  return _iceI_begin_areYouThere(iceP_gn, iceP_j, context, del, cookie);
1423  }
1424 
1425  bool end_areYouThere(const ::Ice::AsyncResultPtr&);
1426 
1427  private:
1428 
1429  ::Ice::AsyncResultPtr _iceI_begin_areYouThere(const ::std::string&, ::Ice::Int, const ::Ice::Context&, const ::IceInternal::CallbackBasePtr&, const ::Ice::LocalObjectPtr& cookie = 0, bool sync = false);
1430 
1431  public:
1432 
1433  ::Ice::ObjectPrx sync(const ::Ice::Context& context = ::Ice::noExplicitContext)
1434  {
1435  return end_sync(_iceI_begin_sync(context, ::IceInternal::dummyCallback, 0, true));
1436  }
1437 
1438  ::Ice::AsyncResultPtr begin_sync(const ::Ice::Context& context = ::Ice::noExplicitContext)
1439  {
1440  return _iceI_begin_sync(context, ::IceInternal::dummyCallback, 0);
1441  }
1442 
1443  ::Ice::AsyncResultPtr begin_sync(const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1444  {
1445  return _iceI_begin_sync(::Ice::noExplicitContext, del, cookie);
1446  }
1447 
1448  ::Ice::AsyncResultPtr begin_sync(const ::Ice::Context& context, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1449  {
1450  return _iceI_begin_sync(context, del, cookie);
1451  }
1452 
1453  ::Ice::AsyncResultPtr begin_sync(const ::IceStormElection::Callback_Node_syncPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1454  {
1455  return _iceI_begin_sync(::Ice::noExplicitContext, del, cookie);
1456  }
1457 
1458  ::Ice::AsyncResultPtr begin_sync(const ::Ice::Context& context, const ::IceStormElection::Callback_Node_syncPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1459  {
1460  return _iceI_begin_sync(context, del, cookie);
1461  }
1462 
1463  ::Ice::ObjectPrx end_sync(const ::Ice::AsyncResultPtr&);
1464 
1465  private:
1466 
1467  ::Ice::AsyncResultPtr _iceI_begin_sync(const ::Ice::Context&, const ::IceInternal::CallbackBasePtr&, const ::Ice::LocalObjectPtr& cookie = 0, bool sync = false);
1468 
1469  public:
1470 
1471  ::IceStormElection::NodeInfoSeq nodes(const ::Ice::Context& context = ::Ice::noExplicitContext)
1472  {
1473  return end_nodes(_iceI_begin_nodes(context, ::IceInternal::dummyCallback, 0, true));
1474  }
1475 
1476  ::Ice::AsyncResultPtr begin_nodes(const ::Ice::Context& context = ::Ice::noExplicitContext)
1477  {
1478  return _iceI_begin_nodes(context, ::IceInternal::dummyCallback, 0);
1479  }
1480 
1481  ::Ice::AsyncResultPtr begin_nodes(const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1482  {
1483  return _iceI_begin_nodes(::Ice::noExplicitContext, del, cookie);
1484  }
1485 
1486  ::Ice::AsyncResultPtr begin_nodes(const ::Ice::Context& context, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1487  {
1488  return _iceI_begin_nodes(context, del, cookie);
1489  }
1490 
1491  ::Ice::AsyncResultPtr begin_nodes(const ::IceStormElection::Callback_Node_nodesPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1492  {
1493  return _iceI_begin_nodes(::Ice::noExplicitContext, del, cookie);
1494  }
1495 
1496  ::Ice::AsyncResultPtr begin_nodes(const ::Ice::Context& context, const ::IceStormElection::Callback_Node_nodesPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1497  {
1498  return _iceI_begin_nodes(context, del, cookie);
1499  }
1500 
1501  ::IceStormElection::NodeInfoSeq end_nodes(const ::Ice::AsyncResultPtr&);
1502 
1503  private:
1504 
1505  ::Ice::AsyncResultPtr _iceI_begin_nodes(const ::Ice::Context&, const ::IceInternal::CallbackBasePtr&, const ::Ice::LocalObjectPtr& cookie = 0, bool sync = false);
1506 
1507  public:
1508 
1509  ::IceStormElection::QueryInfo query(const ::Ice::Context& context = ::Ice::noExplicitContext)
1510  {
1511  return end_query(_iceI_begin_query(context, ::IceInternal::dummyCallback, 0, true));
1512  }
1513 
1514  ::Ice::AsyncResultPtr begin_query(const ::Ice::Context& context = ::Ice::noExplicitContext)
1515  {
1516  return _iceI_begin_query(context, ::IceInternal::dummyCallback, 0);
1517  }
1518 
1519  ::Ice::AsyncResultPtr begin_query(const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1520  {
1521  return _iceI_begin_query(::Ice::noExplicitContext, del, cookie);
1522  }
1523 
1524  ::Ice::AsyncResultPtr begin_query(const ::Ice::Context& context, const ::Ice::CallbackPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1525  {
1526  return _iceI_begin_query(context, del, cookie);
1527  }
1528 
1529  ::Ice::AsyncResultPtr begin_query(const ::IceStormElection::Callback_Node_queryPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1530  {
1531  return _iceI_begin_query(::Ice::noExplicitContext, del, cookie);
1532  }
1533 
1534  ::Ice::AsyncResultPtr begin_query(const ::Ice::Context& context, const ::IceStormElection::Callback_Node_queryPtr& del, const ::Ice::LocalObjectPtr& cookie = 0)
1535  {
1536  return _iceI_begin_query(context, del, cookie);
1537  }
1538 
1539  ::IceStormElection::QueryInfo end_query(const ::Ice::AsyncResultPtr&);
1540 
1541  private:
1542 
1543  ::Ice::AsyncResultPtr _iceI_begin_query(const ::Ice::Context&, const ::IceInternal::CallbackBasePtr&, const ::Ice::LocalObjectPtr& cookie = 0, bool sync = false);
1544 
1545  public:
1546 
1547  static const ::std::string& ice_staticId();
1548 
1549  protected:
1550 
1551  virtual ::IceProxy::Ice::Object* _newInstance() const;
1552  };
1553 
1554 }
1555 
1556 
1557 
1558 namespace IceStormElection
1559 {
1560 
1561  class ReplicaObserver : public virtual ::Ice::Object
1562  {
1563  public:
1564 
1567 
1568  virtual ~ReplicaObserver();
1569 
1570  virtual bool ice_isA(const ::std::string&, const ::Ice::Current& = ::Ice::emptyCurrent) const;
1571  virtual ::std::vector< ::std::string> ice_ids(const ::Ice::Current& = ::Ice::emptyCurrent) const;
1572  virtual const ::std::string& ice_id(const ::Ice::Current& = ::Ice::emptyCurrent) const;
1573 
1574  static const ::std::string& ice_staticId();
1575 
1576  virtual void init(const ::IceStormElection::LogUpdate&, const ::IceStormElection::TopicContentSeq&, const ::Ice::Current& = ::Ice::emptyCurrent) = 0;
1577  bool _iceD_init(::IceInternal::Incoming&, const ::Ice::Current&);
1578 
1579  virtual void createTopic(const ::IceStormElection::LogUpdate&, const ::std::string&, const ::Ice::Current& = ::Ice::emptyCurrent) = 0;
1580  bool _iceD_createTopic(::IceInternal::Incoming&, const ::Ice::Current&);
1581 
1582  virtual void destroyTopic(const ::IceStormElection::LogUpdate&, const ::std::string&, const ::Ice::Current& = ::Ice::emptyCurrent) = 0;
1583  bool _iceD_destroyTopic(::IceInternal::Incoming&, const ::Ice::Current&);
1584 
1585  virtual void addSubscriber(const ::IceStormElection::LogUpdate&, const ::std::string&, const ::IceStorm::SubscriberRecord&, const ::Ice::Current& = ::Ice::emptyCurrent) = 0;
1586  bool _iceD_addSubscriber(::IceInternal::Incoming&, const ::Ice::Current&);
1587 
1588  virtual void removeSubscriber(const ::IceStormElection::LogUpdate&, const ::std::string&, const ::Ice::IdentitySeq&, const ::Ice::Current& = ::Ice::emptyCurrent) = 0;
1589  bool _iceD_removeSubscriber(::IceInternal::Incoming&, const ::Ice::Current&);
1590 
1591  virtual bool _iceDispatch(::IceInternal::Incoming&, const ::Ice::Current&);
1592 
1593  protected:
1594 
1595  virtual void _iceWriteImpl(::Ice::OutputStream*) const;
1596  virtual void _iceReadImpl(::Ice::InputStream*);
1597  };
1598 
1599  inline bool operator==(const ReplicaObserver& lhs, const ReplicaObserver& rhs)
1600  {
1601  return static_cast<const ::Ice::Object&>(lhs) == static_cast<const ::Ice::Object&>(rhs);
1602  }
1603 
1604  inline bool operator<(const ReplicaObserver& lhs, const ReplicaObserver& rhs)
1605  {
1606  return static_cast<const ::Ice::Object&>(lhs) < static_cast<const ::Ice::Object&>(rhs);
1607  }
1608 
1609  class TopicManagerSync : public virtual ::Ice::Object
1610  {
1611  public:
1612 
1615 
1616  virtual ~TopicManagerSync();
1617 
1618  virtual bool ice_isA(const ::std::string&, const ::Ice::Current& = ::Ice::emptyCurrent) const;
1619  virtual ::std::vector< ::std::string> ice_ids(const ::Ice::Current& = ::Ice::emptyCurrent) const;
1620  virtual const ::std::string& ice_id(const ::Ice::Current& = ::Ice::emptyCurrent) const;
1621 
1622  static const ::std::string& ice_staticId();
1623 
1624  virtual void getContent(::IceStormElection::LogUpdate&, ::IceStormElection::TopicContentSeq&, const ::Ice::Current& = ::Ice::emptyCurrent) = 0;
1625  bool _iceD_getContent(::IceInternal::Incoming&, const ::Ice::Current&);
1626 
1627  virtual bool _iceDispatch(::IceInternal::Incoming&, const ::Ice::Current&);
1628 
1629  protected:
1630 
1631  virtual void _iceWriteImpl(::Ice::OutputStream*) const;
1632  virtual void _iceReadImpl(::Ice::InputStream*);
1633  };
1634 
1635  inline bool operator==(const TopicManagerSync& lhs, const TopicManagerSync& rhs)
1636  {
1637  return static_cast<const ::Ice::Object&>(lhs) == static_cast<const ::Ice::Object&>(rhs);
1638  }
1639 
1640  inline bool operator<(const TopicManagerSync& lhs, const TopicManagerSync& rhs)
1641  {
1642  return static_cast<const ::Ice::Object&>(lhs) < static_cast<const ::Ice::Object&>(rhs);
1643  }
1644 
1645  class Node : public virtual ::Ice::Object
1646  {
1647  public:
1648 
1651 
1652  virtual ~Node();
1653 
1654  virtual bool ice_isA(const ::std::string&, const ::Ice::Current& = ::Ice::emptyCurrent) const;
1655  virtual ::std::vector< ::std::string> ice_ids(const ::Ice::Current& = ::Ice::emptyCurrent) const;
1656  virtual const ::std::string& ice_id(const ::Ice::Current& = ::Ice::emptyCurrent) const;
1657 
1658  static const ::std::string& ice_staticId();
1659 
1660  virtual void invitation(::Ice::Int, const ::std::string&, const ::Ice::Current& = ::Ice::emptyCurrent) = 0;
1661  bool _iceD_invitation(::IceInternal::Incoming&, const ::Ice::Current&);
1662 
1663  virtual void ready(::Ice::Int, const ::std::string&, const ::Ice::ObjectPrx&, ::Ice::Int, ::Ice::Long, const ::Ice::Current& = ::Ice::emptyCurrent) = 0;
1664  bool _iceD_ready(::IceInternal::Incoming&, const ::Ice::Current&);
1665 
1666  virtual void accept(::Ice::Int, const ::std::string&, const ::Ice::IntSeq&, const ::Ice::ObjectPrx&, const ::IceStormElection::LogUpdate&, ::Ice::Int, const ::Ice::Current& = ::Ice::emptyCurrent) = 0;
1667  bool _iceD_accept(::IceInternal::Incoming&, const ::Ice::Current&);
1668 
1669  virtual bool areYouCoordinator(const ::Ice::Current& = ::Ice::emptyCurrent) const = 0;
1670  bool _iceD_areYouCoordinator(::IceInternal::Incoming&, const ::Ice::Current&) const;
1671 
1672  virtual bool areYouThere(const ::std::string&, ::Ice::Int, const ::Ice::Current& = ::Ice::emptyCurrent) const = 0;
1673  bool _iceD_areYouThere(::IceInternal::Incoming&, const ::Ice::Current&) const;
1674 
1675  virtual ::Ice::ObjectPrx sync(const ::Ice::Current& = ::Ice::emptyCurrent) const = 0;
1676  bool _iceD_sync(::IceInternal::Incoming&, const ::Ice::Current&) const;
1677 
1678  virtual ::IceStormElection::NodeInfoSeq nodes(const ::Ice::Current& = ::Ice::emptyCurrent) const = 0;
1679  bool _iceD_nodes(::IceInternal::Incoming&, const ::Ice::Current&) const;
1680 
1681  virtual ::IceStormElection::QueryInfo query(const ::Ice::Current& = ::Ice::emptyCurrent) const = 0;
1682  bool _iceD_query(::IceInternal::Incoming&, const ::Ice::Current&) const;
1683 
1684  virtual bool _iceDispatch(::IceInternal::Incoming&, const ::Ice::Current&);
1685 
1686  protected:
1687 
1688  virtual void _iceWriteImpl(::Ice::OutputStream*) const;
1689  virtual void _iceReadImpl(::Ice::InputStream*);
1690  };
1691 
1692  inline bool operator==(const Node& lhs, const Node& rhs)
1693  {
1694  return static_cast<const ::Ice::Object&>(lhs) == static_cast<const ::Ice::Object&>(rhs);
1695  }
1696 
1697  inline bool operator<(const Node& lhs, const Node& rhs)
1698  {
1699  return static_cast<const ::Ice::Object&>(lhs) < static_cast<const ::Ice::Object&>(rhs);
1700  }
1701 
1702 }
1703 
1704 namespace Ice
1705 {
1706 
1707  template<>
1708  struct StreamableTraits< ::IceStormElection::TopicContent>
1709  {
1710  static const StreamHelperCategory helper = StreamHelperCategoryStruct;
1711  static const int minWireSize = 3;
1712  static const bool fixedLength = false;
1713  };
1714 
1715  template<typename S>
1716  struct StreamWriter< ::IceStormElection::TopicContent, S>
1717  {
1718  static void write(S* ostr, const ::IceStormElection::TopicContent& v)
1719  {
1720  ostr->write(v.id);
1721  ostr->write(v.records);
1722  }
1723  };
1724 
1725  template<typename S>
1726  struct StreamReader< ::IceStormElection::TopicContent, S>
1727  {
1728  static void read(S* istr, ::IceStormElection::TopicContent& v)
1729  {
1730  istr->read(v.id);
1731  istr->read(v.records);
1732  }
1733  };
1734 
1735  template<>
1737  {
1738  static const StreamHelperCategory helper = StreamHelperCategoryUserException;
1739  };
1740 
1741  template<typename S>
1743  {
1744  static void write(S* ostr, const ::IceStormElection::ObserverInconsistencyException& v)
1745  {
1746  ostr->write(v.reason);
1747  }
1748  };
1749 
1750  template<typename S>
1752  {
1754  {
1755  istr->read(v.reason);
1756  }
1757  };
1758 
1759  template<>
1760  struct StreamableTraits< ::IceStormElection::NodeState>
1761  {
1762  static const StreamHelperCategory helper = StreamHelperCategoryEnum;
1763  static const int minValue = 0;
1764  static const int maxValue = 3;
1765  static const int minWireSize = 1;
1766  static const bool fixedLength = false;
1767  };
1768 
1769  template<>
1770  struct StreamableTraits< ::IceStormElection::NodeInfo>
1771  {
1772  static const StreamHelperCategory helper = StreamHelperCategoryStruct;
1773  static const int minWireSize = 6;
1774  static const bool fixedLength = false;
1775  };
1776 
1777  template<typename S>
1778  struct StreamWriter< ::IceStormElection::NodeInfo, S>
1779  {
1780  static void write(S* ostr, const ::IceStormElection::NodeInfo& v)
1781  {
1782  ostr->write(v.id);
1783  ostr->write(v.n);
1784  }
1785  };
1786 
1787  template<typename S>
1788  struct StreamReader< ::IceStormElection::NodeInfo, S>
1789  {
1790  static void read(S* istr, ::IceStormElection::NodeInfo& v)
1791  {
1792  istr->read(v.id);
1793  istr->read(v.n);
1794  }
1795  };
1796 
1797  template<>
1798  struct StreamableTraits< ::IceStormElection::GroupInfo>
1799  {
1800  static const StreamHelperCategory helper = StreamHelperCategoryStruct;
1801  static const int minWireSize = 20;
1802  static const bool fixedLength = true;
1803  };
1804 
1805  template<typename S>
1806  struct StreamWriter< ::IceStormElection::GroupInfo, S>
1807  {
1808  static void write(S* ostr, const ::IceStormElection::GroupInfo& v)
1809  {
1810  ostr->write(v.id);
1811  ostr->write(v.llu);
1812  }
1813  };
1814 
1815  template<typename S>
1816  struct StreamReader< ::IceStormElection::GroupInfo, S>
1817  {
1818  static void read(S* istr, ::IceStormElection::GroupInfo& v)
1819  {
1820  istr->read(v.id);
1821  istr->read(v.llu);
1822  }
1823  };
1824 
1825  template<>
1826  struct StreamableTraits< ::IceStormElection::QueryInfo>
1827  {
1828  static const StreamHelperCategory helper = StreamHelperCategoryStruct;
1829  static const int minWireSize = 17;
1830  static const bool fixedLength = false;
1831  };
1832 
1833  template<typename S>
1834  struct StreamWriter< ::IceStormElection::QueryInfo, S>
1835  {
1836  static void write(S* ostr, const ::IceStormElection::QueryInfo& v)
1837  {
1838  ostr->write(v.id);
1839  ostr->write(v.coord);
1840  ostr->write(v.group);
1841  ostr->write(v.replica);
1842  ostr->write(v.state);
1843  ostr->write(v.up);
1844  ostr->write(v.max);
1845  }
1846  };
1847 
1848  template<typename S>
1849  struct StreamReader< ::IceStormElection::QueryInfo, S>
1850  {
1851  static void read(S* istr, ::IceStormElection::QueryInfo& v)
1852  {
1853  istr->read(v.id);
1854  istr->read(v.coord);
1855  istr->read(v.group);
1856  istr->read(v.replica);
1857  istr->read(v.state);
1858  istr->read(v.up);
1859  istr->read(v.max);
1860  }
1861  };
1862 
1863 }
1864 
1865 namespace IceStormElection
1866 {
1867 
1868  template<class T>
1869  class CallbackNC_ReplicaObserver_init : public Callback_ReplicaObserver_init_Base, public ::IceInternal::TwowayCallbackNC<T>
1870  {
1871  public:
1872 
1874 
1875  typedef void (T::*Exception)(const ::Ice::Exception&);
1876  typedef void (T::*Sent)(bool);
1877  typedef void (T::*Response)();
1878 
1880  : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
1881  {
1882  }
1883 
1884  virtual void completed(const ::Ice::AsyncResultPtr& result) const
1885  {
1886  ::IceStormElection::ReplicaObserverPrx proxy = ::IceStormElection::ReplicaObserverPrx::uncheckedCast(result->getProxy());
1887  try
1888  {
1889  proxy->end_init(result);
1890  }
1891  catch (const ::Ice::Exception& ex)
1892  {
1893  ::IceInternal::CallbackNC<T>::exception(result, ex);
1894  return;
1895  }
1896  if (_response)
1897  {
1898  (::IceInternal::CallbackNC<T>::_callback.get()->*_response)();
1899  }
1900  }
1901 
1902  private:
1903 
1904  Response _response;
1905  };
1906 
1907  template<class T> Callback_ReplicaObserver_initPtr
1908  newCallback_ReplicaObserver_init(const IceUtil::Handle<T>& instance, void (T::*cb)(), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
1909  {
1910  return new CallbackNC_ReplicaObserver_init<T>(instance, cb, excb, sentcb);
1911  }
1912 
1913  template<class T> Callback_ReplicaObserver_initPtr
1914  newCallback_ReplicaObserver_init(const IceUtil::Handle<T>& instance, void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
1915  {
1916  return new CallbackNC_ReplicaObserver_init<T>(instance, 0, excb, sentcb);
1917  }
1918 
1919  template<class T> Callback_ReplicaObserver_initPtr
1920  newCallback_ReplicaObserver_init(T* instance, void (T::*cb)(), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
1921  {
1922  return new CallbackNC_ReplicaObserver_init<T>(instance, cb, excb, sentcb);
1923  }
1924 
1925  template<class T> Callback_ReplicaObserver_initPtr
1926  newCallback_ReplicaObserver_init(T* instance, void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
1927  {
1928  return new CallbackNC_ReplicaObserver_init<T>(instance, 0, excb, sentcb);
1929  }
1930 
1931  template<class T, typename CT>
1932  class Callback_ReplicaObserver_init : public Callback_ReplicaObserver_init_Base, public ::IceInternal::TwowayCallback<T, CT>
1933  {
1934  public:
1935 
1937 
1938  typedef void (T::*Exception)(const ::Ice::Exception&, const CT&);
1939  typedef void (T::*Sent)(bool, const CT&);
1940  typedef void (T::*Response)(const CT&);
1941 
1943  : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
1944  {
1945  }
1946 
1947  virtual void completed(const ::Ice::AsyncResultPtr& result) const
1948  {
1949  ::IceStormElection::ReplicaObserverPrx proxy = ::IceStormElection::ReplicaObserverPrx::uncheckedCast(result->getProxy());
1950  try
1951  {
1952  proxy->end_init(result);
1953  }
1954  catch (const ::Ice::Exception& ex)
1955  {
1956  ::IceInternal::Callback<T, CT>::exception(result, ex);
1957  return;
1958  }
1959  if (_response)
1960  {
1961  (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(CT::dynamicCast(result->getCookie()));
1962  }
1963  }
1964 
1965  private:
1966 
1967  Response _response;
1968  };
1969 
1970  template<class T, typename CT> Callback_ReplicaObserver_initPtr
1971  newCallback_ReplicaObserver_init(const IceUtil::Handle<T>& instance, void (T::*cb)(const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
1972  {
1973  return new Callback_ReplicaObserver_init<T, CT>(instance, cb, excb, sentcb);
1974  }
1975 
1976  template<class T, typename CT> Callback_ReplicaObserver_initPtr
1977  newCallback_ReplicaObserver_init(const IceUtil::Handle<T>& instance, void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
1978  {
1979  return new Callback_ReplicaObserver_init<T, CT>(instance, 0, excb, sentcb);
1980  }
1981 
1982  template<class T, typename CT> Callback_ReplicaObserver_initPtr
1983  newCallback_ReplicaObserver_init(T* instance, void (T::*cb)(const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
1984  {
1985  return new Callback_ReplicaObserver_init<T, CT>(instance, cb, excb, sentcb);
1986  }
1987 
1988  template<class T, typename CT> Callback_ReplicaObserver_initPtr
1989  newCallback_ReplicaObserver_init(T* instance, void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
1990  {
1991  return new Callback_ReplicaObserver_init<T, CT>(instance, 0, excb, sentcb);
1992  }
1993 
1994  template<class T>
1995  class CallbackNC_ReplicaObserver_createTopic : public Callback_ReplicaObserver_createTopic_Base, public ::IceInternal::TwowayCallbackNC<T>
1996  {
1997  public:
1998 
2000 
2001  typedef void (T::*Exception)(const ::Ice::Exception&);
2002  typedef void (T::*Sent)(bool);
2003  typedef void (T::*Response)();
2004 
2006  : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
2007  {
2008  }
2009 
2010  virtual void completed(const ::Ice::AsyncResultPtr& result) const
2011  {
2012  ::IceStormElection::ReplicaObserverPrx proxy = ::IceStormElection::ReplicaObserverPrx::uncheckedCast(result->getProxy());
2013  try
2014  {
2015  proxy->end_createTopic(result);
2016  }
2017  catch (const ::Ice::Exception& ex)
2018  {
2019  ::IceInternal::CallbackNC<T>::exception(result, ex);
2020  return;
2021  }
2022  if (_response)
2023  {
2024  (::IceInternal::CallbackNC<T>::_callback.get()->*_response)();
2025  }
2026  }
2027 
2028  private:
2029 
2030  Response _response;
2031  };
2032 
2033  template<class T> Callback_ReplicaObserver_createTopicPtr
2034  newCallback_ReplicaObserver_createTopic(const IceUtil::Handle<T>& instance, void (T::*cb)(), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2035  {
2036  return new CallbackNC_ReplicaObserver_createTopic<T>(instance, cb, excb, sentcb);
2037  }
2038 
2039  template<class T> Callback_ReplicaObserver_createTopicPtr
2040  newCallback_ReplicaObserver_createTopic(const IceUtil::Handle<T>& instance, void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2041  {
2042  return new CallbackNC_ReplicaObserver_createTopic<T>(instance, 0, excb, sentcb);
2043  }
2044 
2045  template<class T> Callback_ReplicaObserver_createTopicPtr
2046  newCallback_ReplicaObserver_createTopic(T* instance, void (T::*cb)(), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2047  {
2048  return new CallbackNC_ReplicaObserver_createTopic<T>(instance, cb, excb, sentcb);
2049  }
2050 
2051  template<class T> Callback_ReplicaObserver_createTopicPtr
2052  newCallback_ReplicaObserver_createTopic(T* instance, void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2053  {
2054  return new CallbackNC_ReplicaObserver_createTopic<T>(instance, 0, excb, sentcb);
2055  }
2056 
2057  template<class T, typename CT>
2058  class Callback_ReplicaObserver_createTopic : public Callback_ReplicaObserver_createTopic_Base, public ::IceInternal::TwowayCallback<T, CT>
2059  {
2060  public:
2061 
2063 
2064  typedef void (T::*Exception)(const ::Ice::Exception&, const CT&);
2065  typedef void (T::*Sent)(bool, const CT&);
2066  typedef void (T::*Response)(const CT&);
2067 
2069  : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
2070  {
2071  }
2072 
2073  virtual void completed(const ::Ice::AsyncResultPtr& result) const
2074  {
2075  ::IceStormElection::ReplicaObserverPrx proxy = ::IceStormElection::ReplicaObserverPrx::uncheckedCast(result->getProxy());
2076  try
2077  {
2078  proxy->end_createTopic(result);
2079  }
2080  catch (const ::Ice::Exception& ex)
2081  {
2082  ::IceInternal::Callback<T, CT>::exception(result, ex);
2083  return;
2084  }
2085  if (_response)
2086  {
2087  (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(CT::dynamicCast(result->getCookie()));
2088  }
2089  }
2090 
2091  private:
2092 
2093  Response _response;
2094  };
2095 
2096  template<class T, typename CT> Callback_ReplicaObserver_createTopicPtr
2097  newCallback_ReplicaObserver_createTopic(const IceUtil::Handle<T>& instance, void (T::*cb)(const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2098  {
2099  return new Callback_ReplicaObserver_createTopic<T, CT>(instance, cb, excb, sentcb);
2100  }
2101 
2102  template<class T, typename CT> Callback_ReplicaObserver_createTopicPtr
2103  newCallback_ReplicaObserver_createTopic(const IceUtil::Handle<T>& instance, void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2104  {
2105  return new Callback_ReplicaObserver_createTopic<T, CT>(instance, 0, excb, sentcb);
2106  }
2107 
2108  template<class T, typename CT> Callback_ReplicaObserver_createTopicPtr
2109  newCallback_ReplicaObserver_createTopic(T* instance, void (T::*cb)(const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2110  {
2111  return new Callback_ReplicaObserver_createTopic<T, CT>(instance, cb, excb, sentcb);
2112  }
2113 
2114  template<class T, typename CT> Callback_ReplicaObserver_createTopicPtr
2115  newCallback_ReplicaObserver_createTopic(T* instance, void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2116  {
2117  return new Callback_ReplicaObserver_createTopic<T, CT>(instance, 0, excb, sentcb);
2118  }
2119 
2120  template<class T>
2121  class CallbackNC_ReplicaObserver_destroyTopic : public Callback_ReplicaObserver_destroyTopic_Base, public ::IceInternal::TwowayCallbackNC<T>
2122  {
2123  public:
2124 
2126 
2127  typedef void (T::*Exception)(const ::Ice::Exception&);
2128  typedef void (T::*Sent)(bool);
2129  typedef void (T::*Response)();
2130 
2132  : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
2133  {
2134  }
2135 
2136  virtual void completed(const ::Ice::AsyncResultPtr& result) const
2137  {
2138  ::IceStormElection::ReplicaObserverPrx proxy = ::IceStormElection::ReplicaObserverPrx::uncheckedCast(result->getProxy());
2139  try
2140  {
2141  proxy->end_destroyTopic(result);
2142  }
2143  catch (const ::Ice::Exception& ex)
2144  {
2145  ::IceInternal::CallbackNC<T>::exception(result, ex);
2146  return;
2147  }
2148  if (_response)
2149  {
2150  (::IceInternal::CallbackNC<T>::_callback.get()->*_response)();
2151  }
2152  }
2153 
2154  private:
2155 
2156  Response _response;
2157  };
2158 
2160  newCallback_ReplicaObserver_destroyTopic(const IceUtil::Handle<T>& instance, void (T::*cb)(), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2161  {
2162  return new CallbackNC_ReplicaObserver_destroyTopic<T>(instance, cb, excb, sentcb);
2163  }
2164 
2166  newCallback_ReplicaObserver_destroyTopic(const IceUtil::Handle<T>& instance, void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2167  {
2168  return new CallbackNC_ReplicaObserver_destroyTopic<T>(instance, 0, excb, sentcb);
2169  }
2170 
2172  newCallback_ReplicaObserver_destroyTopic(T* instance, void (T::*cb)(), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2173  {
2174  return new CallbackNC_ReplicaObserver_destroyTopic<T>(instance, cb, excb, sentcb);
2175  }
2176 
2178  newCallback_ReplicaObserver_destroyTopic(T* instance, void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2179  {
2180  return new CallbackNC_ReplicaObserver_destroyTopic<T>(instance, 0, excb, sentcb);
2181  }
2182 
2183  template<class T, typename CT>
2184  class Callback_ReplicaObserver_destroyTopic : public Callback_ReplicaObserver_destroyTopic_Base, public ::IceInternal::TwowayCallback<T, CT>
2185  {
2186  public:
2187 
2189 
2190  typedef void (T::*Exception)(const ::Ice::Exception&, const CT&);
2191  typedef void (T::*Sent)(bool, const CT&);
2192  typedef void (T::*Response)(const CT&);
2193 
2195  : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
2196  {
2197  }
2198 
2199  virtual void completed(const ::Ice::AsyncResultPtr& result) const
2200  {
2201  ::IceStormElection::ReplicaObserverPrx proxy = ::IceStormElection::ReplicaObserverPrx::uncheckedCast(result->getProxy());
2202  try
2203  {
2204  proxy->end_destroyTopic(result);
2205  }
2206  catch (const ::Ice::Exception& ex)
2207  {
2208  ::IceInternal::Callback<T, CT>::exception(result, ex);
2209  return;
2210  }
2211  if (_response)
2212  {
2213  (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(CT::dynamicCast(result->getCookie()));
2214  }
2215  }
2216 
2217  private:
2218 
2219  Response _response;
2220  };
2221 
2222  template<class T, typename CT> Callback_ReplicaObserver_destroyTopicPtr
2223  newCallback_ReplicaObserver_destroyTopic(const IceUtil::Handle<T>& instance, void (T::*cb)(const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2224  {
2225  return new Callback_ReplicaObserver_destroyTopic<T, CT>(instance, cb, excb, sentcb);
2226  }
2227 
2228  template<class T, typename CT> Callback_ReplicaObserver_destroyTopicPtr
2229  newCallback_ReplicaObserver_destroyTopic(const IceUtil::Handle<T>& instance, void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2230  {
2231  return new Callback_ReplicaObserver_destroyTopic<T, CT>(instance, 0, excb, sentcb);
2232  }
2233 
2234  template<class T, typename CT> Callback_ReplicaObserver_destroyTopicPtr
2235  newCallback_ReplicaObserver_destroyTopic(T* instance, void (T::*cb)(const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2236  {
2237  return new Callback_ReplicaObserver_destroyTopic<T, CT>(instance, cb, excb, sentcb);
2238  }
2239 
2240  template<class T, typename CT> Callback_ReplicaObserver_destroyTopicPtr
2241  newCallback_ReplicaObserver_destroyTopic(T* instance, void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2242  {
2243  return new Callback_ReplicaObserver_destroyTopic<T, CT>(instance, 0, excb, sentcb);
2244  }
2245 
2246  template<class T>
2247  class CallbackNC_ReplicaObserver_addSubscriber : public Callback_ReplicaObserver_addSubscriber_Base, public ::IceInternal::TwowayCallbackNC<T>
2248  {
2249  public:
2250 
2252 
2253  typedef void (T::*Exception)(const ::Ice::Exception&);
2254  typedef void (T::*Sent)(bool);
2255  typedef void (T::*Response)();
2256 
2258  : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
2259  {
2260  }
2261 
2262  virtual void completed(const ::Ice::AsyncResultPtr& result) const
2263  {
2264  ::IceStormElection::ReplicaObserverPrx proxy = ::IceStormElection::ReplicaObserverPrx::uncheckedCast(result->getProxy());
2265  try
2266  {
2267  proxy->end_addSubscriber(result);
2268  }
2269  catch (const ::Ice::Exception& ex)
2270  {
2271  ::IceInternal::CallbackNC<T>::exception(result, ex);
2272  return;
2273  }
2274  if (_response)
2275  {
2276  (::IceInternal::CallbackNC<T>::_callback.get()->*_response)();
2277  }
2278  }
2279 
2280  private:
2281 
2282  Response _response;
2283  };
2284 
2286  newCallback_ReplicaObserver_addSubscriber(const IceUtil::Handle<T>& instance, void (T::*cb)(), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2287  {
2288  return new CallbackNC_ReplicaObserver_addSubscriber<T>(instance, cb, excb, sentcb);
2289  }
2290 
2292  newCallback_ReplicaObserver_addSubscriber(const IceUtil::Handle<T>& instance, void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2293  {
2294  return new CallbackNC_ReplicaObserver_addSubscriber<T>(instance, 0, excb, sentcb);
2295  }
2296 
2298  newCallback_ReplicaObserver_addSubscriber(T* instance, void (T::*cb)(), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2299  {
2300  return new CallbackNC_ReplicaObserver_addSubscriber<T>(instance, cb, excb, sentcb);
2301  }
2302 
2304  newCallback_ReplicaObserver_addSubscriber(T* instance, void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2305  {
2306  return new CallbackNC_ReplicaObserver_addSubscriber<T>(instance, 0, excb, sentcb);
2307  }
2308 
2309  template<class T, typename CT>
2310  class Callback_ReplicaObserver_addSubscriber : public Callback_ReplicaObserver_addSubscriber_Base, public ::IceInternal::TwowayCallback<T, CT>
2311  {
2312  public:
2313 
2315 
2316  typedef void (T::*Exception)(const ::Ice::Exception&, const CT&);
2317  typedef void (T::*Sent)(bool, const CT&);
2318  typedef void (T::*Response)(const CT&);
2319 
2321  : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
2322  {
2323  }
2324 
2325  virtual void completed(const ::Ice::AsyncResultPtr& result) const
2326  {
2327  ::IceStormElection::ReplicaObserverPrx proxy = ::IceStormElection::ReplicaObserverPrx::uncheckedCast(result->getProxy());
2328  try
2329  {
2330  proxy->end_addSubscriber(result);
2331  }
2332  catch (const ::Ice::Exception& ex)
2333  {
2334  ::IceInternal::Callback<T, CT>::exception(result, ex);
2335  return;
2336  }
2337  if (_response)
2338  {
2339  (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(CT::dynamicCast(result->getCookie()));
2340  }
2341  }
2342 
2343  private:
2344 
2345  Response _response;
2346  };
2347 
2348  template<class T, typename CT> Callback_ReplicaObserver_addSubscriberPtr
2349  newCallback_ReplicaObserver_addSubscriber(const IceUtil::Handle<T>& instance, void (T::*cb)(const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2350  {
2351  return new Callback_ReplicaObserver_addSubscriber<T, CT>(instance, cb, excb, sentcb);
2352  }
2353 
2354  template<class T, typename CT> Callback_ReplicaObserver_addSubscriberPtr
2355  newCallback_ReplicaObserver_addSubscriber(const IceUtil::Handle<T>& instance, void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2356  {
2357  return new Callback_ReplicaObserver_addSubscriber<T, CT>(instance, 0, excb, sentcb);
2358  }
2359 
2360  template<class T, typename CT> Callback_ReplicaObserver_addSubscriberPtr
2361  newCallback_ReplicaObserver_addSubscriber(T* instance, void (T::*cb)(const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2362  {
2363  return new Callback_ReplicaObserver_addSubscriber<T, CT>(instance, cb, excb, sentcb);
2364  }
2365 
2366  template<class T, typename CT> Callback_ReplicaObserver_addSubscriberPtr
2367  newCallback_ReplicaObserver_addSubscriber(T* instance, void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2368  {
2369  return new Callback_ReplicaObserver_addSubscriber<T, CT>(instance, 0, excb, sentcb);
2370  }
2371 
2372  template<class T>
2374  {
2375  public:
2376 
2378 
2379  typedef void (T::*Exception)(const ::Ice::Exception&);
2380  typedef void (T::*Sent)(bool);
2381  typedef void (T::*Response)();
2382 
2384  : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
2385  {
2386  }
2387 
2388  virtual void completed(const ::Ice::AsyncResultPtr& result) const
2389  {
2390  ::IceStormElection::ReplicaObserverPrx proxy = ::IceStormElection::ReplicaObserverPrx::uncheckedCast(result->getProxy());
2391  try
2392  {
2393  proxy->end_removeSubscriber(result);
2394  }
2395  catch (const ::Ice::Exception& ex)
2396  {
2397  ::IceInternal::CallbackNC<T>::exception(result, ex);
2398  return;
2399  }
2400  if (_response)
2401  {
2402  (::IceInternal::CallbackNC<T>::_callback.get()->*_response)();
2403  }
2404  }
2405 
2406  private:
2407 
2408  Response _response;
2409  };
2410 
2412  newCallback_ReplicaObserver_removeSubscriber(const IceUtil::Handle<T>& instance, void (T::*cb)(), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2413  {
2414  return new CallbackNC_ReplicaObserver_removeSubscriber<T>(instance, cb, excb, sentcb);
2415  }
2416 
2418  newCallback_ReplicaObserver_removeSubscriber(const IceUtil::Handle<T>& instance, void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2419  {
2420  return new CallbackNC_ReplicaObserver_removeSubscriber<T>(instance, 0, excb, sentcb);
2421  }
2422 
2424  newCallback_ReplicaObserver_removeSubscriber(T* instance, void (T::*cb)(), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2425  {
2426  return new CallbackNC_ReplicaObserver_removeSubscriber<T>(instance, cb, excb, sentcb);
2427  }
2428 
2430  newCallback_ReplicaObserver_removeSubscriber(T* instance, void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2431  {
2432  return new CallbackNC_ReplicaObserver_removeSubscriber<T>(instance, 0, excb, sentcb);
2433  }
2434 
2435  template<class T, typename CT>
2436  class Callback_ReplicaObserver_removeSubscriber : public Callback_ReplicaObserver_removeSubscriber_Base, public ::IceInternal::TwowayCallback<T, CT>
2437  {
2438  public:
2439 
2441 
2442  typedef void (T::*Exception)(const ::Ice::Exception&, const CT&);
2443  typedef void (T::*Sent)(bool, const CT&);
2444  typedef void (T::*Response)(const CT&);
2445 
2447  : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
2448  {
2449  }
2450 
2451  virtual void completed(const ::Ice::AsyncResultPtr& result) const
2452  {
2453  ::IceStormElection::ReplicaObserverPrx proxy = ::IceStormElection::ReplicaObserverPrx::uncheckedCast(result->getProxy());
2454  try
2455  {
2456  proxy->end_removeSubscriber(result);
2457  }
2458  catch (const ::Ice::Exception& ex)
2459  {
2460  ::IceInternal::Callback<T, CT>::exception(result, ex);
2461  return;
2462  }
2463  if (_response)
2464  {
2465  (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(CT::dynamicCast(result->getCookie()));
2466  }
2467  }
2468 
2469  private:
2470 
2471  Response _response;
2472  };
2473 
2474  template<class T, typename CT> Callback_ReplicaObserver_removeSubscriberPtr
2475  newCallback_ReplicaObserver_removeSubscriber(const IceUtil::Handle<T>& instance, void (T::*cb)(const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2476  {
2477  return new Callback_ReplicaObserver_removeSubscriber<T, CT>(instance, cb, excb, sentcb);
2478  }
2479 
2480  template<class T, typename CT> Callback_ReplicaObserver_removeSubscriberPtr
2481  newCallback_ReplicaObserver_removeSubscriber(const IceUtil::Handle<T>& instance, void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2482  {
2483  return new Callback_ReplicaObserver_removeSubscriber<T, CT>(instance, 0, excb, sentcb);
2484  }
2485 
2486  template<class T, typename CT> Callback_ReplicaObserver_removeSubscriberPtr
2487  newCallback_ReplicaObserver_removeSubscriber(T* instance, void (T::*cb)(const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2488  {
2489  return new Callback_ReplicaObserver_removeSubscriber<T, CT>(instance, cb, excb, sentcb);
2490  }
2491 
2492  template<class T, typename CT> Callback_ReplicaObserver_removeSubscriberPtr
2493  newCallback_ReplicaObserver_removeSubscriber(T* instance, void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2494  {
2495  return new Callback_ReplicaObserver_removeSubscriber<T, CT>(instance, 0, excb, sentcb);
2496  }
2497 
2498  template<class T>
2499  class CallbackNC_TopicManagerSync_getContent : public Callback_TopicManagerSync_getContent_Base, public ::IceInternal::TwowayCallbackNC<T>
2500  {
2501  public:
2502 
2504 
2505  typedef void (T::*Exception)(const ::Ice::Exception&);
2506  typedef void (T::*Sent)(bool);
2507  typedef void (T::*Response)(const ::IceStormElection::LogUpdate&, const ::IceStormElection::TopicContentSeq&);
2508 
2510  : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
2511  {
2512  }
2513 
2514  virtual void completed(const ::Ice::AsyncResultPtr& result) const
2515  {
2516  ::IceStormElection::TopicManagerSyncPrx proxy = ::IceStormElection::TopicManagerSyncPrx::uncheckedCast(result->getProxy());
2519  try
2520  {
2521  proxy->end_getContent(iceP_llu, iceP_content, result);
2522  }
2523  catch (const ::Ice::Exception& ex)
2524  {
2525  ::IceInternal::CallbackNC<T>::exception(result, ex);
2526  return;
2527  }
2528  if (_response)
2529  {
2530  (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(iceP_llu, iceP_content);
2531  }
2532  }
2533 
2534  private:
2535 
2536  Response _response;
2537  };
2538 
2539  template<class T> Callback_TopicManagerSync_getContentPtr
2540  newCallback_TopicManagerSync_getContent(const IceUtil::Handle<T>& instance, void (T::*cb)(const ::IceStormElection::LogUpdate&, const ::IceStormElection::TopicContentSeq&), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2541  {
2542  return new CallbackNC_TopicManagerSync_getContent<T>(instance, cb, excb, sentcb);
2543  }
2544 
2545  template<class T> Callback_TopicManagerSync_getContentPtr
2546  newCallback_TopicManagerSync_getContent(T* instance, void (T::*cb)(const ::IceStormElection::LogUpdate&, const ::IceStormElection::TopicContentSeq&), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2547  {
2548  return new CallbackNC_TopicManagerSync_getContent<T>(instance, cb, excb, sentcb);
2549  }
2550 
2551  template<class T, typename CT>
2552  class Callback_TopicManagerSync_getContent : public Callback_TopicManagerSync_getContent_Base, public ::IceInternal::TwowayCallback<T, CT>
2553  {
2554  public:
2555 
2557 
2558  typedef void (T::*Exception)(const ::Ice::Exception&, const CT&);
2559  typedef void (T::*Sent)(bool, const CT&);
2560  typedef void (T::*Response)(const ::IceStormElection::LogUpdate&, const ::IceStormElection::TopicContentSeq&, const CT&);
2561 
2563  : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
2564  {
2565  }
2566 
2567  virtual void completed(const ::Ice::AsyncResultPtr& result) const
2568  {
2569  ::IceStormElection::TopicManagerSyncPrx proxy = ::IceStormElection::TopicManagerSyncPrx::uncheckedCast(result->getProxy());
2572  try
2573  {
2574  proxy->end_getContent(iceP_llu, iceP_content, result);
2575  }
2576  catch (const ::Ice::Exception& ex)
2577  {
2578  ::IceInternal::Callback<T, CT>::exception(result, ex);
2579  return;
2580  }
2581  if (_response)
2582  {
2583  (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(iceP_llu, iceP_content, CT::dynamicCast(result->getCookie()));
2584  }
2585  }
2586 
2587  private:
2588 
2589  Response _response;
2590  };
2591 
2592  template<class T, typename CT> Callback_TopicManagerSync_getContentPtr
2593  newCallback_TopicManagerSync_getContent(const IceUtil::Handle<T>& instance, void (T::*cb)(const ::IceStormElection::LogUpdate&, const ::IceStormElection::TopicContentSeq&, const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2594  {
2595  return new Callback_TopicManagerSync_getContent<T, CT>(instance, cb, excb, sentcb);
2596  }
2597 
2598  template<class T, typename CT> Callback_TopicManagerSync_getContentPtr
2599  newCallback_TopicManagerSync_getContent(T* instance, void (T::*cb)(const ::IceStormElection::LogUpdate&, const ::IceStormElection::TopicContentSeq&, const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2600  {
2601  return new Callback_TopicManagerSync_getContent<T, CT>(instance, cb, excb, sentcb);
2602  }
2603 
2604  template<class T>
2605  class CallbackNC_Node_invitation : public Callback_Node_invitation_Base, public ::IceInternal::OnewayCallbackNC<T>
2606  {
2607  public:
2608 
2610 
2611  typedef void (T::*Exception)(const ::Ice::Exception&);
2612  typedef void (T::*Sent)(bool);
2613  typedef void (T::*Response)();
2614 
2616  : ::IceInternal::OnewayCallbackNC<T>(obj, cb, excb, sentcb)
2617  {
2618  }
2619  };
2620 
2621  template<class T> Callback_Node_invitationPtr
2622  newCallback_Node_invitation(const IceUtil::Handle<T>& instance, void (T::*cb)(), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2623  {
2624  return new CallbackNC_Node_invitation<T>(instance, cb, excb, sentcb);
2625  }
2626 
2627  template<class T> Callback_Node_invitationPtr
2628  newCallback_Node_invitation(const IceUtil::Handle<T>& instance, void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2629  {
2630  return new CallbackNC_Node_invitation<T>(instance, 0, excb, sentcb);
2631  }
2632 
2633  template<class T> Callback_Node_invitationPtr
2634  newCallback_Node_invitation(T* instance, void (T::*cb)(), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2635  {
2636  return new CallbackNC_Node_invitation<T>(instance, cb, excb, sentcb);
2637  }
2638 
2639  template<class T> Callback_Node_invitationPtr
2640  newCallback_Node_invitation(T* instance, void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2641  {
2642  return new CallbackNC_Node_invitation<T>(instance, 0, excb, sentcb);
2643  }
2644 
2645  template<class T, typename CT>
2646  class Callback_Node_invitation : public Callback_Node_invitation_Base, public ::IceInternal::OnewayCallback<T, CT>
2647  {
2648  public:
2649 
2651 
2652  typedef void (T::*Exception)(const ::Ice::Exception&, const CT&);
2653  typedef void (T::*Sent)(bool, const CT&);
2654  typedef void (T::*Response)(const CT&);
2655 
2656  Callback_Node_invitation(const TPtr& obj, Response cb, Exception excb, Sent sentcb)
2657  : ::IceInternal::OnewayCallback<T, CT>(obj, cb, excb, sentcb)
2658  {
2659  }
2660  };
2661 
2662  template<class T, typename CT> Callback_Node_invitationPtr
2663  newCallback_Node_invitation(const IceUtil::Handle<T>& instance, void (T::*cb)(const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2664  {
2665  return new Callback_Node_invitation<T, CT>(instance, cb, excb, sentcb);
2666  }
2667 
2668  template<class T, typename CT> Callback_Node_invitationPtr
2669  newCallback_Node_invitation(const IceUtil::Handle<T>& instance, void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2670  {
2671  return new Callback_Node_invitation<T, CT>(instance, 0, excb, sentcb);
2672  }
2673 
2674  template<class T, typename CT> Callback_Node_invitationPtr
2675  newCallback_Node_invitation(T* instance, void (T::*cb)(const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2676  {
2677  return new Callback_Node_invitation<T, CT>(instance, cb, excb, sentcb);
2678  }
2679 
2680  template<class T, typename CT> Callback_Node_invitationPtr
2681  newCallback_Node_invitation(T* instance, void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2682  {
2683  return new Callback_Node_invitation<T, CT>(instance, 0, excb, sentcb);
2684  }
2685 
2686  template<class T>
2687  class CallbackNC_Node_ready : public Callback_Node_ready_Base, public ::IceInternal::OnewayCallbackNC<T>
2688  {
2689  public:
2690 
2692 
2693  typedef void (T::*Exception)(const ::Ice::Exception&);
2694  typedef void (T::*Sent)(bool);
2695  typedef void (T::*Response)();
2696 
2697  CallbackNC_Node_ready(const TPtr& obj, Response cb, Exception excb, Sent sentcb)
2698  : ::IceInternal::OnewayCallbackNC<T>(obj, cb, excb, sentcb)
2699  {
2700  }
2701  };
2702 
2703  template<class T> Callback_Node_readyPtr
2704  newCallback_Node_ready(const IceUtil::Handle<T>& instance, void (T::*cb)(), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2705  {
2706  return new CallbackNC_Node_ready<T>(instance, cb, excb, sentcb);
2707  }
2708 
2709  template<class T> Callback_Node_readyPtr
2710  newCallback_Node_ready(const IceUtil::Handle<T>& instance, void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2711  {
2712  return new CallbackNC_Node_ready<T>(instance, 0, excb, sentcb);
2713  }
2714 
2715  template<class T> Callback_Node_readyPtr
2716  newCallback_Node_ready(T* instance, void (T::*cb)(), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2717  {
2718  return new CallbackNC_Node_ready<T>(instance, cb, excb, sentcb);
2719  }
2720 
2721  template<class T> Callback_Node_readyPtr
2722  newCallback_Node_ready(T* instance, void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2723  {
2724  return new CallbackNC_Node_ready<T>(instance, 0, excb, sentcb);
2725  }
2726 
2727  template<class T, typename CT>
2728  class Callback_Node_ready : public Callback_Node_ready_Base, public ::IceInternal::OnewayCallback<T, CT>
2729  {
2730  public:
2731 
2733 
2734  typedef void (T::*Exception)(const ::Ice::Exception&, const CT&);
2735  typedef void (T::*Sent)(bool, const CT&);
2736  typedef void (T::*Response)(const CT&);
2737 
2738  Callback_Node_ready(const TPtr& obj, Response cb, Exception excb, Sent sentcb)
2739  : ::IceInternal::OnewayCallback<T, CT>(obj, cb, excb, sentcb)
2740  {
2741  }
2742  };
2743 
2744  template<class T, typename CT> Callback_Node_readyPtr
2745  newCallback_Node_ready(const IceUtil::Handle<T>& instance, void (T::*cb)(const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2746  {
2747  return new Callback_Node_ready<T, CT>(instance, cb, excb, sentcb);
2748  }
2749 
2750  template<class T, typename CT> Callback_Node_readyPtr
2751  newCallback_Node_ready(const IceUtil::Handle<T>& instance, void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2752  {
2753  return new Callback_Node_ready<T, CT>(instance, 0, excb, sentcb);
2754  }
2755 
2756  template<class T, typename CT> Callback_Node_readyPtr
2757  newCallback_Node_ready(T* instance, void (T::*cb)(const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2758  {
2759  return new Callback_Node_ready<T, CT>(instance, cb, excb, sentcb);
2760  }
2761 
2762  template<class T, typename CT> Callback_Node_readyPtr
2763  newCallback_Node_ready(T* instance, void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2764  {
2765  return new Callback_Node_ready<T, CT>(instance, 0, excb, sentcb);
2766  }
2767 
2768  template<class T>
2769  class CallbackNC_Node_accept : public Callback_Node_accept_Base, public ::IceInternal::OnewayCallbackNC<T>
2770  {
2771  public:
2772 
2774 
2775  typedef void (T::*Exception)(const ::Ice::Exception&);
2776  typedef void (T::*Sent)(bool);
2777  typedef void (T::*Response)();
2778 
2779  CallbackNC_Node_accept(const TPtr& obj, Response cb, Exception excb, Sent sentcb)
2780  : ::IceInternal::OnewayCallbackNC<T>(obj, cb, excb, sentcb)
2781  {
2782  }
2783  };
2784 
2785  template<class T> Callback_Node_acceptPtr
2786  newCallback_Node_accept(const IceUtil::Handle<T>& instance, void (T::*cb)(), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2787  {
2788  return new CallbackNC_Node_accept<T>(instance, cb, excb, sentcb);
2789  }
2790 
2791  template<class T> Callback_Node_acceptPtr
2792  newCallback_Node_accept(const IceUtil::Handle<T>& instance, void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2793  {
2794  return new CallbackNC_Node_accept<T>(instance, 0, excb, sentcb);
2795  }
2796 
2797  template<class T> Callback_Node_acceptPtr
2798  newCallback_Node_accept(T* instance, void (T::*cb)(), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2799  {
2800  return new CallbackNC_Node_accept<T>(instance, cb, excb, sentcb);
2801  }
2802 
2803  template<class T> Callback_Node_acceptPtr
2804  newCallback_Node_accept(T* instance, void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2805  {
2806  return new CallbackNC_Node_accept<T>(instance, 0, excb, sentcb);
2807  }
2808 
2809  template<class T, typename CT>
2810  class Callback_Node_accept : public Callback_Node_accept_Base, public ::IceInternal::OnewayCallback<T, CT>
2811  {
2812  public:
2813 
2815 
2816  typedef void (T::*Exception)(const ::Ice::Exception&, const CT&);
2817  typedef void (T::*Sent)(bool, const CT&);
2818  typedef void (T::*Response)(const CT&);
2819 
2820  Callback_Node_accept(const TPtr& obj, Response cb, Exception excb, Sent sentcb)
2821  : ::IceInternal::OnewayCallback<T, CT>(obj, cb, excb, sentcb)
2822  {
2823  }
2824  };
2825 
2826  template<class T, typename CT> Callback_Node_acceptPtr
2827  newCallback_Node_accept(const IceUtil::Handle<T>& instance, void (T::*cb)(const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2828  {
2829  return new Callback_Node_accept<T, CT>(instance, cb, excb, sentcb);
2830  }
2831 
2832  template<class T, typename CT> Callback_Node_acceptPtr
2833  newCallback_Node_accept(const IceUtil::Handle<T>& instance, void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2834  {
2835  return new Callback_Node_accept<T, CT>(instance, 0, excb, sentcb);
2836  }
2837 
2838  template<class T, typename CT> Callback_Node_acceptPtr
2839  newCallback_Node_accept(T* instance, void (T::*cb)(const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2840  {
2841  return new Callback_Node_accept<T, CT>(instance, cb, excb, sentcb);
2842  }
2843 
2844  template<class T, typename CT> Callback_Node_acceptPtr
2845  newCallback_Node_accept(T* instance, void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2846  {
2847  return new Callback_Node_accept<T, CT>(instance, 0, excb, sentcb);
2848  }
2849 
2850  template<class T>
2851  class CallbackNC_Node_areYouCoordinator : public Callback_Node_areYouCoordinator_Base, public ::IceInternal::TwowayCallbackNC<T>
2852  {
2853  public:
2854 
2856 
2857  typedef void (T::*Exception)(const ::Ice::Exception&);
2858  typedef void (T::*Sent)(bool);
2859  typedef void (T::*Response)(bool);
2860 
2862  : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
2863  {
2864  }
2865 
2866  virtual void completed(const ::Ice::AsyncResultPtr& result) const
2867  {
2868  ::IceStormElection::NodePrx proxy = ::IceStormElection::NodePrx::uncheckedCast(result->getProxy());
2869  bool ret;
2870  try
2871  {
2872  ret = proxy->end_areYouCoordinator(result);
2873  }
2874  catch (const ::Ice::Exception& ex)
2875  {
2876  ::IceInternal::CallbackNC<T>::exception(result, ex);
2877  return;
2878  }
2879  if (_response)
2880  {
2881  (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(ret);
2882  }
2883  }
2884 
2885  private:
2886 
2887  Response _response;
2888  };
2889 
2890  template<class T> Callback_Node_areYouCoordinatorPtr
2891  newCallback_Node_areYouCoordinator(const IceUtil::Handle<T>& instance, void (T::*cb)(bool), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2892  {
2893  return new CallbackNC_Node_areYouCoordinator<T>(instance, cb, excb, sentcb);
2894  }
2895 
2896  template<class T> Callback_Node_areYouCoordinatorPtr
2897  newCallback_Node_areYouCoordinator(T* instance, void (T::*cb)(bool), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2898  {
2899  return new CallbackNC_Node_areYouCoordinator<T>(instance, cb, excb, sentcb);
2900  }
2901 
2902  template<class T, typename CT>
2903  class Callback_Node_areYouCoordinator : public Callback_Node_areYouCoordinator_Base, public ::IceInternal::TwowayCallback<T, CT>
2904  {
2905  public:
2906 
2908 
2909  typedef void (T::*Exception)(const ::Ice::Exception&, const CT&);
2910  typedef void (T::*Sent)(bool, const CT&);
2911  typedef void (T::*Response)(bool, const CT&);
2912 
2914  : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
2915  {
2916  }
2917 
2918  virtual void completed(const ::Ice::AsyncResultPtr& result) const
2919  {
2920  ::IceStormElection::NodePrx proxy = ::IceStormElection::NodePrx::uncheckedCast(result->getProxy());
2921  bool ret;
2922  try
2923  {
2924  ret = proxy->end_areYouCoordinator(result);
2925  }
2926  catch (const ::Ice::Exception& ex)
2927  {
2928  ::IceInternal::Callback<T, CT>::exception(result, ex);
2929  return;
2930  }
2931  if (_response)
2932  {
2933  (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(ret, CT::dynamicCast(result->getCookie()));
2934  }
2935  }
2936 
2937  private:
2938 
2939  Response _response;
2940  };
2941 
2942  template<class T, typename CT> Callback_Node_areYouCoordinatorPtr
2943  newCallback_Node_areYouCoordinator(const IceUtil::Handle<T>& instance, void (T::*cb)(bool, const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2944  {
2945  return new Callback_Node_areYouCoordinator<T, CT>(instance, cb, excb, sentcb);
2946  }
2947 
2948  template<class T, typename CT> Callback_Node_areYouCoordinatorPtr
2949  newCallback_Node_areYouCoordinator(T* instance, void (T::*cb)(bool, const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
2950  {
2951  return new Callback_Node_areYouCoordinator<T, CT>(instance, cb, excb, sentcb);
2952  }
2953 
2954  template<class T>
2955  class CallbackNC_Node_areYouThere : public Callback_Node_areYouThere_Base, public ::IceInternal::TwowayCallbackNC<T>
2956  {
2957  public:
2958 
2960 
2961  typedef void (T::*Exception)(const ::Ice::Exception&);
2962  typedef void (T::*Sent)(bool);
2963  typedef void (T::*Response)(bool);
2964 
2966  : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
2967  {
2968  }
2969 
2970  virtual void completed(const ::Ice::AsyncResultPtr& result) const
2971  {
2972  ::IceStormElection::NodePrx proxy = ::IceStormElection::NodePrx::uncheckedCast(result->getProxy());
2973  bool ret;
2974  try
2975  {
2976  ret = proxy->end_areYouThere(result);
2977  }
2978  catch (const ::Ice::Exception& ex)
2979  {
2980  ::IceInternal::CallbackNC<T>::exception(result, ex);
2981  return;
2982  }
2983  if (_response)
2984  {
2985  (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(ret);
2986  }
2987  }
2988 
2989  private:
2990 
2991  Response _response;
2992  };
2993 
2994  template<class T> Callback_Node_areYouTherePtr
2995  newCallback_Node_areYouThere(const IceUtil::Handle<T>& instance, void (T::*cb)(bool), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
2996  {
2997  return new CallbackNC_Node_areYouThere<T>(instance, cb, excb, sentcb);
2998  }
2999 
3000  template<class T> Callback_Node_areYouTherePtr
3001  newCallback_Node_areYouThere(T* instance, void (T::*cb)(bool), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
3002  {
3003  return new CallbackNC_Node_areYouThere<T>(instance, cb, excb, sentcb);
3004  }
3005 
3006  template<class T, typename CT>
3007  class Callback_Node_areYouThere : public Callback_Node_areYouThere_Base, public ::IceInternal::TwowayCallback<T, CT>
3008  {
3009  public:
3010 
3012 
3013  typedef void (T::*Exception)(const ::Ice::Exception&, const CT&);
3014  typedef void (T::*Sent)(bool, const CT&);
3015  typedef void (T::*Response)(bool, const CT&);
3016 
3017  Callback_Node_areYouThere(const TPtr& obj, Response cb, Exception excb, Sent sentcb)
3018  : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
3019  {
3020  }
3021 
3022  virtual void completed(const ::Ice::AsyncResultPtr& result) const
3023  {
3024  ::IceStormElection::NodePrx proxy = ::IceStormElection::NodePrx::uncheckedCast(result->getProxy());
3025  bool ret;
3026  try
3027  {
3028  ret = proxy->end_areYouThere(result);
3029  }
3030  catch (const ::Ice::Exception& ex)
3031  {
3032  ::IceInternal::Callback<T, CT>::exception(result, ex);
3033  return;
3034  }
3035  if (_response)
3036  {
3037  (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(ret, CT::dynamicCast(result->getCookie()));
3038  }
3039  }
3040 
3041  private:
3042 
3043  Response _response;
3044  };
3045 
3046  template<class T, typename CT> Callback_Node_areYouTherePtr
3047  newCallback_Node_areYouThere(const IceUtil::Handle<T>& instance, void (T::*cb)(bool, const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
3048  {
3049  return new Callback_Node_areYouThere<T, CT>(instance, cb, excb, sentcb);
3050  }
3051 
3052  template<class T, typename CT> Callback_Node_areYouTherePtr
3053  newCallback_Node_areYouThere(T* instance, void (T::*cb)(bool, const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
3054  {
3055  return new Callback_Node_areYouThere<T, CT>(instance, cb, excb, sentcb);
3056  }
3057 
3058  template<class T>
3059  class CallbackNC_Node_sync : public Callback_Node_sync_Base, public ::IceInternal::TwowayCallbackNC<T>
3060  {
3061  public:
3062 
3064 
3065  typedef void (T::*Exception)(const ::Ice::Exception&);
3066  typedef void (T::*Sent)(bool);
3067  typedef void (T::*Response)(const ::Ice::ObjectPrx&);
3068 
3069  CallbackNC_Node_sync(const TPtr& obj, Response cb, Exception excb, Sent sentcb)
3070  : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
3071  {
3072  }
3073 
3074  virtual void completed(const ::Ice::AsyncResultPtr& result) const
3075  {
3076  ::IceStormElection::NodePrx proxy = ::IceStormElection::NodePrx::uncheckedCast(result->getProxy());
3077  ::Ice::ObjectPrx ret;
3078  try
3079  {
3080  ret = proxy->end_sync(result);
3081  }
3082  catch (const ::Ice::Exception& ex)
3083  {
3084  ::IceInternal::CallbackNC<T>::exception(result, ex);
3085  return;
3086  }
3087  if (_response)
3088  {
3089  (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(ret);
3090  }
3091  }
3092 
3093  private:
3094 
3095  Response _response;
3096  };
3097 
3098  template<class T> Callback_Node_syncPtr
3099  newCallback_Node_sync(const IceUtil::Handle<T>& instance, void (T::*cb)(const ::Ice::ObjectPrx&), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
3100  {
3101  return new CallbackNC_Node_sync<T>(instance, cb, excb, sentcb);
3102  }
3103 
3104  template<class T> Callback_Node_syncPtr
3105  newCallback_Node_sync(T* instance, void (T::*cb)(const ::Ice::ObjectPrx&), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
3106  {
3107  return new CallbackNC_Node_sync<T>(instance, cb, excb, sentcb);
3108  }
3109 
3110  template<class T, typename CT>
3111  class Callback_Node_sync : public Callback_Node_sync_Base, public ::IceInternal::TwowayCallback<T, CT>
3112  {
3113  public:
3114 
3116 
3117  typedef void (T::*Exception)(const ::Ice::Exception&, const CT&);
3118  typedef void (T::*Sent)(bool, const CT&);
3119  typedef void (T::*Response)(const ::Ice::ObjectPrx&, const CT&);
3120 
3121  Callback_Node_sync(const TPtr& obj, Response cb, Exception excb, Sent sentcb)
3122  : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
3123  {
3124  }
3125 
3126  virtual void completed(const ::Ice::AsyncResultPtr& result) const
3127  {
3128  ::IceStormElection::NodePrx proxy = ::IceStormElection::NodePrx::uncheckedCast(result->getProxy());
3129  ::Ice::ObjectPrx ret;
3130  try
3131  {
3132  ret = proxy->end_sync(result);
3133  }
3134  catch (const ::Ice::Exception& ex)
3135  {
3136  ::IceInternal::Callback<T, CT>::exception(result, ex);
3137  return;
3138  }
3139  if (_response)
3140  {
3141  (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(ret, CT::dynamicCast(result->getCookie()));
3142  }
3143  }
3144 
3145  private:
3146 
3147  Response _response;
3148  };
3149 
3150  template<class T, typename CT> Callback_Node_syncPtr
3151  newCallback_Node_sync(const IceUtil::Handle<T>& instance, void (T::*cb)(const ::Ice::ObjectPrx&, const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
3152  {
3153  return new Callback_Node_sync<T, CT>(instance, cb, excb, sentcb);
3154  }
3155 
3156  template<class T, typename CT> Callback_Node_syncPtr
3157  newCallback_Node_sync(T* instance, void (T::*cb)(const ::Ice::ObjectPrx&, const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
3158  {
3159  return new Callback_Node_sync<T, CT>(instance, cb, excb, sentcb);
3160  }
3161 
3162  template<class T>
3163  class CallbackNC_Node_nodes : public Callback_Node_nodes_Base, public ::IceInternal::TwowayCallbackNC<T>
3164  {
3165  public:
3166 
3168 
3169  typedef void (T::*Exception)(const ::Ice::Exception&);
3170  typedef void (T::*Sent)(bool);
3172 
3173  CallbackNC_Node_nodes(const TPtr& obj, Response cb, Exception excb, Sent sentcb)
3174  : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
3175  {
3176  }
3177 
3178  virtual void completed(const ::Ice::AsyncResultPtr& result) const
3179  {
3180  ::IceStormElection::NodePrx proxy = ::IceStormElection::NodePrx::uncheckedCast(result->getProxy());
3182  try
3183  {
3184  ret = proxy->end_nodes(result);
3185  }
3186  catch (const ::Ice::Exception& ex)
3187  {
3188  ::IceInternal::CallbackNC<T>::exception(result, ex);
3189  return;
3190  }
3191  if (_response)
3192  {
3193  (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(ret);
3194  }
3195  }
3196 
3197  private:
3198 
3199  Response _response;
3200  };
3201 
3202  template<class T> Callback_Node_nodesPtr
3203  newCallback_Node_nodes(const IceUtil::Handle<T>& instance, void (T::*cb)(const ::IceStormElection::NodeInfoSeq&), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
3204  {
3205  return new CallbackNC_Node_nodes<T>(instance, cb, excb, sentcb);
3206  }
3207 
3208  template<class T> Callback_Node_nodesPtr
3209  newCallback_Node_nodes(T* instance, void (T::*cb)(const ::IceStormElection::NodeInfoSeq&), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
3210  {
3211  return new CallbackNC_Node_nodes<T>(instance, cb, excb, sentcb);
3212  }
3213 
3214  template<class T, typename CT>
3215  class Callback_Node_nodes : public Callback_Node_nodes_Base, public ::IceInternal::TwowayCallback<T, CT>
3216  {
3217  public:
3218 
3220 
3221  typedef void (T::*Exception)(const ::Ice::Exception&, const CT&);
3222  typedef void (T::*Sent)(bool, const CT&);
3223  typedef void (T::*Response)(const ::IceStormElection::NodeInfoSeq&, const CT&);
3224 
3225  Callback_Node_nodes(const TPtr& obj, Response cb, Exception excb, Sent sentcb)
3226  : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
3227  {
3228  }
3229 
3230  virtual void completed(const ::Ice::AsyncResultPtr& result) const
3231  {
3232  ::IceStormElection::NodePrx proxy = ::IceStormElection::NodePrx::uncheckedCast(result->getProxy());
3234  try
3235  {
3236  ret = proxy->end_nodes(result);
3237  }
3238  catch (const ::Ice::Exception& ex)
3239  {
3240  ::IceInternal::Callback<T, CT>::exception(result, ex);
3241  return;
3242  }
3243  if (_response)
3244  {
3245  (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(ret, CT::dynamicCast(result->getCookie()));
3246  }
3247  }
3248 
3249  private:
3250 
3251  Response _response;
3252  };
3253 
3254  template<class T, typename CT> Callback_Node_nodesPtr
3255  newCallback_Node_nodes(const IceUtil::Handle<T>& instance, void (T::*cb)(const ::IceStormElection::NodeInfoSeq&, const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
3256  {
3257  return new Callback_Node_nodes<T, CT>(instance, cb, excb, sentcb);
3258  }
3259 
3260  template<class T, typename CT> Callback_Node_nodesPtr
3261  newCallback_Node_nodes(T* instance, void (T::*cb)(const ::IceStormElection::NodeInfoSeq&, const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
3262  {
3263  return new Callback_Node_nodes<T, CT>(instance, cb, excb, sentcb);
3264  }
3265 
3266  template<class T>
3267  class CallbackNC_Node_query : public Callback_Node_query_Base, public ::IceInternal::TwowayCallbackNC<T>
3268  {
3269  public:
3270 
3272 
3273  typedef void (T::*Exception)(const ::Ice::Exception&);
3274  typedef void (T::*Sent)(bool);
3275  typedef void (T::*Response)(const ::IceStormElection::QueryInfo&);
3276 
3277  CallbackNC_Node_query(const TPtr& obj, Response cb, Exception excb, Sent sentcb)
3278  : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
3279  {
3280  }
3281 
3282  virtual void completed(const ::Ice::AsyncResultPtr& result) const
3283  {
3284  ::IceStormElection::NodePrx proxy = ::IceStormElection::NodePrx::uncheckedCast(result->getProxy());
3286  try
3287  {
3288  ret = proxy->end_query(result);
3289  }
3290  catch (const ::Ice::Exception& ex)
3291  {
3292  ::IceInternal::CallbackNC<T>::exception(result, ex);
3293  return;
3294  }
3295  if (_response)
3296  {
3297  (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(ret);
3298  }
3299  }
3300 
3301  private:
3302 
3303  Response _response;
3304  };
3305 
3306  template<class T> Callback_Node_queryPtr
3307  newCallback_Node_query(const IceUtil::Handle<T>& instance, void (T::*cb)(const ::IceStormElection::QueryInfo&), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
3308  {
3309  return new CallbackNC_Node_query<T>(instance, cb, excb, sentcb);
3310  }
3311 
3312  template<class T> Callback_Node_queryPtr
3313  newCallback_Node_query(T* instance, void (T::*cb)(const ::IceStormElection::QueryInfo&), void (T::*excb)(const ::Ice::Exception&), void (T::*sentcb)(bool) = 0)
3314  {
3315  return new CallbackNC_Node_query<T>(instance, cb, excb, sentcb);
3316  }
3317 
3318  template<class T, typename CT>
3319  class Callback_Node_query : public Callback_Node_query_Base, public ::IceInternal::TwowayCallback<T, CT>
3320  {
3321  public:
3322 
3324 
3325  typedef void (T::*Exception)(const ::Ice::Exception&, const CT&);
3326  typedef void (T::*Sent)(bool, const CT&);
3327  typedef void (T::*Response)(const ::IceStormElection::QueryInfo&, const CT&);
3328 
3329  Callback_Node_query(const TPtr& obj, Response cb, Exception excb, Sent sentcb)
3330  : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
3331  {
3332  }
3333 
3334  virtual void completed(const ::Ice::AsyncResultPtr& result) const
3335  {
3336  ::IceStormElection::NodePrx proxy = ::IceStormElection::NodePrx::uncheckedCast(result->getProxy());
3338  try
3339  {
3340  ret = proxy->end_query(result);
3341  }
3342  catch (const ::Ice::Exception& ex)
3343  {
3344  ::IceInternal::Callback<T, CT>::exception(result, ex);
3345  return;
3346  }
3347  if (_response)
3348  {
3349  (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(ret, CT::dynamicCast(result->getCookie()));
3350  }
3351  }
3352 
3353  private:
3354 
3355  Response _response;
3356  };
3357 
3358  template<class T, typename CT> Callback_Node_queryPtr
3359  newCallback_Node_query(const IceUtil::Handle<T>& instance, void (T::*cb)(const ::IceStormElection::QueryInfo&, const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
3360  {
3361  return new Callback_Node_query<T, CT>(instance, cb, excb, sentcb);
3362  }
3363 
3364  template<class T, typename CT> Callback_Node_queryPtr
3365  newCallback_Node_query(T* instance, void (T::*cb)(const ::IceStormElection::QueryInfo&, const CT&), void (T::*excb)(const ::Ice::Exception&, const CT&), void (T::*sentcb)(bool, const CT&) = 0)
3366  {
3367  return new Callback_Node_query<T, CT>(instance, cb, excb, sentcb);
3368  }
3369 
3370 }
3371 
3372 #endif
3373 
3374 #include <IceUtil/PopDisableWarnings.h>
3375 #endif
IceStormElection::Callback_ReplicaObserver_init::Sent
void(T::* Sent)(bool, const CT &)
Definition: Election.h:1939
IceStormElection::CallbackNC_ReplicaObserver_removeSubscriber::CallbackNC_ReplicaObserver_removeSubscriber
CallbackNC_ReplicaObserver_removeSubscriber(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2383
IceStormElection::newCallback_ReplicaObserver_destroyTopic
Callback_ReplicaObserver_destroyTopicPtr newCallback_ReplicaObserver_destroyTopic(const IceUtil::Handle< T > &instance, void(T::*cb)(), void(T::*excb)(const ::Ice::Exception &), void(T::*sentcb)(bool)=0)
Definition: Election.h:2160
IceStormElection::Callback_Node_invitation_Base
Definition: Election.h:960
IceStormElection::Callback_Node_ready::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2732
IceStormElection::Callback_Node_sync::Exception
void(T::* Exception)(const ::Ice::Exception &, const CT &)
Definition: Election.h:3117
IceStormElection::CallbackNC_Node_accept::CallbackNC_Node_accept
CallbackNC_Node_accept(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2779
IceStormElection::Callback_Node_areYouThere::Sent
void(T::* Sent)(bool, const CT &)
Definition: Election.h:3014
IceStormElection::Callback_ReplicaObserver_removeSubscriber::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2440
IceStorm::SubscriberRecordSeq
::std::vector< ::IceStorm::SubscriberRecord > SubscriberRecordSeq
Definition: SubscriberRecord.h:225
IceStormElection::CallbackNC_ReplicaObserver_init
Definition: Election.h:1869
IceStormElection::CallbackNC_Node_nodes::Sent
void(T::* Sent)(bool)
Definition: Election.h:3170
IceStormElection::ReplicaObserver::ice_isA
virtual bool ice_isA(const ::std::string &, const ::Ice::Current &=::Ice::emptyCurrent) const
Definition: Election.cpp:1581
IceProxy::IceStormElection::Node::begin_areYouThere
::Ice::AsyncResultPtr begin_areYouThere(const ::std::string &iceP_gn, ::Ice::Int iceP_j, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1400
IceStormElection::Callback_ReplicaObserver_addSubscriber
Definition: Election.h:2310
IceStormElection::ReplicaObserverPrxPtr
ReplicaObserverPrx ReplicaObserverPrxPtr
Definition: Election.h:791
IceStormElection::Callback_Node_accept::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2814
IceStormElection::CallbackNC_Node_sync::Exception
void(T::* Exception)(const ::Ice::Exception &)
Definition: Election.h:3065
IceStormElection::Callback_TopicManagerSync_getContentPtr
::IceUtil::Handle< Callback_TopicManagerSync_getContent_Base > Callback_TopicManagerSync_getContentPtr
Definition: Election.h:958
Ice::StreamReader< ::IceStormElection::QueryInfo, S >::read
static void read(S *istr, ::IceStormElection::QueryInfo &v)
Definition: Election.h:1851
IceStormElection::CallbackNC_ReplicaObserver_addSubscriber::CallbackNC_ReplicaObserver_addSubscriber
CallbackNC_ReplicaObserver_addSubscriber(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2257
IceProxy::IceStormElection::Node::begin_areYouCoordinator
::Ice::AsyncResultPtr begin_areYouCoordinator(const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1362
IceStormElection::CallbackNC_Node_areYouThere::Exception
void(T::* Exception)(const ::Ice::Exception &)
Definition: Election.h:2961
IceProxy::IceStormElection::Node::begin_ready
::Ice::AsyncResultPtr begin_ready(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::ObjectPrx &iceP_coordinator, ::Ice::Int iceP_max, ::Ice::Long iceP_generation, const ::Ice::Context &context, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1296
IceStormElection::Callback_ReplicaObserver_addSubscriberPtr
::IceUtil::Handle< Callback_ReplicaObserver_addSubscriber_Base > Callback_ReplicaObserver_addSubscriberPtr
Definition: Election.h:952
IceStormElection::TopicManagerSync::_iceDispatch
virtual bool _iceDispatch(::IceInternal::Incoming &, const ::Ice::Current &)
Definition: Election.cpp:1864
IceStormElection::Callback_Node_ready::Callback_Node_ready
Callback_Node_ready(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2738
armarx::aron::ret
ReaderT::InputType T & ret
Definition: rw.h:17
IceStormElection::GroupInfo::operator>
bool operator>(const GroupInfo &rhs_) const
Definition: Election.h:914
IceProxy::IceStormElection::Node::begin_sync
::Ice::AsyncResultPtr begin_sync(const ::Ice::Context &context, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1448
IceStormElection::Callback_Node_accept
Definition: Election.h:2810
IceProxy::IceStormElection::ReplicaObserver::begin_addSubscriber
::Ice::AsyncResultPtr begin_addSubscriber(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_topic, const ::IceStorm::SubscriberRecord &iceP_record, const ::IceStormElection::Callback_ReplicaObserver_addSubscriberPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1127
IceStormElection::CallbackNC_TopicManagerSync_getContent
Definition: Election.h:2499
IceStormElection::TopicManagerSync
Interface used to sync topics.
Definition: Election.ice:125
IceStormElection::CallbackNC_Node_accept::Sent
void(T::* Sent)(bool)
Definition: Election.h:2776
IceStormElection::Node::ice_isA
virtual bool ice_isA(const ::std::string &, const ::Ice::Current &=::Ice::emptyCurrent) const
Definition: Election.cpp:1949
IceStormElection::CallbackNC_Node_areYouThere::Sent
void(T::* Sent)(bool)
Definition: Election.h:2962
IceStormElection::QueryInfo::id
::Ice::Int id
Definition: Election.h:928
IceProxy::IceStormElection::Node::begin_nodes
::Ice::AsyncResultPtr begin_nodes(const ::Ice::Context &context, const ::IceStormElection::Callback_Node_nodesPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1496
IceStormElection::CallbackNC_ReplicaObserver_init::Sent
void(T::* Sent)(bool)
Definition: Election.h:1876
IceProxy::IceStormElection::Node::begin_nodes
::Ice::AsyncResultPtr begin_nodes(const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1481
IceStormElection::Node::_iceD_query
bool _iceD_query(::IceInternal::Incoming &, const ::Ice::Current &) const
Definition: Election.cpp:2090
IceStormElection::GroupInfo::operator<=
bool operator<=(const GroupInfo &rhs_) const
Definition: Election.h:910
IceStormElection::ReplicaObserver::init
void init(LogUpdate llu, TopicContentSeq content)
Initialize the observer.
IceStormElection::CallbackNC_Node_accept::Exception
void(T::* Exception)(const ::Ice::Exception &)
Definition: Election.h:2775
IceStormElection::CallbackNC_Node_invitation::CallbackNC_Node_invitation
CallbackNC_Node_invitation(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2615
IceProxy::IceStormElection::Node::begin_query
::Ice::AsyncResultPtr begin_query(const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1519
IceStormElection::Callback_Node_areYouCoordinator::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:2918
IceStormElection::GroupInfo::operator>=
bool operator>=(const GroupInfo &rhs_) const
Definition: Election.h:918
IceStormElection::TopicManagerSync::getContent
void getContent(out LogUpdate llu, out TopicContentSeq content)
Retrieve the topic content.
IceStormElection::ReplicaObserver::_iceD_destroyTopic
bool _iceD_destroyTopic(::IceInternal::Incoming &, const ::Ice::Current &)
Definition: Election.cpp:1640
IceStormElection::CallbackNC_Node_sync::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:3074
IceStormElection::CallbackNC_Node_areYouCoordinator::Exception
void(T::* Exception)(const ::Ice::Exception &)
Definition: Election.h:2857
IceProxy::IceStormElection::Node::begin_accept
::Ice::AsyncResultPtr begin_accept(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::IntSeq &iceP_forwardedInvites, const ::Ice::ObjectPrx &iceP_observer, const ::IceStormElection::LogUpdate &iceP_llu, ::Ice::Int iceP_max, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1324
IceStormElection::CallbackNC_Node_invitation::Exception
void(T::* Exception)(const ::Ice::Exception &)
Definition: Election.h:2611
IceStormElection::ReplicaObserver::removeSubscriber
void removeSubscriber(LogUpdate llu, string topic, Ice::IdentitySeq subscribers)
Remove a subscriber from a topic.
IceStormElection::Callback_ReplicaObserver_init_Base
Definition: Election.h:942
IceStormElection::Callback_ReplicaObserver_removeSubscriber_Base
Definition: Election.h:954
IceProxy::IceStormElection::Node::begin_ready
::Ice::AsyncResultPtr begin_ready(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::ObjectPrx &iceP_coordinator, ::Ice::Int iceP_max, ::Ice::Long iceP_generation, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1291
IceProxy::IceStormElection::upCast
::IceProxy::Ice::Object * upCast(::IceProxy::IceStormElection::ReplicaObserver *)
Definition: Election.cpp:919
IceStormElection::Node::ready
void ready(int j, string gn, Object *coordinator, int max, long generation)
Call from the group coordinator to a node to inform the node that the replica group is active.
IceStormElection::CallbackNC_ReplicaObserver_destroyTopic::CallbackNC_ReplicaObserver_destroyTopic
CallbackNC_ReplicaObserver_destroyTopic(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2131
IceStormElection::Callback_TopicManagerSync_getContent_Base
Definition: Election.h:957
IceStormElection::Node::_iceReadImpl
virtual void _iceReadImpl(::Ice::InputStream *)
Definition: Election.cpp:2197
IceProxy::IceStormElection::ReplicaObserver::createTopic
void createTopic(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_name, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1031
IceStormElection::CallbackNC_TopicManagerSync_getContent::Sent
void(T::* Sent)(bool)
Definition: Election.h:2506
IceStormElection::newCallback_Node_ready
Callback_Node_readyPtr newCallback_Node_ready(const IceUtil::Handle< T > &instance, void(T::*cb)(), void(T::*excb)(const ::Ice::Exception &), void(T::*sentcb)(bool)=0)
Definition: Election.h:2704
IceStormElection::Callback_Node_areYouThere_Base
Definition: Election.h:972
IceStormElection::Callback_ReplicaObserver_createTopicPtr
::IceUtil::Handle< Callback_ReplicaObserver_createTopic_Base > Callback_ReplicaObserver_createTopicPtr
Definition: Election.h:946
IceStormElection::Node::ProxyType
NodePrx ProxyType
Definition: Election.h:1649
IceStormElection::Node::areYouThere
idempotent bool areYouThere(string gn, int j)
Determine if the node is a member of the given group with the given coordinator.
IceStormElection::Callback_Node_sync::Callback_Node_sync
Callback_Node_sync(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:3121
IceStormElection::QueryInfo::coord
int coord
The nodes coordinator.
Definition: Election.ice:183
IceStormElection::CallbackNC_Node_sync::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:3063
IceStormElection::Node::_iceD_areYouThere
bool _iceD_areYouThere(::IceInternal::Incoming &, const ::Ice::Current &) const
Definition: Election.cpp:2049
IceStormElection::Callback_Node_sync::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:3126
IceStormElection::Callback_Node_accept::Callback_Node_accept
Callback_Node_accept(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2820
IceProxy::IceStormElection::ReplicaObserver::init
void init(const ::IceStormElection::LogUpdate &iceP_llu, const ::IceStormElection::TopicContentSeq &iceP_content, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:993
IceStormElection::CallbackNC_Node_accept::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2773
IceStormElection::NodePrx
::IceInternal::ProxyHandle< ::IceProxy::IceStormElection::Node > NodePrx
Definition: Election.h:804
IceStormElection::CallbackNC_TopicManagerSync_getContent::Exception
void(T::* Exception)(const ::Ice::Exception &)
Definition: Election.h:2505
IceProxy::IceStormElection::Node::begin_nodes
::Ice::AsyncResultPtr begin_nodes(const ::Ice::Context &context, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1486
IceStormElection::Node::nodes
idempotent NodeInfoSeq nodes()
Get the replication group information.
IceStormElection::CallbackNC_Node_nodes::Exception
void(T::* Exception)(const ::Ice::Exception &)
Definition: Election.h:3169
IceStormElection::CallbackNC_ReplicaObserver_init::Exception
void(T::* Exception)(const ::Ice::Exception &)
Definition: Election.h:1875
IceProxy::IceStormElection::TopicManagerSync::begin_getContent
::Ice::AsyncResultPtr begin_getContent(const ::IceStormElection::Callback_TopicManagerSync_getContentPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1214
IceProxy::IceStormElection::TopicManagerSync::getContent
void getContent(::IceStormElection::LogUpdate &iceP_llu, ::IceStormElection::TopicContentSeq &iceP_content, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1194
IceProxy::IceStormElection::ReplicaObserver::begin_init
::Ice::AsyncResultPtr begin_init(const ::IceStormElection::LogUpdate &iceP_llu, const ::IceStormElection::TopicContentSeq &iceP_content, const ::Ice::Context &context, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1008
IceStormElection::upCast
::Ice::Object * upCast(::IceStormElection::ReplicaObserver *)
Definition: Election.cpp:1564
IceStormElection::GroupInfo::llu
LogUpdate llu
The last known log update for this node.
Definition: Election.ice:172
IceStormElection::CallbackNC_ReplicaObserver_createTopic::Sent
void(T::* Sent)(bool)
Definition: Election.h:2002
IceStormElection::QueryInfo
Definition: Election.ice:177
IceStormElection::Callback_Node_readyPtr
::IceUtil::Handle< Callback_Node_ready_Base > Callback_Node_readyPtr
Definition: Election.h:964
IceProxy::IceStormElection::ReplicaObserver::begin_init
::Ice::AsyncResultPtr begin_init(const ::IceStormElection::LogUpdate &iceP_llu, const ::IceStormElection::TopicContentSeq &iceP_content, const ::IceStormElection::Callback_ReplicaObserver_initPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1013
IceProxy::IceStormElection::ReplicaObserver::begin_addSubscriber
::Ice::AsyncResultPtr begin_addSubscriber(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_topic, const ::IceStorm::SubscriberRecord &iceP_record, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1117
IceStormElection::CallbackNC_TopicManagerSync_getContent::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:2514
IceProxy::IceStormElection::Node::begin_sync
::Ice::AsyncResultPtr begin_sync(const ::IceStormElection::Callback_Node_syncPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1453
IceStormElection::CallbackNC_ReplicaObserver_removeSubscriber::Exception
void(T::* Exception)(const ::Ice::Exception &)
Definition: Election.h:2379
IceStormElection::CallbackNC_Node_nodes::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:3167
IceStormElection::ReplicaObserverPtr
::IceInternal::Handle< ::IceStormElection::ReplicaObserver > ReplicaObserverPtr
Definition: Election.h:789
IceProxy::IceStormElection::Node::begin_areYouThere
::Ice::AsyncResultPtr begin_areYouThere(const ::std::string &iceP_gn, ::Ice::Int iceP_j, const ::Ice::Context &context, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1410
IceStormElection::newCallback_Node_areYouThere
Callback_Node_areYouTherePtr newCallback_Node_areYouThere(const IceUtil::Handle< T > &instance, void(T::*cb)(bool), void(T::*excb)(const ::Ice::Exception &), void(T::*sentcb)(bool)=0)
Definition: Election.h:2995
IceStormElection::Callback_ReplicaObserver_destroyTopic::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:2199
IceStormElection::CallbackNC_ReplicaObserver_destroyTopic::Sent
void(T::* Sent)(bool)
Definition: Election.h:2128
IceStormElection::CallbackNC_Node_ready
Definition: Election.h:2687
IceProxy::IceStormElection::ReplicaObserver::begin_destroyTopic
::Ice::AsyncResultPtr begin_destroyTopic(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_name, const ::IceStormElection::Callback_ReplicaObserver_destroyTopicPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1089
IceStormElection::QueryInfo::up
GroupInfoSeq up
The sequence of nodes in this nodes group.
Definition: Election.ice:195
IceStormElection::CallbackNC_ReplicaObserver_destroyTopic::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2125
IceProxy::IceStormElection::Node::begin_query
::Ice::AsyncResultPtr begin_query(const ::Ice::Context &context, const ::IceStormElection::Callback_Node_queryPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1534
IceStormElection::newCallback_ReplicaObserver_init
Callback_ReplicaObserver_initPtr newCallback_ReplicaObserver_init(const IceUtil::Handle< T > &instance, void(T::*cb)(), void(T::*excb)(const ::Ice::Exception &), void(T::*sentcb)(bool)=0)
Definition: Election.h:1908
IceStormElection::CallbackNC_Node_sync::CallbackNC_Node_sync
CallbackNC_Node_sync(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:3069
IceStormElection::LogUpdate
A struct used for marking the last log update.
Definition: LLURecord.h:100
IceStormElection::CallbackNC_ReplicaObserver_addSubscriber::Sent
void(T::* Sent)(bool)
Definition: Election.h:2254
IceStormElection::Callback_Node_sync_Base
Definition: Election.h:975
IceStormElection::TopicManagerSync::ProxyType
TopicManagerSyncPrx ProxyType
Definition: Election.h:1613
IceStormElection::GroupInfo::operator==
bool operator==(const GroupInfo &rhs_) const
Definition: Election.h:864
IceStormElection::CallbackNC_Node_areYouThere
Definition: Election.h:2955
IceStormElection::ReplicaObserver::_iceWriteImpl
virtual void _iceWriteImpl(::Ice::OutputStream *) const
Definition: Election.cpp:1761
IceStormElection::Callback_Node_nodes::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:3219
IceStormElection::Callback_Node_areYouCoordinator
Definition: Election.h:2903
IceProxy::IceStormElection::ReplicaObserver::begin_createTopic
::Ice::AsyncResultPtr begin_createTopic(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_name, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1036
IceStormElection::CallbackNC_ReplicaObserver_init::CallbackNC_ReplicaObserver_init
CallbackNC_ReplicaObserver_init(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:1879
IceStormElection::Node::areYouCoordinator
idempotent bool areYouCoordinator()
Determine if this node is a coordinator.
IceStormElection::Callback_Node_queryPtr
::IceUtil::Handle< Callback_Node_query_Base > Callback_Node_queryPtr
Definition: Election.h:982
IceStormElection::CallbackNC_Node_query::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:3271
IceStormElection::Callback_Node_areYouCoordinatorPtr
::IceUtil::Handle< Callback_Node_areYouCoordinator_Base > Callback_Node_areYouCoordinatorPtr
Definition: Election.h:970
IceStormElection::_icePatchObjectPtr
void _icePatchObjectPtr(ReplicaObserverPtr &, const ::Ice::ObjectPtr &)
Definition: Election.cpp:1777
IceStormElection::NodeStateElection
@ NodeStateElection
The node is electing a leader.
Definition: Election.ice:144
IceProxy::IceStormElection::ReplicaObserver::begin_addSubscriber
::Ice::AsyncResultPtr begin_addSubscriber(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_topic, const ::IceStorm::SubscriberRecord &iceP_record, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1112
IceStormElection::CallbackNC_Node_invitation::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2609
IceStormElection::ReplicaObserver
The replica observer.
Definition: Election.ice:42
IceProxy::IceStormElection
Definition: Election.h:765
IceStormElection::TopicManagerSync::~TopicManagerSync
virtual ~TopicManagerSync()
Definition: Election.cpp:1786
IceProxy::IceStormElection::ReplicaObserver::begin_addSubscriber
::Ice::AsyncResultPtr begin_addSubscriber(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_topic, const ::IceStorm::SubscriberRecord &iceP_record, const ::Ice::Context &context, const ::IceStormElection::Callback_ReplicaObserver_addSubscriberPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1132
IceStormElection::QueryInfo::replica
::Ice::ObjectPrx replica
Definition: Election.h:931
IceStormElection::CallbackNC_ReplicaObserver_destroyTopic::Exception
void(T::* Exception)(const ::Ice::Exception &)
Definition: Election.h:2127
IceProxy::IceStormElection::Node::begin_sync
::Ice::AsyncResultPtr begin_sync(const ::Ice::Context &context, const ::IceStormElection::Callback_Node_syncPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1458
IceStormElection::TopicManagerSync::_iceReadImpl
virtual void _iceReadImpl(::Ice::InputStream *)
Definition: Election.cpp:1911
IceStormElection::CallbackNC_ReplicaObserver_createTopic::Exception
void(T::* Exception)(const ::Ice::Exception &)
Definition: Election.h:2001
IceStormElection::NodeInfo::n
Node * n
The node proxy.
Definition: Election.ice:160
IceStormElection::Callback_Node_invitation::Callback_Node_invitation
Callback_Node_invitation(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2656
IceStormElection::QueryInfo::id
int id
The node id.
Definition: Election.ice:180
IceStormElection::Node::ice_ids
virtual ::std::vector< ::std::string > ice_ids(const ::Ice::Current &=::Ice::emptyCurrent) const
Definition: Election.cpp:1955
IceProxy::IceStormElection::ReplicaObserver::begin_destroyTopic
::Ice::AsyncResultPtr begin_destroyTopic(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_name, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1079
IceStormElection::CallbackNC_Node_areYouThere::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2959
IceStormElection::CallbackNC_Node_query
Definition: Election.h:3267
IceStormElection::Node::_iceD_areYouCoordinator
bool _iceD_areYouCoordinator(::IceInternal::Incoming &, const ::Ice::Current &) const
Definition: Election.cpp:2037
IceStormElection::newCallback_Node_query
Callback_Node_queryPtr newCallback_Node_query(const IceUtil::Handle< T > &instance, void(T::*cb)(const ::IceStormElection::QueryInfo &), void(T::*excb)(const ::Ice::Exception &), void(T::*sentcb)(bool)=0)
Definition: Election.h:3307
IceProxy::IceStormElection::Node::begin_areYouCoordinator
::Ice::AsyncResultPtr begin_areYouCoordinator(const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1367
IceProxy::IceStormElection::Node::areYouThere
bool areYouThere(const ::std::string &iceP_gn, ::Ice::Int iceP_j, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1395
IceStormElection::Callback_Node_invitation::Sent
void(T::* Sent)(bool, const CT &)
Definition: Election.h:2653
IceStormElection::Callback_Node_nodes::Sent
void(T::* Sent)(bool, const CT &)
Definition: Election.h:3222
IceProxy::IceStormElection::ReplicaObserver::destroyTopic
void destroyTopic(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_name, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1069
IceStormElection::operator==
bool operator==(const ReplicaObserver &lhs, const ReplicaObserver &rhs)
Definition: Election.h:1599
IceProxy::IceStormElection::Node::nodes
::IceStormElection::NodeInfoSeq nodes(const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1471
IceStormElection::ObserverInconsistencyException
Thrown if an observer detects an inconsistency.
Definition: Election.ice:35
IceStormElection::CallbackNC_Node_invitation
Definition: Election.h:2605
IceStormElection::newCallback_Node_nodes
Callback_Node_nodesPtr newCallback_Node_nodes(const IceUtil::Handle< T > &instance, void(T::*cb)(const ::IceStormElection::NodeInfoSeq &), void(T::*excb)(const ::Ice::Exception &), void(T::*sentcb)(bool)=0)
Definition: Election.h:3203
IceStormElection::ReplicaObserver::addSubscriber
void addSubscriber(LogUpdate llu, string topic, IceStorm::SubscriberRecord record)
Add a subscriber to a topic.
IceInternal::Handle
Definition: forward_declarations.h:8
IceStormElection::Callback_Node_query
Definition: Election.h:3319
IceStormElection::NodePrxPtr
NodePrx NodePrxPtr
Definition: Election.h:805
IceStormElection::Callback_ReplicaObserver_destroyTopic::Exception
void(T::* Exception)(const ::Ice::Exception &, const CT &)
Definition: Election.h:2190
IceStormElection::Callback_Node_query::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:3334
IceStormElection::ReplicaObserver::PointerType
ReplicaObserverPtr PointerType
Definition: Election.h:1566
IceStormElection::CallbackNC_ReplicaObserver_destroyTopic
Definition: Election.h:2121
IceStorm::SubscriberRecord
Used to store persistent information for persistent subscribers.
Definition: SubscriberRecord.h:214
IceStormElection::Node::sync
idempotent Object * sync()
Get the sync object for the replica hosted by this node.
IceStormElection::ObserverInconsistencyException::ice_throw
virtual void ice_throw() const
Definition: Election.cpp:899
IceStormElection::Callback_Node_query::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:3323
IceStormElection::Callback_Node_areYouCoordinator::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2907
IceStormElection::Callback_Node_invitation::Exception
void(T::* Exception)(const ::Ice::Exception &, const CT &)
Definition: Election.h:2652
IceStormElection::ObserverInconsistencyException::reason
string reason
The reason for the inconsistency.
Definition: Election.ice:38
IceStormElection::Callback_ReplicaObserver_destroyTopic::Sent
void(T::* Sent)(bool, const CT &)
Definition: Election.h:2191
Ice::StreamWriter< ::IceStormElection::TopicContent, S >::write
static void write(S *ostr, const ::IceStormElection::TopicContent &v)
Definition: Election.h:1718
IceStormElection::TopicContentSeq
::std::vector< ::IceStormElection::TopicContent > TopicContentSeq
A sequence of topic content.
Definition: Election.h:819
IceProxy::IceStormElection::ReplicaObserver::begin_addSubscriber
::Ice::AsyncResultPtr begin_addSubscriber(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_topic, const ::IceStorm::SubscriberRecord &iceP_record, const ::Ice::Context &context, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1122
IceStormElection::Callback_ReplicaObserver_addSubscriber::Exception
void(T::* Exception)(const ::Ice::Exception &, const CT &)
Definition: Election.h:2316
IceProxy::IceStormElection::TopicManagerSync
Definition: Election.h:1190
IceStormElection::Callback_ReplicaObserver_destroyTopic_Base
Definition: Election.h:948
IceStormElection::Callback_Node_nodes_Base
Definition: Election.h:978
GfxTL::Identity
void Identity(MatrixXX< N, N, T > *a)
Definition: MatrixXX.h:523
IceStormElection::TopicContent::id
Ice::Identity id
The topic identity.
Definition: Election.ice:26
IceStormElection::Callback_ReplicaObserver_removeSubscriber::Exception
void(T::* Exception)(const ::Ice::Exception &, const CT &)
Definition: Election.h:2442
IceStormElection::TopicManagerSync::PointerType
TopicManagerSyncPtr PointerType
Definition: Election.h:1614
IceStormElection::NodeStateInactive
@ NodeStateInactive
The node is inactive and awaiting an election.
Definition: Election.ice:142
IceStormElection::TopicContent
The contents of topic.
Definition: Election.ice:23
IceStormElection::Node
A replica node.
Definition: Election.ice:202
IceStormElection::TopicManagerSyncPtr
::IceInternal::Handle< ::IceStormElection::TopicManagerSync > TopicManagerSyncPtr
Definition: Election.h:796
IceStormElection::CallbackNC_Node_ready::Exception
void(T::* Exception)(const ::Ice::Exception &)
Definition: Election.h:2693
IceStormElection::newCallback_TopicManagerSync_getContent
Callback_TopicManagerSync_getContentPtr newCallback_TopicManagerSync_getContent(const IceUtil::Handle< T > &instance, void(T::*cb)(const ::IceStormElection::LogUpdate &, const ::IceStormElection::TopicContentSeq &), void(T::*excb)(const ::Ice::Exception &), void(T::*sentcb)(bool)=0)
Definition: Election.h:2540
IceStormElection::Callback_ReplicaObserver_destroyTopicPtr
::IceUtil::Handle< Callback_ReplicaObserver_destroyTopic_Base > Callback_ReplicaObserver_destroyTopicPtr
Definition: Election.h:949
IceStormElection::NodePtr
::IceInternal::Handle< ::IceStormElection::Node > NodePtr
Definition: Election.h:803
IceProxy::IceStormElection::TopicManagerSync::begin_getContent
::Ice::AsyncResultPtr begin_getContent(const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1199
IceStormElection::newCallback_Node_invitation
Callback_Node_invitationPtr newCallback_Node_invitation(const IceUtil::Handle< T > &instance, void(T::*cb)(), void(T::*excb)(const ::Ice::Exception &), void(T::*sentcb)(bool)=0)
Definition: Election.h:2622
IceStormElection::Node::_iceDispatch
virtual bool _iceDispatch(::IceInternal::Incoming &, const ::Ice::Current &)
Definition: Election.cpp:2122
IceStormElection::Callback_Node_areYouCoordinator::Exception
void(T::* Exception)(const ::Ice::Exception &, const CT &)
Definition: Election.h:2909
IceStormElection::QueryInfo::max
int max
The highest priority node that this node has seen.
Definition: Election.ice:198
IceStormElection::Callback_ReplicaObserver_init::Exception
void(T::* Exception)(const ::Ice::Exception &, const CT &)
Definition: Election.h:1938
IceStormElection::CallbackNC_Node_query::Exception
void(T::* Exception)(const ::Ice::Exception &)
Definition: Election.h:3273
IceStormElection::CallbackNC_Node_sync::Sent
void(T::* Sent)(bool)
Definition: Election.h:3066
IceStormElection::NodeState
NodeState
The node state.
Definition: Election.ice:139
IceProxy::IceStormElection::ReplicaObserver::begin_init
::Ice::AsyncResultPtr begin_init(const ::IceStormElection::LogUpdate &iceP_llu, const ::IceStormElection::TopicContentSeq &iceP_content, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1003
IceStormElection::Callback_ReplicaObserver_createTopic
Definition: Election.h:2058
IceStormElection
Definition: DBTypes.ice:17
IceProxy::IceStormElection::ReplicaObserver::begin_createTopic
::Ice::AsyncResultPtr begin_createTopic(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_name, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1041
IceStormElection::Callback_ReplicaObserver_removeSubscriber::Sent
void(T::* Sent)(bool, const CT &)
Definition: Election.h:2443
IceStormElection::GroupInfoSeq
::std::vector< ::IceStormElection::GroupInfo > GroupInfoSeq
A sequence of group info.
Definition: Election.h:924
IceStormElection::ReplicaObserver::ProxyType
ReplicaObserverPrx ProxyType
Definition: Election.h:1565
IceStormElection::Callback_Node_ready::Sent
void(T::* Sent)(bool, const CT &)
Definition: Election.h:2735
IceStormElection::Node::ice_id
virtual const ::std::string & ice_id(const ::Ice::Current &=::Ice::emptyCurrent) const
Definition: Election.cpp:1961
IceStormElection::Node::accept
void accept(int j, string gn, Ice::IntSeq forwardedInvites, Object *observer, LogUpdate llu, int max)
Called to accept an invitation into the given group.
IceStormElection::QueryInfo::group
string group
The nodes group name.
Definition: Election.ice:186
IceProxy::IceStormElection::Node::begin_invitation
::Ice::AsyncResultPtr begin_invitation(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::Context &context, const ::IceStormElection::Callback_Node_invitationPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1268
IceStormElection::Callback_Node_syncPtr
::IceUtil::Handle< Callback_Node_sync_Base > Callback_Node_syncPtr
Definition: Election.h:976
IceProxy::IceStormElection::Node::begin_ready
::Ice::AsyncResultPtr begin_ready(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::ObjectPrx &iceP_coordinator, ::Ice::Int iceP_max, ::Ice::Long iceP_generation, const ::IceStormElection::Callback_Node_readyPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1301
IceStormElection::TopicManagerSyncPrxPtr
TopicManagerSyncPrx TopicManagerSyncPrxPtr
Definition: Election.h:798
IceStormElection::Callback_Node_ready
Definition: Election.h:2728
IceStormElection::Callback_ReplicaObserver_removeSubscriber::Callback_ReplicaObserver_removeSubscriber
Callback_ReplicaObserver_removeSubscriber(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2446
IceStormElection::CallbackNC_ReplicaObserver_removeSubscriber::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:2388
IceStormElection::CallbackNC_ReplicaObserver_createTopic
Definition: Election.h:1995
IceStormElection::Callback_ReplicaObserver_initPtr
::IceUtil::Handle< Callback_ReplicaObserver_init_Base > Callback_ReplicaObserver_initPtr
Definition: Election.h:943
IceStormElection::Callback_TopicManagerSync_getContent::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:2567
IceStormElection::Callback_TopicManagerSync_getContent::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2556
IceStormElection::Callback_Node_areYouThere::Exception
void(T::* Exception)(const ::Ice::Exception &, const CT &)
Definition: Election.h:3013
IceStormElection::Callback_ReplicaObserver_removeSubscriber::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:2451
IceProxy::IceStormElection::Node::begin_query
::Ice::AsyncResultPtr begin_query(const ::IceStormElection::Callback_Node_queryPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1529
IceProxy::IceStormElection::ReplicaObserver::begin_createTopic
::Ice::AsyncResultPtr begin_createTopic(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_name, const ::Ice::Context &context, const ::IceStormElection::Callback_ReplicaObserver_createTopicPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1056
IceStormElection::Callback_Node_acceptPtr
::IceUtil::Handle< Callback_Node_accept_Base > Callback_Node_acceptPtr
Definition: Election.h:967
IceStormElection::Callback_Node_accept_Base
Definition: Election.h:966
IceStormElection::Callback_ReplicaObserver_init::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:1947
IceStormElection::CallbackNC_ReplicaObserver_init::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:1873
IceStormElection::Node::~Node
virtual ~Node()
Definition: Election.cpp:1928
IceStormElection::CallbackNC_ReplicaObserver_addSubscriber
Definition: Election.h:2247
IceStormElection::TopicManagerSync::ice_id
virtual const ::std::string & ice_id(const ::Ice::Current &=::Ice::emptyCurrent) const
Definition: Election.cpp:1819
IceStormElection::GroupInfo
The group info.
Definition: Election.ice:167
Ice::StreamWriter< ::IceStormElection::ObserverInconsistencyException, S >::write
static void write(S *ostr, const ::IceStormElection::ObserverInconsistencyException &v)
Definition: Election.h:1744
IceProxy::IceStormElection::_readProxy
void _readProxy(::Ice::InputStream *, ::IceInternal::ProxyHandle< ::IceProxy::IceStormElection::ReplicaObserver > &)
IceStormElection::NodeInfo
All nodes in the replication group.
Definition: Election.ice:155
IceStormElection::Callback_Node_sync::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:3115
armarx::read
void read(auto &eigen, auto *table)
Definition: FTSensorCalibrationGuiWidgetController.cpp:462
IceProxy::IceStormElection::ReplicaObserver
Definition: Election.h:989
IceStormElection::CallbackNC_TopicManagerSync_getContent::CallbackNC_TopicManagerSync_getContent
CallbackNC_TopicManagerSync_getContent(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2509
IceStormElection::CallbackNC_ReplicaObserver_removeSubscriber::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2377
IceStormElection::ReplicaObserver::ice_id
virtual const ::std::string & ice_id(const ::Ice::Current &=::Ice::emptyCurrent) const
Definition: Election.cpp:1593
IceStormElection::CallbackNC_ReplicaObserver_createTopic::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:1999
IceStormElection::TopicManagerSync::ice_staticId
static const ::std::string & ice_staticId()
Definition: Election.cpp:1825
IceStormElection::Callback_Node_nodes::Callback_Node_nodes
Callback_Node_nodes(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:3225
IceStormElection::ReplicaObserver::_iceD_addSubscriber
bool _iceD_addSubscriber(::IceInternal::Incoming &, const ::Ice::Current &)
Definition: Election.cpp:1655
IceStormElection::CallbackNC_ReplicaObserver_addSubscriber::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:2262
IceStormElection::NodeStateReorganization
@ NodeStateReorganization
The replica group is reorganizing.
Definition: Election.ice:146
armarx::VariantType::Long
const VariantTypeId Long
Definition: Variant.h:917
IceStormElection::Callback_ReplicaObserver_init::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:1936
IceStormElection::Callback_Node_nodes
Definition: Election.h:3215
IceStormElection::CallbackNC_Node_areYouCoordinator::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2855
IceProxy::IceStormElection::ReplicaObserver::begin_removeSubscriber
::Ice::AsyncResultPtr begin_removeSubscriber(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_topic, const ::Ice::IdentitySeq &iceP_subscribers, const ::IceStormElection::Callback_ReplicaObserver_removeSubscriberPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1165
IceStormElection::NodeInfo::id
::Ice::Int id
Definition: Election.h:853
Ice::StreamReader< ::IceStormElection::GroupInfo, S >::read
static void read(S *istr, ::IceStormElection::GroupInfo &v)
Definition: Election.h:1818
Ice::StreamReader< ::IceStormElection::NodeInfo, S >::read
static void read(S *istr, ::IceStormElection::NodeInfo &v)
Definition: Election.h:1790
IceProxy::IceStormElection::Node::begin_areYouCoordinator
::Ice::AsyncResultPtr begin_areYouCoordinator(const ::IceStormElection::Callback_Node_areYouCoordinatorPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1377
IceProxy::IceStormElection::Node::begin_nodes
::Ice::AsyncResultPtr begin_nodes(const ::IceStormElection::Callback_Node_nodesPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1491
IceStormElection::Callback_ReplicaObserver_removeSubscriberPtr
::IceUtil::Handle< Callback_ReplicaObserver_removeSubscriber_Base > Callback_ReplicaObserver_removeSubscriberPtr
Definition: Election.h:955
IceStormElection::Node::_iceD_sync
bool _iceD_sync(::IceInternal::Incoming &, const ::Ice::Current &) const
Definition: Election.cpp:2066
IceProxy::IceStormElection::Node::query
::IceStormElection::QueryInfo query(const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1509
IceStormElection::Callback_ReplicaObserver_init::Callback_ReplicaObserver_init
Callback_ReplicaObserver_init(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:1942
IceProxy::IceStormElection::ReplicaObserver::begin_init
::Ice::AsyncResultPtr begin_init(const ::IceStormElection::LogUpdate &iceP_llu, const ::IceStormElection::TopicContentSeq &iceP_content, const ::Ice::Context &context, const ::IceStormElection::Callback_ReplicaObserver_initPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1018
IceStormElection::NodeInfo::n
::IceStormElection::NodePrx n
Definition: Election.h:854
IceStormElection::ObserverInconsistencyException::_readImpl
virtual void _readImpl(::Ice::InputStream *)
Definition: Election.cpp:913
IceProxy::IceStormElection::TopicManagerSync::begin_getContent
::Ice::AsyncResultPtr begin_getContent(const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1204
IceStormElection::Callback_Node_query::Exception
void(T::* Exception)(const ::Ice::Exception &, const CT &)
Definition: Election.h:3325
IceProxy::IceStormElection::ReplicaObserver::begin_removeSubscriber
::Ice::AsyncResultPtr begin_removeSubscriber(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_topic, const ::Ice::IdentitySeq &iceP_subscribers, const ::Ice::Context &context, const ::IceStormElection::Callback_ReplicaObserver_removeSubscriberPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1170
IceProxy::IceStormElection::ReplicaObserver::removeSubscriber
void removeSubscriber(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_topic, const ::Ice::IdentitySeq &iceP_subscribers, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1145
IceInternal
Definition: InstrumentationI.h:16
IceProxy::IceStormElection::Node::begin_nodes
::Ice::AsyncResultPtr begin_nodes(const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1476
IceStormElection::operator<
bool operator<(const ReplicaObserver &lhs, const ReplicaObserver &rhs)
Definition: Election.h:1604
IceStormElection::Callback_ReplicaObserver_createTopic::Sent
void(T::* Sent)(bool, const CT &)
Definition: Election.h:2065
IceStormElection::NodeStateNormal
@ NodeStateNormal
The replica group is active & replicating.
Definition: Election.ice:148
IceStormElection::Node::_iceWriteImpl
virtual void _iceWriteImpl(::Ice::OutputStream *) const
Definition: Election.cpp:2189
IceStormElection::ReplicaObserver::_iceD_createTopic
bool _iceD_createTopic(::IceInternal::Incoming &, const ::Ice::Current &)
Definition: Election.cpp:1625
IceStormElection::ObserverInconsistencyException::ice_id
virtual ::std::string ice_id() const
Definition: Election.cpp:887
IceStormElection::TopicManagerSync::_iceD_getContent
bool _iceD_getContent(::IceInternal::Incoming &, const ::Ice::Current &)
Definition: Election.cpp:1836
IceStormElection::CallbackNC_Node_areYouCoordinator::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:2866
IceProxy::IceStormElection::ReplicaObserver::begin_removeSubscriber
::Ice::AsyncResultPtr begin_removeSubscriber(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_topic, const ::Ice::IdentitySeq &iceP_subscribers, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1155
IceStormElection::CallbackNC_Node_nodes
Definition: Election.h:3163
IceStormElection::Callback_Node_areYouThere::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:3011
IceStormElection::Node::invitation
void invitation(int j, string gn)
Invite the node into a group with the given coordinator and group name.
IceStormElection::ReplicaObserver::_iceD_init
bool _iceD_init(::IceInternal::Incoming &, const ::Ice::Current &)
Definition: Election.cpp:1610
IceStormElection::CallbackNC_ReplicaObserver_addSubscriber::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2251
IceStormElection::Callback_Node_invitation
Definition: Election.h:2646
IceStormElection::Callback_Node_areYouCoordinator::Sent
void(T::* Sent)(bool, const CT &)
Definition: Election.h:2910
IceProxy::IceStormElection::Node::begin_invitation
::Ice::AsyncResultPtr begin_invitation(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1248
IceStormElection::ObserverInconsistencyException::_writeImpl
virtual void _writeImpl(::Ice::OutputStream *) const
Definition: Election.cpp:905
Ice::StreamWriter< ::IceStormElection::QueryInfo, S >::write
static void write(S *ostr, const ::IceStormElection::QueryInfo &v)
Definition: Election.h:1836
IceProxy::IceStormElection::ReplicaObserver::begin_destroyTopic
::Ice::AsyncResultPtr begin_destroyTopic(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_name, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1074
IceProxy::IceStormElection::Node::begin_invitation
::Ice::AsyncResultPtr begin_invitation(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1253
IceStormElection::Callback_ReplicaObserver_destroyTopic::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2188
IceStormElection::ReplicaObserver::_iceDispatch
virtual bool _iceDispatch(::IceInternal::Incoming &, const ::Ice::Current &)
Definition: Election.cpp:1706
IceStormElection::Callback_TopicManagerSync_getContent::Exception
void(T::* Exception)(const ::Ice::Exception &, const CT &)
Definition: Election.h:2558
IceProxy::IceStormElection::Node::begin_accept
::Ice::AsyncResultPtr begin_accept(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::IntSeq &iceP_forwardedInvites, const ::Ice::ObjectPrx &iceP_observer, const ::IceStormElection::LogUpdate &iceP_llu, ::Ice::Int iceP_max, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1329
IceStormElection::CallbackNC_Node_nodes::CallbackNC_Node_nodes
CallbackNC_Node_nodes(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:3173
IceStormElection::ReplicaObserverPrx
::IceInternal::ProxyHandle< ::IceProxy::IceStormElection::ReplicaObserver > ReplicaObserverPrx
Definition: Election.h:790
IceStormElection::Callback_Node_invitationPtr
::IceUtil::Handle< Callback_Node_invitation_Base > Callback_Node_invitationPtr
Definition: Election.h:961
IceProxy::IceStormElection::Node::begin_areYouCoordinator
::Ice::AsyncResultPtr begin_areYouCoordinator(const ::Ice::Context &context, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1372
IceProxy::IceStormElection::ReplicaObserver::begin_createTopic
::Ice::AsyncResultPtr begin_createTopic(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_name, const ::Ice::Context &context, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1046
IceStormElection::GroupInfo::llu
::IceStormElection::LogUpdate llu
Definition: Election.h:862
IceStormElection::CallbackNC_ReplicaObserver_addSubscriber::Exception
void(T::* Exception)(const ::Ice::Exception &)
Definition: Election.h:2253
IceProxy::IceStormElection::ReplicaObserver::begin_removeSubscriber
::Ice::AsyncResultPtr begin_removeSubscriber(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_topic, const ::Ice::IdentitySeq &iceP_subscribers, const ::Ice::Context &context, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1160
IceStormElection::Node::_iceD_accept
bool _iceD_accept(::IceInternal::Incoming &, const ::Ice::Current &)
Definition: Election.cpp:2014
IceProxy::IceStormElection::Node::begin_areYouThere
::Ice::AsyncResultPtr begin_areYouThere(const ::std::string &iceP_gn, ::Ice::Int iceP_j, const ::Ice::Context &context, const ::IceStormElection::Callback_Node_areYouTherePtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1420
Ice::StreamReader< ::IceStormElection::TopicContent, S >::read
static void read(S *istr, ::IceStormElection::TopicContent &v)
Definition: Election.h:1728
IceStormElection::NodeInfo::id
int id
The identity of the node.
Definition: Election.ice:158
Ice
Definition: DBTypes.cpp:64
armarx::ctrlutil::v
double v(double t, double v0, double a0, double j)
Definition: CtrlUtil.h:35
SubscriberRecord.h
IceStormElection::newCallback_Node_areYouCoordinator
Callback_Node_areYouCoordinatorPtr newCallback_Node_areYouCoordinator(const IceUtil::Handle< T > &instance, void(T::*cb)(bool), void(T::*excb)(const ::Ice::Exception &), void(T::*sentcb)(bool)=0)
Definition: Election.h:2891
IceStormElection::ObserverInconsistencyException::ObserverInconsistencyException
ObserverInconsistencyException()
Definition: Election.h:825
IceProxy::IceStormElection::Node::begin_invitation
::Ice::AsyncResultPtr begin_invitation(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::Context &context, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1258
IceStormElection::Callback_Node_accept::Exception
void(T::* Exception)(const ::Ice::Exception &, const CT &)
Definition: Election.h:2816
IceStormElection::TopicManagerSync::_iceWriteImpl
virtual void _iceWriteImpl(::Ice::OutputStream *) const
Definition: Election.cpp:1903
IceStormElection::TopicManagerSync::ice_ids
virtual ::std::vector< ::std::string > ice_ids(const ::Ice::Current &=::Ice::emptyCurrent) const
Definition: Election.cpp:1813
IceStormElection::CallbackNC_Node_areYouThere::CallbackNC_Node_areYouThere
CallbackNC_Node_areYouThere(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2965
IceStormElection::Callback_Node_areYouThere
Definition: Election.h:3007
IceProxy::IceStormElection::Node::begin_accept
::Ice::AsyncResultPtr begin_accept(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::IntSeq &iceP_forwardedInvites, const ::Ice::ObjectPrx &iceP_observer, const ::IceStormElection::LogUpdate &iceP_llu, ::Ice::Int iceP_max, const ::Ice::Context &context, const ::IceStormElection::Callback_Node_acceptPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1344
IceStormElection::Callback_Node_nodes::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:3230
Response
Definition: Response.h:34
std
Definition: Application.h:66
IceStormElection::QueryInfo::state
NodeState state
The node state.
Definition: Election.ice:192
IceStormElection::Node::ice_staticId
static const ::std::string & ice_staticId()
Definition: Election.cpp:1967
IceStormElection::Callback_ReplicaObserver_createTopic::Exception
void(T::* Exception)(const ::Ice::Exception &, const CT &)
Definition: Election.h:2064
IceStormElection::CallbackNC_Node_accept
Definition: Election.h:2769
IceStormElection::Callback_Node_areYouTherePtr
::IceUtil::Handle< Callback_Node_areYouThere_Base > Callback_Node_areYouTherePtr
Definition: Election.h:973
IceStormElection::CallbackNC_ReplicaObserver_createTopic::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:2010
IceStormElection::ReplicaObserver::_iceD_removeSubscriber
bool _iceD_removeSubscriber(::IceInternal::Incoming &, const ::Ice::Current &)
Definition: Election.cpp:1672
IceUtil::Handle
Definition: forward_declarations.h:29
IceStormElection::QueryInfo::coord
::Ice::Int coord
Definition: Election.h:929
IceStormElection::CallbackNC_Node_areYouCoordinator::Sent
void(T::* Sent)(bool)
Definition: Election.h:2858
IceStormElection::Callback_ReplicaObserver_destroyTopic::Callback_ReplicaObserver_destroyTopic
Callback_ReplicaObserver_destroyTopic(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2194
IceStormElection::newCallback_ReplicaObserver_removeSubscriber
Callback_ReplicaObserver_removeSubscriberPtr newCallback_ReplicaObserver_removeSubscriber(const IceUtil::Handle< T > &instance, void(T::*cb)(), void(T::*excb)(const ::Ice::Exception &), void(T::*sentcb)(bool)=0)
Definition: Election.h:2412
IceStormElection::CallbackNC_Node_nodes::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:3178
IceStormElection::CallbackNC_Node_sync
Definition: Election.h:3059
IceStormElection::Callback_ReplicaObserver_addSubscriber::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:2325
IceStormElection::NodeInfoSeq
::std::vector< ::IceStormElection::NodeInfo > NodeInfoSeq
A sequence of node info.
Definition: Election.h:857
IceStormElection::CallbackNC_ReplicaObserver_removeSubscriber
Definition: Election.h:2373
IceStormElection::TopicContent::id
::Ice::Identity id
Definition: Election.h:815
IceStormElection::Callback_Node_nodes::Exception
void(T::* Exception)(const ::Ice::Exception &, const CT &)
Definition: Election.h:3221
IceStormElection::CallbackNC_Node_areYouCoordinator::CallbackNC_Node_areYouCoordinator
CallbackNC_Node_areYouCoordinator(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2861
IceStormElection::Node::query
idempotent QueryInfo query()
Get the query information for the given node.
IceStormElection::CallbackNC_Node_areYouCoordinator
Definition: Election.h:2851
armarx::VariantType::Int
const VariantTypeId Int
Definition: Variant.h:916
IceStormElection::Node::_iceD_invitation
bool _iceD_invitation(::IceInternal::Incoming &, const ::Ice::Current &)
Definition: Election.cpp:1978
IceStormElection::Callback_ReplicaObserver_createTopic_Base
Definition: Election.h:945
IceStormElection::QueryInfo::group
::std::string group
Definition: Election.h:930
Ice::StreamWriter< ::IceStormElection::NodeInfo, S >::write
static void write(S *ostr, const ::IceStormElection::NodeInfo &v)
Definition: Election.h:1780
IceStormElection::GroupInfo::id
int id
The identity of the node.
Definition: Election.ice:170
IceStormElection::CallbackNC_ReplicaObserver_createTopic::CallbackNC_ReplicaObserver_createTopic
CallbackNC_ReplicaObserver_createTopic(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2005
IceProxy::IceStormElection::TopicManagerSync::begin_getContent
::Ice::AsyncResultPtr begin_getContent(const ::Ice::Context &context, const ::IceStormElection::Callback_TopicManagerSync_getContentPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1219
IceStormElection::newCallback_Node_accept
Callback_Node_acceptPtr newCallback_Node_accept(const IceUtil::Handle< T > &instance, void(T::*cb)(), void(T::*excb)(const ::Ice::Exception &), void(T::*sentcb)(bool)=0)
Definition: Election.h:2786
IceProxy::IceStormElection::Node::areYouCoordinator
bool areYouCoordinator(const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1357
IceProxy::IceStormElection::ReplicaObserver::addSubscriber
void addSubscriber(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_topic, const ::IceStorm::SubscriberRecord &iceP_record, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1107
IceProxy::IceStormElection::Node::accept
void accept(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::IntSeq &iceP_forwardedInvites, const ::Ice::ObjectPrx &iceP_observer, const ::IceStormElection::LogUpdate &iceP_llu, ::Ice::Int iceP_max, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1319
IceProxy::IceStormElection::ReplicaObserver::begin_destroyTopic
::Ice::AsyncResultPtr begin_destroyTopic(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_name, const ::Ice::Context &context, const ::IceStormElection::Callback_ReplicaObserver_destroyTopicPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1094
IceStormElection::GroupInfo::operator<
bool operator<(const GroupInfo &rhs_) const
Definition: Election.h:881
IceStormElection::CallbackNC_Node_invitation::Sent
void(T::* Sent)(bool)
Definition: Election.h:2612
IceStormElection::GroupInfo::id
::Ice::Int id
Definition: Election.h:861
IceProxy::IceStormElection::Node::begin_query
::Ice::AsyncResultPtr begin_query(const ::Ice::Context &context, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1524
IceStormElection::Callback_ReplicaObserver_removeSubscriber
Definition: Election.h:2436
IceStormElection::Callback_Node_query::Callback_Node_query
Callback_Node_query(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:3329
IceStormElection::newCallback_ReplicaObserver_createTopic
Callback_ReplicaObserver_createTopicPtr newCallback_ReplicaObserver_createTopic(const IceUtil::Handle< T > &instance, void(T::*cb)(), void(T::*excb)(const ::Ice::Exception &), void(T::*sentcb)(bool)=0)
Definition: Election.h:2034
IceStormElection::Callback_Node_ready::Exception
void(T::* Exception)(const ::Ice::Exception &, const CT &)
Definition: Election.h:2734
IceStormElection::QueryInfo::up
::IceStormElection::GroupInfoSeq up
Definition: Election.h:933
IceProxy::IceStormElection::Node::begin_accept
::Ice::AsyncResultPtr begin_accept(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::IntSeq &iceP_forwardedInvites, const ::Ice::ObjectPrx &iceP_observer, const ::IceStormElection::LogUpdate &iceP_llu, ::Ice::Int iceP_max, const ::Ice::Context &context, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1334
IceStormElection::ReplicaObserver::ice_staticId
static const ::std::string & ice_staticId()
Definition: Election.cpp:1599
IceProxy::IceStormElection::ReplicaObserver::begin_destroyTopic
::Ice::AsyncResultPtr begin_destroyTopic(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_name, const ::Ice::Context &context, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1084
IceStormElection::ReplicaObserver::_iceReadImpl
virtual void _iceReadImpl(::Ice::InputStream *)
Definition: Election.cpp:1769
IceProxy::IceStormElection::Node::begin_invitation
::Ice::AsyncResultPtr begin_invitation(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::IceStormElection::Callback_Node_invitationPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1263
IceStormElection::Callback_TopicManagerSync_getContent::Callback_TopicManagerSync_getContent
Callback_TopicManagerSync_getContent(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2562
IceStormElection::CallbackNC_Node_query::CallbackNC_Node_query
CallbackNC_Node_query(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:3277
IceStormElection::CallbackNC_Node_ready::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2691
IceProxy::IceStormElection::ReplicaObserver::begin_init
::Ice::AsyncResultPtr begin_init(const ::IceStormElection::LogUpdate &iceP_llu, const ::IceStormElection::TopicContentSeq &iceP_content, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:998
IceProxy::IceStormElection::ReplicaObserver::begin_createTopic
::Ice::AsyncResultPtr begin_createTopic(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_name, const ::IceStormElection::Callback_ReplicaObserver_createTopicPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1051
IceStormElection::Callback_ReplicaObserver_createTopic::Callback_ReplicaObserver_createTopic
Callback_ReplicaObserver_createTopic(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2068
IceStormElection::CallbackNC_TopicManagerSync_getContent::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2503
armarx::aron::type::ObjectPtr
std::shared_ptr< Object > ObjectPtr
Definition: Object.h:37
IceStormElection::Callback_Node_sync::Sent
void(T::* Sent)(bool, const CT &)
Definition: Election.h:3118
IceProxy::IceStormElection::Node::begin_areYouCoordinator
::Ice::AsyncResultPtr begin_areYouCoordinator(const ::Ice::Context &context, const ::IceStormElection::Callback_Node_areYouCoordinatorPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1382
IceStormElection::TopicContent::records
::IceStorm::SubscriberRecordSeq records
Definition: Election.h:816
T
float T
Definition: UnscentedKalmanFilterTest.cpp:35
IceStormElection::Callback_Node_query_Base
Definition: Election.h:981
IceStormElection::CallbackNC_Node_query::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:3282
IceStormElection::QueryInfo::replica
Object * replica
The replica the node is managing.
Definition: Election.ice:189
IceStormElection::QueryInfo::state
::IceStormElection::NodeState state
Definition: Election.h:932
IceStormElection::Callback_ReplicaObserver_createTopic::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:2073
IceProxy::IceStormElection::Node::begin_areYouThere
::Ice::AsyncResultPtr begin_areYouThere(const ::std::string &iceP_gn, ::Ice::Int iceP_j, const ::IceStormElection::Callback_Node_areYouTherePtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1415
IceStormElection::Callback_Node_sync
Definition: Election.h:3111
IceStormElection::newCallback_Node_sync
Callback_Node_syncPtr newCallback_Node_sync(const IceUtil::Handle< T > &instance, void(T::*cb)(const ::Ice::ObjectPrx &), void(T::*excb)(const ::Ice::Exception &), void(T::*sentcb)(bool)=0)
Definition: Election.h:3099
IceProxy::IceStormElection::Node
Definition: Election.h:1239
IceStormElection::CallbackNC_Node_ready::CallbackNC_Node_ready
CallbackNC_Node_ready(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2697
IceStormElection::TopicManagerSync::ice_isA
virtual bool ice_isA(const ::std::string &, const ::Ice::Current &=::Ice::emptyCurrent) const
Definition: Election.cpp:1807
Ice::StreamWriter< ::IceStormElection::GroupInfo, S >::write
static void write(S *ostr, const ::IceStormElection::GroupInfo &v)
Definition: Election.h:1808
IceProxy::IceStormElection::Node::begin_sync
::Ice::AsyncResultPtr begin_sync(const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1438
IceStormElection::CallbackNC_ReplicaObserver_removeSubscriber::Sent
void(T::* Sent)(bool)
Definition: Election.h:2380
IceProxy::IceStormElection::Node::ready
void ready(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::ObjectPrx &iceP_coordinator, ::Ice::Int iceP_max, ::Ice::Long iceP_generation, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1281
IceStormElection::Callback_Node_accept::Sent
void(T::* Sent)(bool, const CT &)
Definition: Election.h:2817
IceStormElection::ReplicaObserver::destroyTopic
void destroyTopic(LogUpdate llu, string name)
Destroy the topic with the given name.
IceStormElection::Node::_iceD_nodes
bool _iceD_nodes(::IceInternal::Incoming &, const ::Ice::Current &) const
Definition: Election.cpp:2078
IceProxy::IceStormElection::Node::begin_areYouThere
::Ice::AsyncResultPtr begin_areYouThere(const ::std::string &iceP_gn, ::Ice::Int iceP_j, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1405
IceStormElection::TopicManagerSyncPrx
::IceInternal::ProxyHandle< ::IceProxy::IceStormElection::TopicManagerSync > TopicManagerSyncPrx
Definition: Election.h:797
IceStormElection::Callback_Node_query::Sent
void(T::* Sent)(bool, const CT &)
Definition: Election.h:3326
IceStormElection::Callback_Node_invitation::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2650
IceStormElection::Callback_ReplicaObserver_addSubscriber_Base
Definition: Election.h:951
IceStormElection::Callback_Node_nodesPtr
::IceUtil::Handle< Callback_Node_nodes_Base > Callback_Node_nodesPtr
Definition: Election.h:979
IceStormElection::Callback_Node_areYouThere::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:3022
IceStormElection::CallbackNC_ReplicaObserver_init::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:1884
IceStormElection::QueryInfo::max
::Ice::Int max
Definition: Election.h:934
IceStormElection::ReplicaObserver::ice_ids
virtual ::std::vector< ::std::string > ice_ids(const ::Ice::Current &=::Ice::emptyCurrent) const
Definition: Election.cpp:1587
IceProxy::IceStormElection::Node::begin_query
::Ice::AsyncResultPtr begin_query(const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1514
IceProxy::IceStormElection::Node::begin_ready
::Ice::AsyncResultPtr begin_ready(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::ObjectPrx &iceP_coordinator, ::Ice::Int iceP_max, ::Ice::Long iceP_generation, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1286
LLURecord.h
IceStormElection::TopicContent::records
IceStorm::SubscriberRecordSeq records
The topic subscribers.
Definition: Election.ice:28
IceStormElection::CallbackNC_ReplicaObserver_destroyTopic::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:2136
IceProxy::IceStormElection::Node::invitation
void invitation(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1243
IceStormElection::Callback_Node_areYouCoordinator_Base
Definition: Election.h:969
IceProxy::IceStormElection::Node::begin_ready
::Ice::AsyncResultPtr begin_ready(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::ObjectPrx &iceP_coordinator, ::Ice::Int iceP_max, ::Ice::Long iceP_generation, const ::Ice::Context &context, const ::IceStormElection::Callback_Node_readyPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1306
IceStormElection::Node::PointerType
NodePtr PointerType
Definition: Election.h:1650
IceStormElection::ObserverInconsistencyException::~ObserverInconsistencyException
virtual ~ObserverInconsistencyException()
Definition: Election.cpp:882
IceStormElection::newCallback_ReplicaObserver_addSubscriber
Callback_ReplicaObserver_addSubscriberPtr newCallback_ReplicaObserver_addSubscriber(const IceUtil::Handle< T > &instance, void(T::*cb)(), void(T::*excb)(const ::Ice::Exception &), void(T::*sentcb)(bool)=0)
Definition: Election.h:2286
IceStormElection::Callback_TopicManagerSync_getContent
Definition: Election.h:2552
IceProxy::IceStormElection::TopicManagerSync::begin_getContent
::Ice::AsyncResultPtr begin_getContent(const ::Ice::Context &context, const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1209
IceStormElection::Callback_TopicManagerSync_getContent::Sent
void(T::* Sent)(bool, const CT &)
Definition: Election.h:2559
IceStormElection::Callback_ReplicaObserver_createTopic::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2062
IceProxy::IceStormElection::Node::begin_accept
::Ice::AsyncResultPtr begin_accept(::Ice::Int iceP_j, const ::std::string &iceP_gn, const ::Ice::IntSeq &iceP_forwardedInvites, const ::Ice::ObjectPrx &iceP_observer, const ::IceStormElection::LogUpdate &iceP_llu, ::Ice::Int iceP_max, const ::IceStormElection::Callback_Node_acceptPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1339
IceStormElection::Callback_ReplicaObserver_addSubscriber::Sent
void(T::* Sent)(bool, const CT &)
Definition: Election.h:2317
IceStormElection::ObserverInconsistencyException::ice_clone
virtual ObserverInconsistencyException * ice_clone() const
Definition: Election.cpp:893
IceProxy::IceStormElection::ReplicaObserver::begin_removeSubscriber
::Ice::AsyncResultPtr begin_removeSubscriber(const ::IceStormElection::LogUpdate &iceP_llu, const ::std::string &iceP_topic, const ::Ice::IdentitySeq &iceP_subscribers, const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1150
IceStormElection::Callback_Node_ready_Base
Definition: Election.h:963
IceProxy::IceStormElection::Node::sync
::Ice::ObjectPrx sync(const ::Ice::Context &context=::Ice::noExplicitContext)
Definition: Election.h:1433
IceStormElection::Callback_ReplicaObserver_destroyTopic
Definition: Election.h:2184
IceProxy::IceStormElection::Node::begin_sync
::Ice::AsyncResultPtr begin_sync(const ::Ice::CallbackPtr &del, const ::Ice::LocalObjectPtr &cookie=0)
Definition: Election.h:1443
IceStormElection::GroupInfo::operator!=
bool operator!=(const GroupInfo &rhs_) const
Definition: Election.h:906
IceStormElection::Callback_Node_areYouThere::Callback_Node_areYouThere
Callback_Node_areYouThere(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:3017
IceStormElection::Callback_Node_areYouCoordinator::Callback_Node_areYouCoordinator
Callback_Node_areYouCoordinator(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2913
IceStormElection::CallbackNC_Node_areYouThere::completed
virtual void completed(const ::Ice::AsyncResultPtr &result) const
Definition: Election.h:2970
IceStormElection::ReplicaObserver::createTopic
void createTopic(LogUpdate llu, string name)
Create the topic with the given name.
IceStormElection::CallbackNC_Node_ready::Sent
void(T::* Sent)(bool)
Definition: Election.h:2694
IceStormElection::Callback_ReplicaObserver_init
Definition: Election.h:1932
IceStormElection::ReplicaObserver::~ReplicaObserver
virtual ~ReplicaObserver()
Definition: Election.cpp:1560
IceStormElection::Callback_ReplicaObserver_addSubscriber::Callback_ReplicaObserver_addSubscriber
Callback_ReplicaObserver_addSubscriber(const TPtr &obj, Response cb, Exception excb, Sent sentcb)
Definition: Election.h:2320
Ice::StreamReader< ::IceStormElection::ObserverInconsistencyException, S >::read
static void read(S *istr, ::IceStormElection::ObserverInconsistencyException &v)
Definition: Election.h:1753
IceStormElection::Node::_iceD_ready
bool _iceD_ready(::IceInternal::Incoming &, const ::Ice::Current &)
Definition: Election.cpp:1993
IceStormElection::Callback_ReplicaObserver_addSubscriber::TPtr
IceUtil::Handle< T > TPtr
Definition: Election.h:2314
IceStormElection::CallbackNC_Node_query::Sent
void(T::* Sent)(bool)
Definition: Election.h:3274