OTP-8016, OTP-8056, OTP-8103, OTP-8106, OTP-8312, OTP-8315, OTP-8327, OTP-8349,

OTP-8351, OTP-8359 & OTP-8371.

3 files changed, 73 insertions, 745 deletions

diff --git a/lib/inets/src/http_client/Makefile b/lib/inets/src/http_client/Makefile
index 23170f439f..628c91421f 100644
--- a/lib/inets/src/http_client/Makefile
+++ b/lib/inets/src/http_client/Makefile
@@ -1,19 +1,19 @@
 #
 # %CopyrightBegin%
-# 
-# Copyright Ericsson AB 2005-2009. All Rights Reserved.
-# 
+#
+# Copyright Ericsson AB 2005-2010. All Rights Reserved.
+#
 # The contents of this file are subject to the Erlang Public License,
 # Version 1.1, (the "License"); you may not use this file except in
 # compliance with the License. You should have received a copy of the
 # Erlang Public License along with this software. If not, it can be
 # retrieved online at http://www.erlang.org/.
-# 
+#
 # Software distributed under the License is distributed on an "AS IS"
 # basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
 # the License for the specific language governing rights and limitations
 # under the License.
-# 
+#
 # %CopyrightEnd%
 #
 #
@@ -22,6 +22,7 @@ include $(ERL_TOP)/make/target.mk
 EBIN = ../../ebin
 include $(ERL_TOP)/make/$(TARGET)/otp.mk
 
+
 # ----------------------------------------------------
 # Application version
 # ----------------------------------------------------
@@ -29,17 +30,20 @@ include ../../vsn.mk
 
 VSN = $(INETS_VSN)
 
+
 # ----------------------------------------------------
 # Release directory specification
 # ----------------------------------------------------
-RELSYSDIR = $(RELEASE_PATH)/lib/inets-$(VSN)
+RELSYSDIR = $(RELEASE_PATH)/lib/$(APPLICATION)-$(VSN)
+
 
 # ----------------------------------------------------
 # Target Specs
 # ----------------------------------------------------
 MODULES = \
 	http \
-	http_cookie \
+	httpc \
+	httpc_cookie \
 	httpc_handler \
 	httpc_manager \
 	httpc_sup \
@@ -55,20 +59,24 @@ ERL_FILES = $(MODULES:%=%.erl)
 
 TARGET_FILES= $(MODULES:%=$(EBIN)/%.$(EMULATOR)) 
 
+
 # ----------------------------------------------------
 # INETS FLAGS
 # ----------------------------------------------------
-INETS_FLAGS = -D'SERVER_SOFTWARE="inets/$(VSN)"' \
+INETS_FLAGS = -D'SERVER_SOFTWARE="$(APPLICATION)/$(VSN)"'
+
 
 # ----------------------------------------------------
 # FLAGS
 # ----------------------------------------------------
 INETS_ERL_FLAGS += -I ../http_lib -I ../inets_app -pa ../../ebin
 
-ERL_COMPILE_FLAGS += $(INETS_ERL_FLAGS)\
+ERL_COMPILE_FLAGS += $(INETS_ERL_FLAGS) \
 		     $(INETS_FLAGS) \
                      +'{parse_transform,sys_pre_attributes}' \
                      +'{attribute,insert,app_vsn,$(APP_VSN)}'
+
+
 # ----------------------------------------------------
 # Targets
 # ----------------------------------------------------
@@ -94,6 +102,7 @@ release_spec: opt
 release_docs_spec:
 
 info:
+	@echo "APPLICATION       = $(APPLICATION)"
 	@echo "INETS_DEBUG       = $(INETS_DEBUG)"
 	@echo "INETS_FLAGS       = $(INETS_FLAGS)"
 	@echo "ERL_COMPILE_FLAGS = $(ERL_COMPILE_FLAGS)"
diff --git a/lib/inets/src/http_client/http.erl b/lib/inets/src/http_client/http.erl
index ce5d7723f0..7e1e90b50e 100644
--- a/lib/inets/src/http_client/http.erl
+++ b/lib/inets/src/http_client/http.erl
@@ -1,19 +1,19 @@
 %%
 %% %CopyrightBegin%
-%% 
-%% Copyright Ericsson AB 2002-2009. All Rights Reserved.
-%% 
+%%
+%% Copyright Ericsson AB 2002-2010. All Rights Reserved.
+%%
 %% The contents of this file are subject to the Erlang Public License,
 %% Version 1.1, (the "License"); you may not use this file except in
 %% compliance with the License. You should have received a copy of the
 %% Erlang Public License along with this software. If not, it can be
 %% retrieved online at http://www.erlang.org/.
