anchor.diff:  init(_) ->
       process_flag(trap_exit, true),
       net_kernel:monitor_nodes(true),
  +    Live = [node() | nodes()],
       ?DOC_TO_REP = ets:new(?DOC_TO_REP, [named_table, set, public]),
       ?REP_TO_STATE = ets:new(?REP_TO_STATE, [named_table, set, public]),
       ?DB_TO_SEQ = ets:new(?DB_TO_SEQ, [named_table, set, public]),
  
positive.code: process_update(State, DbName, {Change}) ->
      {RepProps} = JsonRepDoc = get_json_value(doc, Change),
      DocId = get_json_value(<<"_id">>, RepProps),
      case {owner(DbName, DocId), get_json_value(deleted, Change, false)} of
      {_, true} ->
          rep_doc_deleted(DbName, DocId),
          State;
  
negative.code:     couch_event:stop_listener(Listener).
  
  
  code_change(1, State, _Extra) ->
      {ok, erlang:append_element(State, [node() | nodes()])};
  code_change(_OldVsn, State, _Extra) ->
      {ok, State}.
  
  