You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@htrace.apache.org by cm...@apache.org on 2015/02/22 03:18:54 UTC
incubator-htrace git commit: HTRACE-112. addendum: add missing diff
Repository: incubator-htrace
Updated Branches:
refs/heads/master 7b34b4242 -> 97e26a590
HTRACE-112. addendum: add missing diff
Project: http://git-wip-us.apache.org/repos/asf/incubator-htrace/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-htrace/commit/97e26a59
Tree: http://git-wip-us.apache.org/repos/asf/incubator-htrace/tree/97e26a59
Diff: http://git-wip-us.apache.org/repos/asf/incubator-htrace/diff/97e26a59
Branch: refs/heads/master
Commit: 97e26a59033d59a6ad25aae9b69cecd208dbc061
Parents: 7b34b42
Author: Colin P. Mccabe <cm...@apache.org>
Authored: Sat Feb 21 18:18:31 2015 -0800
Committer: Colin P. Mccabe <cm...@apache.org>
Committed: Sat Feb 21 18:18:31 2015 -0800
----------------------------------------------------------------------
.../main/java/org/apache/htrace/impl/LocalFileSpanReceiver.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-htrace/blob/97e26a59/htrace-core/src/main/java/org/apache/htrace/impl/LocalFileSpanReceiver.java
----------------------------------------------------------------------
diff --git a/htrace-core/src/main/java/org/apache/htrace/impl/LocalFileSpanReceiver.java b/htrace-core/src/main/java/org/apache/htrace/impl/LocalFileSpanReceiver.java
index e2ddad1..190d575 100644
--- a/htrace-core/src/main/java/org/apache/htrace/impl/LocalFileSpanReceiver.java
+++ b/htrace-core/src/main/java/org/apache/htrace/impl/LocalFileSpanReceiver.java
@@ -101,13 +101,15 @@ public class LocalFileSpanReceiver implements SpanReceiver {
*/
private final int WRITEV_SIZE = 20;
+ private final static ByteBuffer newlineBuf =
+ ByteBuffer.wrap(new byte[] { (byte)0xa });
+
/**
* Flushes a bufferedSpans array.
*/
private void doFlush(byte[][] toFlush, int len) throws IOException {
int bidx = 0, widx = 0;
ByteBuffer writevBufs[] = new ByteBuffer[2 * WRITEV_SIZE];
- ByteBuffer newlineBuf = ByteBuffer.wrap(new byte[] { (byte)0xa });
while (true) {
if (widx == writevBufs.length) {