summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2014-06-27 16:32:16 +0100
committerSimon MacMullen <simon@rabbitmq.com>2014-06-27 16:32:16 +0100
commit17f707949072f7ca07c7430c9bb3cde3de9a8a9c (patch)
tree61f43d2ab84ae749ec9f16dd7ddbff1aeafbfed9
parentc7df58362d60a763c9830e9ada2d70bbcdbbfdeb (diff)
downloadrabbitmq-server-bug26171.tar.gz
Remove some unreachable code - members_state will be filled once we have joined, and now we join immediately at startup.bug26171
-rw-r--r--src/gm.erl17
1 files changed, 0 insertions, 17 deletions
diff --git a/src/gm.erl b/src/gm.erl
index 253fd8a3..696b7fa3 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},