If I understand your code correctly you look for the start of a new
packet. Shouldn't you check for the packet end instead? Just because you
see the start of a new packet it doesn't necessarily mean the in
variable contains a complete packet.
The CumulativeProtocolDecoder will remember the received bytes until
your doDecode() method returns true. Your code should look something like:
if (isCompletePacket(in)) {
// Create the MessageReq object from the bytes and call out.write()
} else {
// No complete packet in in. Wait for more data by returning false.
return false;
}
Do you have some means of determining if a complete packet is in the in
variable?
HTH
/Niklas
Sungwon Jung wrote:
sorry.
I received large packet, prints "RAW DATA" twice.
first, print RAW DATA include packet header.
second, print RAW DATA (just data).
sorry, English is poor.
<all code>
public class PacketReqAnalysis extends CumulativeProtocolDecoder
{
protected boolean doDecode(IoSession session, ByteBuffer in,
ProtocolDecoderOutput out) throws Exception {
logger.debug( "RAW DATA - " + in.getHexDump() );
int start = in.get() & 0xFF;
if( start == PacketDefine.START ) {
ByteBuffer pk = ByteBuffer.allocate( 2, false );
pk.setAutoExpand( true );
pk.put( (byte)start );
pk.putShort( (short)(in.getShort() & 0xFFFF) );
pk.put( (byte)in.get() );
pk.put( (byte)in.get() );
int size = in.getInt();
pk.putInt( size );
pk.put( (byte)in.get() );
pk.put( (byte)in.get() );
byte[] bytes = new byte[ size ];
in.get( bytes );
pk.put( bytes );
MessageReq request = new MessageReq( session, pk, out,
start );
out.write( acu_request );
return true;
} else {
logger.debug( "out doDecode-------------------" );
logger.debug( "buf is " + in.getHexDump() );
logger.debug( "out doDecode-------------------" );
return false;
}
}
}
On 10/15/07, Niklas Therning <[EMAIL PROTECTED]> wrote:
Sungwon Jung wrote:
Hello. I'm using MINA 1.1.2.
I'm using CumulativeProtocolDecoder.
When I recieved large size packet(about 220bytes), the packet is splited.
How can I assemble the splited packet?
Thank you.
my code>
public class PacketReqAnalysis extends CumulativeProtocolDecoder
{
protected boolean doDecode(IoSession session, ByteBuffer in,
ProtocolDecoderOutput out) throws Exception {
if( start == PacketDefine.START ) {
return true;
} else {
return false;
}
}
}
Your code looks weird. Is this really all code? Where does the start
variable come from?
/Niklas
