21 #include <com/sun/star/accessibility/XAccessibleEventListener.hpp>
35 typedef std::pair< AccessibleEventNotifier::TClientId,
36 AccessibleEventObject > ClientEvent;
38 typedef ::comphelper::OInterfaceContainerHelper4<XAccessibleEventListener> ListenerContainer;
39 typedef std::map< AccessibleEventNotifier::TClientId, ListenerContainer* > ClientMap;
42 typedef std::map<AccessibleEventNotifier::TClientId,
43 AccessibleEventNotifier::TClientId> IntervalMap;
53 IntervalMap& GetFreeIntervals()
55 static IntervalMap
MAP =
59 map.insert(std::make_pair(
60 std::numeric_limits<AccessibleEventNotifier::TClientId>::max(), 1));
66 void releaseId(AccessibleEventNotifier::TClientId
const nId)
68 IntervalMap & rFreeIntervals(GetFreeIntervals());
69 IntervalMap::iterator
const upper(rFreeIntervals.upper_bound(nId));
70 assert(upper != rFreeIntervals.end());
71 assert(nId < upper->second);
72 if (nId + 1 == upper->second)
78 IntervalMap::iterator
const lower(rFreeIntervals.lower_bound(nId));
79 if (lower != rFreeIntervals.end() && lower->first == nId - 1)
82 rFreeIntervals.insert(std::make_pair(nId, lower->second));
83 rFreeIntervals.erase(lower);
87 rFreeIntervals.insert(std::make_pair(nId, nId));
95 AccessibleEventNotifier::TClientId generateId()
97 IntervalMap & rFreeIntervals(GetFreeIntervals());
98 assert(!rFreeIntervals.empty());
99 IntervalMap::iterator
const iter(rFreeIntervals.begin());
100 AccessibleEventNotifier::TClientId
const nFirst = iter->first;
101 AccessibleEventNotifier::TClientId
const nFreeId = iter->second;
102 assert(nFreeId <= nFirst);
103 if (nFreeId != nFirst)
109 rFreeIntervals.erase(iter);
112 assert(gaClients.end() == gaClients.find(nFreeId));
132 bool implLookupClient(
133 const AccessibleEventNotifier::TClientId nClient,
134 ClientMap::iterator& rPos )
137 ClientMap &rClients = gaClients;
138 rPos = rClients.find( nClient );
139 assert( rClients.end() != rPos &&
140 "AccessibleEventNotifier::implLookupClient: invalid client id "
141 "(did you register your client?)!" );
143 return ( rClients.end() != rPos );
152 std::scoped_lock aGuard( GetLocalMutex() );
158 ListenerContainer * pNewListeners =
new ListenerContainer();
160 gaClients.emplace( nNewClientId, pNewListeners );
168 std::scoped_lock aGuard( GetLocalMutex() );
170 ClientMap::iterator aClientPos;
171 if ( !implLookupClient( _nClient, aClientPos ) )
176 delete aClientPos->second;
177 gaClients.erase( aClientPos );
182 const TClientId _nClient,
const Reference< XInterface >& _rxEventSource )
184 std::unique_lock aGuard( GetLocalMutex() );
186 ClientMap::iterator aClientPos;
187 if (!implLookupClient(_nClient, aClientPos))
192 std::unique_ptr<ListenerContainer> pListeners(aClientPos->second);
198 gaClients.erase(aClientPos);
202 EventObject aDisposalEvent;
203 aDisposalEvent.Source = _rxEventSource;
206 pListeners->disposeAndClear( aGuard, aDisposalEvent );
210 const TClientId _nClient,
const Reference< XAccessibleEventListener >& _rxListener )
212 std::unique_lock aGuard( GetLocalMutex() );
214 ClientMap::iterator aClientPos;
215 if ( !implLookupClient( _nClient, aClientPos ) )
219 if ( _rxListener.is() )
220 aClientPos->second->addInterface( aGuard, _rxListener );
222 return aClientPos->second->getLength(aGuard);
226 const TClientId _nClient,
const Reference< XAccessibleEventListener >& _rxListener )
228 std::unique_lock aGuard( GetLocalMutex() );
230 ClientMap::iterator aClientPos;
231 if ( !implLookupClient( _nClient, aClientPos ) )
235 if ( _rxListener.is() )
236 aClientPos->second->removeInterface( aGuard, _rxListener );
238 return aClientPos->second->getLength(aGuard);
243 std::vector< Reference< XAccessibleEventListener > >
aListeners;
246 std::unique_lock aGuard( GetLocalMutex() );
248 ClientMap::iterator aClientPos;
249 if ( !implLookupClient( _nClient, aClientPos ) )
254 aListeners = aClientPos->second->getElements(aGuard);
258 for (
const auto& rListener : aListeners )
262 rListener->notifyEvent( _rEvent );
#define MAP(name, prefix, token, type, context)
static sal_Int32 removeEventListener(const TClientId _nClient, const css::uno::Reference< css::accessibility::XAccessibleEventListener > &_rxListener)
revokes a listener for the given client
static void revokeClientNotifyDisposing(const TClientId _nClient, const css::uno::Reference< css::uno::XInterface > &_rxEventSource)
revokes a client, with additionally notifying a disposing event to all listeners registered for this ...
static void revokeClient(const TClientId _nClient)
revokes a broadcaster of AccessibleEvents
std::map< OUString, rtl::Reference< Entity > > map
static void addEvent(const TClientId _nClient, const css::accessibility::AccessibleEventObject &_rEvent)
adds an event, which is to be broadcasted, to the queue
static TClientId registerClient()
registers a client of this class, means a broadcaster of AccessibleEvents
static sal_Int32 addEventListener(const TClientId _nClient, const css::uno::Reference< css::accessibility::XAccessibleEventListener > &_rxListener)
registers a listener for the given client