sharetester.java

java 文件下载器。可自定义

// Decompiled by Jad v1.5.8e2. Copyright 2001 Pavel Kouznetsov.
// Jad home page: http://kpdus.tripod.com/jad.html
// Decompiler options: packimports(3) fieldsfirst ansi space 
// Source File Name:   ShareTester.java

package org.gudy.azureus2.pluginsimpl.local.sharing.test;

import java.io.PrintStream;
import java.util.*;
import org.gudy.azureus2.core3.util.*;
import org.gudy.azureus2.plugins.*;
import org.gudy.azureus2.plugins.download.*;
import org.gudy.azureus2.plugins.logging.Logger;
import org.gudy.azureus2.plugins.logging.LoggerChannel;
import org.gudy.azureus2.plugins.peers.*;
import org.gudy.azureus2.plugins.sharing.*;

public class ShareTester
	implements Plugin, PluginListener, ShareManagerListener
{

	protected static AESemaphore init_sem = new AESemaphore("ShareTester");
	private static AEMonitor class_mon = new AEMonitor("ShareTester");
	protected static ShareTester singleton;
	protected Map seed_transport_map;
	protected PluginInterface plugin_interface;

	public ShareTester()
	{
		seed_transport_map = new HashMap();
	}

	public static ShareTester getSingleton()
	{
		ShareTester sharetester;
		class_mon.enter();
		if (singleton == null)
		{
			(new AEThread("plugin initialiser ") {

				public void runSupport()
				{
					PluginManager.registerPlugin(org/gudy/azureus2/pluginsimpl/local/sharing/test/ShareTester);
					Properties props = new Properties();
					props.put("MULTI_INSTANCE", "true");
					PluginManager.startAzureus(1, props);
				}

			}).start();
			init_sem.reserve();
		}
		sharetester = singleton;
		class_mon.exit();
		return sharetester;
		Exception exception;
		exception;
		class_mon.exit();
		throw exception;
	}

	public void initialize(PluginInterface _pi)
	{
		plugin_interface = _pi;
		singleton = this;
		init_sem.release();
		LoggerChannel log = plugin_interface.getLogger().getChannel("Plugin Test");
		log.log(1, "Plugin Initialised");
		plugin_interface.addListener(this);
	}

	public void initializationComplete()
	{
		try
		{
			DownloadManager dm = plugin_interface.getDownloadManager();
			dm.addListener(new DownloadManagerListener() {

				final ShareTester this$0;

				public void downloadAdded(final Download download)
				{
					System.out.println((new StringBuilder()).append("downloadAdded: ").append(download).toString());
					download.addListener(new DownloadListener() {

						final Download val$download;
						final 2 this$1;

						public void stateChanged(Download dl, int old, int cur)
						{
							System.out.println((new StringBuilder()).append("statechange:").append(old).append("-> ").append(cur).append("  (").append(download).append(")").toString());
						}

						public void positionChanged(Download download, int old, int cur)
						{
							System.out.println((new StringBuilder()).append("statechange:").append(old).append("-> ").append(cur).append("  (").append(download).append(")").toString());
						}

					
					{
						this$1 = 2.this;
						download = download1;
						super();
					}
					});
					download.addTrackerListener(new DownloadTrackerListener() {

						final 2 this$1;

						public void scrapeResult(DownloadScrapeResult result)
						{
							System.out.println((new StringBuilder()).append("scrapeResult:").append(result.getSeedCount()).append("/").append(result.getNonSeedCount()).toString());
						}

						public void announceResult(DownloadAnnounceResult result)
						{
							if (result.getResponseType() == 1)
								System.out.println((new StringBuilder()).append("announceResult:").append(result.getReportedPeerCount()).append("/").append(result.getSeedCount()).append("/").append(result.getNonSeedCount()).toString());
							else
								System.out.println((new StringBuilder()).append("announceResult:").append(result.getError()).toString());
						}

					
					{
						this$1 = 2.this;
						super();
					}
					});
					download.addPeerListener(new DownloadPeerListener() {

						final 2 this$1;

						public void peerManagerAdded(Download download, PeerManager peer_manager)
						{
							peer_manager.addListener(new PeerManagerListener() {

								final 3 this$2;

								public void peerAdded(PeerManager manager, Peer peer)
								{
									System.out.println((new StringBuilder()).append("peerAdded:").append(peer.getIp()).toString());
								}

								public void peerRemoved(PeerManager manager, Peer peer)
								{
									System.out.println((new StringBuilder()).append("peerRemoved:").append(peer.getIp()).toString());
								}

						
						{
							this$2 = 3.this;
							super();
						}
							});
						}

						public void peerManagerRemoved(Download download1, PeerManager peermanager)
						{
						}

					
					{
						this$1 = 2.this;
						super();
					}
					});
				}

				public void downloadRemoved(Download download)
				{
					System.out.println((new StringBuilder()).append("downloadRemoved").append(download).toString());
				}

			
			{
				this$0 = ShareTester.this;
				super();
			}
			});
			ShareManager sm = plugin_interface.getShareManager();
			sm.addListener(this);
			sm.initialise();
		}
		catch (ShareException e)
		{
			Debug.printStackTrace(e);
		}
		catch (Throwable e)
		{
			Debug.printStackTrace(e);
		}
	}

	public void closedownInitiated()
	{
	}

	public void closedownComplete()
	{
	}

	public void resourceAdded(ShareResource resource)
	{
		System.out.println((new StringBuilder()).append("resource added:").append(resource.getName()).toString());
		if (resource.getType() == 3)
		{
			ShareResourceDirContents c = (ShareResourceDirContents)resource;
			ShareResource kids[] = c.getChildren();
			for (int i = 0; i < kids.length; i++)
				System.out.println((new StringBuilder()).append("\t").append(kids[i].getName()).toString());

		}
	}

	public void resourceModified(ShareResource resource)
	{
		System.out.println((new StringBuilder()).append("resource modified:").append(resource.getName()).toString());
	}

	public void resourceDeleted(ShareResource resource)
	{
		System.out.println((new StringBuilder()).append("resource deleted:").append(resource.getName()).toString());
	}

	public void reportProgress(int i)
	{
	}

	public void reportCurrentTask(String task_description)
	{
		System.out.println(task_description);
	}

	public static void main(String args[])
	{
		getSingleton();
	}

}