cassandra-pr mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aweisberg <...@git.apache.org>
Subject [GitHub] cassandra pull request #265: 14705
Date Mon, 10 Sep 2018 19:22:42 GMT
Github user aweisberg commented on a diff in the pull request:

    https://github.com/apache/cassandra/pull/265#discussion_r216442898
  
    --- Diff: src/java/org/apache/cassandra/service/reads/repair/BlockingReadRepair.java ---
    @@ -53,15 +53,16 @@
         protected final Queue<BlockingPartitionRepair> repairs = new ConcurrentLinkedQueue<>();
         private final int blockFor;
     
    -    BlockingReadRepair(ReadCommand command, P replicaPlan, long queryStartNanoTime)
    +    BlockingReadRepair(ReadCommand command, ReplicaPlan.Shared<P> replicaPlan,
long queryStartNanoTime)
         {
             super(command, replicaPlan, queryStartNanoTime);
    -        this.blockFor = replicaPlan.consistencyLevel().blockFor(cfs.keyspace);
    +        this.blockFor = replicaPlan().consistencyLevel().blockFor(cfs.keyspace);
         }
     
         public UnfilteredPartitionIterators.MergeListener getMergeListener(P replicaPlan)
         {
    -        return new PartitionIteratorMergeListener<>(replicaPlan, command, this.replicaPlan.consistencyLevel(),
this);
    +        // TODO: why are we referencing a different replicaPlan here?
    --- End diff --
    
    TODO indeed looking at DataResolver it's modifying the replica plan without updating the
shared one https://github.com/apache/cassandra/pull/265/files#diff-7e5dd130632299911e49b12afe86c85aR121
    So they would be different?


---

---------------------------------------------------------------------
To unsubscribe, e-mail: pr-unsubscribe@cassandra.apache.org
For additional commands, e-mail: pr-help@cassandra.apache.org


Mime
View raw message