anchor.diff:      %% Find transaction record.
       case ets:lookup(?COORDINATING_TRANSACTIONS, Id) of 
           [{_Id, #transaction{participants=Participants, committed=Committed0} = Transaction}] ->
  -            lager:info("Received commit_ack from node ~p at node: ~p", [FromNode, node()]),
  +            partisan_logger:info("Received commit_ack from node ~p at node: ~p", [FromNode, node()]),
   
               %% Update committed.
               Committed = lists:usort(Committed0 ++ [FromNode]),
  
positive.code:     %% Find transaction record.
      case ets:lookup(?COORDINATING_TRANSACTIONS, Id) of 
          [{_Id, #transaction{coordinator_status=CoordinatorStatus, participants=Participants, precommitted=Precommitted, from=From} = Transaction0}] ->
              lager:info("Coordinator timeout when participant ~p was in the ~p state.", [node(), CoordinatorStatus]),
  
              case CoordinatorStatus of 
                  commit_authorized ->
                      lager:info("Coordinator ~p in commit_authorized state, moving to abort.", [node()]),
  
                      %% Update local state.
                      Transaction = Transaction0#transaction{coordinator_status=aborting},
                      true = ets:insert(?COORDINATING_TRANSACTIONS, {Id, Transaction}),
  
                      %% Reply to caller.
                      lager:info("Aborting transaction: ~p", [Id]),
                      partisan_pluggable_peer_service_manager:forward_message(From, error),
  
                      %% Send notification to abort.
                      lists:foreach(fun(N) ->
                          lager:info("~p: sending abort message to node ~p: ~p", [node(), N, Id]),
                          partisan_pluggable_peer_service_manager:forward_message(N, undefined, ?MODULE, {abort, Transaction}, [])
                      end, membership(Participants)),
  
                      ok;
                  commit_finalizing ->
                      lager:info("Coordinator ~p in commit_finalizing state, moving to abort.", [node()]),
  
                      %% Have we made a decision?
                      case lists:usort(Participants) =:= lists:usort(Precommitted) of 
  
negative.code: 
      %% Send prepare message to all participants including ourself.
      lists:foreach(fun(N) ->
          partisan_logger:info("~p: sending prepare message to node ~p: ~p", [node(), N, Message]),
          partisan_pluggable_peer_service_manager:forward_message(N, undefined, ?MODULE, {prepare, Transaction}, [])
      end, membership(Membership)),
  
  