@@ -292,44 +292,19 @@ func setupPartitionedRangeWithHandlers(
292292 return pr , nil
293293}
294294
295- func (pr * testClusterPartitionedRange ) deactivate () { pr .set (false ) }
296- func (pr * testClusterPartitionedRange ) activate () { pr .set (true ) }
295+ func (pr * testClusterPartitionedRange ) activate () { pr .set (true ) }
297296func (pr * testClusterPartitionedRange ) set (active bool ) {
298297 pr .mu .Lock ()
299298 defer pr .mu .Unlock ()
300299 pr .mu .partitioned = active
301300}
302301
303- func (pr * testClusterPartitionedRange ) addReplica (replicaID roachpb.ReplicaID ) {
304- pr .mu .Lock ()
305- defer pr .mu .Unlock ()
306- pr .mu .partitionedReplicas [replicaID ] = true
307- }
308-
309302func (pr * testClusterPartitionedRange ) addStore (storeID roachpb.StoreID ) {
310303 pr .mu .Lock ()
311304 defer pr .mu .Unlock ()
312305 pr .mu .partitionedStores [storeID ] = true
313306}
314307
315- func (pr * testClusterPartitionedRange ) removeStore (storeID roachpb.StoreID ) {
316- pr .mu .Lock ()
317- defer pr .mu .Unlock ()
318-
319- pr .mu .partitionedStores [storeID ] = false
320- }
321-
322- func (pr * testClusterPartitionedRange ) extend (
323- tc * testcluster.TestCluster ,
324- rangeID roachpb.RangeID ,
325- replicaID roachpb.ReplicaID ,
326- partitionedNode int ,
327- activated bool ,
328- funcs kvtestutils.UnreliableRaftHandlerFuncs ,
329- ) (* testClusterPartitionedRange , error ) {
330- return setupPartitionedRangeWithHandlers (tc , rangeID , replicaID , partitionedNode , activated , pr .handlers , funcs )
331- }
332-
333308// dropRaftMessagesFrom sets up a Raft message handler on the given server that
334309// drops inbound Raft messages from the given range and replica IDs. In addition
335310// to raft messages, StoreLiveness messages from the replica IDs' store are also
0 commit comments