anchor.diff:       {"javascript_bucket_map_reduce_test()",
         ?_test(begin
                    reset_riak(),
  -                 {ok, Pid} = start_link(?TEST_IP, ?TEST_PORT),
  +                 {ok, Pid} = start_link(test_ip(), test_port()),
                    Store = fun({K,V}) ->
                                    O=riakc_obj:new(<<"bucket">>, K),
                                    ?MODULE:put(Pid,riakc_obj:update_value(O, V, "application/json"))
  
positive.code:     %% Until there is a good way to empty the vnodes, require the
      %% test to run with ETS and kill the vnode master/sup to empty all the ETS tables
      %% and the ring manager to remove any bucket properties
      ok = rpc:call(?TEST_RIAK_NODE, application, set_env, [riak_kv, storage_backend, riak_kv_ets_backend]),
  
      %% Restart the vnodes so they come up with ETS
      ok = supervisor:terminate_child({riak_kv_sup, ?TEST_RIAK_NODE}, riak_kv_vnode_master),
      ok = supervisor:terminate_child({riak_core_sup, ?TEST_RIAK_NODE}, riak_core_vnode_sup),
      {ok, _} = supervisor:restart_child({riak_core_sup, ?TEST_RIAK_NODE}, riak_core_vnode_sup),
      {ok, _} = supervisor:restart_child({riak_kv_sup, ?TEST_RIAK_NODE}, riak_kv_vnode_master),
      
      %% Now reset the ring so bucket properties are default
      Ring = rpc:call(?TEST_RIAK_NODE, riak_core_ring, fresh, []),
      ok = rpc:call(?TEST_RIAK_NODE, riak_core_ring_manager, set_my_ring, [Ring]).
  
  
  riak_pb_listener_pid() ->
      Children = supervisor:which_children({riak_kv_sup, ?TEST_RIAK_NODE}),
      hd([Pid || {Mod,Pid,_,_} <- Children, Mod == riak_kv_pb_listener]).
  
  pause_riak_pb_listener() ->
      Pid = riak_pb_listener_pid(),
      rpc:call(?TEST_RIAK_NODE, sys, suspend, [Pid]).
  
  resume_riak_pb_listener() ->
      Pid = riak_pb_listener_pid(),
      rpc:call(?TEST_RIAK_NODE, sys, resume, [Pid]).
  
  kill_riak_pb_sockets() ->
      case supervisor:which_children({riak_kv_pb_socket_sup, ?TEST_RIAK_NODE}) of
          [] ->
              ok;
          Children ->
              Pids = [Pid || {_,Pid,_,_} <- Children],
              [rpc:call(?TEST_RIAK_NODE, erlang, exit, [Pid, kill]) || Pid <- Pids],
              erlang:yield(),
              kill_riak_pb_sockets()
      end.
  
negative.code:      {"javascript_source_map_test()",
        ?_test(begin
                   reset_riak(),
                   {ok, Pid} = start_link(test_ip(), test_port()),
                   B = <<"bucket">>,
                   K = <<"foo">>,
                   O=riakc_obj:new(B, K),
  