public class DataPacket extends AbstractLocalPacket
header = packetRank middle = data end = key
end, header, middle
Constructor and Description |
---|
DataPacket(int packetRank,
io.netty.buffer.ByteBuf data,
io.netty.buffer.ByteBuf key) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
void |
createEnd(LocalChannelReference lcr)
Prepare the End buffer
|
static DataPacket |
createFromBuffer(int headerLength,
int middleLength,
int endLength,
io.netty.buffer.ByteBuf buf) |
void |
createHeader(LocalChannelReference lcr)
Prepare the Header buffer
|
void |
createMiddle(LocalChannelReference lcr)
Prepare the Middle buffer
|
io.netty.buffer.ByteBuf |
getData() |
io.netty.buffer.ByteBuf |
getKey() |
int |
getLengthPacket() |
int |
getPacketRank() |
byte |
getType() |
boolean |
isKeyValid(FilesystemBasedDigest.DigestAlgo algo) |
String |
toString() |
getLocalPacket, retain
public DataPacket(int packetRank, io.netty.buffer.ByteBuf data, io.netty.buffer.ByteBuf key)
packetRank
- data
- key
- public static DataPacket createFromBuffer(int headerLength, int middleLength, int endLength, io.netty.buffer.ByteBuf buf) throws OpenR66ProtocolPacketException
headerLength
- middleLength
- endLength
- buf
- OpenR66ProtocolPacketException
public void createEnd(LocalChannelReference lcr) throws OpenR66ProtocolPacketException
AbstractLocalPacket
createEnd
in class AbstractLocalPacket
OpenR66ProtocolPacketException
public void createHeader(LocalChannelReference lcr) throws OpenR66ProtocolPacketException
AbstractLocalPacket
createHeader
in class AbstractLocalPacket
OpenR66ProtocolPacketException
public void createMiddle(LocalChannelReference lcr) throws OpenR66ProtocolPacketException
AbstractLocalPacket
createMiddle
in class AbstractLocalPacket
OpenR66ProtocolPacketException
public byte getType()
getType
in class AbstractLocalPacket
public String toString()
toString
in class AbstractLocalPacket
public int getPacketRank()
public int getLengthPacket()
public io.netty.buffer.ByteBuf getData()
public io.netty.buffer.ByteBuf getKey()
public boolean isKeyValid(FilesystemBasedDigest.DigestAlgo algo)
public void clear()
clear
in class AbstractLocalPacket
Copyright © 2009–2020 Waarp. All rights reserved.