aboutsummaryrefslogtreecommitdiffstats
path: root/lib/wx/src/wxe_server.erl
diff options
context:
space:
mode:
authorDan Gudmundsson <[email protected]>2014-12-19 09:58:42 +0100
committerDan Gudmundsson <[email protected]>2014-12-19 09:58:42 +0100
commitddbe8a821ad57bfc2a1bcd29ed80ae8cfffe1c0e (patch)
treec396eed1aa1a5c3e5fb6c2a7474e366e0f246eb5 /lib/wx/src/wxe_server.erl
parent7cf95c33a50a705c38226bccd0caa76a96f92ea5 (diff)
downloadotp-ddbe8a821ad57bfc2a1bcd29ed80ae8cfffe1c0e.tar.gz
otp-ddbe8a821ad57bfc2a1bcd29ed80ae8cfffe1c0e.tar.bz2
otp-ddbe8a821ad57bfc2a1bcd29ed80ae8cfffe1c0e.zip
wx: Do not crash server when going down
If a connect request was made during the takedown of wx it would crash.
Diffstat (limited to 'lib/wx/src/wxe_server.erl')
-rw-r--r--lib/wx/src/wxe_server.erl14
1 files changed, 9 insertions, 5 deletions
diff --git a/lib/wx/src/wxe_server.erl b/lib/wx/src/wxe_server.erl
index 465b9da2e0..8ef568c102 100644
--- a/lib/wx/src/wxe_server.erl
+++ b/lib/wx/src/wxe_server.erl
@@ -223,14 +223,18 @@ handle_connect(Object, #evh{handler=undefined, cb=Callback} = EvData0,
Error ->
{reply, Error, State0}
end;
-handle_connect(Object, EvData=#evh{handler=Handler},
+handle_connect(Object, EvData=#evh{handler=Handler},
From, State0 = #state{users=Users}) ->
%% Correct process is already listening just register it
put(Handler, From),
- User0 = #user{events=Listeners0} = gb_trees:get(From, Users),
- User = User0#user{events=[{Object,EvData}|Listeners0]},
- State = State0#state{users=gb_trees:update(From, User, Users)},
- {reply, ok, State}.
+ case gb_trees:get(From, Users) of
+ {value, User0 = #user{events=Listeners0}} ->
+ User = User0#user{events=[{Object,EvData}|Listeners0]},
+ State = State0#state{users=gb_trees:update(From, User, Users)},
+ {reply, ok, State};
+ none -> %% We are closing up the shop
+ {reply, {error, terminating}, State0}
+ end.
invoke_cb({{Ev=#wx{}, Ref=#wx_ref{}}, FunId,_}, _S) ->
%% Event callbacks