rawmessageadapter.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:   RawMessageAdapter.java

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

import com.aelitis.azureus.core.networkmanager.RawMessage;
import com.aelitis.azureus.core.peermanager.messaging.Message;
import java.nio.ByteBuffer;
import org.gudy.azureus2.core3.util.DirectByteBuffer;
import org.gudy.azureus2.pluginsimpl.local.messaging.MessageAdapter;

public class RawMessageAdapter extends MessageAdapter
	implements org.gudy.azureus2.plugins.network.RawMessage, RawMessage
{

	private org.gudy.azureus2.plugins.network.RawMessage plug_msg;
	private RawMessage core_msg;

	public RawMessageAdapter(org.gudy.azureus2.plugins.network.RawMessage plug_msg)
	{
		super(plug_msg);
		this.plug_msg = null;
		core_msg = null;
		this.plug_msg = plug_msg;
	}

	public RawMessageAdapter(RawMessage core_msg)
	{
		super(core_msg);
		plug_msg = null;
		this.core_msg = null;
		this.core_msg = core_msg;
	}

	public ByteBuffer[] getRawPayload()
	{
		if (core_msg == null)
			return plug_msg.getRawPayload();
		DirectByteBuffer dbbs[] = core_msg.getRawData();
		ByteBuffer bbs[] = new ByteBuffer[dbbs.length];
		for (int i = 0; i < dbbs.length; i++)
			bbs[i] = dbbs[i].getBuffer((byte)11);

		return bbs;
	}

	public DirectByteBuffer[] getRawData()
	{
		if (plug_msg == null)
			return core_msg.getRawData();
		ByteBuffer bbs[] = plug_msg.getRawPayload();
		DirectByteBuffer dbbs[] = new DirectByteBuffer[bbs.length];
		for (int i = 0; i < bbs.length; i++)
			dbbs[i] = new DirectByteBuffer(bbs[i]);

		return dbbs;
	}

	public int getPriority()
	{
		return 1;
	}

	public boolean isNoDelay()
	{
		return true;
	}

	public void setNoDelay()
	{
	}

	public Message[] messagesToRemove()
	{
		return null;
	}

	public org.gudy.azureus2.plugins.messaging.Message getOriginalMessage()
	{
		if (plug_msg == null)
			return new MessageAdapter(core_msg.getBaseMessage());
		else
			return plug_msg.getOriginalMessage();
	}

	public Message getBaseMessage()
	{
		if (core_msg == null)
			return new MessageAdapter(plug_msg.getOriginalMessage());
		else
			return core_msg.getBaseMessage();
	}
}