summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@lshift.net>2009-04-22 21:39:57 +0100
committerMatthew Sackman <matthew@lshift.net>2009-04-22 21:39:57 +0100
commit269f1dc10a1b2727f799730bd48ed452620e2f0b (patch)
tree31709aadeeba4121ad7b3c56bbe5a8ef638fd972
parentffba4bc3a76efa5f102db4d639403e2f0921e8f4 (diff)
downloadrabbitmq-server-git-269f1dc10a1b2727f799730bd48ed452620e2f0b.tar.gz
added a test
-rw-r--r--Makefile2
-rw-r--r--src/rabbit_tests.erl17
2 files changed, 18 insertions, 1 deletions
diff --git a/Makefile b/Makefile
index b7464244c2..d55ab3762e 100644
--- a/Makefile
+++ b/Makefile
@@ -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).