rdev/gossip-revisited
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Use byte buffer

Browse Source
This commit is contained in:
Edward Capriolo
2015-01-09 11:38:15 -05:00
parent b18ad35f17
commit ab5ceac638
1 changed files with 0 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/com/google/code/gossip/manager/impl/SendMembersActiveGossipThread.java
View File

@ -13,7 +13,6 @@ import com.google.code.gossip.GossipService;
import com.google.code.gossip.LocalGossipMember; import com.google.code.gossip.LocalGossipMember;
import com.google.code.gossip.manager.ActiveGossipThread; import com.google.code.gossip.manager.ActiveGossipThread;
import com.google.code.gossip.manager.GossipManager; import com.google.code.gossip.manager.GossipManager;
import com.sun.xml.internal.ws.util.ByteArrayBuffer;
abstract public class SendMembersActiveGossipThread extends ActiveGossipThread { abstract public class SendMembersActiveGossipThread extends ActiveGossipThread {
@ -73,21 +72,10 @@ abstract public class SendMembersActiveGossipThread extends ActiveGossipThread {
GossipService.debug("Sending message ("+packet_length+" bytes): " + jsonArray.toString()); GossipService.debug("Sending message ("+packet_length+" bytes): " + jsonArray.toString());
ByteArrayBuffer byteBuffer = new ByteArrayBuffer();
// Write the first 4 bytes with the length of the rest of the packet.
byteBuffer.write(length_bytes);
// Write the json data.
byteBuffer.write(json_bytes);
byte[] buf = byteBuffer.getRawData();
/*
ByteBuffer byteBuffer = ByteBuffer.allocate(4 + json_bytes.length); ByteBuffer byteBuffer = ByteBuffer.allocate(4 + json_bytes.length);
byteBuffer.put(length_bytes); byteBuffer.put(length_bytes);
byteBuffer.put(json_bytes); byteBuffer.put(json_bytes);
byte[] buf = byteBuffer.array(); byte[] buf = byteBuffer.array();
*/
DatagramSocket socket = new DatagramSocket(); DatagramSocket socket = new DatagramSocket();
DatagramPacket datagramPacket = new DatagramPacket(buf, buf.length, dest, member.getPort()); DatagramPacket datagramPacket = new DatagramPacket(buf, buf.length, dest, member.getPort());