anchor.diff:                                               ?log_error("Got unexpected exit signal in vbucket change txn body: ~p", [ExitMsg]),
                                                exit({txn_crashed, ExitMsg});
                                            {done, RV} ->
  -                                             RV;
  +                                             {ok, RV};
                                            {'$gen_call', {Pid, _} = From, get_downstream} ->
                                                gen_tcp:controlling_process(NewDownstream, Pid),
                                                gen_server:reply(From, {ok, NewDownstream}),
  
positive.code:     end.
  
  change_vbucket_filter(Bucket, SrcNode, #child_id{dest_node = DstNode} = ChildId, NewVBuckets) ->
      Lambda = quote_transform:lambda(fun (Bucket, SrcNode, ChildId, NewVBuckets) ->
                                              try ns_vbm_sup:have_local_change_vbucket_filter() of
                                                  true -> {ok, ns_vbm_sup:local_change_vbucket_filter(Bucket, SrcNode, ChildId, NewVBuckets)}
                                              catch error:undef ->
                                                      old_version
                                              end
                                      end),
      case rpc:call(SrcNode, erlang, apply, [Lambda, [Bucket, SrcNode, ChildId, NewVBuckets]]) of
          old_version ->
              kill_child(SrcNode, Bucket, ChildId),
              start_child(SrcNode, Bucket, NewVBuckets, DstNode);
          {ok, Ref} ->
              Ref
      end.
  
  %% @doc Set up replication from the given source node to a list of
  
negative.code:          local_change_vbucket_filter/4]).
  
  -export([init/1]).
  
  %%
  %% API
  