rptracker.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:   RPTracker.java

package org.gudy.azureus2.pluginsimpl.remote.tracker;

import java.net.InetAddress;
import java.net.URL;
import org.gudy.azureus2.plugins.torrent.Torrent;
import org.gudy.azureus2.plugins.tracker.*;
import org.gudy.azureus2.plugins.tracker.web.*;
import org.gudy.azureus2.pluginsimpl.remote.*;
import org.gudy.azureus2.pluginsimpl.remote.torrent.RPTorrent;

// Referenced classes of package org.gudy.azureus2.pluginsimpl.remote.tracker:
//			RPTrackerTorrent

public class RPTracker extends RPObject
	implements Tracker
{

	protected transient Tracker delegate;

	public static RPTracker create(Tracker _delegate)
	{
		RPTracker res = (RPTracker)_lookupLocal(_delegate);
		if (res == null)
			res = new RPTracker(_delegate);
		return res;
	}

	protected RPTracker(Tracker _delegate)
	{
		super(_delegate);
	}

	protected void _setDelegate(Object _delegate)
	{
		delegate = (Tracker)_delegate;
	}

	public Object _setLocal()
		throws RPException
	{
		return _fixupLocal();
	}

	public RPReply _process(RPRequest request)
	{
		String method;
		Object params[];
		method = request.getMethod();
		params = request.getParams();
		if (!method.equals("host[Torrent,boolean]"))
			break MISSING_BLOCK_LABEL_109;
		RPTrackerTorrent res;
		Torrent torrent = params[0] != null ? (Torrent)((RPTorrent)params[0])._setLocal() : null;
		if (torrent == null)
			throw new RPException("Invalid torrent");
		TrackerTorrent tt = delegate.host(torrent, ((Boolean)params[1]).booleanValue());
		res = RPTrackerTorrent.create(tt);
		return new RPReply(res);
		TrackerException e;
		e;
		return new RPReply(e);
		if (method.equals("getTorrents"))
		{
			TrackerTorrent torrents[] = delegate.getTorrents();
			RPTrackerTorrent res[] = new RPTrackerTorrent[torrents.length];
			for (int i = 0; i < res.length; i++)
				res[i] = RPTrackerTorrent.create(torrents[i]);

			return new RPReply(res);
		} else
		{
			throw new RPException((new StringBuilder()).append("Unknown method: ").append(method).toString());
		}
	}

	public TrackerTorrent host(Torrent torrent, boolean persistent)
		throws TrackerException
	{
		RPTrackerTorrent resp;
		resp = (RPTrackerTorrent)_dispatcher.dispatch(new RPRequest(this, "host[Torrent,boolean]", new Object[] {
			torrent, new Boolean(persistent)
		})).getResponse();
		resp._setRemote(_dispatcher);
		return resp;
		RPException e;
		e;
		if (e.getCause() instanceof TrackerException)
			throw (TrackerException)e.getCause();
		else
			throw e;
	}

	public TrackerTorrent host(Torrent torrent, boolean persistent, boolean passive)
		throws TrackerException
	{
		notSupported();
		return null;
	}

	public TrackerTorrent publish(Torrent torrent)
		throws TrackerException
	{
		notSupported();
		return null;
	}

	public TrackerTorrent[] getTorrents()
	{
		RPTrackerTorrent res[] = (RPTrackerTorrent[])(RPTrackerTorrent[])_dispatcher.dispatch(new RPRequest(this, "getTorrents", null)).getResponse();
		for (int i = 0; i < res.length; i++)
			res[i]._setRemote(_dispatcher);

		return res;
	}

	public TrackerTorrent getTorrent(Torrent t)
	{
		notSupported();
		return null;
	}

	public TrackerWebContext createWebContext(int port, int protocol)
		throws TrackerException
	{
		notSupported();
		return null;
	}

	public TrackerWebContext createWebContext(String name, int port, int protocol)
		throws TrackerException
	{
		notSupported();
		return null;
	}

	public TrackerWebContext createWebContext(String name, int port, int protocol, InetAddress bind_ip)
		throws TrackerException
	{
		notSupported();
		return null;
	}

	public void addListener(TrackerListener trackerlistener)
	{
	}

	public void removeListener(TrackerListener trackerlistener)
	{
	}

	public String getName()
	{
		notSupported();
		return null;
	}

	public URL[] getURLs()
	{
		notSupported();
		return null;
	}

	public void addPageGenerator(TrackerWebPageGenerator trackerwebpagegenerator)
	{
	}

	public void removePageGenerator(TrackerWebPageGenerator trackerwebpagegenerator)
	{
	}

	public TrackerWebPageGenerator[] getPageGenerators()
	{
		notSupported();
		return null;
	}

	public void addAuthenticationListener(TrackerAuthenticationListener trackerauthenticationlistener)
	{
	}

	public void removeAuthenticationListener(TrackerAuthenticationListener trackerauthenticationlistener)
	{
	}

	public void destroy()
	{
		notSupported();
	}
}