anchor.diff:      LinkKey = <<"yo">>,
   
       {setup,
  -     prepare_runtime(),
  -     teardown_runtime(),
  +     setup(),
  +     cleanup(),
        fun(_) ->
            [
             ?_test(
  
positive.code:     riak_pipe:eoi(Pipe),
      ok.
  
  setup_demo_test_() ->
      {foreach,
       prepare_runtime(),
       teardown_runtime(),
       [
        fun(_) ->
                {"Setup demo test",
                 fun() ->
                         Num = 5,
                         {ok, C} = riak:local_client(),
                         [ok = C:put(riak_object:new(
                                       <<"foonum">>,
                                       list_to_binary("bar"++integer_to_list(X)),
                                       X)) 
                          || X <- lists:seq(1, Num)],
                         [{ok, _} = C:get(<<"foonum">>,
                                        list_to_binary("bar"++integer_to_list(X)))
                          || X <- lists:seq(1, Num)],
                         ok
                 end}
        end
       ]
      }.
  
  compat_basic1_test_() ->
      IntsBucket = <<"foonum">>,
      ReduceSumFun = fun(Inputs, _) -> [lists:sum(Inputs)] end,
  
negative.code: -module(mapred_test).
  
  -include_lib("eunit/include/eunit.hrl").
  -compile(export_all).
  
  setup() ->
      riak_kv_test_util:common_setup(?MODULE, fun configure/1).
  
  cleanup() ->
      riak_kv_test_util:common_cleanup(?MODULE, fun configure/1).
  
  configure(load) ->
      KVSettings = [{storage_backend, riak_kv_memory_backend},
                    {test, true},
                    {vnode_vclocks, true},
                    {pb_ip, "0.0.0.0"},
                    {pb_port, 48087}, % arbitrary #
                    {map_js_vm_count, 4},
                    {reduce_js_vm_count, 3}],
      CoreSettings = [{handoff_ip, "0.0.0.0"},
                       {handoff_port, 9183},
                       {ring_creation_size, 16}],
      [ application:set_env(riak_core, K, V) || {K,V} <- CoreSettings ],
      [ application:set_env(riak_kv, K, V) || {K,V} <- KVSettings ],
      ok;
  configure(unload) ->
      application:set_env(riak_api, services, dict:new());
  configure(start) ->
      riak_core:wait_for_service(riak_pipe);
  configure(_) ->
      ok.
  
  inputs_gen_seq(Pipe, Max, _Timeout) ->
      [riak_pipe:queue_work(Pipe, X) || X <- lists:seq(1, Max)],
  