btmessagemanager.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:   BTMessageManager.java

package org.gudy.azureus2.plugins.messaging.bittorrent;

import com.aelitis.azureus.core.peermanager.messaging.Message;
import com.aelitis.azureus.core.peermanager.messaging.bittorrent.BTCancel;
import com.aelitis.azureus.core.peermanager.messaging.bittorrent.BTPiece;
import com.aelitis.azureus.core.peermanager.messaging.bittorrent.BTRequest;
import java.nio.ByteBuffer;
import org.gudy.azureus2.core3.util.DirectByteBuffer;
import org.gudy.azureus2.pluginsimpl.local.messaging.MessageAdapter;

// Referenced classes of package org.gudy.azureus2.plugins.messaging.bittorrent:
//			BTMessageCancel, BTMessagePiece, BTMessageRequest

public class BTMessageManager
{

	public static final String ID_BTMESSAGE_REQUEST = "BT_REQUEST";
	public static final String ID_BTMESSAGE_CANCEL = "BT_CANCEL";
	public static final String ID_BTMESSAGE_PIECE = "BT_PIECE";
	public static final String ID_BTMESSAGE_UNCHOKE = "BT_UNCHOKE";

	public BTMessageManager()
	{
	}

	public static BTMessageRequest createCoreBTRequestAdaptation(org.gudy.azureus2.plugins.messaging.Message core_made_message)
	{
		Message core_msg = ((MessageAdapter)core_made_message).getCoreMessage();
		if (core_msg.getID().equals("BT_REQUEST"))
			return new BTMessageRequest(core_msg);
		else
			return null;
	}

	public static BTMessageCancel createCoreBTCancelAdaptation(org.gudy.azureus2.plugins.messaging.Message core_made_message)
	{
		Message core_msg = ((MessageAdapter)core_made_message).getCoreMessage();
		if (core_msg.getID().equals("BT_CANCEL"))
			return new BTMessageCancel(core_msg);
		else
			return null;
	}

	public static BTMessagePiece createCoreBTPieceAdaptation(org.gudy.azureus2.plugins.messaging.Message core_made_message)
	{
		Message core_msg = ((MessageAdapter)core_made_message).getCoreMessage();
		if (core_msg.getID().equals("BT_PIECE"))
			return new BTMessagePiece(core_msg);
		else
			return null;
	}

	public static org.gudy.azureus2.plugins.messaging.Message createCoreBTRequest(int piece_number, int piece_offset, int length)
	{
		return new MessageAdapter(new BTRequest(piece_number, piece_offset, length, (byte)1));
	}

	public static org.gudy.azureus2.plugins.messaging.Message createCoreBTCancel(int piece_number, int piece_offset, int length)
	{
		return new MessageAdapter(new BTCancel(piece_number, piece_offset, length, (byte)1));
	}

	public static org.gudy.azureus2.plugins.messaging.Message createCoreBTPiece(int piece_number, int piece_offset, ByteBuffer data)
	{
		return new MessageAdapter(new BTPiece(piece_number, piece_offset, new DirectByteBuffer(data), (byte)1));
	}
}