FilesExpand file tree

 master

/

CloudSDEncoder.java

Copy path

BlameMore file actions

BlameMore file actions

Latest commit

 

History

History

History

43 lines (38 loc) · 1.28 KB

 master

/

CloudSDEncoder.java

Top

File metadata and controls

• Code
• Blame

43 lines (38 loc) · 1.28 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

package lambdacloud.net;

import io.netty.buffer.ByteBuf;

import io.netty.channel.ChannelHandlerContext;

import io.netty.handler.codec.MessageToByteEncoder;

import java.io.UnsupportedEncodingException;

import java.nio.ByteBuffer;

import lambdacloud.core.CloudSD;

public class CloudSDEncoder extends MessageToByteEncoder<CloudSD> {

@Override

protected void encode(ChannelHandlerContext ctx, CloudSD var, ByteBuf out) {

// Convert to a BigInteger first for easier implementation.

int nameLen = 0;

int dataLen = var.getData().length * 8;

int packageLen = 0;

byte[] allData = null;

try {

byte[] nameBytes = var.getLabel().getBytes("UTF-8");

nameLen = nameBytes.length;

packageLen = nameLen + dataLen;

allData = new byte[packageLen];

System.arraycopy(nameBytes, 0, allData, 0, nameLen);

} catch (UnsupportedEncodingException e) {

e.printStackTrace();

}

byte[] data = new byte[dataLen];

ByteBuffer buf = ByteBuffer.wrap(data);

for (double d : var.getData()) {

buf.putDouble(d);

}

System.arraycopy(buf.array(), 0, allData, nameLen, dataLen);

// Write a message.

out.writeByte((byte) 'D'); // magic number

out.writeInt(nameLen); // name length

out.writeInt(var.isOnCloud()?1:0);

out.writeInt(dataLen); // data length

out.writeBytes(allData); // data

}

}