anchor.diff:           add_with_meta/5, add_with_meta/7,
            delete_with_meta/5, delete_with_meta/4,
            connect_and_send_isasl_refresh/0,
  -         create_new_checkpoint/2]).
  +         create_new_checkpoint/2,
  +         eval/2]).
   
   -include("mc_constants.hrl").
   -include("mc_entry.hrl").
  
positive.code: -define(CHECK_INTERVAL, 10000).
  -define(CHECK_WARMUP_INTERVAL, 500).
  -define(VBUCKET_POLL_INTERVAL, 100).
  -define(TIMEOUT, ns_config_ets_dup:get_timeout(ns_memcached_outer, 60000)).
  -define(TIMEOUT_OPEN_CHECKPOINT, ns_config_ets_dup:get_timeout(ns_memcached_open_checkpoint, 60000)).
  -define(TIMEOUT_HEAVY, ns_config_ets_dup:get_timeout(ns_memcached_outer_heavy, 60000)).
  
negative.code:     do_call(server(Bucket),
              {create_new_checkpoint, VBucket},
              ?TIMEOUT_HEAVY).
  
  eval(Bucket, Fn) ->
      Ref = make_ref(),
      case do_call(server(Bucket), {eval, Fn, Ref}, ?EVAL_TIMEOUT) of
          {thrown, Ref, T, E, Stack} ->
              erlang:raise(T, E, Stack);
          V ->
              V
      end.
  
  %% @doc send a sync command to memcached instance
  -spec sync(bucket_name(), binary(), integer(), integer()) ->
  