FileDocCategorySizeDatePackage
AZSessionCancel.javaAPI DocAzureus 3.0.3.44528Sun Mar 04 21:08:16 GMT 2007com.aelitis.azureus.core.peermanager.messaging.azureus.session

AZSessionCancel

public class AZSessionCancel extends Object implements com.aelitis.azureus.core.peermanager.messaging.azureus.AZMessage
BitTorrent cancel message.

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

  
  
               
    this.session_id = session_id;
    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 ) != 16 ) {
      throw new MessageException( "[" +getID() + "] decode error: payload.remaining[" +data.remaining( DirectByteBuffer.SS_MSG )+ "] != 16" );
    }
    
    int id = data.getInt( DirectByteBuffer.SS_MSG );
    
    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: length < 0" );
    }
    
    data.returnToPool();
    
    return new AZSessionCancel( id, num, offset, length, version );
  
public voiddestroy()

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

    if( buffer == null ) {
      buffer = DirectByteBufferPool.getBuffer( DirectByteBuffer.AL_MSG, 16 );
      buffer.putInt( DirectByteBuffer.SS_MSG, session_id );
      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 = getID()+ " session #" +session_id+ " piece #" + piece_number + ":" + piece_offset + "->" + (piece_offset + length -1);
    }
    
    return description; 
  
public java.lang.StringgetFeatureID()

  throw new RuntimeException( "not implemented" );  
public intgetFeatureSubID()

  throw new RuntimeException( "not implemented" );  
public java.lang.StringgetID()

  return AZMessage.ID_AZ_SESSION_CANCEL;  
public byte[]getIDBytes()

  return AZMessage.ID_AZ_SESSION_CANCEL_BYTES;  
public intgetLength()

  return length;  
public intgetPieceNumber()

  return piece_number;  
public intgetPieceOffset()

  return piece_offset;  
public intgetSessionID()

  return session_id;  
public intgetType()

  return Message.TYPE_PROTOCOL_PAYLOAD;  
public bytegetVersion()

 return version;