FileDocCategorySizeDatePackage
BTCancel.javaAPI DocAzureus 3.0.3.44100Sun Mar 04 21:08:16 GMT 2007com.aelitis.azureus.core.peermanager.messaging.bittorrent

BTCancel

public class BTCancel extends Object implements BTMessage
BitTorrent cancel message.

Fields Summary
private DirectByteBuffer
buffer
private byte
version
private String
description
private final int
piece_number
private final int
piece_offset
private final int
length
Constructors Summary
public BTCancel(int piece_number, int piece_offset, int length, byte version)

  
  
             
    this.piece_number = piece_number;
    this.piece_offset = piece_offset;
    this.length = length;
    this.version = version;
  
Methods Summary
public com.aelitis.azureus.core.peermanager.messaging.Messagedeserialize(DirectByteBuffer data, byte version)

    if( data == null ) {
      throw new MessageException( "[" +getID() +"] decode error: data == null" );
    }
    
    if( data.remaining( DirectByteBuffer.SS_MSG ) != 12 ) {
      throw new MessageException( "[" +getID() +  "] decode error: payload.remaining[" +data.remaining( DirectByteBuffer.SS_MSG )+ "] != 12" );
    }
    
    int num = data.getInt( DirectByteBuffer.SS_MSG );
    if( num < 0 ) {
      throw new MessageException( "[" +getID() + "] decode error: num < 0" );
    }
    
    int offset = data.getInt( DirectByteBuffer.SS_MSG );
    if( offset < 0 ) {
      throw new MessageException( "[" +getID()+ "] decode error: offset < 0" );
    }
    
    int length = data.getInt( DirectByteBuffer.SS_MSG );
    if( length < 0 ) {
      throw new MessageException( "[" +getID() + "] decode error: lngth < 0" );
    }
    
    data.returnToPool();
    
    return new BTCancel( num, offset, length, version );
  
public voiddestroy()

    if( buffer != null )  buffer.returnToPool();
  
public DirectByteBuffer[]getData()

    if( buffer == null ) {
      buffer = DirectByteBufferPool.getBuffer( DirectByteBuffer.AL_MSG_BT_CANCEL, 12 );
      buffer.putInt( DirectByteBuffer.SS_MSG, piece_number );
      buffer.putInt( DirectByteBuffer.SS_MSG, piece_offset );
      buffer.putInt( DirectByteBuffer.SS_MSG, length );
      buffer.flip( DirectByteBuffer.SS_MSG );
    }
    
    return new DirectByteBuffer[]{ buffer };
  
public java.lang.StringgetDescription()

    if( description == null ) {
      description = BTMessage.ID_BT_CANCEL + " piece #" + piece_number + ":" + piece_offset + "->" + (piece_offset + length -1);
    }
    
    return description; 
  
public java.lang.StringgetFeatureID()

  return BTMessage.BT_FEATURE_ID;  
public intgetFeatureSubID()

  return BTMessage.SUBID_BT_CANCEL;  
public java.lang.StringgetID()

  return BTMessage.ID_BT_CANCEL;  
public byte[]getIDBytes()

  return BTMessage.ID_BT_CANCEL_BYTES;  
public intgetLength()

  return length;  
public intgetPieceNumber()

  return piece_number;  
public intgetPieceOffset()

  return piece_offset;  
public intgetType()

  return Message.TYPE_PROTOCOL_PAYLOAD;  
public bytegetVersion()

 return version;