anchor.diff:  -spec new_buffer() -> buffer().
   new_buffer() -> sets:new().
   
  -%%%%%%%%%
  +-spec remove_query_commans(buffer()) -> buffer().
  +remove_query_commans(Buffer) -> sets:filter(fun is_update/1, Buffer).
  +
  +%%%%%%%%%%%%%%%%%%%%%
  +%% Access of module State
  +%%%%%%%%%%%%%%%%%%%%%
   
   -spec tablename(state()) -> ?PDB:db().
   tablename(State) -> element(1, State).
  -
   
   -spec get_load(state()) -> non_neg_integer().
   get_load(State) -> ?PDB:get_load(State).
  
positive.code:     accept_val = new_buffer() :: buffer(),
      active = false :: boolean(),
  
      crdt_type = null :: null | crdt:crdt_module(),
      cmd_set = new_buffer() :: buffer(),
      crdt = null :: null | crdt:crdt(),
      replies = #replies{} :: #replies{} | done,
  
      loop_val = null :: buffer(),
      loop_iter = null :: non_neg_integer(),
  
      prop_wait_list = [] :: [tuple()]
    }).
  
  %% More sensible management of query commands... these do not have to be sent
  %% to remotely as they are noops for updates?
  
  -type buffer() :: set:sets(buffer_element()).
  -type buffer_element() ::
    {comm:mypid(),
      {qfun, crdt:query_fun() | [crdt:query_fun()]}
      | [crdt:update_fun()]}.
  
  %% initialize: return initial state.
  -spec init(atom() | tuple()) -> state().
  
negative.code: 
  -record(pstate,
    {
      cid = 0 :: non_neg_integer(), %% used to give command unique identifier
  
      %% core protocol variables 
      seq = 0 :: non_neg_integer(),
      max_seq = -1 :: integer(),
  
  