anchor.diff:      end.
   
   
  -do_qbuf_exists(QBufRef, #state{qbufs = QBufs} = State) ->
  -    case get_qbuf_record(QBufRef, QBufs) of
  -        false ->
  -            {reply, false, State};
  -        _QBuf ->
  -            {reply, true, State}
  -    end.
  -
  -
   do_batch_put(QBufRef, Data, #state{qbufs          = QBufs0,
                                      total_size     = TotalSize0,
                                      hard_watermark = HardWatermark} = State0) ->
  
positive.code: %% @doc Dispose of this query buffer (do nothing if it does not exist).
  delete_qbuf(QBufRef) ->
      gen_server:call(?SERVER, {delete_qbuf, QBufRef}).
  
  -spec get_qbufs() -> [{qbuf_ref(), proplists:proplist()}].
  %% @doc List active qbufs, with properties
  get_qbufs() ->
      gen_server:call(?SERVER, get_qbufs).
  
  -spec qbuf_exists(qbuf_ref()) -> boolean().
  %% @doc Check if there is a query buffer for this Query.
  qbuf_exists(QBufRef) ->
      gen_server:call(?SERVER, {qbuf_exists, QBufRef}).
  
  -spec is_qbuf_ready(qbuf_ref()) -> boolean().
  %% @doc Check if results are ready for this Query.
  is_qbuf_ready(QBufRef) ->
      gen_server:call(?SERVER, {is_qbuf_ready, QBufRef}).
  
  -spec get_qbuf_orig_query(qbuf_ref()) -> {ok, ?SQL_SELECT{}} | {error, bad_qbuf_ref}.
  %% @doc Get the original SQL used when this qbuf was created.
  get_qbuf_orig_query(QBufRef) ->
      gen_server:call(?SERVER, {get_qbuf_orig_query, QBufRef}).
  
  -spec get_qbuf_size(qbuf_ref()) ->
                             {ok, non_neg_integer()} | {error, bad_qbuf_ref}.
  %% @doc Report the qbuf total size (not the size of the files backing this buffer).
  get_qbuf_size(QBufRef) ->
      gen_server:call(?SERVER, {get_qbuf_size, QBufRef}).
  
  -spec get_total_size() -> non_neg_integer().
  %% @doc Compute the total size of all temp tables.
  get_total_size() ->
      gen_server:call(?SERVER, get_total_size).
  
  -spec batch_put(qbuf_ref(), [data_row()]) ->
                         ok | {error, bad_qbuf_ref|overfull}.
  
negative.code:          get_or_create_qbuf/4,  %% new Query arrives, with some Options
           get_qbuf_expiry/1,
           get_max_query_data_size/0,
           set_max_query_data_size/1,
           set_qbuf_expiry/2,
           set_ready_waiting_process/2,  %% notify a Pid when all chunks are here
  