anchor.diff:      riak_core:wait_for_service(riak_kv),
       ok.
   
  +%% @doc Performs generic, riak_kv-specific and test-specific cleanup
  +%% when used within a test fixture. This includes stopping dependent
  +%% applications, stopping distributed Erlang, and killing pernicious
  +%% processes. The given `CleanupFun' will be called with the argument
  +%% `stop' before other components are stopped.
  +%%
  +%% @see common_cleanup/2, dep_apps/2, do_dep_apps/2
  +-spec cleanup(Test::string(), CleanupFun::fun((stop) -> any()), SetupResult::setup | atom()) -> ok.
   cleanup(Test, CleanupFun, setup) ->
       %% Remove existing ring files so we have a fresh ring
       os:cmd("rm -rf " ++ Test ++ "/ring"),
  
positive.code:                     _ ->
                          application:set_env(lager, handlers, [{lager_console_backend, debug}])
                  end;
             (unload) ->
                  %% TODO: Remove this when the deregistration PR gets merged
                  Services = riak_api_pb_service:dispatch_table(),
                  NewServices = lists:foldl(
                                  fun dict:erase/2,
  
negative.code:     Mod:terminate(reason, statename, state),
      Mod:code_change(oldvsn, statename, state, extra).
  
  %% @doc Stop a running pid - unlink and exit(kill) the process
  stop_process(undefined) ->
      ok;
  stop_process(RegName) when is_atom(RegName) ->
  