Updated Branches: refs/heads/trunk d7468ea14 -> e49d140bb
fix for logging events' correct thread name; patch by yukim reviewed by David Alves for CASSANDRA-4599 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/e49d140b Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/e49d140b Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/e49d140b Branch: refs/heads/trunk Commit: e49d140bb72264a503a634d5603c25766c78e50d Parents: d7468ea Author: Yuki Morishita <[email protected]> Authored: Fri Aug 31 18:41:47 2012 -0500 Committer: Yuki Morishita <[email protected]> Committed: Fri Aug 31 18:41:47 2012 -0500 ---------------------------------------------------------------------- .../apache/cassandra/tracing/TracingAppender.java | 3 ++- 1 files changed, 2 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/e49d140b/src/java/org/apache/cassandra/tracing/TracingAppender.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/tracing/TracingAppender.java b/src/java/org/apache/cassandra/tracing/TracingAppender.java index 25b7056..3643adf 100644 --- a/src/java/org/apache/cassandra/tracing/TracingAppender.java +++ b/src/java/org/apache/cassandra/tracing/TracingAppender.java @@ -34,6 +34,7 @@ public class TracingAppender extends AppenderSkeleton return; final int elapsed = state.elapsed(); + final String threadName = event.getThreadName(); StageManager.getStage(Stage.TRACING).execute(new WrappedRunnable() { public void runMayThrow() throws TimedOutException, UnavailableException @@ -43,7 +44,7 @@ public class TracingAppender extends AppenderSkeleton CFMetaData cfMeta = CFMetaData.TraceEventsCf; ColumnFamily cf = ColumnFamily.create(cfMeta); addColumn(cf, buildName(cfMeta, eventId, bytes("source")), FBUtilities.getBroadcastAddress()); - addColumn(cf, buildName(cfMeta, eventId, bytes("thread")), event.getThreadName()); + addColumn(cf, buildName(cfMeta, eventId, bytes("thread")), threadName); addColumn(cf, buildName(cfMeta, eventId, bytes("happened_at")), event.getTimeStamp()); addColumn(cf, buildName(cfMeta, eventId, bytes("source_elapsed")), elapsed); addColumn(cf, buildName(cfMeta, eventId, bytes("activity")), event.getMessage());
