anchor.diff:  tests_avail() ->
       %% [test_sane_result].
       [test_sane_result,
  -     test_join].
  -    %%  test_leave].
  +     test_join,
  +     test_leave].
   
   init_per_suite(Config) ->
       unittest_helper:init_per_suite(Config).
  
positive.code:     ok.
  
  test_leave(_Config) ->
      _ = api_vm:add_nodes(2),
      unittest_helper:wait_for_stable_ring(),
      unittest_helper:check_ring_size_fully_joined(4),
      ?proto_sched(start),
      Res = api_mr:start_job(get_wc_job_erl()),
      _ = api_vm:kill_nodes(2),
      unittest_helper:wait_for_stable_ring(),
      unittest_helper:check_ring_size_fully_joined(2),
      check_results(Res),
      ok.
  
  get_wc_job_erl() ->
  
negative.code: 
  add_data() ->
      Data = [{"1", "MapReduce allows for distributed processing of the map and reduction operations."}
              , {"3", "Provided each mapping operation can run independently, all maps may be performed in parallel."}
              , {"5", "This example data set contains one single word only once."}
              , {"7", "Now I am too lazy to construct another sentence that actually makes sense."}
             ],
      [api_tx:write(Key, {Key, Value}) || {Key, Value} <- Data],
      ok.
  