-%% 
+%%
 %% Software distributed under the License is distributed on an "AS IS"
 %% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
 %% the License for the specific language governing rights and limitations
 %% under the License.
-%% 
+%%
 %% %CopyrightEnd%
 %%
 %%
@@ -24,7 +24,6 @@
 %%%      - RFC 2818 HTTP Over TLS
 
 -module(http).
--behaviour(inets_service).
 
 %% API
 -export([request/1, request/2, request/4, request/5,
@@ -35,15 +34,6 @@
 	 cookie_header/2, stream_next/1,
 	 default_profile/0]).
 
-%% Behavior callbacks
--export([start_standalone/1, start_service/1, 
-	 stop_service/1, services/0, service_info/1]).
-
--include("http_internal.hrl").
--include("httpc_internal.hrl").
-
--define(DEFAULT_PROFILE, default).
-
 
 %%%=========================================================================
 %%%  API
@@ -51,751 +41,75 @@
 
 %%--------------------------------------------------------------------------
 %% request(Url [, Profile]) ->
-%%           {ok, {StatusLine, Headers, Body}} | {error,Reason} 
-%%
-%%	Url - string() 
-%% Description: Calls request/4 with default values.
+%% request(Method, Request, HTTPOptions, Options [, Profile])
 %%--------------------------------------------------------------------------
 
