anchor.diff:  init([ZKHost, ZKPort, Framework, Cluster]) ->
       process_flag(trap_exit, true),
       {ok, ZK} = erlzk:connect([{ZKHost, ZKPort}], 30000),
  -    case do_configure(ZK, Framework, Cluster) of
  -        {error, Reason} ->
  -            lager:error("No nodes are available: ~p", [Reason]);
  -        _ -> ok
  -    end,
  +    do_configure(ZK, Framework, Cluster),
       {ok, #state{zk=ZK, framework=Framework, cluster=Cluster}}.
   
   handle_call({get_status}, _From,
  
positive.code:     F1 = fun(CNode, Acc) ->
          ZKNode1 = lists:flatten(io_lib:format("~s/~s",[ZKNode0, CNode])),
          NodeJson = get_data(ZK, ZKNode1),
          {struct,[{<<"NodeName">>,NodeName}]} = mochijson2:decode(NodeJson),
          [_, Host] = string:tokens(binary_to_list(NodeName), "@"),
          [{list_to_atom(binary_to_list(NodeName)), Host}|Acc] end,
      NodeNames = lists:foldl(F1, [], CNodes),
  
      F2 = fun({NodeName, Host}, Acc) ->
          {_, HTTPPort} = http_listener(NodeName),
          {_, PBPort} = pb_listener(NodeName),
          [[{name, NodeName},
           {protobuf,
             [{host, list_to_binary(Host)}, {port, PBPort}]},
           {http,
              [{host, list_to_binary(Host)}, {port, HTTPPort}]}]|Acc] end,
      Nodes = lists:foldl(F2, [], NodeNames),
      Nodes.
  
  do_synchronize_riak_nodes(ZK, ZKNode) ->
  
negative.code:             []
      end.
  
  % remote(N, M, F, A) ->
  %     safe_rpc(N, M, F, A, 60000).
  %
  % safe_rpc(Node, Module, Function, Args, Timeout) ->
  %     try rpc:call(Node, Module, Function, Args, Timeout) of
  %         Result ->
  %             Result
  %     catch
  %         'EXIT':{noproc, _NoProcDetails} ->
  %             {badrpc, rpc_process_down}
  %     end.
  
  riak_node_is_available(_, []) -> false;
  riak_node_is_available(Id, [[{name, Id}|_]|_]) -> true;
  riak_node_is_available(Id, [[{name, _}|_]|Rest]) ->
      riak_node_is_available(Id, Rest).
  
  do_configure(ZK, Framework, Cluster) ->
      ZKNode = coordinated_nodes_zknode(Framework, Cluster),
      do_synchronize_riak_nodes(ZK, ZKNode),
      do_watch_riak_nodes(ZK, ZKNode).
  