anchor.diff:  -export([handle/2]).
   
   -record(state, {labels_queue :: queue(),
  -                ops_dict :: dict(),
  +                ops,
  +                queue_len,
                   myid}).
                  
   reg_name(MyId) ->  list_to_atom(integer_to_list(MyId) ++ atom_to_list(?MODULE)). 
  
positive.code:     [{IndexNode, _Type}] = PrefList,
      saturn_proxy_vnode:propagate(IndexNode, BKey, Value, Clock).
  
  flush_queue([], S0) ->
      S0#state{labels_queue=queue:new()};
  
  flush_queue([Label|Rest]=Labels, S0=#state{ops_dict=Ops0, myid=MyId}) ->
      case Label#label.operation of
          remote_read ->
              Payload = Label#label.payload,
  
negative.code:                 false ->
                      noop
              end,
              true;
          update ->
              case ets:lookup(Ops, Label) of
                  [{Label, Value}] ->
                      ok = execute_operation(Label, Value),
                      true = ets:delete(Ops, Label),
                      true;
                  [] ->
                      lager:info("Operation not received for label: ~p", [Label]),
                      false
              end
      end.
  
  