Class EventDispatcher

java.lang.Object

org.apache.felix.framework.util.EventDispatcher

public class EventDispatcher
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	EventDispatcher.Request

Field Summary

Fields

Modifier and Type	Field	Description
private Map<BundleContext, List<ListenerInfo>>	m_bndlListeners
private Map<BundleContext, List<ListenerInfo>>	m_fwkListeners
private final Logger	m_logger
private static int	m_references
private final ServiceRegistry	m_registry
private static final List<EventDispatcher.Request>	m_requestList
private static final List<EventDispatcher.Request>	m_requestPool
private static final SecureAction	m_secureAction
private static boolean	m_stopping
private Map<BundleContext, List<ListenerInfo>>	m_svcListeners
private Map<BundleContext, List<ListenerInfo>>	m_syncBndlListeners
private static Thread	m_thread
private static final String	m_threadLock

Constructor Summary

Constructors

Constructor	Description
EventDispatcher(Logger logger, ServiceRegistry registry)

Method Summary

Modifier and Type	Method	Description
Filter	addListener(BundleContext bc, Class clazz, EventListener l, Filter filter)
private static Map<BundleContext, List<ListenerInfo>>	addListenerInfo(Map<BundleContext, List<ListenerInfo>> listeners, ListenerInfo info)
private <T> Set<BundleContext>	createWhitelistFromHooks(EventObject event, Framework felix, Map<BundleContext, List<ListenerInfo>> listeners1, Map<BundleContext, List<ListenerInfo>> listeners2, Class<T> hookClass)
private Map<BundleContext, List<ListenerInfo>>	filterListenersUsingHooks(ServiceEvent event, Framework felix, Map<BundleContext, List<ListenerInfo>> listeners)
void	fireBundleEvent(BundleEvent event, Framework felix)
private static void	fireEventAsynchronously(EventDispatcher dispatcher, int type, Map<BundleContext, List<ListenerInfo>> listeners, EventObject event)
private static void	fireEventImmediately(EventDispatcher dispatcher, int type, Map<BundleContext, List<ListenerInfo>> listeners, EventObject event, Dictionary oldProps)
void	fireFrameworkEvent(FrameworkEvent event)
void	fireServiceEvent(ServiceEvent event, Dictionary oldProps, Framework felix)
Collection<ListenerHook.ListenerInfo>	getAllServiceListeners()	Returns all existing service listener information into a collection of ListenerHook.ListenerInfo objects.
private static void	invokeBundleListenerCallback(Bundle bundle, EventListener l, EventObject event)
private static void	invokeFrameworkListenerCallback(Bundle bundle, EventListener l, EventObject event)
private static void	invokeServiceListenerCallback(Bundle bundle, EventListener l, Filter filter, Object acc, EventObject event, Dictionary oldProps)
ListenerHook.ListenerInfo	removeListener(BundleContext bc, Class clazz, EventListener l)
private static Map<BundleContext, List<ListenerInfo>>	removeListenerInfo(Map<BundleContext, List<ListenerInfo>> listeners, BundleContext bc, int idx)
private static Map<BundleContext, List<ListenerInfo>>	removeListenerInfos(Map<BundleContext, List<ListenerInfo>> listeners, BundleContext bc)
void	removeListeners(BundleContext bc)
private static void	run()	This is the dispatching thread's main loop.
void	startDispatching()
void	stopDispatching()
Filter	updateListener(BundleContext bc, Class clazz, EventListener l, Filter filter)
private static Map<BundleContext, List<ListenerInfo>>	updateListenerInfo(Map<BundleContext, List<ListenerInfo>> listeners, int idx, ListenerInfo info)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

m_logger

private final Logger m_logger

m_registry

private final ServiceRegistry m_registry

m_fwkListeners

private Map<BundleContext, List<ListenerInfo>> m_fwkListeners

m_bndlListeners

private Map<BundleContext, List<ListenerInfo>> m_bndlListeners

m_syncBndlListeners

private Map<BundleContext, List<ListenerInfo>> m_syncBndlListeners

