anchor.diff:      process_flag(trap_exit, true),
   
       Epoch = maybe_load_epoch_from_disk(),
  -    
  +
       Myself = myself(),
       Active = sets:add_element(Myself, sets:new()),
       Passive = sets:new(),
       Connections = partisan_peer_service_connections:new(),
  -    
  +
       SentMessageMap = dict:new(),
       RecvMessageMap = dict:new(),
   
  
positive.code:                #state{myself=Myself0,
                        active=Active0,
                        tag=Tag0,
                        sent_message_map=SentMessageMap0,
                        recv_message_map=RecvMessageMap0}=State0) ->
      lager:debug("Node ~p received the JOIN message from ~p, epoch ~p",
  
negative.code:             true ->
                  case is_addable(DisconnectId, Peer, SentMessageMap0) of
                      true ->
                          case partisan_peer_service_connections:find(Peer, Connections) of
                              {ok, _Entries} ->
                                  lager:debug("Node ~p accepted neighbor peer ~p",
                                              [Myself0, Peer]),
                                  LastDisconnectId = get_current_id(Peer, RecvMessageMap0),
                                  %% Reply to acknowledge the neighbor was accepted.
                                  do_send_message(
                                    Peer,
                                    {neighbor_accepted, Myself0, Tag0, LastDisconnectId, Exchange_Ack},
                                    Connections),
  
                                  State1 = add_to_active_view(Peer, PeerTag,
                                                              State0#state{connections = Connections}),
  
                                  lager:debug("Node ~p active view: ~p",
                                              [Myself0, members(State1#state.active)]),
  
                                  State1;
                              {error, not_found} ->
                                  %% the connections does not change, the peer can not be connected
                                  State0
                          end;
                      false ->
                          lager:debug("Node ~p rejected neighbor peer ~p",
                                     [Myself0, Peer]),
  