anchor.diff:              {reply, {stream, ReqId}, State#state{req = Req, req_ctx = ReqId,
                                                    column_info = ColumnInfo}};
           {error, Reason} ->
  -            {reply, make_rpberrresp(
  -                      ?E_LISTKEYS, flat_format("Failed to list keys: ~p", [Reason])),
  -             State}
  +            {reply, failed_listkeys_response(Reason), State}
       end.
   
   
  
positive.code:             %% the dialyzer (and of course, for the odd chance
              %% of Erlang imps crashing nodes between create
              %% and activate calls)
              {reply, make_rpberrresp(
                        ?E_CREATED_GHOST,
                        flat_format("Table ~s has been created but found missing", [Table])),
               State}
      end.
  
  
  
negative.code:         ok ->
              wait_until_active(Table, State, ?TABLE_ACTIVATE_WAIT);
          {error, Reason} ->
              {reply, table_create_fail_response(Table, Reason), State}
      end.
  
  wait_until_active(Table, State, 0) ->
      {reply, table_activate_fail_response(Table), State};
  wait_until_active(Table, State, Seconds) ->
      case riak_core_bucket_type:activate(Table) of
          ok ->
  