/*
* Created on 12 Feb 2007
* Created by Allan Crooks
* Copyright (C) 2007 Aelitis, All Rights Reserved.
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* AELITIS, SAS au capital de 46,603.30 euros
* 8 Allee Lenotre, La Grille Royale, 78600 Le Mesnil le Roi, France.
*/
package org.gudy.azureus2.pluginsimpl.local.download;
import java.util.*;
import org.gudy.azureus2.core3.util.*;
import org.gudy.azureus2.plugins.download.Download;
import org.gudy.azureus2.plugins.download.DownloadActivationEvent;
import org.gudy.azureus2.plugins.download.DownloadActivationListener;
import org.gudy.azureus2.plugins.download.DownloadAnnounceResult;
import org.gudy.azureus2.plugins.download.DownloadEventNotifier;
import org.gudy.azureus2.plugins.download.DownloadListener;
import org.gudy.azureus2.plugins.download.DownloadManager;
import org.gudy.azureus2.plugins.download.DownloadManagerListener;
import org.gudy.azureus2.plugins.download.DownloadPeerListener;
import org.gudy.azureus2.plugins.download.DownloadPropertyEvent;
import org.gudy.azureus2.plugins.download.DownloadPropertyListener;
import org.gudy.azureus2.plugins.download.DownloadRemovalVetoException;
import org.gudy.azureus2.plugins.download.DownloadScrapeResult;
import org.gudy.azureus2.plugins.download.DownloadTrackerListener;
import org.gudy.azureus2.plugins.download.DownloadWillBeRemovedListener;
import org.gudy.azureus2.plugins.peers.PeerManager;
/**
* This is an implementation of DownloadEventNotifier to be simplify life for
* plugins if they want to register event listeners across all downloads managed
* by Azureus.
*/
public class DownloadEventNotifierImpl implements DownloadEventNotifier {
private DownloadActivationNotifier download_activation_notifier;
private DownloadNotifier download_notifier;
private DownloadPeerNotifier download_peer_notifier;
private DownloadPropertyNotifier download_property_notifier;
private DownloadTrackerNotifier download_tracker_notifier;
private DownloadTrackerNotifier download_tracker_notifier_instant;
private DownloadWillBeRemovedNotifier download_will_be_removed_notifier;
private DownloadManager dm;
public DownloadEventNotifierImpl(DownloadManager dm) {
this.dm = dm;
this.download_activation_notifier = new DownloadActivationNotifier();
this.download_notifier = new DownloadNotifier();
this.download_peer_notifier = new DownloadPeerNotifier();
this.download_property_notifier = new DownloadPropertyNotifier();
this.download_tracker_notifier = new DownloadTrackerNotifier(false);
this.download_tracker_notifier_instant = new DownloadTrackerNotifier(true);
this.download_will_be_removed_notifier = new DownloadWillBeRemovedNotifier();
}
public void addActivationListener(DownloadActivationListener l) {
this.download_activation_notifier.addListener(l);
}
public void addDownloadWillBeRemovedListener(DownloadWillBeRemovedListener l) {
this.download_will_be_removed_notifier.addListener(l);
}
public void addListener(DownloadListener l) {
this.download_notifier.addListener(l);
}
public void addPeerListener(DownloadPeerListener l) {
this.download_peer_notifier.addListener(l);
}
public void addPropertyListener(DownloadPropertyListener l) {
this.download_property_notifier.addListener(l);
}
public void addTrackerListener(DownloadTrackerListener l) {
this.download_tracker_notifier.addListener(l);
}
public void addTrackerListener(DownloadTrackerListener l, boolean immediateTrigger) {
(immediateTrigger ? this.download_tracker_notifier_instant : this.download_tracker_notifier).addListener(l);
}
public void removeActivationListener(DownloadActivationListener l) {
this.download_activation_notifier.removeListener(l);
}
public void removeDownloadWillBeRemovedListener(DownloadWillBeRemovedListener l) {
this.download_will_be_removed_notifier.removeListener(l);
}
public void removeListener(DownloadListener l) {
this.download_notifier.removeListener(l);
}
public void removePeerListener(DownloadPeerListener l) {
this.download_peer_notifier.removeListener(l);
}
public void removePropertyListener(DownloadPropertyListener l) {
this.download_property_notifier.removeListener(l);
}
public void removeTrackerListener(DownloadTrackerListener l) {
// We don't know which notifier we added it to, so remove it from both.
this.download_tracker_notifier.removeListener(l);
this.download_tracker_notifier_instant.removeListener(l);
}
private abstract class BaseDownloadListener implements DownloadManagerListener {
protected ArrayList listeners = new ArrayList();
private AEMonitor this_mon;
private BaseDownloadListener() {
this_mon = new AEMonitor(getClass().getName());
}
void addListener(Object o) {
boolean register_with_downloads = false;
try {
this_mon.enter();
register_with_downloads = listeners.isEmpty();
ArrayList new_listeners = new ArrayList(listeners);
new_listeners.add(o);
this.listeners = new_listeners;
}
finally {
this_mon.exit();
}
if (register_with_downloads) {
dm.addListener(this, true);
}
}
void removeListener(Object o) {
boolean unregister_from_downloads = false;
try {
this_mon.enter();
ArrayList new_listeners = new ArrayList(listeners);
new_listeners.remove(o);
this.listeners = new_listeners;
unregister_from_downloads = this.listeners.isEmpty();
}
finally {
this_mon.exit();
}
if (unregister_from_downloads) {
dm.removeListener(this, true);
}
}
}
public class DownloadActivationNotifier extends BaseDownloadListener implements DownloadActivationListener {
public void downloadAdded(Download download) {download.addActivationListener(this);}
public void downloadRemoved(Download download) {download.removeActivationListener(this);}
public boolean activationRequested(DownloadActivationEvent event) {
Iterator itr = this.listeners.iterator();
while (itr.hasNext()) {
try {if (((DownloadActivationListener)itr.next()).activationRequested(event)) {return true;}}
catch (Throwable t) {Debug.printStackTrace(t);}
}
return false;
}
}
public class DownloadNotifier extends BaseDownloadListener implements DownloadListener {
public void downloadAdded(Download download) {download.addListener(this);}
public void downloadRemoved(Download download) {download.removeListener(this);}
public void stateChanged(Download download, int old_state, int new_state) {
Iterator itr = this.listeners.iterator();
while (itr.hasNext()) {
try {((DownloadListener)itr.next()).stateChanged(download, old_state, new_state);}
catch (Throwable t) {Debug.printStackTrace(t);}
}
}
public void positionChanged(Download download, int old_position, int new_position) {
Iterator itr = this.listeners.iterator();
while (itr.hasNext()) {
try {((DownloadListener)itr.next()).positionChanged(download, old_position, new_position);}
catch (Throwable t) {Debug.printStackTrace(t);}
}
}
}
public class DownloadPeerNotifier extends BaseDownloadListener implements DownloadPeerListener {
public void downloadAdded(Download download) {download.addPeerListener(this);}
public void downloadRemoved(Download download) {download.removePeerListener(this);}
public void peerManagerAdded(Download download, PeerManager peer_manager) {
Iterator itr = this.listeners.iterator();
while (itr.hasNext()) {
try {((DownloadPeerListener)itr.next()).peerManagerAdded(download, peer_manager);}
catch (Throwable t) {Debug.printStackTrace(t);}
}
}
public void peerManagerRemoved(Download download, PeerManager peer_manager) {
Iterator itr = this.listeners.iterator();
while (itr.hasNext()) {
try {((DownloadPeerListener)itr.next()).peerManagerRemoved(download, peer_manager);}
catch (Throwable t) {Debug.printStackTrace(t);}
}
}
}
public class DownloadPropertyNotifier extends BaseDownloadListener implements DownloadPropertyListener {
public void downloadAdded(Download download) {download.addPropertyListener(this);}
public void downloadRemoved(Download download) {download.removePropertyListener(this);}
public void propertyChanged(Download download, DownloadPropertyEvent event) {
Iterator itr = this.listeners.iterator();
while (itr.hasNext()) {
try {((DownloadPropertyListener)itr.next()).propertyChanged(download, event);}
catch (Throwable t) {Debug.printStackTrace(t);}
}
}
}
public class DownloadWillBeRemovedNotifier extends BaseDownloadListener implements DownloadWillBeRemovedListener {
public void downloadAdded(Download download) {download.addDownloadWillBeRemovedListener(this);}
public void downloadRemoved(Download download) {download.removeDownloadWillBeRemovedListener(this);}
public void downloadWillBeRemoved(Download download) throws DownloadRemovalVetoException {
Iterator itr = this.listeners.iterator();
while (itr.hasNext()) {
try {((DownloadWillBeRemovedListener)itr.next()).downloadWillBeRemoved(download);}
catch (DownloadRemovalVetoException e) {throw e;}
catch (Throwable t) {Debug.printStackTrace(t);}
}
}
}
public class DownloadTrackerNotifier extends BaseDownloadListener implements DownloadTrackerListener {
private boolean instant_notify;
public DownloadTrackerNotifier(boolean instant_notify) {this.instant_notify = instant_notify;}
public void downloadAdded(Download download) {download.addTrackerListener(this, this.instant_notify);}
public void downloadRemoved(Download download) {download.removeTrackerListener(this);}
public void scrapeResult(DownloadScrapeResult result) {
Iterator itr = this.listeners.iterator();
while (itr.hasNext()) {
try {((DownloadTrackerListener)itr.next()).scrapeResult(result);}
catch (Throwable t) {Debug.printStackTrace(t);}
}
}
public void announceResult(DownloadAnnounceResult result) {
Iterator itr = this.listeners.iterator();
while (itr.hasNext()) {
try {((DownloadTrackerListener)itr.next()).announceResult(result);}
catch (Throwable t) {Debug.printStackTrace(t);}
}
}
}
}
|
