anchor.diff:              false ->
                   case Msg of
                       {bulk_distribute, Proc, N, Env, Data} ->
  -                        RangeData = get_range_data(Data, Range),
  -                        ?TRACE("~p bulk_distribute: sending to node ~p on interval ~p
  -                               Msg: ~p",
  -                               [self(), node:pidX(Head), Range, {bulkowner, Id, Range,
  -                              {bulk_distribute, Proc, N, Env, RangeData}, Parents}]),
  +                        {RangeData, _Rest} = lists:partition(
  +                                fun(Entry) ->
  +                                    intervals:in(?RT:hash_key(element(1, Entry)),
  +                                                Range)
  +                                end, Data),
                           comm:send(node:pidX(Head),
                                 {bulkowner, Id, Range,
                                 {bulk_distribute, Proc, N, Env, RangeData}, Parents});
  
positive.code: -author('schuett@zib.de').
  -vsn('$Id$').
  
  -define(TRACE(X, Y), io:format(X, Y)).
  
  -include("scalaris.hrl").
  
  % public API:
  -export([issue_bulk_owner/3, issue_send_reply/4,
           issue_bulk_distribute/5, issue_bulk_distribute/6,
           send_reply/5, send_reply_failed/6]).
  
  % only use inside the dht_node process:
  
negative.code:     comm:send_local(DHTNode, {bulkowner, reply, Id, Target, Msg, Parents}).
  
  -spec issue_bulk_distribute(ID::uid:global_uid(), atom(), pos_integer(),
                             comm:message(), [tuple()]) -> ok.
  issue_bulk_distribute(Id, Proc, Pos, Msg, Data) ->
      DHTNode = pid_groups:find_a(dht_node),
      comm:send_local(DHTNode, {bulkowner, start, Id, intervals:all(), {bulk_distribute, Proc,
                                                          Pos, Msg, Data}}).
  
  -spec send_reply(Id::uid:global_uid(), Target::comm:mypid(), Msg::comm:message(),
  