| | |
| | | extractIntermediateListener(ConfigAddListener configListener) { |
| | | // @Checkstyle:on |
| | | if (configListener instanceof ConfigAddListenerAdaptor) { |
| | | ConfigAddListenerAdaptor<T> adaptor = ((ConfigAddListenerAdaptor<T>) configListener); |
| | | ConfigAddListenerAdaptor<T> adaptor = (ConfigAddListenerAdaptor<T>) configListener; |
| | | return Pair.of(adaptor, adaptor.getServerManagedObjectAddListener()); |
| | | } |
| | | return Pair.empty(); |
| | |
| | | int i = delayWrappers; |
| | | for (; i > 0; i--) { |
| | | wrappedListener = delayListener.getDelayedAddListener(); |
| | | if (wrappedListener != null && wrappedListener instanceof DelayedConfigAddListener) { |
| | | if (wrappedListener instanceof DelayedConfigAddListener) { |
| | | delayListener = (DelayedConfigAddListener) configListener; |
| | | } else { |
| | | break; |
| | |
| | | |
| | | ConfigAddListener delayedListener = delayListener.getDelayedAddListener(); |
| | | |
| | | if (delayedListener != null && delayedListener instanceof ConfigAddListenerAdaptor) { |
| | | if (delayedListener instanceof ConfigAddListenerAdaptor) { |
| | | ConfigAddListenerAdaptor<?> adaptor = (ConfigAddListenerAdaptor<?>) delayedListener; |
| | | ServerManagedObjectAddListener<?> l2 = adaptor.getServerManagedObjectAddListener(); |
| | | if (l2 instanceof ServerManagedObjectAddListenerAdaptor<?>) { |
| | |
| | | int i = delayWrappers; |
| | | for (; i > 0; i--) { |
| | | wrappedListener = delayListener.getDelayedAddListener(); |
| | | if (wrappedListener != null && wrappedListener instanceof DelayedConfigAddListener) { |
| | | if (wrappedListener instanceof DelayedConfigAddListener) { |
| | | delayListener = (DelayedConfigAddListener) l; |
| | | } else { |
| | | break; |
| | |
| | | |
| | | ConfigDeleteListener delayedListener = delayListener.getDelayedDeleteListener(); |
| | | |
| | | if (delayedListener != null && delayedListener instanceof ConfigDeleteListenerAdaptor) { |
| | | if (delayedListener instanceof ConfigDeleteListenerAdaptor) { |
| | | ConfigDeleteListenerAdaptor<?> adaptor = (ConfigDeleteListenerAdaptor<?>) delayedListener; |
| | | ServerManagedObjectDeleteListener<?> l2 = adaptor.getServerManagedObjectDeleteListener(); |
| | | if (l2 instanceof ServerManagedObjectDeleteListenerAdaptor<?>) { |
| | |
| | | int i = delayWrappers; |
| | | for (; i > 0; i--) { |
| | | wrappedListener = delayListener.getDelayedAddListener(); |
| | | if (wrappedListener != null && wrappedListener instanceof DelayedConfigAddListener) { |
| | | if (wrappedListener instanceof DelayedConfigAddListener) { |
| | | delayListener = (DelayedConfigAddListener) configListener; |
| | | } else { |
| | | break; |
| | |
| | | |
| | | ConfigAddListener delayedListener = delayListener.getDelayedAddListener(); |
| | | |
| | | if (delayedListener != null && delayedListener instanceof ConfigAddListenerAdaptor) { |
| | | if (delayedListener instanceof ConfigAddListenerAdaptor) { |
| | | ConfigAddListenerAdaptor<?> adaptor = (ConfigAddListenerAdaptor<?>) delayedListener; |
| | | if (adaptor.getServerManagedObjectAddListener() == listener) { |
| | | configRepository.deregisterAddListener(parentDN, configListener); |
| | |
| | | int i = delayWrappers; |
| | | for (; i > 0; i--) { |
| | | wrappedListener = delayListener.getDelayedAddListener(); |
| | | if (wrappedListener != null && wrappedListener instanceof DelayedConfigAddListener) { |
| | | if (wrappedListener instanceof DelayedConfigAddListener) { |
| | | delayListener = (DelayedConfigAddListener) configListener; |
| | | } else { |
| | | break; |
| | |
| | | |
| | | ConfigDeleteListener delayedListener = delayListener.getDelayedDeleteListener(); |
| | | |
| | | if (delayedListener != null && delayedListener instanceof ConfigDeleteListenerAdaptor) { |
| | | if (delayedListener instanceof ConfigDeleteListenerAdaptor) { |
| | | ConfigDeleteListenerAdaptor<?> adaptor = (ConfigDeleteListenerAdaptor<?>) delayedListener; |
| | | if (adaptor.getServerManagedObjectDeleteListener() == listener) { |
| | | configRepository.deregisterAddListener(parentDN, configListener); |