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
117
118
|
/* -*- C++ -*- */
//$Id$
ACE_INLINE int
TAO_Transport_Cache_Manager::bind (TAO_Cache_ExtId &ext_id,
TAO_Cache_IntId &int_id)
{
ACE_MT (ACE_GUARD_RETURN (ACE_Lock,
guard,
*this->cache_lock_,
-1));
return this->bind_i (ext_id,
int_id);
}
ACE_INLINE int
TAO_Transport_Cache_Manager::cache_transport (
TAO_Transport_Descriptor_Interface *prop,
TAO_Transport *transport)
{
// Compose the ExternId & Intid
TAO_Cache_ExtId ext_id (prop);
TAO_Cache_IntId int_id (transport);
return this->bind (ext_id,
int_id);
}
ACE_INLINE int
TAO_Transport_Cache_Manager::purge (void)
{
ACE_MT (ACE_GUARD_RETURN (ACE_Lock, ace_mon, *this->cache_lock_, 0));
DESCRIPTOR_SET sorted_set = 0;
int size = this->fill_set_i (sorted_set);
// Only call close_entries () if sorted_set != 0. It takes control of
// sorted_set and cleans up any allocated memory. If sorted_set == 0,
// then there is nothing to de-allocate.
if (sorted_set != 0)
{
this->close_entries (sorted_set, size);
}
return 0;
}
ACE_INLINE int
TAO_Transport_Cache_Manager::purge_entry (HASH_MAP_ENTRY *&entry)
{
// Double checked locking
if(entry == 0)
return 0;
ACE_MT (ACE_GUARD_RETURN (ACE_Lock, guard, *this->cache_lock_, -1));
return this->purge_entry_i (entry);
}
ACE_INLINE void
TAO_Transport_Cache_Manager::mark_invalid (HASH_MAP_ENTRY *&entry)
{
if(entry == 0)
return;
// Double checked locking
ACE_MT (ACE_GUARD (ACE_Lock, guard, *this->cache_lock_));
this->mark_invalid_i (entry);
}
ACE_INLINE int
TAO_Transport_Cache_Manager::make_idle (HASH_MAP_ENTRY *&entry)
{
if(entry == 0)
return -1;
ACE_MT (ACE_GUARD_RETURN (ACE_Lock, guard, *this->cache_lock_, -1));
return this->make_idle_i (entry);
}
ACE_INLINE int
TAO_Transport_Cache_Manager::close (ACE_Handle_Set &reactor_registered,
TAO_EventHandlerSet &unregistered)
{
// The cache lock pointer should only be zero if
// Transport_Cache_Manager::open() was never called. Note that
// only one thread opens the Transport_Cache_Manager at any given
// time, so it is safe to check for a non-zero lock pointer.
if (this->cache_lock_ == 0)
return -1;
ACE_MT (ACE_GUARD_RETURN (ACE_Lock,
guard,
*this->cache_lock_,
-1));
return this->close_i (reactor_registered, unregistered);
}
ACE_INLINE size_t
TAO_Transport_Cache_Manager::current_size (void) const
{
return this->cache_map_.current_size ();
}
ACE_INLINE size_t
TAO_Transport_Cache_Manager::total_size (void) const
{
return this->cache_map_.total_size ();
}
|
