Repository: apex-core Updated Branches: refs/heads/master 6f0dffaf9 -> 1e9896bb4
APEXCORE-610 Avoid multiple calls to getBytes. Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/44bc4b7a Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/44bc4b7a Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/44bc4b7a Branch: refs/heads/master Commit: 44bc4b7a58298e228e749b58288e30187736ae86 Parents: 7ea7f60 Author: Tushar R. Gosavi <[email protected]> Authored: Tue Jan 17 14:08:13 2017 +0530 Committer: Tushar R. Gosavi <[email protected]> Committed: Tue Jan 17 14:08:13 2017 +0530 ---------------------------------------------------------------------- .../main/java/com/datatorrent/bufferserver/packet/Tuple.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-core/blob/44bc4b7a/bufferserver/src/main/java/com/datatorrent/bufferserver/packet/Tuple.java ---------------------------------------------------------------------- diff --git a/bufferserver/src/main/java/com/datatorrent/bufferserver/packet/Tuple.java b/bufferserver/src/main/java/com/datatorrent/bufferserver/packet/Tuple.java index a75c7f1..de3cae8 100644 --- a/bufferserver/src/main/java/com/datatorrent/bufferserver/packet/Tuple.java +++ b/bufferserver/src/main/java/com/datatorrent/bufferserver/packet/Tuple.java @@ -95,9 +95,10 @@ public abstract class Tuple public static int writeString(String identifier, byte[] array, int offset) { - offset = VarInt.write(identifier.getBytes().length, array, offset); - System.arraycopy(identifier.getBytes(), 0, array, offset, identifier.getBytes().length); - return offset + identifier.getBytes().length; + byte[] identifierBytes = identifier.getBytes(); + offset = VarInt.write(identifierBytes.length, array, offset); + System.arraycopy(identifierBytes, 0, array, offset, identifierBytes.length); + return offset + identifierBytes.length; } protected int readVarInt()
