valitydev/riak_test
14
0
Fork 0
mirror of https://github.com/valitydev/riak_test.git synced 2024-11-06 08:35:22 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

commented out reference to unused intercept

Browse Source
This commit is contained in:
Jon Anderson 2013-08-19 11:33:36 -04:00
parent 85590f27f4
commit a2b7100e4e
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
intercepts/riak_repl2_rtq_intercepts.erl
View File

@ -12,7 +12,7 @@ slow_trim_q(State) ->
%% This hideousness is necessary in order to have this intercept sleep only
%% on the first iteration. With hope, it causes the message queue of the
%% RTQ to spike enough to initiate overload handling, then subsequently
%% allow the queue to drain, overload flipped off, and the writes to complete.
%% allows the queue to drain, overload to flip off, and the writes to complete.
case get(hosed) of
undefined ->
put(hosed, true);

14
tests/repl_rt_overload.erl
View File

@ -5,7 +5,7 @@
%% -------------------------------------------------------------------
-module(repl_rt_overload).
-behaviour(riak_test).
-export([confirm/0, check_size/1, slow_write_calls/1, slow_trim_q/1]).
-export([confirm/0, check_size/1, slow_trim_q/1]).
-include_lib("eunit/include/eunit.hrl").
-define(RTSINK_MAX_WORKERS, 1).
@ -166,11 +166,11 @@ load_intercepts(Node) ->
rt_intercept:load_code(Node).
%% @doc Slow down handle_info (write calls)
slow_write_calls(Node) ->
%% disable forwarding of the heartbeat function call
lager:info("Slowing down sink do_write calls on ~p", [Node]),
rt_intercept:add(Node, {riak_repl2_rtsink_conn,
[{{handle_info, 2}, slow_handle_info}]}).
% slow_write_calls(Node) ->
% %% disable forwarding of the heartbeat function call
% lager:info("Slowing down sink do_write calls on ~p", [Node]),
% rt_intercept:add(Node, {riak_repl2_rtsink_conn,
% [{{handle_info, 2}, slow_handle_info}]}).
slow_trim_q(Node) ->
lager:info("Slowing down trim_q calls on ~p", [Node]),
@ -187,4 +187,4 @@ check_size(Node) ->
io:format("mailbox size of riak_repl2_rtq: ~p", [Len]),
timer:sleep(2000),
check_size(Node).
check_size(Node).