anchor.diff:                  Data,
                   TotalSize, HardWatermark) ->
       ChunkSize = compute_chunk_size(Data),
  -    if TotalSize + ChunkSize > HardWatermark ->
  +    case TotalSize + ChunkSize > HardWatermark of
  +        true ->
               {error, total_qbuf_size_limit_reached};
  -       el/=se ->
  +        false ->
               %% ChunkId will be used to construct a new and unique key
               %% for each record. Ideally, this should be the serial
               %% number of the subquery.
  
positive.code:             State9 = touch_qbuf(QBufRef, State0),
              {reply, {ok, {existing, QBufRef}}, State9};
          {ok, {new, QBufRef}} ->
              if TotalSize > SoftWMark ->
                      {reply, {error, total_qbuf_size_limit_reached}, State0};
                 el/=se ->
                      DDL = ?DDL{table = Table} = sql_to_ddl(OrigDDL, SQL),
                      lager:info("creating new query buffer ~p (ref ~p) for ~p", [Table, QBufRef, SQL]),
                      case riak_kv_qry_buffers_ldb:new_table(Table, RootPath) of
  
negative.code:                                ddl = ?DDL{table = Table},
                                 last_accessed = LastAccessed}}) ->
                    ExpiresOn = advance_timestamp(LastAccessed, IncompleteQbufReleaseMsec),
                    case ExpiresOn < Now of
                        true ->
                            ok = kill_qbuf(RootPath, Table, LdbRef),
                            lager:debug("Reaped incompletely filled qbuf ~p", [Table]),
                            false;
                        false ->
                            true
                    end
            end,
  