anchor.diff:      NodeConfig = [ {monitor_master, true},
                      {startup_functions, [ {code, set_path, [CodePath]} ]}],
   
  -    case ct_slave:start(Name, NodeConfig) of
  -        {ok, Node} ->
  -            PrivDir = proplists:get_value(priv_dir, Config),
  -            NodeDir = filename:join([PrivDir, Node, Case]),
  -
  -            %% Manually force sasl loading, and disable the logger.
  -            ok = rpc:call(Node, application, load, [sasl]),
  -            ok = rpc:call(Node, application, set_env,
  -                          [sasl, sasl_error_logger, false]),
  -            ok = rpc:call(Node, application, start, [sasl]),
  -
  -            ok = rpc:call(Node, application, load, [plumtree]),
  -            ok = rpc:call(Node, application, load, [partisan]),
  -            ok = rpc:call(Node, application, load, [lager]),
  -            ok = rpc:call(Node, application, load, [lasp]),
  -            ok = rpc:call(Node, application, set_env, [sasl,
  -                                                       sasl_error_logger,
  -                                                       false]),
  -            ok = rpc:call(Node, application, set_env, [lasp,
  -                                                       instrumentation,
  -                                                       false]),
  -            ok = rpc:call(Node, application, set_env, [lager,
  -                                                       log_root,
  -                                                       NodeDir]),
  -            ok = rpc:call(Node, application, set_env, [plumtree,
  -                                                       plumtree_data_dir,
  -                                                       NodeDir]),
  -            ok = rpc:call(Node, application, set_env, [plumtree,
  -                                                       peer_service,
  -                                                       partisan_peer_service]),
  -            ok = rpc:call(Node, application, set_env, [plumtree,
  -                                                       broadcast_exchange_timer,
  -                                                       ?EXCHANGE_TIMER]),
  -            ok = rpc:call(Node, application, set_env, [plumtree,
  -                                                       broadcast_mods,
  -                                                       [lasp_plumtree_broadcast_distribution_backend]]),
  -            ok = rpc:call(Node, application, set_env, [lasp,
  -                                                       data_root,
  -                                                       NodeDir]),
  -            try
  -                {ok, _} = rpc:call(Node, application, ensure_all_started, [lasp])
  -            catch
  -                _:Error ->
  -                    lager:info("Node initialization for ~p failed: ~p", [Node, Error]),
  -                    lists:foreach(fun(N) ->
  -                                          WebPort = rpc:call(N,
  -                                                             lasp_config,
  -                                                             get,
  -                                                             [web_port, undefined]),
  -                                          PeerPort = rpc:call(N,
  -                                                              lasp_config,
  -                                                              get,
  -                                                              [peer_port, undefined]),
  -                                          lager:info("Node: ~p PeerPort: ~p WebPort ~p", [N, PeerPort, WebPort])
  -                                  end, proplists:get_value(started, Config) ++ [Node]),
  -                    ct:fail(can_not_initialize_node)
  -            end,
  -            ok = wait_until(fun() ->
  -                            case rpc:call(Node, lasp_peer_service, members, []) of
  -                                {ok, _Res} -> true;
  -                                _ -> false
  -                            end
  -                    end, 60, 500),
  -            Node;
  -        {error, already_started, Node} ->
  -            ct_slave:stop(Name),
  -            wait_until_offline(Node),
  -            start_node(Name, Config, Case)
  -    end.
  +    Node = start_slave(Name, NodeConfig, Case),
  +    load_lasp(Node, Config, Case),
  +    start_lasp(Node, Config).
   
   partition_cluster(ANodes, BNodes) ->
       pmap(fun({Node1, Node2}) ->
  
positive.code:                   lasp_peer_service,
                    join,
                    [{N, {127, 0, 0, 1}, PeerPort}]).
  
negative.code:          puniform/1,
           join_to/2,
           partition_cluster/2,
           heal_cluster/2,
           load_lasp/3,
           start_lasp/2]).
  
  -define(EXCHANGE_TIMER, 120).
  
  