1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
// -*- C++ -*-
/*
* @file AsyncListManager.h
*
* @author Phil Mesnier <mesnier_p@ociweb.com>
*/
#ifndef IMR_ASYNCLISTMANAGER_H_
#define IMR_ASYNCLISTMANAGER_H_
#include "locator_export.h"
#include "ImR_LocatorC.h"
#include "ace/Vector_T.h"
#include "ace/SString.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
#pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/Intrusive_Ref_Count_Handle_T.h"
#if defined (ACE_HAS_CPP11)
# include <atomic>
#else
# include "ace/Atomic_Op.h"
#endif /* ACE_HAS_CPP11 */
#include "LiveCheck.h"
class Locator_Repository;
//----------------------------------------------------------------------------
/*
* @class AsyncListManager
*
* @brief manages active detection of multiple servers to satisfy "list -a"
*
* A client of the locator may issue a list command to be filtered to
* currently active servers only. To satisfy that request each server must
* be pinged to determine liveness. The AsyncListManager handles the
* callbacks for all of the ping requests as efficiently as possible.
*/
class AsyncListManager
{
public:
AsyncListManager (const Locator_Repository *repo,
PortableServer::POA_ptr poa,
LiveCheck *pinger);
~AsyncListManager (void);
PortableServer::POA_ptr poa (void);
void list (ImplementationRepository::AMH_AdministrationResponseHandler_ptr _tao_rh,
CORBA::ULong count);
CORBA::ULong list (ImplementationRepository::AMH_ServerInformationIteratorResponseHandler_ptr _tao_rh,
CORBA::ULong start, CORBA::ULong count);
bool evaluate_status (CORBA::ULong index, LiveStatus status, int pid);
void ping_replied (CORBA::ULong index, LiveStatus status, int pid);
AsyncListManager *_add_ref (void);
void _remove_ref (void);
private:
void init_list (void);
void list_i (CORBA::ULong start, CORBA::ULong count);
bool make_iterator (ImplementationRepository::ServerInformationIterator_out si,
CORBA::ULong start);
void final_state (void);
const Locator_Repository *repo_;
PortableServer::POA_var poa_;
ImplementationRepository::AMH_AdministrationResponseHandler_var primary_;
ImplementationRepository::AMH_ServerInformationIteratorResponseHandler_var secondary_;
LiveCheck *pinger_;
ImplementationRepository::ServerInformationList server_list_;
CORBA::ULong first_;
CORBA::ULong how_many_;
CORBA::ULong waiters_;
#if defined (ACE_HAS_CPP11)
std::atomic<int> refcount_;
#else
ACE_Atomic_Op<TAO_SYNCH_MUTEX, int> refcount_;
#endif /* ACE_HAS_CPP11 */
};
typedef TAO_Intrusive_Ref_Count_Handle<AsyncListManager> AsyncListManager_ptr;
//----------------------------------------------------------------------------
class ListLiveListener : public LiveListener
{
public:
ListLiveListener (const char * server,
int pid,
CORBA::ULong index,
AsyncListManager *owner,
LiveCheck &pinger);
virtual ~ListLiveListener (void);
bool start (void);
void cancel (void);
LiveStatus status (void);
bool status_changed (LiveStatus status);
private:
AsyncListManager_ptr owner_;
LiveCheck &pinger_;
LiveStatus status_;
CORBA::ULong index_;
bool started_;
int pid_;
};
#endif /* IMR_ASYNCACCESSMANGER_H_ */
|
