anchor.diff:  put(Value, Next, Key, Table) ->
       [{_Key,V}] = ets:lookup(Table, Key),
       Threads = V#dv.waiting_threads,
  -    BindingList = V#dv.bindingList,
  +    BindingList = V#dv.binding_list,
       V1 = #dv{value= Value, next =Next, lazy=false, bounded= true},
       ets:insert(Table, {Key, V1}),
       notifyAll(BindingList, Value),
  
positive.code:     [{IndexNode, _Type}] = PrefList,
      riak_core_vnode_master:command(IndexNode, {replyFetch, Id, FromP, DV}, derflowdis_vnode_master).
  
  
  notifyValue(Id, Value) ->
      DocIdx = riak_core_util:chash_key({?BUCKET, term_to_binary(Id)}),
      PrefList = riak_core_apl:get_primary_apl(DocIdx, 1, derflowdis),
      [{IndexNode, _Type}] = PrefList,
      riak_core_vnode_master:command(IndexNode, {notifyValue, Id, Value}, derflowdis_vnode_master).
  	
  
  
  get_new_id() -> 
      DocIdx = riak_core_util:chash_key({?BUCKET, term_to_binary(now())}),
      PrefList = riak_core_apl:get_primary_apl(DocIdx, 1, derflowdis),
      [{IndexNode, _Type}] = PrefList,
      riak_core_vnode_master:sync_spawn_command(IndexNode, get_new_id, derflowdis_vnode_master).
  
  wait_needed(Id) -> 
      DocIdx = riak_core_util:chash_key({?BUCKET, term_to_binary(Id)}),
      PrefList = riak_core_apl:get_primary_apl(DocIdx, 1, derflowdis),
      [{IndexNode, _Type}] = PrefList,
  
negative.code: execute_and_put(F, Arg, Next, Key, Table) ->
      [{_Key,V}] = ets:lookup(Table, Key),
      Threads = V#dv.waiting_threads,
      BindingList = V#dv.binding_list,
      Value = F(Arg),
      V1 = #dv{value= Value, next =Next, lazy=false,bounded= true},
      ets:insert(Table, {Key, V1}),
  