diff options
author | Ingela Anderton Andin <[email protected]> | 2017-06-07 10:18:32 +0200 |
---|---|---|
committer | Ingela Anderton Andin <[email protected]> | 2017-06-07 10:18:32 +0200 |
commit | f66bca0ad272dbed8ec0b3b1b35d182cf65f7a1d (patch) | |
tree | bc01cfda1b806a8dfcc3206bdd5506f5d6faa80e | |
parent | ea9998ac2441dcfe3e7bd64d70c18e70b1b5b407 (diff) | |
parent | 8fe699b8ca17a3e9e1a3cd1821e112b9983a74ae (diff) | |
download | otp-f66bca0ad272dbed8ec0b3b1b35d182cf65f7a1d.tar.gz otp-f66bca0ad272dbed8ec0b3b1b35d182cf65f7a1d.tar.bz2 otp-f66bca0ad272dbed8ec0b3b1b35d182cf65f7a1d.zip |
Merge branch 'ingela/inets/ERL-382'
* ingela/inets/ERL-382:
inets: httpc - Gracefull normal shutdown
-rw-r--r-- | lib/inets/src/http_client/httpc_handler.erl | 43 |
1 files changed, 23 insertions, 20 deletions
diff --git a/lib/inets/src/http_client/httpc_handler.erl b/lib/inets/src/http_client/httpc_handler.erl index 89c17a8679..4b2bcc7242 100644 --- a/lib/inets/src/http_client/httpc_handler.erl +++ b/lib/inets/src/http_client/httpc_handler.erl @@ -1175,17 +1175,20 @@ handle_empty_queue(Session, ProfileName, TimeOut, State) -> %% If a pipline | keep_alive session has been idle for some time is not %% closed by the server, the client may want to close it. NewState = activate_queue_timeout(TimeOut, State), - update_session(ProfileName, Session, #session.queue_length, 0), - %% Note mfa will be initialized when a new request - %% arrives. - {noreply, - NewState#state{request = undefined, - mfa = undefined, - status_line = undefined, - headers = undefined, - body = undefined - } - }. + case update_session(ProfileName, Session, #session.queue_length, 0) of + {stop, Reason} -> + {stop, {shutdown, Reason}, State}; + _ -> + %% Note mfa will be initialized when a new request + %% arrives. + {noreply, + NewState#state{request = undefined, + mfa = undefined, + status_line = undefined, + headers = undefined, + body = undefined + }} + end. receive_response(Request, Session, Data, State) -> NewState = init_wait_for_response_state(Request, State), @@ -1677,7 +1680,7 @@ update_session(ProfileName, #session{id = SessionId} = Session, Pos, Value) -> Session2 = erlang:setelement(Pos, Session, Value), insert_session(Session2, ProfileName); error:badarg -> - exit(normal); %% Manager has been shutdown + {stop, normal}; T:E -> %% Unexpected this must be an error! Stacktrace = erlang:get_stacktrace(), @@ -1697,14 +1700,14 @@ update_session(ProfileName, #session{id = SessionId} = Session, Pos, Value) -> Session, (catch httpc_manager:lookup_session(SessionId, ProfileName)), T, E]), - exit({failed_updating_session, - [{profile, ProfileName}, - {session_id, SessionId}, - {pos, Pos}, - {value, Value}, - {etype, T}, - {error, E}, - {stacktrace, Stacktrace}]}) + {stop, {failed_updating_session, + [{profile, ProfileName}, + {session_id, SessionId}, + {pos, Pos}, + {value, Value}, + {etype, T}, + {error, E}, + {stacktrace, Stacktrace}]}} end. |