From ebbdaef86a10a41c0bc7f76690d19c48d219d296 Mon Sep 17 00:00:00 2001 From: Vlad Ionescu Date: Tue, 1 Sep 2009 15:40:12 +0100 Subject: improved dialysis --- .hgignore | 2 ++ Makefile | 51 +++++++++++++++++++++++++++++++++++++++++++++++++-- 2 files changed, 51 insertions(+), 2 deletions(-) diff --git a/.hgignore b/.hgignore index 839f1601..74c90eb0 100644 --- a/.hgignore +++ b/.hgignore @@ -11,6 +11,8 @@ syntax: regexp ^include/rabbit_framing.hrl$ ^src/rabbit_framing.erl$ ^rabbit.plt$ +^basic.plt$ +^\.last_valid_dialysis$ ^ebin/rabbit.app$ ^ebin/rabbit.rel$ ^ebin/rabbit.boot$ diff --git a/Makefile b/Makefile index f0702756..c065ef9c 100644 --- a/Makefile +++ b/Makefile @@ -2,6 +2,10 @@ ifndef TMPDIR TMPDIR := /tmp endif +ifndef ERL_HOME +ERL_HOME := /usr/local/lib/erlang +endif + RABBITMQ_NODENAME=rabbit RABBITMQ_SERVER_START_ARGS= RABBITMQ_MNESIA_DIR=$(TMPDIR)/rabbitmq-$(RABBITMQ_NODENAME)-mnesia @@ -18,6 +22,9 @@ MANPAGES=$(patsubst %.pod, %.gz, $(wildcard docs/*.[0-9].pod)) PYTHON=python +BASIC_PLT=basic.plt +PLT=rabbit.plt + ifndef USE_SPECS # our type specs rely on features / bug fixes in dialyzer that are # only available in R13B upwards (R13B is eshell 5.7.1) @@ -60,14 +67,54 @@ $(SOURCE_DIR)/rabbit_framing.erl: codegen.py $(AMQP_CODEGEN_DIR)/amqp_codegen.py $(EBIN_DIR)/rabbit.boot $(EBIN_DIR)/rabbit.script: $(EBIN_DIR)/rabbit.app $(EBIN_DIR)/rabbit.rel $(TARGETS) erl -noshell -eval 'systools:make_script("ebin/rabbit", [{path, ["ebin"]}]), halt().' -dialyze: $(BEAM_TARGETS) - dialyzer -c $? +dialyze: $(BASIC_PLT) $(PLT) .last_valid_dialysis + +create_plt: $(BASIC_PLT) $(PLT) + +$(PLT): $(BEAM_TARGETS) + if [ -f $@ -a $(BASIC_PLT) -ot $@ ]; then \ + DIALYZER_INPUT_FILES="$?"; \ + else \ + cp $(BASIC_PLT) $@ && \ + DIALYZER_INPUT_FILES="$(BEAM_TARGETS)"; \ + fi; \ + DIALYZER_OUTPUT=$$(dialyzer --plt $@ --add_to_plt -c $$DIALYZER_INPUT_FILES); \ + echo "$$DIALYZER_OUTPUT"; \ + echo "$$DIALYZER_OUTPUT" | grep "done (passed successfully)" + +.last_valid_dialysis: $(BEAM_TARGETS) + DIALYZER_OUTPUT=$$(erl -noinput -eval \ + "{ok, Files} = regexp:split(\"$?\", \" \"), \ + lists:foreach( \ + fun(Warning) -> io:format(\"~s\", [dialyzer:format_warning(Warning)]) end, \ + dialyzer:run([{init_plt, \"$(PLT)\"}, {files, Files}])), \ + halt()."); \ + if [ ! "$$DIALYZER_OUTPUT" ]; then \ + echo "Ok, dialyzer returned no warnings." && \ + touch .last_valid_dialysis; \ + else \ + echo "dialyzer returned the following warnings:" && \ + echo "$$DIALYZER_OUTPUT" && \ + false; \ + fi + +$(BASIC_PLT): $(ERL_HOME) + -dialyzer --plt $@ --build_plt -r \ + $(shell ls -d $(ERL_HOME)/lib/stdlib-*/ebin \ + $(ERL_HOME)/lib/kernel-*/ebin \ + $(ERL_HOME)/lib/mnesia-*/ebin \ + $(ERL_HOME)/lib/os_mon-*/ebin \ + $(ERL_HOME)/lib/ssl-*/ebin \ + $(ERL_HOME)/lib/eunit-*/ebin \ + $(ERL_HOME)/lib/tools-*/ebin \ + $(ERL_HOME)/lib/sasl-*/ebin) clean: rm -f $(EBIN_DIR)/*.beam rm -f $(EBIN_DIR)/rabbit.app $(EBIN_DIR)/rabbit.boot $(EBIN_DIR)/rabbit.script rm -f $(INCLUDE_DIR)/rabbit_framing.hrl $(SOURCE_DIR)/rabbit_framing.erl codegen.pyc rm -f docs/*.[0-9].gz + rm -f $(PLT) .last_valid_dialysis cleandb: rm -rf $(RABBITMQ_MNESIA_DIR)/* -- cgit v1.2.1 From e35b2a8ee0bcd96da45cbc0d6c66c5903d5cece8 Mon Sep 17 00:00:00 2001 From: Vlad Ionescu Date: Tue, 1 Sep 2009 16:14:42 +0100 Subject: nicer enumeration of otp applications rabbit depends on --- Makefile | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/Makefile b/Makefile index c065ef9c..db8854ce 100644 --- a/Makefile +++ b/Makefile @@ -100,14 +100,7 @@ $(PLT): $(BEAM_TARGETS) $(BASIC_PLT): $(ERL_HOME) -dialyzer --plt $@ --build_plt -r \ - $(shell ls -d $(ERL_HOME)/lib/stdlib-*/ebin \ - $(ERL_HOME)/lib/kernel-*/ebin \ - $(ERL_HOME)/lib/mnesia-*/ebin \ - $(ERL_HOME)/lib/os_mon-*/ebin \ - $(ERL_HOME)/lib/ssl-*/ebin \ - $(ERL_HOME)/lib/eunit-*/ebin \ - $(ERL_HOME)/lib/tools-*/ebin \ - $(ERL_HOME)/lib/sasl-*/ebin) + $(shell bash -c "ls -d $(ERL_HOME)/lib/{stdlib,kernel,mnesia,os_mon,ssl,eunit,tools,sasl}-*/ebin") clean: rm -f $(EBIN_DIR)/*.beam -- cgit v1.2.1 From f43ab8b2fa61d4e1fd98fd0a57b81a119ec9f65a Mon Sep 17 00:00:00 2001 From: Vlad Ionescu Date: Tue, 1 Sep 2009 16:43:39 +0100 Subject: checking if required applications exist in specified ERL_HOME --- Makefile | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/Makefile b/Makefile index db8854ce..4032d6b2 100644 --- a/Makefile +++ b/Makefile @@ -99,8 +99,13 @@ $(PLT): $(BEAM_TARGETS) fi $(BASIC_PLT): $(ERL_HOME) - -dialyzer --plt $@ --build_plt -r \ - $(shell bash -c "ls -d $(ERL_HOME)/lib/{stdlib,kernel,mnesia,os_mon,ssl,eunit,tools,sasl}-*/ebin") + OTP_APPS='$(shell bash -c "ls -d $(ERL_HOME)/lib/{stdlib,kernel,mnesia,os_mon,ssl,eunit,tools,sasl}-*/ebin")'; \ + if [ ! "$$OTP_APPS" ]; then \ + echo "Did not find required OTP applications. Check ERL_HOME variable." && \ + false; \ + else \ + dialyzer --plt $@ --build_plt -r $$OTP_APPS || true; \ + fi clean: rm -f $(EBIN_DIR)/*.beam -- cgit v1.2.1 From f6768066d5c604ced90def93d78541f0eb25a492 Mon Sep 17 00:00:00 2001 From: Vlad Ionescu Date: Wed, 2 Sep 2009 16:15:01 +0100 Subject: basic.plt created via erlang shell; fixing create_plt make target name --- Makefile | 24 +++++++++++------------- 1 file changed, 11 insertions(+), 13 deletions(-) diff --git a/Makefile b/Makefile index 4032d6b2..1174f1a9 100644 --- a/Makefile +++ b/Makefile @@ -2,10 +2,6 @@ ifndef TMPDIR TMPDIR := /tmp endif -ifndef ERL_HOME -ERL_HOME := /usr/local/lib/erlang -endif - RABBITMQ_NODENAME=rabbit RABBITMQ_SERVER_START_ARGS= RABBITMQ_MNESIA_DIR=$(TMPDIR)/rabbitmq-$(RABBITMQ_NODENAME)-mnesia @@ -69,7 +65,7 @@ $(EBIN_DIR)/rabbit.boot $(EBIN_DIR)/rabbit.script: $(EBIN_DIR)/rabbit.app $(EBIN dialyze: $(BASIC_PLT) $(PLT) .last_valid_dialysis -create_plt: $(BASIC_PLT) $(PLT) +create-plt: $(BASIC_PLT) $(PLT) $(PLT): $(BEAM_TARGETS) if [ -f $@ -a $(BASIC_PLT) -ot $@ ]; then \ @@ -98,14 +94,16 @@ $(PLT): $(BEAM_TARGETS) false; \ fi -$(BASIC_PLT): $(ERL_HOME) - OTP_APPS='$(shell bash -c "ls -d $(ERL_HOME)/lib/{stdlib,kernel,mnesia,os_mon,ssl,eunit,tools,sasl}-*/ebin")'; \ - if [ ! "$$OTP_APPS" ]; then \ - echo "Did not find required OTP applications. Check ERL_HOME variable." && \ - false; \ - else \ - dialyzer --plt $@ --build_plt -r $$OTP_APPS || true; \ - fi +$(BASIC_PLT): + erl -noinput -eval \ + "OptsRecord = dialyzer_options:build([ \ + {analysis_type, plt_build}, \ + {init_plt, \"$(BASIC_PLT)\"}, \ + {files_rec, lists:map( \ + fun(App) -> code:lib_dir(App) ++ \"/ebin\" end, \ + [stdlib, kernel, mnesia, os_mon, ssl, eunit, tools, sasl])}]), \ + dialyzer_cl:start(OptsRecord), \ + halt()." clean: rm -f $(EBIN_DIR)/*.beam -- cgit v1.2.1 From b45448edcab38ae2c9a3ca52c450106a1ecf2634 Mon Sep 17 00:00:00 2001 From: Vlad Ionescu Date: Wed, 2 Sep 2009 20:01:38 +0100 Subject: moving dialyzer stuff to src/rabbit_dialyzer.erl --- Makefile | 37 ++++++-------------- src/rabbit_dialyzer.erl | 93 +++++++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 104 insertions(+), 26 deletions(-) create mode 100644 src/rabbit_dialyzer.erl diff --git a/Makefile b/Makefile index 1174f1a9..dab3ba94 100644 --- a/Makefile +++ b/Makefile @@ -42,6 +42,8 @@ AMQP_SPEC_JSON_PATH=$(AMQP_CODEGEN_DIR)/amqp-0.8.json ERL_CALL=erl_call -sname $(RABBITMQ_NODENAME) -e +ERL_RABBIT_DIALYZER=erl -noinput -eval "code:load_abs(\"$(EBIN_DIR)/rabbit_dialyzer\")." + all: $(TARGETS) $(EBIN_DIR)/rabbit.app: $(EBIN_DIR)/rabbit_app.in $(BEAM_TARGETS) generate_app @@ -72,38 +74,21 @@ $(PLT): $(BEAM_TARGETS) DIALYZER_INPUT_FILES="$?"; \ else \ cp $(BASIC_PLT) $@ && \ + rm -f .last_valid_dialysis && \ DIALYZER_INPUT_FILES="$(BEAM_TARGETS)"; \ fi; \ - DIALYZER_OUTPUT=$$(dialyzer --plt $@ --add_to_plt -c $$DIALYZER_INPUT_FILES); \ - echo "$$DIALYZER_OUTPUT"; \ - echo "$$DIALYZER_OUTPUT" | grep "done (passed successfully)" + $(ERL_RABBIT_DIALYZER) -eval \ + "rabbit_dialyzer:update_plt(\"$@\", \"$$DIALYZER_INPUT_FILES\"), halt()." .last_valid_dialysis: $(BEAM_TARGETS) - DIALYZER_OUTPUT=$$(erl -noinput -eval \ - "{ok, Files} = regexp:split(\"$?\", \" \"), \ - lists:foreach( \ - fun(Warning) -> io:format(\"~s\", [dialyzer:format_warning(Warning)]) end, \ - dialyzer:run([{init_plt, \"$(PLT)\"}, {files, Files}])), \ - halt()."); \ - if [ ! "$$DIALYZER_OUTPUT" ]; then \ - echo "Ok, dialyzer returned no warnings." && \ - touch .last_valid_dialysis; \ - else \ - echo "dialyzer returned the following warnings:" && \ - echo "$$DIALYZER_OUTPUT" && \ - false; \ - fi + $(ERL_RABBIT_DIALYZER) -eval \ + "rabbit_dialyzer:dialyze_files(\"$(PLT)\", \"$?\"), halt()." && \ + touch $@ $(BASIC_PLT): - erl -noinput -eval \ - "OptsRecord = dialyzer_options:build([ \ - {analysis_type, plt_build}, \ - {init_plt, \"$(BASIC_PLT)\"}, \ - {files_rec, lists:map( \ - fun(App) -> code:lib_dir(App) ++ \"/ebin\" end, \ - [stdlib, kernel, mnesia, os_mon, ssl, eunit, tools, sasl])}]), \ - dialyzer_cl:start(OptsRecord), \ - halt()." + $(MAKE) $(EBIN_DIR)/rabbit_dialyzer.beam + $(ERL_RABBIT_DIALYZER) -eval \ + "rabbit_dialyzer:create_basic_plt(\"$@\"), halt()." clean: rm -f $(EBIN_DIR)/*.beam diff --git a/src/rabbit_dialyzer.erl b/src/rabbit_dialyzer.erl new file mode 100644 index 00000000..cc3aaf12 --- /dev/null +++ b/src/rabbit_dialyzer.erl @@ -0,0 +1,93 @@ +%% The contents of this file are subject to the Mozilla Public License +%% Version 1.1 (the "License"); you may not use this file except in +%% compliance with the License. You may obtain a copy of the License at +%% http://www.mozilla.org/MPL/ +%% +%% Software distributed under the License is distributed on an "AS IS" +%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the +%% License for the specific language governing rights and limitations +%% under the License. +%% +%% The Original Code is RabbitMQ. +%% +%% The Initial Developers of the Original Code are LShift Ltd, +%% Cohesive Financial Technologies LLC, and Rabbit Technologies Ltd. +%% +%% Portions created before 22-Nov-2008 00:00:00 GMT by LShift Ltd, +%% Cohesive Financial Technologies LLC, or Rabbit Technologies Ltd +%% are Copyright (C) 2007-2008 LShift Ltd, Cohesive Financial +%% Technologies LLC, and Rabbit Technologies Ltd. +%% +%% Portions created by LShift Ltd are Copyright (C) 2007-2009 LShift +%% Ltd. Portions created by Cohesive Financial Technologies LLC are +%% Copyright (C) 2007-2009 Cohesive Financial Technologies +%% LLC. Portions created by Rabbit Technologies Ltd are Copyright +%% (C) 2007-2009 Rabbit Technologies Ltd. +%% +%% All Rights Reserved. +%% +%% Contributor(s): ______________________________________. +%% + +-module(rabbit_dialyzer). +-include("rabbit.hrl"). + +-export([create_basic_plt/1, update_plt/2, dialyze_files/2]). + +%%---------------------------------------------------------------------------- + +-ifdef(use_specs). + +-spec(create_basic_plt/1 :: (string()) -> 'ok'). +-spec(update_plt/2 :: (string(), string()) -> 'ok'). +-spec(dialyze_files/2 :: (string(), string()) -> 'ok'). + +-endif. + +%%---------------------------------------------------------------------------- + +create_basic_plt(BasicPltPath) -> + OptsRecord = dialyzer_options:build([ + {analysis_type, plt_build}, + {init_plt, BasicPltPath}, + {files_rec, otp_apps_dependencies_paths()}]), + dialyzer_cl:start(OptsRecord), + ok. + +update_plt(PltPath, ModifiedFiles) -> + {ok, Files} = regexp:split(ModifiedFiles, " "), + DialyzerWarnings = dialyzer:run([ + {analysis_type, plt_add}, + {init_plt, PltPath}, + {files, Files}]), + print_warnings(DialyzerWarnings), + ok. + +dialyze_files(PltPath, ModifiedFiles) -> + {ok, Files} = regexp:split(ModifiedFiles, " "), + DialyzerWarnings = dialyzer:run([ + {init_plt, PltPath}, + {files, Files}]), + case DialyzerWarnings of + [] -> + io:format("Ok, dialyzer returned no warnings.~n", []), + ok; + _ -> + io:format("~nFAILED! dialyzer returned the following warnings:~n", []), + print_warnings(DialyzerWarnings), + erlang:error({dialyzer_warnings, DialyzerWarnings}) + end. + +print_warnings(DialyzerWarnings) -> + lists:foreach( + fun + (Warning) -> io:format("~s", [dialyzer:format_warning(Warning)]) + end, + DialyzerWarnings), + io:format("~n", []), + ok. + +otp_apps_dependencies_paths() -> + lists:map( + fun(App) -> code:lib_dir(App, ebin) end, + [stdlib, kernel, mnesia, os_mon, ssl, eunit, tools, sasl]). -- cgit v1.2.1 From 206f26e2ba9d779ad47009e173c4a93aba9558e1 Mon Sep 17 00:00:00 2001 From: Vlad Ionescu Date: Wed, 2 Sep 2009 20:53:08 +0100 Subject: nicer rabbit_dialyzer:otp_apps_dependencies_paths --- src/rabbit_dialyzer.erl | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/rabbit_dialyzer.erl b/src/rabbit_dialyzer.erl index cc3aaf12..5664f1da 100644 --- a/src/rabbit_dialyzer.erl +++ b/src/rabbit_dialyzer.erl @@ -88,6 +88,5 @@ print_warnings(DialyzerWarnings) -> ok. otp_apps_dependencies_paths() -> - lists:map( - fun(App) -> code:lib_dir(App, ebin) end, - [stdlib, kernel, mnesia, os_mon, ssl, eunit, tools, sasl]). + [code:lib_dir(App, ebin) || + App <- [stdlib, kernel, mnesia, os_mon, ssl, eunit, tools, sasl]]. -- cgit v1.2.1 From cf6bad454391addb8cb70aa4e71e9f9928dbd4db Mon Sep 17 00:00:00 2001 From: Vlad Ionescu Date: Wed, 9 Sep 2009 13:48:07 +0100 Subject: fixing compatibility with latest dialyzer --- src/rabbit_dialyzer.erl | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/rabbit_dialyzer.erl b/src/rabbit_dialyzer.erl index 5664f1da..4d78adbe 100644 --- a/src/rabbit_dialyzer.erl +++ b/src/rabbit_dialyzer.erl @@ -49,7 +49,7 @@ create_basic_plt(BasicPltPath) -> OptsRecord = dialyzer_options:build([ {analysis_type, plt_build}, - {init_plt, BasicPltPath}, + {output_plt, BasicPltPath}, {files_rec, otp_apps_dependencies_paths()}]), dialyzer_cl:start(OptsRecord), ok. @@ -59,6 +59,7 @@ update_plt(PltPath, ModifiedFiles) -> DialyzerWarnings = dialyzer:run([ {analysis_type, plt_add}, {init_plt, PltPath}, + {output_plt, PltPath}, {files, Files}]), print_warnings(DialyzerWarnings), ok. -- cgit v1.2.1 From 5ed84ee6fa15d9749b610a0d0bfc4ae3b118da6a Mon Sep 17 00:00:00 2001 From: Vlad Ionescu Date: Wed, 9 Sep 2009 15:12:29 +0100 Subject: fixing dependencies in dialyzer-related make targets --- Makefile | 25 ++++++++++++------------- 1 file changed, 12 insertions(+), 13 deletions(-) diff --git a/Makefile b/Makefile index dab3ba94..360ad1fc 100644 --- a/Makefile +++ b/Makefile @@ -11,7 +11,7 @@ SOURCE_DIR=src EBIN_DIR=ebin INCLUDE_DIR=include SOURCES=$(wildcard $(SOURCE_DIR)/*.erl) -BEAM_TARGETS=$(EBIN_DIR)/rabbit_framing.beam $(patsubst $(SOURCE_DIR)/%.erl, $(EBIN_DIR)/%.beam,$(SOURCES)) +BEAM_TARGETS=$(EBIN_DIR)/rabbit_framing.beam $(patsubst $(SOURCE_DIR)/%.erl, $(EBIN_DIR)/%.beam, $(SOURCES)) TARGETS=$(EBIN_DIR)/rabbit.app $(BEAM_TARGETS) WEB_URL=http://stage.rabbitmq.com/ MANPAGES=$(patsubst %.pod, %.gz, $(wildcard docs/*.[0-9].pod)) @@ -65,24 +65,23 @@ $(SOURCE_DIR)/rabbit_framing.erl: codegen.py $(AMQP_CODEGEN_DIR)/amqp_codegen.py $(EBIN_DIR)/rabbit.boot $(EBIN_DIR)/rabbit.script: $(EBIN_DIR)/rabbit.app $(EBIN_DIR)/rabbit.rel $(TARGETS) erl -noshell -eval 'systools:make_script("ebin/rabbit", [{path, ["ebin"]}]), halt().' -dialyze: $(BASIC_PLT) $(PLT) .last_valid_dialysis +dialyze: .last_valid_dialysis -create-plt: $(BASIC_PLT) $(PLT) +create-plt: $(PLT) -$(PLT): $(BEAM_TARGETS) - if [ -f $@ -a $(BASIC_PLT) -ot $@ ]; then \ - DIALYZER_INPUT_FILES="$?"; \ +$(PLT): $(BEAM_TARGETS) $(BASIC_PLT) + test -f $@ -a $(BASIC_PLT) -ot $@ || cp $(BASIC_PLT) $@ + $(ERL_RABBIT_DIALYZER) -eval \ + "rabbit_dialyzer:update_plt(\"$@\", \"$(BEAM_TARGETS)\"), halt()." + +.last_valid_dialysis: $(BEAM_TARGETS) $(PLT) + if [ $(PLT) -ot $@ ]; then \ + DIALYZER_INPUT_FILES="$(filter %.beam, $?)"; \ else \ - cp $(BASIC_PLT) $@ && \ - rm -f .last_valid_dialysis && \ DIALYZER_INPUT_FILES="$(BEAM_TARGETS)"; \ fi; \ $(ERL_RABBIT_DIALYZER) -eval \ - "rabbit_dialyzer:update_plt(\"$@\", \"$$DIALYZER_INPUT_FILES\"), halt()." - -.last_valid_dialysis: $(BEAM_TARGETS) - $(ERL_RABBIT_DIALYZER) -eval \ - "rabbit_dialyzer:dialyze_files(\"$(PLT)\", \"$?\"), halt()." && \ + "rabbit_dialyzer:dialyze_files(\"$(PLT)\", \"$$DIALYZER_INPUT_FILES\"), halt()." && \ touch $@ $(BASIC_PLT): -- cgit v1.2.1 From 3313f61b68c633ea3a4c042facd450875d1a3b1e Mon Sep 17 00:00:00 2001 From: Vlad Ionescu Date: Mon, 14 Sep 2009 12:48:49 +0100 Subject: replacing ERL_DIALYZER with ERL_EBIN in makefile --- Makefile | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/Makefile b/Makefile index 360ad1fc..3007baa6 100644 --- a/Makefile +++ b/Makefile @@ -42,7 +42,7 @@ AMQP_SPEC_JSON_PATH=$(AMQP_CODEGEN_DIR)/amqp-0.8.json ERL_CALL=erl_call -sname $(RABBITMQ_NODENAME) -e -ERL_RABBIT_DIALYZER=erl -noinput -eval "code:load_abs(\"$(EBIN_DIR)/rabbit_dialyzer\")." +ERL_EBIN=erl -noinput -pa $(EBIN_DIR) all: $(TARGETS) @@ -71,7 +71,7 @@ create-plt: $(PLT) $(PLT): $(BEAM_TARGETS) $(BASIC_PLT) test -f $@ -a $(BASIC_PLT) -ot $@ || cp $(BASIC_PLT) $@ - $(ERL_RABBIT_DIALYZER) -eval \ + $(ERL_EBIN) -eval \ "rabbit_dialyzer:update_plt(\"$@\", \"$(BEAM_TARGETS)\"), halt()." .last_valid_dialysis: $(BEAM_TARGETS) $(PLT) @@ -80,13 +80,13 @@ $(PLT): $(BEAM_TARGETS) $(BASIC_PLT) else \ DIALYZER_INPUT_FILES="$(BEAM_TARGETS)"; \ fi; \ - $(ERL_RABBIT_DIALYZER) -eval \ + $(ERL_EBIN) -eval \ "rabbit_dialyzer:dialyze_files(\"$(PLT)\", \"$$DIALYZER_INPUT_FILES\"), halt()." && \ touch $@ $(BASIC_PLT): - $(MAKE) $(EBIN_DIR)/rabbit_dialyzer.beam - $(ERL_RABBIT_DIALYZER) -eval \ + $(MAKE) all + $(ERL_EBIN) -eval \ "rabbit_dialyzer:create_basic_plt(\"$@\"), halt()." clean: -- cgit v1.2.1 From f3118f859589ddbe741e04d9ad994cd7b36fa623 Mon Sep 17 00:00:00 2001 From: Vlad Ionescu Date: Tue, 15 Sep 2009 13:18:59 +0100 Subject: fixing basic.plt dependencies --- Makefile | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/Makefile b/Makefile index 3007baa6..609b645e 100644 --- a/Makefile +++ b/Makefile @@ -70,7 +70,7 @@ dialyze: .last_valid_dialysis create-plt: $(PLT) $(PLT): $(BEAM_TARGETS) $(BASIC_PLT) - test -f $@ -a $(BASIC_PLT) -ot $@ || cp $(BASIC_PLT) $@ + test -f $@ || cp $(BASIC_PLT) $@ $(ERL_EBIN) -eval \ "rabbit_dialyzer:update_plt(\"$@\", \"$(BEAM_TARGETS)\"), halt()." @@ -84,10 +84,13 @@ $(PLT): $(BEAM_TARGETS) $(BASIC_PLT) "rabbit_dialyzer:dialyze_files(\"$(PLT)\", \"$$DIALYZER_INPUT_FILES\"), halt()." && \ touch $@ -$(BASIC_PLT): - $(MAKE) all - $(ERL_EBIN) -eval \ - "rabbit_dialyzer:create_basic_plt(\"$@\"), halt()." +$(BASIC_PLT): $(BEAM_TARGETS) + if [ -f $@ ]; then \ + touch $@; \ + else \ + $(ERL_EBIN) -eval \ + "rabbit_dialyzer:create_basic_plt(\"$@\"), halt()."; \ + fi clean: rm -f $(EBIN_DIR)/*.beam -- cgit v1.2.1 From 879fea84045d606716454fbaaecd39f84be69782 Mon Sep 17 00:00:00 2001 From: Matthias Radestock Date: Fri, 18 Sep 2009 06:08:44 +0100 Subject: handle timeouts in cpu_sup:avg1 gracefully Also, it turns out that the load avg is an int, not a float --- src/rabbit_load.erl | 17 ++++++++++++----- 1 file changed, 12 insertions(+), 5 deletions(-) diff --git a/src/rabbit_load.erl b/src/rabbit_load.erl index 7bf85347..6ef638cb 100644 --- a/src/rabbit_load.erl +++ b/src/rabbit_load.erl @@ -41,7 +41,7 @@ -ifdef(use_specs). -type(erlang_node() :: atom()). --type(load() :: {{non_neg_integer(), float()}, erlang_node()}). +-type(load() :: {{non_neg_integer(), integer() | 'unknown'}, erlang_node()}). -spec(local_load/0 :: () -> load()). -spec(remote_loads/0 :: () -> [load()]). -spec(pick/0 :: () -> erlang_node()). @@ -52,8 +52,11 @@ local_load() -> LoadAvg = case whereis(cpu_sup) of - undefined -> 0.0; - _Other -> cpu_sup:avg1() + undefined -> unknown; + _ -> case cpu_sup:avg1() of + L when is_integer(L) -> L; + {error, timeout} -> unknown + end end, {{statistics(run_queue), LoadAvg}, node()}. @@ -65,8 +68,12 @@ remote_loads() -> pick() -> RemoteLoads = remote_loads(), {{RunQ, LoadAvg}, Node} = local_load(), - %% add bias towards current node - AdjustedLoadAvg = LoadAvg * ?FUDGE_FACTOR, + %% add bias towards current node; we rely on Erlang's term order + %% of SomeFloat < local_unknown < unknown. + AdjustedLoadAvg = case LoadAvg of + unknown -> local_unknown; + _ -> LoadAvg * ?FUDGE_FACTOR + end, Loads = [{{RunQ, AdjustedLoadAvg}, Node} | RemoteLoads], {_, SelectedNode} = lists:min(Loads), SelectedNode. -- cgit v1.2.1 From b84783b5d9e607fbc967e5e261f4d89aa03962f0 Mon Sep 17 00:00:00 2001 From: Matthias Radestock Date: Mon, 21 Sep 2009 07:24:38 +0100 Subject: do not time out waitng for channel.close_ok, wait forever instead This is to prevent the following observable protocol violation: C->S: 1:channel.open S->C: 1:channel.open_ok C->S: 1:some command that triggers a channel close S->C: 1:channel.close (client waits for longer than server close_ok timeout) C->S: 1:channel.open S->C: 1:channel.open_ok The second channel.open should have been ignored by the server, and it should not have returned a channel.open_ok. --- src/rabbit_reader.erl | 85 +++++++++++++++++---------------------------------- 1 file changed, 28 insertions(+), 57 deletions(-) diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 690e6f0e..5d7f8a42 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -49,7 +49,6 @@ -define(HANDSHAKE_TIMEOUT, 10). -define(NORMAL_TIMEOUT, 3). -define(CLOSING_TIMEOUT, 1). --define(CHANNEL_CLOSING_TIMEOUT, 1). -define(CHANNEL_TERMINATION_TIMEOUT, 3). %--------------------------------------------------------------------------- @@ -94,23 +93,19 @@ %% -> log error, wait for channels to terminate forcefully, start %% terminate_connection timer, send close, *closed* %% channel exit with soft error -%% -> log error, start terminate_channel timer, mark channel as -%% closing, *running* -%% terminate_channel timeout -> remove 'closing' mark, *running* +%% -> log error, mark channel as closing, *running* %% handshake_timeout -> ignore, *running* %% heartbeat timeout -> *throw* %% closing: %% socket close -> *terminate* %% receive frame -> ignore, *closing* -%% terminate_channel timeout -> remove 'closing' mark, *closing* %% handshake_timeout -> ignore, *closing* %% heartbeat timeout -> *throw* %% channel exit with hard error %% -> log error, wait for channels to terminate forcefully, start %% terminate_connection timer, send close, *closed* %% channel exit with soft error -%% -> log error, start terminate_channel timer, mark channel as -%% closing +%% -> log error, mark channel as closing %% if last channel to exit then send connection.close_ok, %% start terminate_connection timer, *closed* %% else *closing* @@ -123,7 +118,6 @@ %% *closed* %% receive frame -> ignore, *closed* %% terminate_connection timeout -> *terminate* -%% terminate_channel timeout -> remove 'closing' mark, *closed* %% handshake_timeout -> ignore, *closed* %% heartbeat timeout -> *throw* %% channel exit -> log error, *closed* @@ -292,8 +286,6 @@ mainloop(Parent, Deb, State = #v1{sock= Sock, recv_ref = Ref}) -> mainloop(Parent, Deb, handle_channel_exit(Channel, Reason, State)); {'EXIT', Pid, Reason} -> mainloop(Parent, Deb, handle_dependent_exit(Pid, Reason, State)); - {terminate_channel, Channel, Ref1} -> - mainloop(Parent, Deb, terminate_channel(Channel, Ref1, State)); terminate_connection -> State; handshake_timeout -> @@ -341,32 +333,15 @@ close_connection(State = #v1{connection = #connection{ State#v1{connection_state = closed}. close_channel(Channel, State) -> - Ref = make_ref(), - TRef = erlang:send_after(1000 * ?CHANNEL_CLOSING_TIMEOUT, - self(), - {terminate_channel, Channel, Ref}), - put({closing_channel, Channel}, {Ref, TRef}), - State. - -terminate_channel(Channel, Ref, State) -> - case get({closing_channel, Channel}) of - undefined -> ok; %% got close_ok in the meantime - {Ref, _} -> erase({closing_channel, Channel}), - ok; - {_Ref, _} -> ok %% got close_ok, and have new closing channel - end, + put({channel, Channel}, closing), State. handle_channel_exit(Channel, Reason, State) -> - %% We remove the channel from the inbound map only. That allows - %% the channel to be re-opened, but also means the remaining - %% cleanup, including possibly closing the connection, is deferred - %% until we get the (normal) exit signal. - erase({channel, Channel}), handle_exception(State, Channel, Reason). handle_dependent_exit(Pid, normal, State) -> - channel_cleanup(Pid), + erase({chpid, Pid}), + erase({closing_chpid, Pid}), maybe_close(State); handle_dependent_exit(Pid, Reason, State) -> case channel_cleanup(Pid) of @@ -470,10 +445,20 @@ handle_frame(Type, Channel, Payload, State) -> ok = check_for_close(Channel, ChPid, AnalyzedFrame), ok = rabbit_framing_channel:process(ChPid, AnalyzedFrame), State; + closing -> + %% According to the spec, after sending a + %% channel.close we must ignore all frames except + %% channel.close_ok. + case AnalyzedFrame of + {method, 'channel.close_ok', _} -> + erase({channel, Channel}); + _ -> ok + end, + State; undefined -> case State#v1.connection_state of - running -> send_to_new_channel( - Channel, AnalyzedFrame, State), + running -> ok = send_to_new_channel( + Channel, AnalyzedFrame, State), State; Other -> throw({channel_frame_while_starting, Channel, Other, AnalyzedFrame}) @@ -716,31 +701,17 @@ i(Item, #v1{}) -> %%-------------------------------------------------------------------------- send_to_new_channel(Channel, AnalyzedFrame, State) -> - case get({closing_channel, Channel}) of - undefined -> - #v1{sock = Sock, - connection = #connection{ - frame_max = FrameMax, - user = #user{username = Username}, - vhost = VHost}} = State, - WriterPid = rabbit_writer:start(Sock, Channel, FrameMax), - ChPid = rabbit_framing_channel:start_link( - fun rabbit_channel:start_link/5, - [Channel, self(), WriterPid, Username, VHost]), - put({channel, Channel}, {chpid, ChPid}), - put({chpid, ChPid}, {channel, Channel}), - ok = rabbit_framing_channel:process(ChPid, AnalyzedFrame); - {_, TRef} -> - %% According to the spec, after sending a channel.close we - %% must ignore all frames except channel.close_ok. - case AnalyzedFrame of - {method, 'channel.close_ok', _} -> - erlang:cancel_timer(TRef), - erase({closing_channel, Channel}), - ok; - _Other -> ok - end - end. + #v1{sock = Sock, connection = #connection{ + frame_max = FrameMax, + user = #user{username = Username}, + vhost = VHost}} = State, + WriterPid = rabbit_writer:start(Sock, Channel, FrameMax), + ChPid = rabbit_framing_channel:start_link( + fun rabbit_channel:start_link/5, + [Channel, self(), WriterPid, Username, VHost]), + put({channel, Channel}, {chpid, ChPid}), + put({chpid, ChPid}, {channel, Channel}), + ok = rabbit_framing_channel:process(ChPid, AnalyzedFrame). check_for_close(Channel, ChPid, {method, 'channel.close', _}) -> channel_cleanup(ChPid), -- cgit v1.2.1 From 5ff2563f1ab5305509bf3be6691ea4493f98e85e Mon Sep 17 00:00:00 2001 From: Matthias Radestock Date: Mon, 21 Sep 2009 08:19:07 +0100 Subject: get rid of closing_chpid process dict entries They were entirely redundant. It is now the case the the chpid process dict entries only get removed when receiving an EXIT signal from a channel, which is more obviously correct. --- src/rabbit_reader.erl | 29 +++++++++-------------------- 1 file changed, 9 insertions(+), 20 deletions(-) diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 5d7f8a42..ec0c70fb 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -341,7 +341,6 @@ handle_channel_exit(Channel, Reason, State) -> handle_dependent_exit(Pid, normal, State) -> erase({chpid, Pid}), - erase({closing_chpid, Pid}), maybe_close(State); handle_dependent_exit(Pid, Reason, State) -> case channel_cleanup(Pid) of @@ -351,17 +350,10 @@ handle_dependent_exit(Pid, Reason, State) -> channel_cleanup(Pid) -> case get({chpid, Pid}) of - undefined -> - case get({closing_chpid, Pid}) of - undefined -> undefined; - {channel, Channel} -> - erase({closing_chpid, Pid}), - Channel - end; - {channel, Channel} -> - erase({channel, Channel}), - erase({chpid, Pid}), - Channel + undefined -> undefined; + {channel, Channel} -> erase({channel, Channel}), + erase({chpid, Pid}), + Channel end. all_channels() -> [Pid || {{chpid, Pid},_} <- get()]. @@ -442,7 +434,11 @@ handle_frame(Type, Channel, Payload, State) -> %%?LOGDEBUG("Ch ~p Frame ~p~n", [Channel, AnalyzedFrame]), case get({channel, Channel}) of {chpid, ChPid} -> - ok = check_for_close(Channel, ChPid, AnalyzedFrame), + case AnalyzedFrame of + {method, 'channel.close', _} -> + erase({channel, Channel}); + _ -> ok + end, ok = rabbit_framing_channel:process(ChPid, AnalyzedFrame), State; closing -> @@ -713,13 +709,6 @@ send_to_new_channel(Channel, AnalyzedFrame, State) -> put({chpid, ChPid}, {channel, Channel}), ok = rabbit_framing_channel:process(ChPid, AnalyzedFrame). -check_for_close(Channel, ChPid, {method, 'channel.close', _}) -> - channel_cleanup(ChPid), - put({closing_chpid, ChPid}, {channel, Channel}), - ok; -check_for_close(_Channel, _ChPid, _Frame) -> - ok. - log_channel_error(ConnectionState, Channel, Reason) -> rabbit_log:error("connection ~p (~p), channel ~p - error:~n~p~n", [self(), ConnectionState, Channel, Reason]). -- cgit v1.2.1 From fbe392f9fb86cd25f0852e9ab3361c01894913a3 Mon Sep 17 00:00:00 2001 From: Paul Jones Date: Mon, 21 Sep 2009 08:21:34 +0100 Subject: Removed unused .boot generation target; added rabbit.rel to list of files removed on clean --- Makefile | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/Makefile b/Makefile index f0702756..a94406a3 100644 --- a/Makefile +++ b/Makefile @@ -57,15 +57,12 @@ $(INCLUDE_DIR)/rabbit_framing.hrl: codegen.py $(AMQP_CODEGEN_DIR)/amqp_codegen.p $(SOURCE_DIR)/rabbit_framing.erl: codegen.py $(AMQP_CODEGEN_DIR)/amqp_codegen.py $(AMQP_SPEC_JSON_PATH) $(PYTHON) codegen.py body $(AMQP_SPEC_JSON_PATH) $@ -$(EBIN_DIR)/rabbit.boot $(EBIN_DIR)/rabbit.script: $(EBIN_DIR)/rabbit.app $(EBIN_DIR)/rabbit.rel $(TARGETS) - erl -noshell -eval 'systools:make_script("ebin/rabbit", [{path, ["ebin"]}]), halt().' - dialyze: $(BEAM_TARGETS) dialyzer -c $? clean: rm -f $(EBIN_DIR)/*.beam - rm -f $(EBIN_DIR)/rabbit.app $(EBIN_DIR)/rabbit.boot $(EBIN_DIR)/rabbit.script + rm -f $(EBIN_DIR)/rabbit.app $(EBIN_DIR)/rabbit.boot $(EBIN_DIR)/rabbit.script $(EBIN_DIR)/rabbit.rel rm -f $(INCLUDE_DIR)/rabbit_framing.hrl $(SOURCE_DIR)/rabbit_framing.erl codegen.pyc rm -f docs/*.[0-9].gz -- cgit v1.2.1 From 10fb1ebf5b464101b11989a333cee73f3d02c2c8 Mon Sep 17 00:00:00 2001 From: Matthias Radestock Date: Mon, 21 Sep 2009 08:22:59 +0100 Subject: include channel# in unknown_frame error --- src/rabbit_reader.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 690e6f0e..761794f1 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -451,7 +451,7 @@ handle_frame(_Type, _Channel, _Payload, State = #v1{connection_state = CS}) State; handle_frame(Type, 0, Payload, State) -> case analyze_frame(Type, Payload) of - error -> throw({unknown_frame, Type, Payload}); + error -> throw({unknown_frame, 0, Type, Payload}); heartbeat -> State; trace -> State; {method, MethodName, FieldsBin} -> @@ -460,7 +460,7 @@ handle_frame(Type, 0, Payload, State) -> end; handle_frame(Type, Channel, Payload, State) -> case analyze_frame(Type, Payload) of - error -> throw({unknown_frame, Type, Payload}); + error -> throw({unknown_frame, Channel, Type, Payload}); heartbeat -> throw({unexpected_heartbeat_frame, Channel}); trace -> throw({unexpected_trace_frame, Channel}); AnalyzedFrame -> -- cgit v1.2.1 From 4ec4db48aa0803d15e682d57cca47bc66a43293c Mon Sep 17 00:00:00 2001 From: Paul Jones Date: Mon, 21 Sep 2009 08:44:49 +0100 Subject: Added unix and windows variants of deactivate plugins script; initial packaging changes --- packaging/debs/Debian/debian/rules | 2 +- packaging/macports/net/rabbitmq-server/Portfile | 1 + packaging/windows/Makefile | 1 + scripts/rabbitmq-deactivate-plugins | 37 +++++++++++++++++++++++++ scripts/rabbitmq-deactivate-plugins.bat | 35 +++++++++++++++++++++++ 5 files changed, 75 insertions(+), 1 deletion(-) create mode 100755 scripts/rabbitmq-deactivate-plugins create mode 100644 scripts/rabbitmq-deactivate-plugins.bat diff --git a/packaging/debs/Debian/debian/rules b/packaging/debs/Debian/debian/rules index 365eea6e..5e357955 100644 --- a/packaging/debs/Debian/debian/rules +++ b/packaging/debs/Debian/debian/rules @@ -17,6 +17,6 @@ install/rabbitmq-server:: for script in rabbitmqctl rabbitmq-server rabbitmq-multi; do \ install -p -D -m 0755 debian/rabbitmq-script-wrapper $(DEB_DESTDIR)usr/sbin/$$script; \ done - for script in rabbitmq-activate-plugins; do \ + for script in rabbitmq-activate-plugins rabbitmq-deactivate-plugins; do \ install -p -D -m 0755 debian/rabbitmq-asroot-script-wrapper $(DEB_DESTDIR)usr/sbin/$$script; \ done diff --git a/packaging/macports/net/rabbitmq-server/Portfile b/packaging/macports/net/rabbitmq-server/Portfile index 1826d5c4..cf1a3a03 100644 --- a/packaging/macports/net/rabbitmq-server/Portfile +++ b/packaging/macports/net/rabbitmq-server/Portfile @@ -94,6 +94,7 @@ post-destroot { ${wrappersbin}/rabbitmq-activate-plugins file copy ${wrappersbin}/rabbitmq-multi ${wrappersbin}/rabbitmq-server file copy ${wrappersbin}/rabbitmq-multi ${wrappersbin}/rabbitmqctl + file copy ${wrappersbin}/rabbitmq-activate-plugins ${wrappersbin}/rabbitmq-deactivate-plugins } pre-install { diff --git a/packaging/windows/Makefile b/packaging/windows/Makefile index 387becb3..f17fe777 100644 --- a/packaging/windows/Makefile +++ b/packaging/windows/Makefile @@ -14,6 +14,7 @@ dist: mv $(SOURCE_DIR)/scripts/rabbitmqctl.bat $(SOURCE_DIR)/sbin mv $(SOURCE_DIR)/scripts/rabbitmq-multi.bat $(SOURCE_DIR)/sbin mv $(SOURCE_DIR)/scripts/rabbitmq-activate-plugins.bat $(SOURCE_DIR)/sbin + mv $(SOURCE_DIR)/scripts/rabbitmq-deactivate-plugins.bat $(SOURCE_DIR)/sbin rm -rf $(SOURCE_DIR)/scripts rm -rf $(SOURCE_DIR)/codegen* $(SOURCE_DIR)/Makefile rm -f $(SOURCE_DIR)/README diff --git a/scripts/rabbitmq-deactivate-plugins b/scripts/rabbitmq-deactivate-plugins new file mode 100755 index 00000000..771c4734 --- /dev/null +++ b/scripts/rabbitmq-deactivate-plugins @@ -0,0 +1,37 @@ +#!/bin/sh +## The contents of this file are subject to the Mozilla Public License +## Version 1.1 (the "License"); you may not use this file except in +## compliance with the License. You may obtain a copy of the License at +## http://www.mozilla.org/MPL/ +## +## Software distributed under the License is distributed on an "AS IS" +## basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the +## License for the specific language governing rights and limitations +## under the License. +## +## The Original Code is RabbitMQ. +## +## The Initial Developers of the Original Code are LShift Ltd, +## Cohesive Financial Technologies LLC, and Rabbit Technologies Ltd. +## +## Portions created before 22-Nov-2008 00:00:00 GMT by LShift Ltd, +## Cohesive Financial Technologies LLC, or Rabbit Technologies Ltd +## are Copyright (C) 2007-2008 LShift Ltd, Cohesive Financial +## Technologies LLC, and Rabbit Technologies Ltd. +## +## Portions created by LShift Ltd are Copyright (C) 2007-2009 LShift +## Ltd. Portions created by Cohesive Financial Technologies LLC are +## Copyright (C) 2007-2009 Cohesive Financial Technologies +## LLC. Portions created by Rabbit Technologies Ltd are Copyright +## (C) 2007-2009 Rabbit Technologies Ltd. +## +## All Rights Reserved. +## +## Contributor(s): ______________________________________. +## + +. `dirname $0`/rabbitmq-env + +RABBITMQ_EBIN=${RABBITMQ_HOME}/ebin + +rm -f ${RABBITMQ_EBIN}/rabbit.rel ${RABBITMQ_EBIN}/rabbit.script ${RABBITMQ_EBIN}/rabbit.boot diff --git a/scripts/rabbitmq-deactivate-plugins.bat b/scripts/rabbitmq-deactivate-plugins.bat new file mode 100644 index 00000000..190fdef7 --- /dev/null +++ b/scripts/rabbitmq-deactivate-plugins.bat @@ -0,0 +1,35 @@ +@echo off +REM The contents of this file are subject to the Mozilla Public License +REM Version 1.1 (the "License"); you may not use this file except in +REM compliance with the License. You may obtain a copy of the License at +REM http://www.mozilla.org/MPL/ +REM +REM Software distributed under the License is distributed on an "AS IS" +REM basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the +REM License for the specific language governing rights and limitations +REM under the License. +REM +REM The Original Code is RabbitMQ. +REM +REM The Initial Developers of the Original Code are LShift Ltd, +REM Cohesive Financial Technologies LLC, and Rabbit Technologies Ltd. +REM +REM Portions created before 22-Nov-2008 00:00:00 GMT by LShift Ltd, +REM Cohesive Financial Technologies LLC, or Rabbit Technologies Ltd +REM are Copyright (C) 2007-2008 LShift Ltd, Cohesive Financial +REM Technologies LLC, and Rabbit Technologies Ltd. +REM +REM Portions created by LShift Ltd are Copyright (C) 2007-2009 LShift +REM Ltd. Portions created by Cohesive Financial Technologies LLC are +REM Copyright (C) 2007-2009 Cohesive Financial Technologies +REM LLC. Portions created by Rabbit Technologies Ltd are Copyright +REM (C) 2007-2009 Rabbit Technologies Ltd. +REM +REM All Rights Reserved. +REM +REM Contributor(s): ______________________________________. +REM + +set RABBITMQ_EBIN_DIR="%~dp0..\ebin" + +del /f %RABBITMQ_EBIN_DIR%\rabbit.rel %RABBITMQ_EBIN_DIR%\rabbit.script %RABBITMQ_EBIN_DIR%\rabbit.boot -- cgit v1.2.1 From 2cf2fbb166fffe331310e453cb02c1c57e85c54e Mon Sep 17 00:00:00 2001 From: Paul Jones Date: Mon, 21 Sep 2009 08:55:48 +0100 Subject: Added rabbitmq-deactivate-plugins to output package --- Makefile | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Makefile b/Makefile index a94406a3..5f36d13e 100644 --- a/Makefile +++ b/Makefile @@ -170,7 +170,7 @@ install: all docs_all install_dirs cp -r ebin include LICENSE LICENSE-MPL-RabbitMQ INSTALL $(TARGET_DIR) chmod 0755 scripts/* - for script in rabbitmq-env rabbitmq-server rabbitmqctl rabbitmq-multi rabbitmq-activate-plugins; do \ + for script in rabbitmq-env rabbitmq-server rabbitmqctl rabbitmq-multi rabbitmq-activate-plugins rabbitmq-deactivate-plugins; do \ cp scripts/$$script $(TARGET_DIR)/sbin; \ [ -e $(SBIN_DIR)/$$script ] || ln -s $(SCRIPTS_REL_PATH)/$$script $(SBIN_DIR)/$$script; \ done -- cgit v1.2.1 From fe8952249034da820d4cdda353cab4680c44f67a Mon Sep 17 00:00:00 2001 From: Paul Jones Date: Mon, 21 Sep 2009 08:59:39 +0100 Subject: Added deactivate plugins wrapper in RPM packages --- packaging/RPMS/Fedora/rabbitmq-server.spec | 1 + 1 file changed, 1 insertion(+) diff --git a/packaging/RPMS/Fedora/rabbitmq-server.spec b/packaging/RPMS/Fedora/rabbitmq-server.spec index 7f442831..30cfb99f 100644 --- a/packaging/RPMS/Fedora/rabbitmq-server.spec +++ b/packaging/RPMS/Fedora/rabbitmq-server.spec @@ -56,6 +56,7 @@ install -p -D -m 0755 %{_rabbit_wrapper} %{buildroot}%{_sbindir}/rabbitmqctl install -p -D -m 0755 %{_rabbit_wrapper} %{buildroot}%{_sbindir}/rabbitmq-server install -p -D -m 0755 %{_rabbit_wrapper} %{buildroot}%{_sbindir}/rabbitmq-multi install -p -D -m 0755 %{_rabbit_asroot_wrapper} %{buildroot}%{_sbindir}/rabbitmq-activate-plugins +install -p -D -m 0755 %{_rabbit_asroot_wrapper} %{buildroot}%{_sbindir}/rabbitmq-deactivate-plugins install -p -D -m 0644 %{S:3} %{buildroot}%{_sysconfdir}/logrotate.d/rabbitmq-server -- cgit v1.2.1 From 3c047addbb00dd8f3d441a9289f4855d553e7344 Mon Sep 17 00:00:00 2001 From: Paul Jones Date: Mon, 21 Sep 2009 09:18:03 +0100 Subject: Corrected behaviour of run-node so the boot file is not used --- Makefile | 3 ++- scripts/rabbitmq-server | 5 +++-- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/Makefile b/Makefile index a94406a3..cc5f92ac 100644 --- a/Makefile +++ b/Makefile @@ -79,13 +79,14 @@ BASIC_SCRIPT_ENVIRONMENT_SETTINGS=\ run: all $(BASIC_SCRIPT_ENVIRONMENT_SETTINGS) \ - RABBITMQ_NODE_ONLY=true \ + RABBITMQ_ALLOW_INPUT=true \ RABBITMQ_SERVER_START_ARGS="$(RABBITMQ_SERVER_START_ARGS) -s rabbit" \ ./scripts/rabbitmq-server run-node: all $(BASIC_SCRIPT_ENVIRONMENT_SETTINGS) \ RABBITMQ_NODE_ONLY=true \ + RABBITMQ_ALLOW_INPUT=true \ RABBITMQ_SERVER_START_ARGS="$(RABBITMQ_SERVER_START_ARGS)" \ ./scripts/rabbitmq-server diff --git a/scripts/rabbitmq-server b/scripts/rabbitmq-server index 547220b4..e5317bb1 100755 --- a/scripts/rabbitmq-server +++ b/scripts/rabbitmq-server @@ -73,10 +73,11 @@ else fi RABBITMQ_START_RABBIT= -[ "x" = "x$RABBITMQ_NODE_ONLY" ] && RABBITMQ_START_RABBIT='-noinput -s rabbit' +[ "x" = "x$RABBITMQ_ALLOW_INPUT" ] && RABBITMQ_START_RABBIT='-noinput' +[ "x" = "x$RABBITMQ_NODE_ONLY" ] && RABBITMQ_START_RABBIT="${RABBITMQ_START_RABBIT} -s rabbit" RABBITMQ_EBIN_ROOT="${RABBITMQ_HOME}/ebin" -if [ -f "${RABBITMQ_EBIN_ROOT}/rabbit.boot" ]; then +if [ -f "${RABBITMQ_EBIN_ROOT}/rabbit.boot" ] && [ "x" = "x$RABBITMQ_NODE_ONLY" ]; then RABBITMQ_BOOT_FILE="${RABBITMQ_EBIN_ROOT}/rabbit" RABBITMQ_EBIN_PATH="" else -- cgit v1.2.1 From 07dfd12d73756d53c2362e4644d196f4b4c2e890 Mon Sep 17 00:00:00 2001 From: Matthias Radestock Date: Tue, 22 Sep 2009 10:55:57 +0100 Subject: remove extra_startup_steps from app config This should have been done as part of bug17880. --- ebin/rabbit_app.in | 1 - 1 file changed, 1 deletion(-) diff --git a/ebin/rabbit_app.in b/ebin/rabbit_app.in index 6fc6e464..dd907d1a 100644 --- a/ebin/rabbit_app.in +++ b/ebin/rabbit_app.in @@ -17,7 +17,6 @@ {env, [{tcp_listeners, [{"0.0.0.0", 5672}]}, {ssl_listeners, []}, {ssl_options, []}, - {extra_startup_steps, []}, {default_user, <<"guest">>}, {default_pass, <<"guest">>}, {default_vhost, <<"/">>}, -- cgit v1.2.1 From c759aea4c0f1116714bf6aa14320d613acbb4a09 Mon Sep 17 00:00:00 2001 From: Vlad Ionescu Date: Tue, 22 Sep 2009 16:41:50 +0100 Subject: getting rid of the .last_valid_dialysis approach; better erlang termination on failed dialysis --- .hgignore | 1 - Makefile | 28 ++++++++++------------------ src/rabbit_dialyzer.erl | 16 +++++++++++----- 3 files changed, 21 insertions(+), 24 deletions(-) diff --git a/.hgignore b/.hgignore index 74c90eb0..766e3aa8 100644 --- a/.hgignore +++ b/.hgignore @@ -12,7 +12,6 @@ syntax: regexp ^src/rabbit_framing.erl$ ^rabbit.plt$ ^basic.plt$ -^\.last_valid_dialysis$ ^ebin/rabbit.app$ ^ebin/rabbit.rel$ ^ebin/rabbit.boot$ diff --git a/Makefile b/Makefile index 609b645e..1199b73f 100644 --- a/Makefile +++ b/Makefile @@ -19,7 +19,7 @@ MANPAGES=$(patsubst %.pod, %.gz, $(wildcard docs/*.[0-9].pod)) PYTHON=python BASIC_PLT=basic.plt -PLT=rabbit.plt +RABBIT_PLT=rabbit.plt ifndef USE_SPECS # our type specs rely on features / bug fixes in dialyzer that are @@ -65,31 +65,23 @@ $(SOURCE_DIR)/rabbit_framing.erl: codegen.py $(AMQP_CODEGEN_DIR)/amqp_codegen.py $(EBIN_DIR)/rabbit.boot $(EBIN_DIR)/rabbit.script: $(EBIN_DIR)/rabbit.app $(EBIN_DIR)/rabbit.rel $(TARGETS) erl -noshell -eval 'systools:make_script("ebin/rabbit", [{path, ["ebin"]}]), halt().' -dialyze: .last_valid_dialysis - -create-plt: $(PLT) - -$(PLT): $(BEAM_TARGETS) $(BASIC_PLT) - test -f $@ || cp $(BASIC_PLT) $@ +dialyze: $(BEAM_TARGETS) $(BASIC_PLT) $(ERL_EBIN) -eval \ - "rabbit_dialyzer:update_plt(\"$@\", \"$(BEAM_TARGETS)\"), halt()." + "rabbit_dialyzer:halt_with_code(rabbit_dialyzer:dialyze_files(\"$(BASIC_PLT)\", \"$(BEAM_TARGETS)\"))." -.last_valid_dialysis: $(BEAM_TARGETS) $(PLT) - if [ $(PLT) -ot $@ ]; then \ - DIALYZER_INPUT_FILES="$(filter %.beam, $?)"; \ - else \ - DIALYZER_INPUT_FILES="$(BEAM_TARGETS)"; \ - fi; \ +create-plt: $(RABBIT_PLT) + +$(RABBIT_PLT): $(BEAM_TARGETS) $(BASIC_PLT) + cp $(BASIC_PLT) $@ $(ERL_EBIN) -eval \ - "rabbit_dialyzer:dialyze_files(\"$(PLT)\", \"$$DIALYZER_INPUT_FILES\"), halt()." && \ - touch $@ + "rabbit_dialyzer:halt_with_code(rabbit_dialyzer:add_to_plt(\"$@\", \"$(BEAM_TARGETS)\"))." $(BASIC_PLT): $(BEAM_TARGETS) if [ -f $@ ]; then \ touch $@; \ else \ $(ERL_EBIN) -eval \ - "rabbit_dialyzer:create_basic_plt(\"$@\"), halt()."; \ + "rabbit_dialyzer:halt_with_code(rabbit_dialyzer:create_basic_plt(\"$@\"))."; \ fi clean: @@ -97,7 +89,7 @@ clean: rm -f $(EBIN_DIR)/rabbit.app $(EBIN_DIR)/rabbit.boot $(EBIN_DIR)/rabbit.script rm -f $(INCLUDE_DIR)/rabbit_framing.hrl $(SOURCE_DIR)/rabbit_framing.erl codegen.pyc rm -f docs/*.[0-9].gz - rm -f $(PLT) .last_valid_dialysis + rm -f $(RABBIT_PLT) cleandb: rm -rf $(RABBITMQ_MNESIA_DIR)/* diff --git a/src/rabbit_dialyzer.erl b/src/rabbit_dialyzer.erl index 4d78adbe..c75a001b 100644 --- a/src/rabbit_dialyzer.erl +++ b/src/rabbit_dialyzer.erl @@ -32,15 +32,16 @@ -module(rabbit_dialyzer). -include("rabbit.hrl"). --export([create_basic_plt/1, update_plt/2, dialyze_files/2]). +-export([create_basic_plt/1, add_to_plt/2, dialyze_files/2, halt_with_code/1]). %%---------------------------------------------------------------------------- -ifdef(use_specs). -spec(create_basic_plt/1 :: (string()) -> 'ok'). --spec(update_plt/2 :: (string(), string()) -> 'ok'). +-spec(add_to_plt/2 :: (string(), string()) -> 'ok'). -spec(dialyze_files/2 :: (string(), string()) -> 'ok'). +-spec(halt_with_code/1 :: (atom()) -> no_return()). -endif. @@ -54,8 +55,8 @@ create_basic_plt(BasicPltPath) -> dialyzer_cl:start(OptsRecord), ok. -update_plt(PltPath, ModifiedFiles) -> - {ok, Files} = regexp:split(ModifiedFiles, " "), +add_to_plt(PltPath, FilesString) -> + {ok, Files} = regexp:split(FilesString, " "), DialyzerWarnings = dialyzer:run([ {analysis_type, plt_add}, {init_plt, PltPath}, @@ -76,7 +77,7 @@ dialyze_files(PltPath, ModifiedFiles) -> _ -> io:format("~nFAILED! dialyzer returned the following warnings:~n", []), print_warnings(DialyzerWarnings), - erlang:error({dialyzer_warnings, DialyzerWarnings}) + fail end. print_warnings(DialyzerWarnings) -> @@ -91,3 +92,8 @@ print_warnings(DialyzerWarnings) -> otp_apps_dependencies_paths() -> [code:lib_dir(App, ebin) || App <- [stdlib, kernel, mnesia, os_mon, ssl, eunit, tools, sasl]]. + +halt_with_code(ok) -> + halt(); +halt_with_code(fail) -> + halt(1). -- cgit v1.2.1 From 936e4de0ee9cf55ebb08246e2c367c8c64c66b51 Mon Sep 17 00:00:00 2001 From: Vlad Ionescu Date: Wed, 23 Sep 2009 13:58:05 +0100 Subject: broker now prints the location of rabbit.app on startup --- src/rabbit.erl | 14 ++++++++++---- src/rabbit_misc.erl | 16 ++++++++++++++++ 2 files changed, 26 insertions(+), 4 deletions(-) diff --git a/src/rabbit.erl b/src/rabbit.erl index ef1e0049..2b292412 100644 --- a/src/rabbit.erl +++ b/src/rabbit.erl @@ -215,6 +215,11 @@ log_location(Type) -> _ -> undefined end. +app_location() -> + {ok, Application} = application:get_application(), + rabbit_misc:absolute_path( + code:where_is_file(atom_to_list(Application) ++ ".app")). + %--------------------------------------------------------------------------- print_banner() -> @@ -237,10 +242,11 @@ print_banner() -> [Product, string:right([$v|Version], ProductLen), ?PROTOCOL_VERSION_MAJOR, ?PROTOCOL_VERSION_MINOR, ?COPYRIGHT_MESSAGE, ?INFORMATION_MESSAGE]), - Settings = [{"node", node()}, - {"log", log_location(kernel)}, - {"sasl log", log_location(sasl)}, - {"database dir", rabbit_mnesia:dir()}], + Settings = [{"node", node()}, + {"app descriptor", app_location()}, + {"log", log_location(kernel)}, + {"sasl log", log_location(sasl)}, + {"database dir", rabbit_mnesia:dir()}], DescrLen = lists:max([length(K) || {K, _V} <- Settings]), Format = "~-" ++ integer_to_list(DescrLen) ++ "s: ~s~n", lists:foreach(fun ({K, V}) -> io:format(Format, [K, V]) end, Settings), diff --git a/src/rabbit_misc.erl b/src/rabbit_misc.erl index 95a274e3..1af02ddf 100644 --- a/src/rabbit_misc.erl +++ b/src/rabbit_misc.erl @@ -55,6 +55,7 @@ -export([format_stderr/2]). -export([start_applications/1, stop_applications/1]). -export([unfold/2, ceil/1]). +-export([absolute_path/1]). -import(mnesia). -import(lists). @@ -124,6 +125,7 @@ -spec(stop_applications/1 :: ([atom()]) -> 'ok'). -spec(unfold/2 :: (fun ((A) -> ({'true', B, A} | 'false')), A) -> {[B], A}). -spec(ceil/1 :: (number()) -> number()). +-spec(absolute_path/1 :: (string()) -> string()). -endif. @@ -475,3 +477,17 @@ ceil(N) -> 0 -> N; _ -> 1 + T end. + +absolute_path(RelPath) -> + filename:join(absolute_path([], filename:split(filename:absname(RelPath)))). + +absolute_path([_ | ResultParts], [".." | Parts]) -> + absolute_path(ResultParts, Parts); +absolute_path([], [".." | Parts]) -> + absolute_path([], Parts); +absolute_path(ResultParts, ["." | Parts]) -> + absolute_path(ResultParts, Parts); +absolute_path(ResultParts, [Part | Parts]) -> + absolute_path([Part | ResultParts], Parts); +absolute_path(ResultParts, []) -> + lists:reverse(ResultParts). -- cgit v1.2.1 From 73956170c3aaba621371e968d66d55323bca9756 Mon Sep 17 00:00:00 2001 From: Vlad Ionescu Date: Wed, 23 Sep 2009 14:31:30 +0100 Subject: removing rabbit_misc:absolute_path --- src/rabbit.erl | 3 +-- src/rabbit_misc.erl | 16 ---------------- 2 files changed, 1 insertion(+), 18 deletions(-) diff --git a/src/rabbit.erl b/src/rabbit.erl index 2b292412..27f085c2 100644 --- a/src/rabbit.erl +++ b/src/rabbit.erl @@ -217,8 +217,7 @@ log_location(Type) -> app_location() -> {ok, Application} = application:get_application(), - rabbit_misc:absolute_path( - code:where_is_file(atom_to_list(Application) ++ ".app")). + filename:absname(code:where_is_file(atom_to_list(Application) ++ ".app")). %--------------------------------------------------------------------------- diff --git a/src/rabbit_misc.erl b/src/rabbit_misc.erl index 1af02ddf..95a274e3 100644 --- a/src/rabbit_misc.erl +++ b/src/rabbit_misc.erl @@ -55,7 +55,6 @@ -export([format_stderr/2]). -export([start_applications/1, stop_applications/1]). -export([unfold/2, ceil/1]). --export([absolute_path/1]). -import(mnesia). -import(lists). @@ -125,7 +124,6 @@ -spec(stop_applications/1 :: ([atom()]) -> 'ok'). -spec(unfold/2 :: (fun ((A) -> ({'true', B, A} | 'false')), A) -> {[B], A}). -spec(ceil/1 :: (number()) -> number()). --spec(absolute_path/1 :: (string()) -> string()). -endif. @@ -477,17 +475,3 @@ ceil(N) -> 0 -> N; _ -> 1 + T end. - -absolute_path(RelPath) -> - filename:join(absolute_path([], filename:split(filename:absname(RelPath)))). - -absolute_path([_ | ResultParts], [".." | Parts]) -> - absolute_path(ResultParts, Parts); -absolute_path([], [".." | Parts]) -> - absolute_path([], Parts); -absolute_path(ResultParts, ["." | Parts]) -> - absolute_path(ResultParts, Parts); -absolute_path(ResultParts, [Part | Parts]) -> - absolute_path([Part | ResultParts], Parts); -absolute_path(ResultParts, []) -> - lists:reverse(ResultParts). -- cgit v1.2.1 From 562eeaf6ea09d0112f59a6086ba6e820203be4c0 Mon Sep 17 00:00:00 2001 From: Vlad Ionescu Date: Wed, 23 Sep 2009 18:27:31 +0100 Subject: comment for create-plt make target --- Makefile | 1 + 1 file changed, 1 insertion(+) diff --git a/Makefile b/Makefile index eab81cb0..57b2a793 100644 --- a/Makefile +++ b/Makefile @@ -66,6 +66,7 @@ dialyze: $(BEAM_TARGETS) $(BASIC_PLT) $(ERL_EBIN) -eval \ "rabbit_dialyzer:halt_with_code(rabbit_dialyzer:dialyze_files(\"$(BASIC_PLT)\", \"$(BEAM_TARGETS)\"))." +# rabbit.plt is used by rabbitmq-erlang-client's dialyze make target create-plt: $(RABBIT_PLT) $(RABBIT_PLT): $(BEAM_TARGETS) $(BASIC_PLT) -- cgit v1.2.1 From 5e55c7df8d5536c1260f9baa2eb553b033b020a6 Mon Sep 17 00:00:00 2001 From: Matthias Radestock Date: Thu, 24 Sep 2009 06:52:47 +0100 Subject: cosmetic --- src/rabbit_dialyzer.erl | 46 +++++++++++++++++++--------------------------- 1 file changed, 19 insertions(+), 27 deletions(-) diff --git a/src/rabbit_dialyzer.erl b/src/rabbit_dialyzer.erl index c75a001b..23e6fc44 100644 --- a/src/rabbit_dialyzer.erl +++ b/src/rabbit_dialyzer.erl @@ -48,50 +48,42 @@ %%---------------------------------------------------------------------------- create_basic_plt(BasicPltPath) -> - OptsRecord = dialyzer_options:build([ - {analysis_type, plt_build}, - {output_plt, BasicPltPath}, - {files_rec, otp_apps_dependencies_paths()}]), + OptsRecord = dialyzer_options:build( + [{analysis_type, plt_build}, + {output_plt, BasicPltPath}, + {files_rec, otp_apps_dependencies_paths()}]), dialyzer_cl:start(OptsRecord), ok. add_to_plt(PltPath, FilesString) -> {ok, Files} = regexp:split(FilesString, " "), - DialyzerWarnings = dialyzer:run([ - {analysis_type, plt_add}, - {init_plt, PltPath}, - {output_plt, PltPath}, - {files, Files}]), + DialyzerWarnings = dialyzer:run([{analysis_type, plt_add}, + {init_plt, PltPath}, + {output_plt, PltPath}, + {files, Files}]), print_warnings(DialyzerWarnings), ok. dialyze_files(PltPath, ModifiedFiles) -> {ok, Files} = regexp:split(ModifiedFiles, " "), - DialyzerWarnings = dialyzer:run([ - {init_plt, PltPath}, - {files, Files}]), + DialyzerWarnings = dialyzer:run([{init_plt, PltPath}, + {files, Files}]), case DialyzerWarnings of - [] -> - io:format("Ok, dialyzer returned no warnings.~n", []), - ok; - _ -> - io:format("~nFAILED! dialyzer returned the following warnings:~n", []), - print_warnings(DialyzerWarnings), - fail + [] -> io:format("~nOk~n"), + ok; + _ -> io:format("~nFAILED with the following warnings:~n"), + print_warnings(DialyzerWarnings), + fail end. -print_warnings(DialyzerWarnings) -> - lists:foreach( - fun - (Warning) -> io:format("~s", [dialyzer:format_warning(Warning)]) - end, - DialyzerWarnings), - io:format("~n", []), +print_warnings(Warnings) -> + [io:format("~s", [dialyzer:format_warning(W)]) || W <- Warnings], + io:format("~n"), ok. otp_apps_dependencies_paths() -> [code:lib_dir(App, ebin) || - App <- [stdlib, kernel, mnesia, os_mon, ssl, eunit, tools, sasl]]. + App <- [kernel, stdlib, sasl, mnesia, os_mon, ssl, eunit, tools]]. halt_with_code(ok) -> halt(); -- cgit v1.2.1 From f2fd881c9bafa8ca8df21d37ae2ba01d965771ce Mon Sep 17 00:00:00 2001 From: Paul Jones Date: Thu, 24 Sep 2009 08:14:08 +0100 Subject: Removed redundant -s rabbit from the startup args in Makefile --- Makefile | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Makefile b/Makefile index 57b2a793..c98a45ba 100644 --- a/Makefile +++ b/Makefile @@ -103,7 +103,7 @@ BASIC_SCRIPT_ENVIRONMENT_SETTINGS=\ run: all $(BASIC_SCRIPT_ENVIRONMENT_SETTINGS) \ RABBITMQ_ALLOW_INPUT=true \ - RABBITMQ_SERVER_START_ARGS="$(RABBITMQ_SERVER_START_ARGS) -s rabbit" \ + RABBITMQ_SERVER_START_ARGS="$(RABBITMQ_SERVER_START_ARGS)" \ ./scripts/rabbitmq-server run-node: all -- cgit v1.2.1 From 95a97da5af4a488cc1ce62476ea6d518bb61d310 Mon Sep 17 00:00:00 2001 From: Paul Jones Date: Thu, 24 Sep 2009 10:16:44 +0100 Subject: Added pod file to describe rabbitmq-deactivate-plugins --- docs/rabbitmq-activate-plugins.1.pod | 2 +- docs/rabbitmq-deactivate-plugins.1.pod | 37 ++++++++++++++++++++++++++++++++++ 2 files changed, 38 insertions(+), 1 deletion(-) create mode 100644 docs/rabbitmq-deactivate-plugins.1.pod diff --git a/docs/rabbitmq-activate-plugins.1.pod b/docs/rabbitmq-activate-plugins.1.pod index 58ffea79..42f0c4d2 100644 --- a/docs/rabbitmq-activate-plugins.1.pod +++ b/docs/rabbitmq-activate-plugins.1.pod @@ -26,7 +26,7 @@ execute: =head1 SEE ALSO L, L, L, -L +L, L =head1 AUTHOR diff --git a/docs/rabbitmq-deactivate-plugins.1.pod b/docs/rabbitmq-deactivate-plugins.1.pod new file mode 100644 index 00000000..eb4fbb90 --- /dev/null +++ b/docs/rabbitmq-deactivate-plugins.1.pod @@ -0,0 +1,37 @@ +=head1 NAME + +rabbitmq-deactivate-plugins - command line tool for deactivating plugins +in a RabbitMQ broker + +=head1 SYNOPSIS + +rabbitmq-deactivate-plugins + +=head1 DESCRIPTION + +RabbitMQ is an implementation of AMQP, the emerging standard for high +performance enterprise messaging. The RabbitMQ server is a robust and +scalable implementation of an AMQP broker. + +rabbitmq-deactivate-plugins is a command line tool for deactivating +plugins installed into the broker. + +=head1 EXAMPLES + +To deactivate all of the installed plugins in the current RabbitMQ install, +execute: + + rabbitmq-deactivate-plugins + +=head1 SEE ALSO + +L, L, L, +L, L + +=head1 AUTHOR + +The RabbitMQ Team + +=head1 REFERENCES + +RabbitMQ Web Site: L -- cgit v1.2.1 From 11162837adfbd97da08c20d12be96900363ebbf9 Mon Sep 17 00:00:00 2001 From: Matthias Radestock Date: Mon, 28 Sep 2009 16:15:10 +0100 Subject: produce error 2-tuple since that is expected by things like application:start --- src/rabbit_networking.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/rabbit_networking.erl b/src/rabbit_networking.erl index eed21a01..1dd93518 100644 --- a/src/rabbit_networking.erl +++ b/src/rabbit_networking.erl @@ -101,7 +101,7 @@ check_tcp_listener_address(NamePrefix, Host, Port) -> if is_integer(Port) andalso (Port >= 0) andalso (Port =< 65535) -> ok; true -> error_logger:error_msg("invalid port ~p - not 0..65535~n", [Port]), - throw({error, invalid_port, Port}) + throw({error, {invalid_port, Port}}) end, Name = rabbit_misc:tcp_name(NamePrefix, IPAddress, Port), {IPAddress, Name}. -- cgit v1.2.1