-request(Url) ->
-    request(Url, default_profile()).
-
-request(Url, Profile) ->
-    request(get, {Url, []}, [], [], Profile).
-
-
-%%--------------------------------------------------------------------------
-%% request(Method, Request, HTTPOptions, Options [, Profile]) ->
-%%           {ok, {StatusLine, Headers, Body}} | {ok, {Status, Body}} |
-%%           {ok, RequestId} | {error,Reason} | {ok, {saved_as, FilePath}
-%%
-%%	Method - atom() = head | get | put | post | trace | options| delete 
-%%	Request - {Url, Headers} | {Url, Headers, ContentType, Body} 
-%%	Url - string() 
-%%	HTTPOptions - [HttpOption]
-%%	HTTPOption - {timeout, Time} | {connect_timeout, Time} | 
-%%                   {ssl, SSLOptions} | {proxy_auth, {User, Password}}
-%%	Ssloptions = [SSLOption]
-%%	SSLOption =  {verify, code()} | {depth, depth()} | {certfile, path()} |
-%%	{keyfile, path()} | {password, string()} | {cacertfile, path()} |
-%%	{ciphers, string()} 
-%%	Options - [Option]
-%%	Option - {sync, Boolean} | {body_format, BodyFormat} | 
-%%	{full_result, Boolean} | {stream, To} |
-%%      {headers_as_is, Boolean}  
-%%	StatusLine = {HTTPVersion, StatusCode, ReasonPhrase}</v>
-%%	HTTPVersion = string()
-%%	StatusCode = integer()
-%%	ReasonPhrase = string()
-%%	Headers = [Header]
-%%      Header = {Field, Value}
-%%	Field = string()
-%%	Value = string()
-%%	Body = string() | binary() - HTLM-code
-%%
-%% Description: Sends a HTTP-request. The function can be both
-%% syncronus and asynchronous in the later case the function will
-%% return {ok, RequestId} and later on a message will be sent to the
-%% calling process on the format {http, {RequestId, {StatusLine,
-%% Headers, Body}}} or {http, {RequestId, {error, Reason}}}
-%%--------------------------------------------------------------------------
+request(Url)          -> httpc:request(Url).
+request(Url, Profile) -> httpc:request(Url, Profile).
 
 request(Method, Request, HttpOptions, Options) ->
-    request(Method, Request, HttpOptions, Options, default_profile()). 
+    httpc:request(Method, Request, HttpOptions, Options). 
+request(Method, Request, HttpOptions, Options, Profile) ->
+    httpc:request(Method, Request, HttpOptions, Options, Profile). 
 
-request(Method, {Url, Headers}, HTTPOptions, Options, Profile) 
-  when (Method =:= options) orelse 
-       (Method =:= get) orelse 
-       (Method =:= head) orelse 
-       (Method =:= delete) orelse 
-       (Method =:= trace) ->
-    case http_uri:parse(Url) of
-	{error, Reason} ->
-	    {error, Reason};
-	ParsedUrl ->
-	    handle_request(Method, Url, ParsedUrl, Headers, [], [], 
-			   HTTPOptions, Options, Profile)
-    end;
-     
-request(Method, {Url,Headers,ContentType,Body}, HTTPOptions, Options, Profile) 
-  when (Method =:= post) orelse (Method =:= put) ->
-    case http_uri:parse(Url) of
-	{error, Reason} ->
-	    {error, Reason};
-	ParsedUrl ->
-	    handle_request(Method, Url, 
-			   ParsedUrl, Headers, ContentType, Body, 
-			   HTTPOptions, Options, Profile)
-    end.
 
 %%--------------------------------------------------------------------------
-%% request(RequestId) -> ok
-%%   RequestId - As returned by request/4  
-%%                                 
-%% Description: Cancels a HTTP-request.
+%% cancel_request(RequestId [, Profile])
 %%-------------------------------------------------------------------------
-cancel_request(RequestId) ->
-    cancel_request(RequestId, default_profile()).
 
+cancel_request(RequestId) ->
+    httpc:cancel_request(RequestId).
 cancel_request(RequestId, Profile) ->
-    ok = httpc_manager:cancel_request(RequestId, profile_name(Profile)), 
-    receive  
-	%% If the request was allready fullfilled throw away the 
-	%% answer as the request has been canceled.
-	{http, {RequestId, _}} ->
-	    ok 
-    after 0 ->
-	    ok
-    end.
-
-
-set_option(Key, Value) ->
-    set_option(Key, Value, default_profile()).
-
-set_option(Key, Value, Profile) ->
-    set_options([{Key, Value}], Profile).
+    httpc:cancel_request(RequestId, Profile).
 
 
 %%--------------------------------------------------------------------------
-%% set_options(Options [, Profile]) -> ok | {error, Reason}
-%%   Options - [Option]
-%%   Profile - atom()
-%%   Option - {proxy, {Proxy, NoProxy}} | {max_sessions, MaxSessions} | 
-%%            {max_pipeline_length, MaxPipeline} | 
-%%            {pipeline_timeout, PipelineTimeout} | {cookies, CookieMode} | 
-%%            {ipfamily, IpFamily}
-%%   Proxy - {Host, Port}
-%%   NoProxy - [Domain | HostName | IPAddress]   
-%%   MaxSessions, MaxPipeline, PipelineTimeout = integer()   
-%%   CookieMode - enabled | disabled | verify
-%%   IpFamily - inet | inet6 | inet6fb4
-%% Description: Informs the httpc_manager of the new settings. 
+%% set_options(Options [, Profile])
+%% set_option(Key, Value [, Profile])
 %%-------------------------------------------------------------------------
+
 set_options(Options) ->
-    set_options(Options, default_profile()).
+    httpc:set_options(Options).
 set_options(Options, Profile) ->
-    case validate_options(Options) of
-	{ok, Opts} ->
-	    try httpc_manager:set_options(Opts, profile_name(Profile)) of
-		Result ->
-		    Result
-	    catch
-		exit:{noproc, _} ->
-		    {error, inets_not_started}
-	    end;
-	{error, Reason} ->
-	    {error, Reason}
-    end.
+    httpc:set_options(Options, Profile).
+
+set_option(Key, Value) ->
+    httpc:set_option(Key, Value).
+set_option(Key, Value, Profile) ->
+    httpc:set_option(Key, Value, Profile).
 
 
 %%--------------------------------------------------------------------------
-%% verify_cookies(SetCookieHeaders, Url [, Profile]) -> ok | {error, reason} 
-%%   
-%%                                 
-%% Description: Store the cookies from <SetCookieHeaders> 
-%%              in the cookie database
-%% for the profile <Profile>. This function shall be used when the option
-%% cookie is set to verify. 
+%% verify_cookies(SetCookieHeaders, Url [, Profile])
 %%-------------------------------------------------------------------------
-verify_cookies(SetCookieHeaders, Url) ->
-    verify_cookies(SetCookieHeaders, Url, default_profile()).
 
+verify_cookies(SetCookieHeaders, Url) ->
+    httpc:store_cookies(SetCookieHeaders, Url).
 verify_cookies(SetCookieHeaders, Url, Profile) ->
-    {_, _, Host, Port, Path, _} = http_uri:parse(Url),
-    ProfileName = profile_name(Profile),
-    Cookies = http_cookie:cookies(SetCookieHeaders, Path, Host),
-    try httpc_manager:store_cookies(Cookies, {Host, Port}, ProfileName) of
-	_ ->
-	    ok
-    catch 
-	exit:{noproc, _} ->
-	    {error, {not_started, Profile}}
-    end.
+    httpc:store_cookies(SetCookieHeaders, Url, Profile).
+
 
 %%--------------------------------------------------------------------------
-%% cookie_header(Url [, Profile]) -> Header | {error, Reason}
-%%               
-%% Description: Returns the cookie header that would be sent when making
-%% a request to <Url>.
+%% cookie_header(Url [, Profile])
 %%-------------------------------------------------------------------------
-cookie_header(Url) ->
-    cookie_header(Url, default_profile()).
 
+cookie_header(Url) ->
+    httpc:cookie_header(Url).
 cookie_header(Url, Profile) ->
-    try httpc_manager:cookies(Url, profile_name(Profile)) of
-	Header ->
-	    Header
-    catch 
-	exit:{noproc, _} ->
-	    {error, {not_started, Profile}}
-    end.
-
-
-stream_next(Pid) ->
-    httpc_handler:stream_next(Pid).
-
-%%%========================================================================
-%%% Behavior callbacks
-%%%========================================================================
-start_standalone(PropList) ->
-    case proplists:get_value(profile, PropList) of
-	undefined ->
-	    {error, no_profile};
-	Profile ->
-	    Dir = 
-		proplists:get_value(data_dir, PropList, only_session_cookies),
-	    httpc_manager:start_link({Profile, Dir}, stand_alone)
-    end.
-
-start_service(Config) ->
-    httpc_profile_sup:start_child(Config).
-
-stop_service(Profile) when is_atom(Profile) ->
-    httpc_profile_sup:stop_child(Profile);
-stop_service(Pid) when is_pid(Pid) ->
-    case service_info(Pid) of
-	{ok, [{profile, Profile}]} ->
-	    stop_service(Profile);
-	Error ->
-	    Error
-    end.
-
-services() ->
-    [{httpc, Pid} || {_, Pid, _, _} <- 
-			supervisor:which_children(httpc_profile_sup)].
-service_info(Pid) ->
-    try [{ChildName, ChildPid} || 
-	    {ChildName, ChildPid, _, _} <- 
-		supervisor:which_children(httpc_profile_sup)] of
-	Children ->
-	    child_name2info(child_name(Pid, Children))
-    catch
-	exit:{noproc, _} ->
-	    {error, service_not_available} 
-    end.
-
-
-%%%========================================================================
-%%% Internal functions
-%%%========================================================================
-handle_request(Method, Url, 
-	       {Scheme, UserInfo, Host, Port, Path, Query}, 
-	       Headers, ContentType, Body, 
-	       HTTPOptions0, Options, Profile) ->
-
-    HTTPOptions = http_options(HTTPOptions0),
-    Sync        = proplists:get_value(sync, Options, true),
-    NewHeaders  = lists:map(fun({Key, Val}) -> 
-				    {http_util:to_lower(Key), Val} end,
-			    Headers),
-    Stream = proplists:get_value(stream, Options, none),
-    case {Sync, Stream} of
-	{true, self} ->
-	    {error, streaming_error};
-	_ ->
-	    RecordHeaders = header_record(NewHeaders, 
-					  #http_request_h{}, 
-					  Host, 
-					  HTTPOptions#http_options.version),
-	    Request = #request{from     = self(),
-			       scheme   = Scheme, 
-			       address  = {Host,Port},
-			       path     = Path, 
-			       pquery   = Query, 
-			       method   = Method,
-			       headers  = RecordHeaders, 
-			       content  = {ContentType,Body},
-			       settings = HTTPOptions, 
-			       abs_uri  = Url, 
-			       userinfo = UserInfo, 
-			       stream   = Stream, 
-			       headers_as_is = headers_as_is(Headers, Options)},
-	    try httpc_manager:request(Request, profile_name(Profile)) of
-		{ok, RequestId} ->
-		    handle_answer(RequestId, Sync, Options);
-		{error, Reason} ->
-		    {error, Reason}
-	    catch
-		error:{noproc, _} ->
-		    {error, {not_started, Profile}}
-	    end
-    end.
-
-
-handle_answer(RequestId, false, _) ->
-    {ok, RequestId};
-handle_answer(RequestId, true, Options) ->
-    receive
-	{http, {RequestId, saved_to_file}} ->
-	    {ok, saved_to_file};
-	{http, {RequestId, Result = {_,_,_}}} ->
-	    return_answer(Options, Result);
-	{http, {RequestId, {error, Reason}}} ->
-	    {error, Reason}
-    end.
-
-return_answer(Options, {{"HTTP/0.9",_,_}, _, BinBody}) ->
-    Body = format_body(BinBody, Options),
-    {ok, Body};
-   
-return_answer(Options, {StatusLine, Headers, BinBody}) ->
-
-    Body = format_body(BinBody, Options),
-    
-    case proplists:get_value(full_result, Options, true) of
-	true ->
-	    {ok, {StatusLine, Headers, Body}};
-	false ->
-	    {_, Status, _} = StatusLine,
-	    {ok, {Status, Body}}
-    end.
-
-format_body(BinBody, Options) ->
-    case proplists:get_value(body_format, Options, string) of
-	string ->
-	    binary_to_list(BinBody);
-	_ ->
-	    BinBody
-    end.
+    httpc:cookie_header(Url, Profile).
 
-%% This options is a workaround for http servers that do not follow the 
-%% http standard and have case sensative header parsing. Should only be
-%% used if there is no other way to communicate with the server or for
-%% testing purpose.
-headers_as_is(Headers, Options) ->
-     case proplists:get_value(headers_as_is, Options, false) of
-	 false ->
-	     [];
-	 true  ->
-	     Headers
-     end.
 
+%%--------------------------------------------------------------------------
+%% stream_next(Pid)
+%%-------------------------------------------------------------------------
 
-http_options(HttpOptions) ->
-    HttpOptionsDefault = http_options_default(),
-    http_options(HttpOptionsDefault, HttpOptions, #http_options{}).
-
-http_options([], [], Acc) ->
-    Acc;
-http_options([], HttpOptions, Acc) ->
-    Fun = fun(BadOption) ->
-		    Report = io_lib:format("Invalid option ~p ignored ~n", 
-					   [BadOption]),
-		    error_logger:info_report(Report)
-	  end,
-    lists:foreach(Fun, HttpOptions),
-    Acc;
-http_options([{Tag, Default, Idx, Post} | Defaults], HttpOptions, Acc) ->
-    case lists:keysearch(Tag, 1, HttpOptions) of
-	{value, {Tag, Val0}} ->
-	    case Post(Val0) of
-		{ok, Val} ->
-		    Acc2 = setelement(Idx, Acc, Val),
-		    HttpOptions2 = lists:keydelete(Tag, 1, HttpOptions),
-		    http_options(Defaults, HttpOptions2, Acc2);
-		error ->
-		    Report = io_lib:format("Invalid option ~p:~p ignored ~n", 
-					   [Tag, Val0]),
-		    error_logger:info_report(Report),
-		    HttpOptions2 = lists:keydelete(Tag, 1, HttpOptions),
-		    http_options(Defaults, HttpOptions2, Acc)
-	    end;
-	false ->
-	    DefaultVal = 
-		case Default of
-		    {value, Val} ->
-			Val;
-		    {field, DefaultIdx} ->
-			element(DefaultIdx, Acc)
-		end,
-	    Acc2 = setelement(Idx, Acc, DefaultVal),
-	    http_options(Defaults, HttpOptions, Acc2)
-    end.
-		    
-http_options_default() ->
-    VersionPost = 
-	fun(Value) when is_atom(Value) ->
-		{ok, http_util:to_upper(atom_to_list(Value))};
-	   (Value) when is_list(Value) ->
-		{ok, http_util:to_upper(Value)};
-	   (_) ->
-		error
-	end,
-    TimeoutPost = fun(Value) when is_integer(Value) andalso (Value >= 0) ->
-			  {ok, Value};
-		     (infinity = Value) ->
-			  {ok, Value};
-		     (_) ->
-			  error
-		  end,
-    AutoRedirectPost = fun(Value) when (Value =:= true) orelse 
-				       (Value =:= false) ->
-			       {ok, Value};
-			  (_) ->
-			       error
-		       end,
-    SslPost = fun(Value) when is_list(Value) ->
-		      {ok, Value};
-		 (_) ->
-		      error
-	      end,
-    ProxyAuthPost = fun({User, Passwd} = Value) when is_list(User) andalso 
-						     is_list(Passwd) ->
-			    {ok, Value};
-		       (_) ->
-			    error
-		    end,
-    RelaxedPost = fun(Value) when (Value =:= true) orelse 
-				  (Value =:= false) ->
-			  {ok, Value};
-		     (_) ->
-			  error
-		  end,
-    ConnTimeoutPost = 
-	fun(Value) when is_integer(Value) andalso (Value >= 0) ->
-		{ok, Value};
-	   (infinity = Value) ->
-		{ok, Value};
-	   (_) ->
-		error
-	end,
-    [
-     {version,         {value, "HTTP/1.1"},              #http_options.version,         VersionPost}, 
-     {timeout,         {value, ?HTTP_REQUEST_TIMEOUT},   #http_options.timeout,         TimeoutPost},
-     {autoredirect,    {value, true},                    #http_options.autoredirect,    AutoRedirectPost},
-     {ssl,             {value, []},                      #http_options.ssl,             SslPost},
-     {proxy_auth,      {value, undefined},               #http_options.proxy_auth,      ProxyAuthPost},
-     {relaxed,         {value, false},                   #http_options.relaxed,         RelaxedPost},
-     %% this field has to be *after* the timeout field (as that field is used for the default value)
-     {connect_timeout, {field,   #http_options.timeout}, #http_options.connect_timeout, ConnTimeoutPost}
-    ].
-
-validate_options(Options) ->
-    (catch validate_options(Options, [])).
-
-validate_options([], ValidateOptions) ->
-    {ok, lists:reverse(ValidateOptions)};
-
-validate_options([{proxy, Proxy} = Opt| Tail], Acc) ->
-    validate_proxy(Proxy),
-    validate_options(Tail, [Opt | Acc]);
-
-validate_options([{max_sessions, Value} = Opt| Tail], Acc) ->
-    validate_max_sessions(Value),
-    validate_options(Tail, [Opt | Acc]);
-
-validate_options([{keep_alive_timeout, Value} = Opt| Tail], Acc) ->
-    validate_keep_alive_timeout(Value),
-    validate_options(Tail, [Opt | Acc]);
-
-validate_options([{max_keep_alive_length, Value} = Opt| Tail], Acc) ->
-    validate_max_keep_alive_length(Value),
-    validate_options(Tail, [Opt | Acc]);
-
-validate_options([{pipeline_timeout, Value} = Opt| Tail], Acc) ->
-    validate_pipeline_timeout(Value),
-    validate_options(Tail, [Opt | Acc]);
-
-validate_options([{max_pipeline_length, Value} = Opt| Tail], Acc) ->
-    validate_max_pipeline_length(Value), 
-    validate_options(Tail, [Opt | Acc]);
-
-validate_options([{cookies, Value} = Opt| Tail], Acc) ->
-    validate_cookies(Value),
-    validate_options(Tail, [Opt | Acc]);
-
-validate_options([{ipfamily, Value} = Opt| Tail], Acc) ->
-    validate_ipfamily(Value), 
-    validate_options(Tail, [Opt | Acc]);
-
-%% For backward compatibillity
-validate_options([{ipv6, Value}| Tail], Acc) ->
-    NewValue = validate_ipv6(Value), 
-    Opt = {ipfamily, NewValue},
-    validate_options(Tail, [Opt | Acc]);
-
-validate_options([{ip, Value} = Opt| Tail], Acc) ->
-    validate_ip(Value),
-    validate_options(Tail, [Opt | Acc]);
-
-validate_options([{port, Value} = Opt| Tail], Acc) ->
-    validate_port(Value), 
-    validate_options(Tail, [Opt | Acc]);
-
-validate_options([{verbose, Value} = Opt| Tail], Acc) ->
-    validate_verbose(Value), 
-    validate_options(Tail, [Opt | Acc]);
-
-validate_options([{_, _} = Opt| _], _Acc) ->
-    {error, {not_an_option, Opt}}.
-
-
-validate_proxy({{ProxyHost, ProxyPort}, NoProxy} = Proxy) 
-  when is_list(ProxyHost) andalso 
-       is_integer(ProxyPort) andalso 
-       is_list(NoProxy) ->
-    Proxy;
-validate_proxy(BadProxy) ->
-    bad_option(proxy, BadProxy).
-
-validate_max_sessions(Value) when is_integer(Value) andalso (Value >= 0) ->
-    Value;
-validate_max_sessions(BadValue) ->
-    bad_option(max_sessions, BadValue).
-
-validate_keep_alive_timeout(Value) when is_integer(Value) andalso (Value >= 0) ->
-    Value;
-validate_keep_alive_timeout(infinity = Value) ->
-    Value;
-validate_keep_alive_timeout(BadValue) ->
-    bad_option(keep_alive_timeout, BadValue).
-
-validate_max_keep_alive_length(Value) when is_integer(Value) andalso (Value >= 0) ->
-    Value;
-validate_max_keep_alive_length(BadValue) ->
-    bad_option(max_keep_alive_length, BadValue).
-
-validate_pipeline_timeout(Value) when is_integer(Value) ->
-    Value;
-validate_pipeline_timeout(infinity = Value) ->
-    Value;
-validate_pipeline_timeout(BadValue) ->
-    bad_option(pipeline_timeout, BadValue).
-
-validate_max_pipeline_length(Value) when is_integer(Value) ->
-    Value;
-validate_max_pipeline_length(BadValue) ->
-    bad_option(max_pipeline_length, BadValue).
-
-validate_cookies(Value) 
-  when ((Value =:= enabled)  orelse 
-	(Value =:= disabled) orelse 
-	(Value =:= verify)) ->
-    Value;
-validate_cookies(BadValue) ->
-    bad_option(cookies, BadValue).
-
-validate_ipv6(Value) when (Value =:= enabled) orelse (Value =:= disabled) ->
-    case Value of
-	enabled ->
-	    inet6fb4;
-	disabled ->
-	    inet
-    end;  
-validate_ipv6(BadValue) ->
-    bad_option(ipv6, BadValue).
-
-validate_ipfamily(Value) 
-  when (Value =:= inet) orelse (Value =:= inet6) orelse (Value =:= inet6fb4) ->
-    Value;
-validate_ipfamily(BadValue) ->
-    bad_option(ipfamily, BadValue).
-
-validate_ip(Value) 
-  when is_tuple(Value) andalso ((size(Value) =:= 4) orelse (size(Value) =:= 8)) ->
-    Value;
-validate_ip(BadValue) ->
-    bad_option(ip, BadValue).
-    
-validate_port(Value) when is_integer(Value) ->
-    Value;
-validate_port(BadValue) ->
-    bad_option(port, BadValue).
-
-validate_verbose(Value) 
-  when ((Value =:= false) orelse 
-	(Value =:= verbose) orelse 
-	(Value =:= debug) orelse 
-	(Value =:= trace)) ->
-    ok;
-validate_verbose(BadValue) ->
-    bad_option(verbose, BadValue).
-
-bad_option(Option, BadValue) ->
-    throw({error, {bad_option, Option, BadValue}}).
-
-
-
-header_record([], RequestHeaders, Host, Version) ->
-    validate_headers(RequestHeaders, Host, Version);
-header_record([{"cache-control", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{'cache-control' = Val},
-		  Host, Version);  
-header_record([{"connection", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{connection = Val}, Host,
-		 Version);
-header_record([{"date", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{date = Val}, Host, 
-		  Version);  
-header_record([{"pragma", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{pragma = Val}, Host,
-		  Version);  
-header_record([{"trailer", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{trailer = Val}, Host,
-		  Version);  
-header_record([{"transfer-encoding", Val} | Rest], RequestHeaders, Host, 
-	      Version) ->
-    header_record(Rest, 
-		  RequestHeaders#http_request_h{'transfer-encoding' = Val},
-		  Host, Version);  
-header_record([{"upgrade", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{upgrade = Val}, Host,
-		  Version);  
-header_record([{"via", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{via = Val}, Host, 
-		  Version);  
-header_record([{"warning", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{warning = Val}, Host,
-		  Version);  
-header_record([{"accept", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{accept = Val}, Host,
-		  Version);  
-header_record([{"accept-charset", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{'accept-charset' = Val}, 
-		  Host, Version);  
-header_record([{"accept-encoding", Val} | Rest], RequestHeaders, Host, 
-	      Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{'accept-encoding' = Val},
-		  Host, Version);  
-header_record([{"accept-language", Val} | Rest], RequestHeaders, Host, 
-	      Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{'accept-language' = Val},
-		  Host, Version);  
-header_record([{"authorization", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{authorization = Val}, 
-		  Host, Version);  
-header_record([{"expect", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{expect = Val}, Host,
-		  Version);
-header_record([{"from", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{from = Val}, Host, 
-		  Version);  
-header_record([{"host", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{host = Val}, Host, 
-		  Version);
-header_record([{"if-match", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{'if-match' = Val},
-		  Host, Version);  
-header_record([{"if-modified-since", Val} | Rest], RequestHeaders, Host, 
-	      Version) ->
-    header_record(Rest, 
-		  RequestHeaders#http_request_h{'if-modified-since' = Val},
-		  Host, Version);  
-header_record([{"if-none-match", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{'if-none-match' = Val}, 
-		  Host, Version);  
-header_record([{"if-range", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{'if-range' = Val}, 
-		  Host, Version);  
-
-header_record([{"if-unmodified-since", Val} | Rest], RequestHeaders, Host, 
-	      Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{'if-unmodified-since' 
-						      = Val}, Host, Version);  
-header_record([{"max-forwards", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{'max-forwards' = Val}, 
-		  Host, Version);  
-header_record([{"proxy-authorization", Val} | Rest], RequestHeaders, Host, 
-	      Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{'proxy-authorization' 
-						      = Val}, Host, Version);  
-header_record([{"range", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{range = Val}, Host, 
-		  Version);  
-header_record([{"referer", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{referer = Val}, Host, 
-		  Version);  
-header_record([{"te", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{te = Val}, Host, 
-		  Version);  
-header_record([{"user-agent", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{'user-agent' = Val}, 
-		  Host, Version);  
-header_record([{"allow", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{allow = Val}, Host, 
-		  Version);  
-header_record([{"content-encoding", Val} | Rest], RequestHeaders, Host, 
-	      Version) ->
-    header_record(Rest, 
-		  RequestHeaders#http_request_h{'content-encoding' = Val},
-		  Host, Version);  
-header_record([{"content-language", Val} | Rest], RequestHeaders, 
-	      Host, Version) ->
-    header_record(Rest, 
-		  RequestHeaders#http_request_h{'content-language' = Val}, 
-		  Host, Version);  
-header_record([{"content-length", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{'content-length' = Val},
-		  Host, Version);  
-header_record([{"content-location", Val} | Rest], RequestHeaders, 
-	      Host, Version) ->
-    header_record(Rest, 
-		  RequestHeaders#http_request_h{'content-location' = Val},
-		  Host, Version);  
-header_record([{"content-md5", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{'content-md5' = Val}, 
-		  Host, Version);  
-header_record([{"content-range", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{'content-range' = Val},
-		  Host, Version);  
-header_record([{"content-type", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{'content-type' = Val}, 
-		  Host, Version);  
-header_record([{"expires", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{expires = Val}, Host, 
-		  Version);  
-header_record([{"last-modified", Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{'last-modified' = Val},
-		  Host, Version);  
-header_record([{Key, Val} | Rest], RequestHeaders, Host, Version) ->
-    header_record(Rest, RequestHeaders#http_request_h{
-			  other = [{Key, Val} |
-				   RequestHeaders#http_request_h.other]}, 
-		  Host, Version).
+stream_next(Pid) ->
+    httpc:stream_next(Pid).
 
-validate_headers(RequestHeaders = #http_request_h{te = undefined}, Host, 
-		 "HTTP/1.1" = Version) ->
-    validate_headers(RequestHeaders#http_request_h{te = ""}, Host, 
-		     "HTTP/1.1" = Version);
-validate_headers(RequestHeaders = #http_request_h{host = undefined}, 
-		 Host, "HTTP/1.1" = Version) ->
-    validate_headers(RequestHeaders#http_request_h{host = Host}, Host, Version);
-validate_headers(RequestHeaders, _, _) ->
-    RequestHeaders.
 
+%%--------------------------------------------------------------------------
+%% default_profile()
+%%-------------------------------------------------------------------------
 
 default_profile() ->
-    ?DEFAULT_PROFILE.
-
-profile_name(?DEFAULT_PROFILE) ->
-    httpc_manager;
-profile_name(Pid) when is_pid(Pid) ->
-    Pid;
-profile_name(Profile) ->
-    list_to_atom("httpc_manager_" ++ atom_to_list(Profile)).
-
-child_name2info(undefined) ->
-    {error, no_such_service};
-child_name2info(httpc_manager) ->
-    {ok, [{profile, default}]};
-child_name2info({http, Profile}) ->
-    {ok, [{profile, Profile}]}.
-
-child_name(_, []) ->
-    undefined;
-child_name(Pid, [{Name, Pid} | _]) ->
-    Name;
-child_name(Pid, [_ | Children]) ->
-    child_name(Pid, Children).
-
-%% d(F) ->
-%%    d(F, []).
-
-%% d(F, A) -> 
-%%     d(get(dbg), F, A).
-
-%% d(true, F, A) ->
-%%     io:format(user, "~w:~w:" ++ F ++ "~n", [self(), ?MODULE | A]);
-%% d(_, _, _) ->
-%%     ok.
-
+    httpc:default_profile().
diff --git a/lib/inets/src/http_client/httpc_response.erl b/lib/inets/src/http_client/httpc_response.erl
index e2ba66f730..df7d40a33e 100644
--- a/lib/inets/src/http_client/httpc_response.erl
+++ b/lib/inets/src/http_client/httpc_response.erl
@@ -1,19 +1,19 @@
 %%
 %% %CopyrightBegin%
-%% 
-%% Copyright Ericsson AB 2004-2009. All Rights Reserved.
-%% 
+%%
+%% Copyright Ericsson AB 2004-2010. All Rights Reserved.
+%%
 %% The contents of this file are subject to the Erlang Public License,
 %% Version 1.1, (the "License"); you may not use this file except in
 %% compliance with the License. You should have received a copy of the
 %% Erlang Public License along with this software. If not, it can be
 %% retrieved online at http://www.erlang.org/.
-%% 
+%%
 %% Software distributed under the License is distributed on an "AS IS"
 %% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
 %% the License for the specific language governing rights and limitations
 %% under the License.
-%% 
+%%
 %% %CopyrightEnd%
 %%
 
@@ -132,8 +132,13 @@ result(Response = {{_,Code,_}, _, _}, Request) when (Code div 100) =:= 5 ->
 result(Response, Request) -> 
     transparent(Response, Request).
 
-send(To, Msg) -> 
-    To ! {http, Msg}.
+send(Receiver, Msg) when is_pid(Receiver) ->
+    Receiver ! {http, Msg};
+send(Receiver, Msg) when is_function(Receiver) ->
+    (catch Receiver(Msg));
+send({Module, Function, Args}, Msg) ->
+    (catch apply(Module, Function, [Msg | Args])).
+
 
 %%%========================================================================
 %%% Internal functions