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
|
// -*- C++ -*-
//
// $Id$
#ifndef IMR_AsyncStartupWaiterI_H_
#define IMR_AsyncStartupWaiterI_H_
#include "locator_export.h"
#include "AsyncStartupWaiterS.h"
#include "ace/Vector_T.h"
#include "ace/Hash_Map_Manager.h"
#include "ace/Bound_Ptr.h"
#include "ace/SString.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
#pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
class ImR_Locator_i;
class Locator_Export AsyncStartupWaiter_i : public virtual POA_ImplementationRepository::AMH_AsyncStartupWaiter
{
struct PendingData {
PendingData();
PendingData(const char* partial_ior, const char* ior);
ACE_CString partial_ior;
ACE_CString ior;
};
typedef ACE_Vector<PendingData> PendingList;
typedef ACE_Strong_Bound_Ptr<PendingList, ACE_Null_Mutex> PendingListPtr;
typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
PendingListPtr,
ACE_Hash<ACE_CString>,
ACE_Equal_To<ACE_CString>,
ACE_Null_Mutex> PendingMap;
typedef ACE_Vector<ImplementationRepository::AMH_AsyncStartupWaiterResponseHandler_var> RHList;
typedef ACE_Strong_Bound_Ptr<RHList, ACE_Null_Mutex> RHListPtr;
typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
RHListPtr,
ACE_Hash<ACE_CString>,
ACE_Equal_To<ACE_CString>,
ACE_Null_Mutex> WaitingMap;
public:
void wait_for_startup (
ImplementationRepository::AMH_AsyncStartupWaiterResponseHandler_ptr rh,
const char* name ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
void unblock_one(const char* name, const char* partial_ior, const char* ior, bool queue);
void unblock_all(const char* name);
void debug(bool dbg);
private:
ImplementationRepository::AMH_AsyncStartupWaiterResponseHandler_ptr
get_one_waiter(const char* name);
void get_all_waiters(const char* name, RHList& ret);
void send_response(ImplementationRepository::AMH_AsyncStartupWaiterResponseHandler& rh,
const char* name, const char* partial_ior, const char* ior);
private:
WaitingMap waiting_;
PendingMap pending_;
bool debug_;
};
#endif /* AsyncStartupWaiterI_H_ */
|
