anchor.diff:  %%                                   {stop, Reason, State}
   %% @end
   %%--------------------------------------------------------------------
  -handle_info({index_update, _, Term, Term}, State) ->
  -    ?debug("~p received same term: ~p", [?SERVER, Term]),
  -    %%io:format("~p:~p, received same term: ~p~n", [?MODULE, ?LINE, Term]),
  -    {noreply, State};
  -handle_info({index_update,
  +handle_info({remove_term,
   	    << Tid:?TWO_BYTES/big-unsigned-integer-unit:8,
   	    Cid:?TWO_BYTES/big-unsigned-integer-unit:8,
  -	    Key/binary >>, NewTerm, OldTerm}, State) ->
  -    ?debug("~p received term change: ~p -> ~p", [?SERVER, OldTerm, NewTerm]),
  -    %%io:format("~p:~p, received term change: ~s -> ~s~n", [?MODULE, ?LINE, OldTerm, NewTerm]),
  -    spawn(?MODULE, term_index_update, [Tid, Cid, Key, NewTerm, OldTerm]),
  +	    Key/binary >>, Terms}, State) ->
  +    ?debug("~p received remove_term: ~p -> ~p", [?SERVER, Terms]),
  +    spawn(?MODULE, term_index_remove, [Tid, Cid, Key, Terms]),
       {noreply, State};
   handle_info(Info, State) ->
       ?debug("~p received unhandled info: ~p", [?SERVER, Info]),
  
positive.code:       Key, [{ColId, Term} | Rest]) when is_integer(ColId)->
      Tid = encode_unsigned(?TWO_BYTES, TableId),
      Cid = encode_unsigned(?TWO_BYTES, ColId),
      IndexKey = << Tid/binary, Cid/binary, Key/binary >>,
      ok = rocksdb:index_merge(DB, WriteOptions, IndexKey, list_to_binary(Term)),
      index(DB, WriteOptions, TableId, Key, Rest);
  index(DB, WriteOptions, TableId, Key, [_ | Rest]) ->
      index(DB, WriteOptions, TableId, Key, Rest);
  index(_DB, _WriteOptions, _TableId, _Key, []) ->
      ok.
  
  -spec term_index_update(Tid :: integer(),
  			Cid :: integer(),
  			Key :: binary(),
  			NewTerm :: string(),
  			OldTerm :: string()) ->
      ok.
  term_index_update(Tid, Cid, Key, NewTerm, OldTerm) ->
      term_index_update_(?ADD, Tid, Cid, Key, NewTerm),
      term_index_update_(?REM, Tid, Cid, Key, OldTerm).
  
  term_index_update_(_, _, _, _, undefined) ->
      ok;
  term_index_update_(Op, Tid, Cid, Key, Terms) ->
      Tokens = string:tokens(Terms, " "),
      [term_index_update__(Op, Tid, Cid, Key, T) || T <- Tokens].
  
  term_index_update__(Op, Tid, Cid, Key, Term) ->
      {ok, DBKey, DBHashKey} = make_index_key(Tid, Cid, Term),
      {ok, Shard} = gb_hash:get_local_node(?TERM_INDEX_TABLE, DBHashKey),
      enterdb_rdb_worker:term_index(Shard, DBKey, encode_key(Op, Key)).
  
  
negative.code: -export([get_pid/0]).
  
  -export([index/5,
  	 term_index_remove/4,
  	 index_read/2]).
  
  -export([register_ttl/3,
  