28
28
public static final int HEADER_LENGTH = 12;
30
private PacketMagic magic;
31
private PacketType type;
30
private GearmanPacketMagic magic;
31
private GearmanPacketType type;
32
32
private int dataLength;
34
public PacketHeader(PacketMagic magic, PacketType type, int dataLength) {
34
public GearmanPacketHeader(GearmanPacketMagic magic, GearmanPacketType type, int dataLength) {
35
35
this.magic = magic;
37
37
this.dataLength = dataLength;
40
public PacketHeader(byte[] bytes) {
40
public GearmanPacketHeader(byte[] bytes) {
41
41
ByteArrayBuffer baBuff = new ByteArrayBuffer(bytes);
42
magic = PacketMagic.fromBytes(baBuff.subArray(0, 4));
42
magic = GearmanPacketMagic.fromBytes(baBuff.subArray(0, 4));
43
43
int typeInt = ByteUtils.fromBigEndian(baBuff.subArray(4, 8));
44
type = PacketType.get(typeInt);
44
type = GearmanPacketType.get(typeInt);
45
45
dataLength = ByteUtils.fromBigEndian(baBuff.subArray(8, 12));
48
public PacketMagic getMagic() {
48
public GearmanPacketMagic getMagic() {
52
public void setMagic(PacketMagic magic) {
52
public void setMagic(GearmanPacketMagic magic) {
53
53
this.magic = magic;
56
public PacketType getType() {
56
public GearmanPacketType getType() {
60
public void setType(PacketType type) {
60
public void setType(GearmanPacketType type) {