anchor.diff:              Store = write(Key, Value, Store0),
   
               %% Forward to collaboration message.
  -            Myself = myself(),
  -            forward_message(Collaborator, {collaborate, From, Myself, Key, Value}),
  +            Myself = pnode(),
  +            psend(Collaborator, {collaborate, From, Myself, Key, Value}),
               lager:info("~p: node ~p sent replication request for key ~p with value ~p", [?MODULE, node(), Key, Value]),
   
               %% Wait for collaboration ack before proceeding for n-host resilience (n = 2).
  
positive.code:     lager:info("~p: node ~p received forwarded read for key ~p and returning value ~p", [?MODULE, node(), Key, Value]),
  
      %% Send the response to the caller.
      gen_server:reply(From, {ok, Value}),
  
      %% No need to send acknowledgement back to the forwarder: 
      %%  - not needed for control flow.
  
negative.code:     dict:store(Key, Value, Store).
  
  %% @private
  pnode() ->
      node().
  
  %% @private
  pself() ->
      partisan_util:pid().