The R13B03 release.OTP_R13B03

1 files changed, 138 insertions, 0 deletions

diff --git a/lib/crypto/src/crypto_server.erl b/lib/crypto/src/crypto_server.erl
new file mode 100644
index 0000000000..0b1e5c9b02
--- /dev/null
+++ b/lib/crypto/src/crypto_server.erl
@@ -0,0 +1,138 @@
+%%
+%% %CopyrightBegin%
+%% 
+%% Copyright Ericsson AB 1999-2009. 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%
+%%
+
+%% Purpose: Provide cryptographic algorithms.
+
+-module(crypto_server).
+
+-behaviour(gen_server).
+
+-export([start_link/0,client_port/0]).
+
+%% Internal exports, call-back functions.
+-export([init/1,handle_call/3,handle_cast/2,handle_info/2,code_change/3,
+	 terminate/2]).
+
+%% Measurements shows that inlining port_names/0 is worth doing.
+-compile({inline,[{port_names,0}]}).
+
+%%% --------------------------------------------------------
+%%% Interface Functions. 
+%%% --------------------------------------------------------
+
+start_link() ->
+    gen_server:start_link({local, crypto_server}, crypto_server, [], []).
+
+init([]) ->
+    process_flag(trap_exit, true),
+    erl_ddll:start(),
+    PrivDir = code:priv_dir(crypto),
+    LibDir1 = filename:join([PrivDir, "lib"]),
+    {Status, LibDir} =
+	case erl_ddll:load_driver(LibDir1, crypto_drv) of
+	    ok -> {ok,LibDir1};
+	    {error,Error1} ->
+		LibDir2 = 
+		    filename:join(LibDir1, 
+				  erlang:system_info(system_architecture)),
+		Candidate =
+		    filelib:wildcard(filename:join([LibDir2,"crypto_drv*"])),
+		case Candidate of
+		    [] ->
+			{{error,Error1},LibDir1};
+		    _ ->
+			case erl_ddll:load_driver(LibDir2, crypto_drv) of
+			    ok ->
+				{ok,LibDir2};
+			    {error, Error2} ->
+				{{error,Error2},LibDir2}
+			end
+		end
+	end,
+    case Status of
+	ok ->
+	    Cmd = "crypto_drv elibcrypto " ++ 
+		filename:join([LibDir, "elibcrypto"]),
+	    open_ports(Cmd,size(port_names()));
+	{error, E} ->
+	    Str = erl_ddll:format_error(E),
+	    error_logger:error_msg("Unable to load crypto_drv. Failed with error:~n\"~s\"~nOpenSSL might not be installed on this system.~n",[Str]),
+	    {stop,nodriver}
+    end.
+
+open_ports(_,0) ->
+    {ok, []};
+open_ports(Cmd,N) ->   
+    Port = open_port({spawn, Cmd}, []),
+    %% check that driver is loaded, linked and working
+    %% since crypto_drv links towards libcrypto, this is a good thing
+    %% since libcrypto is known to be bad with backwards compatibility
+    case catch port_control(Port, 0, []) of
+	{'EXIT', _} ->
+	    {stop, nodriver};
+	_ ->
+	    register(element(N,port_names()), Port),
+	    open_ports(Cmd,N-1)
+    end.
+
+port_names() -> 
+    { crypto_drv01, crypto_drv02, crypto_drv03, crypto_drv04,
+      crypto_drv05, crypto_drv06, crypto_drv07, crypto_drv08,
+      crypto_drv09, crypto_drv10, crypto_drv11, crypto_drv12,
+      crypto_drv13, crypto_drv14, crypto_drv15, crypto_drv16 }.
+
+client_port() ->
+    element(erlang:system_info(scheduler_id) rem size(port_names()) + 1,
+	    port_names()).
+
+
+%%% --------------------------------------------------------
+%%% The call-back functions.
+%%% --------------------------------------------------------
+
+handle_call(_, _, State) ->
+    {noreply, State}.
+
+handle_cast(_, State) ->
+    {noreply, State}.
+
+handle_info({'EXIT', Pid, _Reason}, State) when is_pid(Pid) ->
+    {noreply, State};
+
+handle_info({'EXIT', Port, Reason}, State) when is_port(Port) ->
+    {stop, {port_died, Reason}, State};
+handle_info(_, State) ->
+    {noreply, State}.
+
+code_change(_OldVsn, State, _Extra) ->
+    {ok, State}.
+
+terminate(_Reason, _State) ->
+    close_ports(size(port_names())).
+
+close_ports(0) ->
+    ok;
+close_ports(N) ->   
+    element(N,port_names()) ! {self(), close},
+    close_ports(N-1).
+
+
+
+
+