transportimpl.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:   TransportImpl.java

package org.gudy.azureus2.pluginsimpl.local.network;

import com.aelitis.azureus.core.networkmanager.NetworkConnection;
import com.aelitis.azureus.core.networkmanager.Transport;
import java.io.IOException;
import java.nio.ByteBuffer;
import org.gudy.azureus2.plugins.network.TransportFilter;

// Referenced classes of package org.gudy.azureus2.pluginsimpl.local.network:
//			TransportFilterImpl

public class TransportImpl
	implements org.gudy.azureus2.plugins.network.Transport
{

	private Transport core_transport;
	private NetworkConnection core_network;

	public TransportImpl(NetworkConnection core_network)
	{
		this.core_network = core_network;
	}

	public TransportImpl(Transport core_transport)
	{
		this.core_transport = core_transport;
	}

	public long read(ByteBuffer buffers[], int array_offset, int length)
		throws IOException
	{
		return coreTransport().read(buffers, array_offset, length);
	}

	public long write(ByteBuffer buffers[], int array_offset, int length)
		throws IOException
	{
		return coreTransport().write(buffers, array_offset, length);
	}

	public Transport coreTransport()
		throws IOException
	{
		if (core_transport == null)
		{
			core_transport = core_network.getTransport();
			if (core_transport == null)
				throw new IOException("Not connected");
		}
		return core_transport;
	}

	public void setFilter(TransportFilter filter)
		throws IOException
	{
		((com.aelitis.azureus.core.networkmanager.impl.TransportImpl)coreTransport()).setFilter(((TransportFilterImpl)filter).filter);
	}
}