anchor.diff:  connect_nodes([], _DCID, _LogReaders, _Publishers, _Desc, _Retries) ->
       ok;
   connect_nodes(_Nodes, _DCID, _LogReaders, _Publishers, Desc, 0) ->
  -    ok = forget_dc(Desc),
  +    ok = forget_dcs([Desc]),
       {error, connection_error};    
   connect_nodes([Node|Rest], DCID, LogReaders, Publishers, Desc, Retries) ->
       case rpc:call(Node, inter_dc_query, add_dc, [DCID, LogReaders], ?COMM_TIMEOUT) of
  
positive.code:     logreaders = LogReaders
    }}.
  
  -spec observe_dc(#descriptor{}) -> ok | inter_dc_conn_err().
  observe_dc(Desc = #descriptor{dcid = DCID, partition_num = PartitionsNumRemote, publishers = Publishers, logreaders = LogReaders}) ->
      PartitionsNumLocal = dc_utilities:get_partitions_num(),
      case PartitionsNumRemote == PartitionsNumLocal of
  	false ->
  
negative.code: -export([
    get_descriptor/0,
    start_bg_processes/1,
    observe_dcs_sync/1,
    dc_successfully_started/0,
    check_node_restart/0,
    forget_dcs/1,
    drop_ping/1]).
  
  