diff options
| -rw-r--r-- | Makefile | 2 | ||||
| -rw-r--r-- | src/rabbit_tests.erl | 17 |
2 files changed, 18 insertions, 1 deletions
@@ -1,6 +1,6 @@ RABBITMQ_NODENAME=rabbit RABBITMQ_SERVER_START_ARGS= -RABBITMQ_MNESIA_DIR=/tmp/rabbitmq-$(RABBITMQ_NODENAME)-mnesia +RABBITMQ_MNESIA_DIR=~/tmp/rabbitmq-$(RABBITMQ_NODENAME)-mnesia RABBITMQ_LOG_BASE=/tmp SOURCE_DIR=src diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl index 1e765d290c..4b72a7422b 100644 --- a/src/rabbit_tests.erl +++ b/src/rabbit_tests.erl @@ -766,6 +766,23 @@ rdq_stress_gc(MsgCount) -> rdq_stop(), passed. +rdq_time_insane_startup() -> + rdq_virgin(), + OneGig = 1024*1024*1024, + rabbit_disk_queue:start_link(OneGig, 5), + Msg = <<>>, + List = lists:seq(1, 1024*1024), + %% 1M empty messages, at say, 100B per message, should all fit + %% within 1GB and thus in a single file + io:format("Publishing 1M empty messages...~n",[]), + [rabbit_disk_queue:tx_publish(N, Msg) || N <- List], + rabbit_disk_queue:tx_commit(q, List), + io:format("...done. Timing restart...~n", []), + rdq_stop(), + Micros = rdq_virgin(), + io:format("...startup took ~w microseconds.~n", [Micros]), + rdq_stop(). + rdq_time_commands(Funcs) -> lists:foreach(fun (F) -> F() end, Funcs). |