diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-06-27 16:32:16 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-06-27 16:32:16 +0100 |
| commit | 249efaf39abb97e183483d057ec54ba14069d05b (patch) | |
| tree | 61f43d2ab84ae749ec9f16dd7ddbff1aeafbfed9 | |
| parent | fabe615f03ce12cdfa7ddf1a8ed0a5eb1c23ce32 (diff) | |
| download | rabbitmq-server-git-249efaf39abb97e183483d057ec54ba14069d05b.tar.gz | |
Remove some unreachable code - members_state will be filled once we have joined, and now we join immediately at startup.
| -rw-r--r-- | src/gm.erl | 17 |
1 files changed, 0 insertions, 17 deletions
diff --git a/src/gm.erl b/src/gm.erl index 253fd8a3f9..696b7fa3e8 100644 --- a/src/gm.erl +++ b/src/gm.erl @@ -570,11 +570,6 @@ init([GroupName, Module, Args, TxnFun]) -> txn_executor = TxnFun }, hibernate, {backoff, ?HIBERNATE_AFTER_MIN, ?HIBERNATE_AFTER_MIN, ?DESIRED_HIBERNATE}}. - -handle_call({confirmed_broadcast, _Msg}, _From, - State = #state { members_state = undefined }) -> - reply(not_joined, State); - handle_call({confirmed_broadcast, Msg}, _From, State = #state { self = Self, right = {Self, undefined}, @@ -590,10 +585,6 @@ handle_call({confirmed_broadcast, Msg}, From, State) -> handle_callback_result({Result, flush_broadcast_buffer( State1 #state { confirms = Confirms1 })}); -handle_call(info, _From, - State = #state { members_state = undefined }) -> - reply(not_joined, State); - handle_call(info, _From, State = #state { group_name = GroupName, module = Module, view = View }) -> @@ -601,10 +592,6 @@ handle_call(info, _From, State = #state { group_name = GroupName, {module, Module}, {group_members, get_pids(alive_view_members(View))}], State); -handle_call({add_on_right, _NewMember}, _From, - State = #state { members_state = undefined }) -> - reply(not_ready, State); - handle_call({add_on_right, NewMember}, _From, State = #state { self = Self, group_name = GroupName, @@ -634,10 +621,6 @@ handle_cast({?TAG, ReqVer, Msg}, if_callback_success( Result, fun handle_msg_true/3, fun handle_msg_false/3, Msg, State1)); -handle_cast({broadcast, _Msg, _SizeHint}, - State = #state { members_state = undefined }) -> - noreply(State); - handle_cast({broadcast, Msg, _SizeHint}, State = #state { self = Self, right = {Self, undefined}, |