@@ -465,7 +465,10 @@ handle_event(?INTERNAL,
465
465
% % next state is waiting for the MLD to close the connection.
466
466
% % But it might not happen, so we'll close it ourselves after a timeout.
467
467
Timeout = application :get_env (erlmld , shutdown_timeout , 5000 ),
468
- {next_state , {? PEER_READ , Kind }, activate (Data ), [{{timeout , shutdown }, Timeout , shutdown }]};
468
+ {next_state ,
469
+ {? PEER_READ , Kind },
470
+ activate (Data ),
471
+ [{{timeout , shutdown }, Timeout , shutdown }]};
469
472
_ ->
470
473
{next_state , {? PEER_READ , NextReadKind }, activate (Data )}
471
474
end ;
@@ -476,7 +479,6 @@ handle_event(info, {tcp, _Socket, _Bin}, _State, _Data) ->
476
479
handle_event (info , Message , _State , # data {worker_state = WorkerState }) ->
477
480
error_logger :error_msg (" ~p ignoring unexpected message ~p~n " , [WorkerState , Message ]),
478
481
keep_state_and_data ;
479
-
480
482
handle_event ({timeout , shutdown }, shutdown , _State , _Data ) ->
481
483
{stop , {error , shutdown_timeout }}.
482
484
0 commit comments