Added a Timeout to the terminate function.

EchoTeam · May 20, 2011 · 9e070fd · 9e070fd
1 parent a7ff74b
commit 9e070fd
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/ezk_connection.erl b/src/ezk_connection.erl
@@ -417,6 +417,9 @@ terminate(_Reason, State) ->
     receive
 	{tcp, Socket, Reply} ->
 	    <<_Iteration:32, _PZxid:64, 0:32>> = Reply
+    after
+	4 ->
+	    ok
     end,
     Watchtable = State#cstate.watchtable,
     ets:foldl(fun({Data, WO, WM}, _Acc0) ->