m_svcListeners

private Map<BundleContext, List<ListenerInfo>> m_svcListeners

m_thread

private static Thread m_thread

m_threadLock

private static final String m_threadLock

m_references

private static int m_references

m_stopping

private static volatile boolean m_stopping

m_requestList

private static final List<EventDispatcher.Request> m_requestList

m_requestPool

private static final List<EventDispatcher.Request> m_requestPool

m_secureAction

private static final SecureAction m_secureAction

Constructor Details

EventDispatcher

public EventDispatcher(Logger logger,
 ServiceRegistry registry)

Method Details

startDispatching

public void startDispatching()

stopDispatching

public void stopDispatching()

addListener

public Filter addListener(BundleContext bc,
 Class clazz,
 EventListener l,
 Filter filter)

removeListener

public ListenerHook.ListenerInfo removeListener(BundleContext bc,
 Class clazz,
 EventListener l)

removeListeners

public void removeListeners(BundleContext bc)

updateListener

public Filter updateListener(BundleContext bc,
 Class clazz,
 EventListener l,
 Filter filter)

getAllServiceListeners

public Collection<ListenerHook.ListenerInfo> getAllServiceListeners()

Returns all existing service listener information into a collection of ListenerHook.ListenerInfo objects. This is used the first time a listener hook is registered to synchronize it with the existing set of listeners.

Returns:

Returns all existing service listener information into a collection of ListenerHook.ListenerInfo objects

fireFrameworkEvent

public void fireFrameworkEvent(FrameworkEvent event)

fireBundleEvent

public void fireBundleEvent(BundleEvent event,
 Framework felix)

fireServiceEvent

public void fireServiceEvent(ServiceEvent event,
 Dictionary oldProps,
 Framework felix)

filterListenersUsingHooks

private Map<BundleContext, List<ListenerInfo>> filterListenersUsingHooks(ServiceEvent event,
 Framework felix,
 Map<BundleContext, List<ListenerInfo>> listeners)

createWhitelistFromHooks

private <T> Set<BundleContext> createWhitelistFromHooks(EventObject event,
 Framework felix,
 Map<BundleContext, List<ListenerInfo>> listeners1,
 Map<BundleContext, List<ListenerInfo>> listeners2,
 Class<T> hookClass)

fireEventAsynchronously

private static void fireEventAsynchronously(EventDispatcher dispatcher,
 int type,
 Map<BundleContext, List<ListenerInfo>> listeners,
 EventObject event)

fireEventImmediately

private static void fireEventImmediately(EventDispatcher dispatcher,
 int type,
 Map<BundleContext, List<ListenerInfo>> listeners,
 EventObject event,
 Dictionary oldProps)

invokeFrameworkListenerCallback

private static void invokeFrameworkListenerCallback(Bundle bundle,
 EventListener l,
 EventObject event)

invokeBundleListenerCallback

private static void invokeBundleListenerCallback(Bundle bundle,
 EventListener l,
 EventObject event)

invokeServiceListenerCallback

private static void invokeServiceListenerCallback(Bundle bundle,
 EventListener l,
 Filter filter,
 Object acc,
 EventObject event,
 Dictionary oldProps)

addListenerInfo

private static Map<BundleContext, List<ListenerInfo>> addListenerInfo(Map<BundleContext, List<ListenerInfo>> listeners,
 ListenerInfo info)

updateListenerInfo

private static Map<BundleContext, List<ListenerInfo>> updateListenerInfo(Map<BundleContext, List<ListenerInfo>> listeners,
 int idx,
 ListenerInfo info)

removeListenerInfo

private static Map<BundleContext, List<ListenerInfo>> removeListenerInfo(Map<BundleContext, List<ListenerInfo>> listeners,
 BundleContext bc,
 int idx)

removeListenerInfos

private static Map<BundleContext, List<ListenerInfo>> removeListenerInfos(Map<BundleContext, List<ListenerInfo>> listeners,
 BundleContext bc)

run

private static void run()

This is the dispatching thread's main loop.