com.tencent.tcaplus.message.impl

Class MessageBufferImpl

java.lang.Object

com.tencent.tcaplus.message.impl.MessageBufferImpl

All Implemented Interfaces:

MessageBuffer

public class MessageBufferImpl
extends Object
implements MessageBuffer

Constructor Summary

Constructors

Constructor and Description
MessageBufferImpl(com.tencent.tcaplus.message.impl.ByteBufferPool byteBufferPool, ObjectPool<byte[]> byteArrayPool)

Method Summary

Modifier and Type	Method and Description
int	capacity()
boolean	decodeHead(ByteBuffer headBuffer)
void	flip()
MessageBuffer	get(byte[] byteArray)
int	getCmd()
short	getMagic()
ByteBuffer[]	getPackets()
int	getPacketsCount()
int	getSeq()
int	getSubCmd()
short	getVersion()
boolean	hasRemaining()
int	limit()
void	packet(byte[] buffer, int offset, int length, boolean needAlloc)
void	packet(TCapdirCSPkg pkg, int pkgVersion) 分包TCapdirCSPkg消息对象
void	packet(TCaplusPkg pkg, int pkgVersion)
void	packet(TCaplusPkg pkg, int pkgVersion, byte[] packetBuf) 分包TCaplusPkg消息对象
int	position()
void	position(int position)
MessageBuffer	put(byte[] src)
MessageBuffer	put(byte[] src, int offset, int length)
void	reset()
void	resize(byte[] buf) 使用外部buffer作为消息buffer
void	resize(int size) 重新分配消息buffer空间大小
void	setCmd(int cmd)
void	setMagic(short magic)
void	setSeq(int seq)
void	setSubCmd(int subCmd)
void	setVersion(short version)
String	toString()
void	unpack(TCapdirCSPkg pkg)
void	unpack(TCaplusPkg pkg)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

MessageBufferImpl

public MessageBufferImpl(com.tencent.tcaplus.message.impl.ByteBufferPool byteBufferPool,
                         ObjectPool<byte[]> byteArrayPool)

Method Detail

resize

public void resize(int size)

Description copied from interface: MessageBuffer

重新分配消息buffer空间大小

Specified by:

resize in interface MessageBuffer

resize

public void resize(byte[] buf)

Description copied from interface: MessageBuffer

使用外部buffer作为消息buffer

Specified by:

resize in interface MessageBuffer

packet

public void packet(TCaplusPkg pkg,
                   int pkgVersion)
            throws TdrException

Specified by:

packet in interface MessageBuffer

Throws:

TdrException

packet

public void packet(TCaplusPkg pkg,
                   int pkgVersion,
                   byte[] packetBuf)
            throws TdrException

Description copied from interface: MessageBuffer

分包TCaplusPkg消息对象

Specified by:

packet in interface MessageBuffer

Throws:

TdrException

packet

public void packet(TCapdirCSPkg pkg,
                   int pkgVersion)
            throws TdrException

Description copied from interface: MessageBuffer

分包TCapdirCSPkg消息对象

Specified by:

packet in interface MessageBuffer

Throws:

TdrException

unpack

public void unpack(TCaplusPkg pkg)
            throws TdrException

Specified by:

unpack in interface MessageBuffer

Throws:

TdrException

unpack

public void unpack(TCapdirCSPkg pkg)
            throws TdrException

Specified by:

unpack in interface MessageBuffer

Throws:

TdrException

getPackets

public ByteBuffer[] getPackets()

Specified by:

getPackets in interface MessageBuffer

getPacketsCount

public int getPacketsCount()

Specified by:

getPacketsCount in interface MessageBuffer

limit

public int limit()

Specified by:

limit in interface MessageBuffer

position

public int position()

Specified by:

position in interface MessageBuffer

position

public void position(int position)

Specified by:

position in interface MessageBuffer

hasRemaining

public boolean hasRemaining()

Specified by:

hasRemaining in interface MessageBuffer

flip

public void flip()

Specified by:

flip in interface MessageBuffer

setMagic

public void setMagic(short magic)

Specified by:

setMagic in interface MessageBuffer

getMagic

public short getMagic()

Specified by:

getMagic in interface MessageBuffer

setCmd

public void setCmd(int cmd)

Specified by:

setCmd in interface MessageBuffer

getCmd

public int getCmd()

Specified by:

getCmd in interface MessageBuffer

getSubCmd

public int getSubCmd()

Specified by:

getSubCmd in interface MessageBuffer

setSubCmd

public void setSubCmd(int subCmd)

Specified by:

setSubCmd in interface MessageBuffer

setVersion

public void setVersion(short version)

Specified by:

setVersion in interface MessageBuffer

getVersion

public short getVersion()

Specified by:

getVersion in interface MessageBuffer

setSeq

public void setSeq(int seq)

Specified by:

setSeq in interface MessageBuffer

getSeq

public int getSeq()

Specified by:

getSeq in interface MessageBuffer

packet

public void packet(byte[] buffer,
                   int offset,
                   int length,
                   boolean needAlloc)

put

public MessageBuffer put(byte[] src)

put

public MessageBuffer put(byte[] src,
                         int offset,
                         int length)

reset

public void reset()

Specified by:

reset in interface MessageBuffer

get

public MessageBuffer get(byte[] byteArray)

capacity

public int capacity()

toString

public String toString()

Overrides:

toString in class Object

decodeHead

public boolean decodeHead(ByteBuffer headBuffer)

Specified by:

decodeHead in interface MessageBuffer