anchor.diff:  %% @doc Kill any replication for a given destination node and vbucket.
   -spec kill_replica(module(), bucket_name(), node(), node(), vbucket_id()) -> ok.
   kill_replica(Policy, Bucket, SrcNode, DstNode, VBucket) ->
  +    assert_is_master_node(),
  +
       case get_replicator(Policy, Bucket, SrcNode, DstNode) of
           undefined ->
               ok;
  
positive.code: 
  -spec kill_all_children(module(), bucket_name(), node() | [node()]) -> ok.
  kill_all_children(Policy, Bucket, Node) when is_atom(Node) ->
      try children(Policy, Bucket, Node) of
          Children ->
              lists:foreach(
                fun (Child) ->
                        kill_child(Policy, Bucket, Node, Child)
                end, Children)
      catch exit:{noproc, _} ->
              %% If the supervisor isn't running, obviously there's no
              %% replication.
              ok
      end;
  kill_all_children(Policy, Bucket, Nodes) ->
      try
          misc:parallel_map(
            fun (Node) ->
                    kill_all_children(Policy, Bucket, Node)
            end, Nodes, ?RPC_TIMEOUT)
      catch
          exit:timeout ->
  
negative.code: -spec stop_replications(module(), bucket_name(),
                          node(), node(), [vbucket_id()]) -> ok.
  stop_replications(Policy, Bucket, SrcNode, DstNode, VBuckets0) ->
      assert_is_master_node(),
  
      VBuckets = ordsets:from_list(VBuckets0),
  
      Node = Policy:supervisor_node(SrcNode, DstNode),
  