messagestreamdecoderadapter.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:   MessageStreamDecoderAdapter.java

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

import com.aelitis.azureus.core.networkmanager.Transport;
import com.aelitis.azureus.core.peermanager.messaging.Message;
import com.aelitis.azureus.core.peermanager.messaging.MessageStreamDecoder;
import java.io.IOException;
import java.nio.ByteBuffer;
import org.gudy.azureus2.pluginsimpl.local.network.TransportImpl;

// Referenced classes of package org.gudy.azureus2.pluginsimpl.local.messaging:
//			MessageAdapter

public class MessageStreamDecoderAdapter
	implements MessageStreamDecoder
{

	private final org.gudy.azureus2.plugins.messaging.MessageStreamDecoder plug_decoder;

	public MessageStreamDecoderAdapter(org.gudy.azureus2.plugins.messaging.MessageStreamDecoder plug_decoder)
	{
		this.plug_decoder = plug_decoder;
	}

	public int performStreamDecode(Transport transport, int max_bytes)
		throws IOException
	{
		return plug_decoder.performStreamDecode(new TransportImpl(transport), max_bytes);
	}

	public int getPercentDoneOfCurrentMessage()
	{
		return -1;
	}

	public Message[] removeDecodedMessages()
	{
		org.gudy.azureus2.plugins.messaging.Message plug_msgs[] = plug_decoder.removeDecodedMessages();
		if (plug_msgs == null || plug_msgs.length < 1)
			return null;
		Message core_msgs[] = new Message[plug_msgs.length];
		for (int i = 0; i < plug_msgs.length; i++)
			core_msgs[i] = new MessageAdapter(plug_msgs[i]);

		return core_msgs;
	}

	public int getProtocolBytesDecoded()
	{
		return plug_decoder.getProtocolBytesDecoded();
	}

	public int getDataBytesDecoded()
	{
		return plug_decoder.getDataBytesDecoded();
	}

	public void pauseDecoding()
	{
		plug_decoder.pauseDecoding();
	}

	public void resumeDecoding()
	{
		plug_decoder.resumeDecoding();
	}

	public ByteBuffer destroy()
	{
		return plug_decoder.destroy();
	}
}