anchor.diff:  -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),
  
positive.code:   when Replica :: {SrcNode::node(), DstNode::node(), vbucket_id()},
         Replicas :: [Replica].
  set_replicas(Policy, Bucket, Replicas, AllNodes) when is_list(Replicas) ->
      Replicators = replicas_to_replicators(Replicas),
      do_set_replicas(Policy, Bucket, Replicators, AllNodes).
  
  
negative.code:    when Change :: {Type, SrcNode :: node(), DstNode :: node(), vbucket_id()},
          Type :: add_replica | kill_replica.
  apply_changes(Policy, Bucket, ChangeTuples) ->
      assert_is_master_node(),
  
      ?log_info("Applying changes:~n~p~n", [ChangeTuples]),
  
      %% In 1.8.1 we clearly know what nodes are affected by change
  