Repository: cassandra Updated Branches: refs/heads/trunk 906fd4d81 -> d92932ac4
Notify whenever we replace an SSTableReader Patch by marcuse; reviewed by yukim for CASSANDRA-8034 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/31235bc3 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/31235bc3 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/31235bc3 Branch: refs/heads/trunk Commit: 31235bc39e662065f06eca0909be0f00d8bc69e9 Parents: 97b1d9f Author: Marcus Eriksson <marc...@apache.org> Authored: Wed Oct 1 17:17:10 2014 +0200 Committer: Marcus Eriksson <marc...@apache.org> Committed: Thu Oct 2 10:53:16 2014 +0200 ---------------------------------------------------------------------- CHANGES.txt | 1 + src/java/org/apache/cassandra/db/DataTracker.java | 3 +++ 2 files changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/31235bc3/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index d3a0ba2..306fdca 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 2.1.1 + * Send notification when opening compaction results early (CASSANDRA-8034) * Make native server start block until properly bound (CASSANDRA-7885) * (cqlsh) Fix IPv6 support (CASSANDRA-7988) * Ignore fat clients when checking for endpoint collision (CASSANDRA-7939) http://git-wip-us.apache.org/repos/asf/cassandra/blob/31235bc3/src/java/org/apache/cassandra/db/DataTracker.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/DataTracker.java b/src/java/org/apache/cassandra/db/DataTracker.java index 24ea9dd..8d66e2a 100644 --- a/src/java/org/apache/cassandra/db/DataTracker.java +++ b/src/java/org/apache/cassandra/db/DataTracker.java @@ -368,6 +368,9 @@ public class DataTracker } while (!view.compareAndSet(currentView, newView)); + if (!oldSSTables.isEmpty()) + notifySSTablesChanged(oldSSTables, newSSTables, OperationType.COMPACTION); + for (SSTableReader sstable : newSSTables) sstable.setTrackedBy(this);
