Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #84 on avoiding stomp array copies

This commit is contained in:
Clebert Suconic 2015-07-20 14:58:39 +01:00
parent 94f84c43aa 8a90de6fbc
commit 96b559307c
3 changed files with 4 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/SimpleBytes.java
View File

@ -35,10 +35,8 @@ public class SimpleBytes
public String getString()
{
if (index == 0) return "";
byte[] realData = new byte[index];
System.arraycopy(contents, 0, realData, 0, realData.length);
return new String(realData, StandardCharsets.UTF_8);
return new String(contents, 0, index, StandardCharsets.UTF_8);
}
public void reset()

12
artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompDecoder.java
View File

@ -312,11 +312,7 @@ public class StompDecoder
{
if (inHeaderName)
{
byte[] data = new byte[pos - headerBytesCopyStart - 1];
System.arraycopy(workingBuffer, headerBytesCopyStart, data, 0, data.length);
headerName = new String(data);
headerName = new String(workingBuffer, headerBytesCopyStart, pos - headerBytesCopyStart - 1);
inHeaderName = false;
@ -339,11 +335,7 @@ public class StompDecoder
break outer;
}
byte[] data = new byte[pos - headerBytesCopyStart - 1];
System.arraycopy(workingBuffer, headerBytesCopyStart, data, 0, data.length);
String headerValue = new String(data);
String headerValue = new String(workingBuffer, headerBytesCopyStart, pos - headerBytesCopyStart - 1);
headers.put(headerName, headerValue);

5
artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompFrame.java
View File

@ -229,10 +229,7 @@ public class StompFrame
iBuffer++;
}
char[] total = new char[iBuffer];
System.arraycopy(buffer, 0, total, 0, iBuffer);
return new String(total);
return new String(buffer, 0, iBuffer);
}
public void setBody(String body)