diff options
Diffstat (limited to 'lib/orber/src/orber_env.erl')
| -rw-r--r-- | lib/orber/src/orber_env.erl | 1456 |
1 files changed, 1456 insertions, 0 deletions
diff --git a/lib/orber/src/orber_env.erl b/lib/orber/src/orber_env.erl new file mode 100644 index 0000000000..79f852eee0 --- /dev/null +++ b/lib/orber/src/orber_env.erl @@ -0,0 +1,1456 @@ +%%-------------------------------------------------------------------- +%% +%% %CopyrightBegin% +%% +%% Copyright Ericsson AB 2004-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% +%% +%% +%%----------------------------------------------------------------- +%% File: orber_env.erl +%% +%% Description: +%% Handling environment parameters for Orber. +%% +%% Creation date: 040723 +%% +%%----------------------------------------------------------------- +-module(orber_env). + +-behaviour(gen_server). + +-include_lib("orber/include/corba.hrl"). +-include_lib("orber/src/orber_iiop.hrl"). + +%%----------------------------------------------------------------- +%% External exports +%%----------------------------------------------------------------- +-export([start/1, configure/2, configure/3, configure_override/2, + multi_configure/1, get_env/1, set_env/2, get_keys/0, env/1, + info/0, info/1]). + +-export([iiop_acl/0, iiop_port/0, nat_iiop_port/0, nat_iiop_port/1, iiop_out_ports/0, + domain/0, ip_address_variable_defined/0, nat_host/0, nat_host/1, host/0, + ip_address/0, ip_address/1, giop_version/0, iiop_timeout/0, + iiop_connection_timeout/0, iiop_setup_connection_timeout/0, + iiop_in_connection_timeout/0, iiop_max_fragments/0, iiop_max_in_requests/0, + iiop_max_in_connections/0, iiop_backlog/0, objectkeys_gc_time/0, + get_ORBInitRef/0, get_ORBDefaultInitRef/0, get_interceptors/0, + get_local_interceptors/0, get_cached_interceptors/0, + set_interceptors/1, is_lightweight/0, get_lightweight_nodes/0, secure/0, + iiop_ssl_backlog/0, iiop_ssl_port/0, nat_iiop_ssl_port/0, nat_iiop_ssl_port/1, + ssl_server_certfile/0, ssl_client_certfile/0, set_ssl_client_certfile/1, + ssl_server_verify/0, ssl_client_verify/0, set_ssl_client_verify/1, + ssl_server_depth/0, ssl_client_depth/0, set_ssl_client_depth/1, + ssl_server_cacertfile/0, ssl_client_cacertfile/0, + set_ssl_client_cacertfile/1, ssl_client_password/0, + ssl_server_password/0, ssl_client_keyfile/0, ssl_server_keyfile/0, + ssl_client_ciphers/0, ssl_server_ciphers/0, ssl_client_cachetimeout/0, + ssl_server_cachetimeout/0, get_flags/0, typechecking/0, + exclude_codeset_ctx/0, exclude_codeset_component/0, partial_security/0, + use_CSIv2/0, use_FT/0, ip_version/0, light_ifr/0, bidir_context/0, + get_debug_level/0, getaddrstr/2, addr2str/1, iiop_packet_size/0, + iiop_ssl_ip_address_local/0, ip_address_local/0, iiop_in_keepalive/0, + iiop_out_keepalive/0, iiop_ssl_in_keepalive/0, iiop_ssl_out_keepalive/0, + iiop_ssl_accept_timeout/0, ssl_generation/0]). + + +%%----------------------------------------------------------------- +%% Internal exports +%%----------------------------------------------------------------- +-export([init/1, terminate/2, handle_call/3]). +-export([handle_cast/2, handle_info/2, code_change/3]). + +%%----------------------------------------------------------------- +%% Record Definitions Etc. +%%----------------------------------------------------------------- +-define(DEBUG_LEVEL, 5). + +-define(FORMAT(_F, _A), {error, lists:flatten(io_lib:format(_F, _A))}). +-define(EFORMAT(_F, _A), exit(lists:flatten(io_lib:format(_F, _A)))). + +-define(ENV_DB, orber_env_db). + +-define(ENV_KEYS, + [flags, iiop_port, nat_iiop_port, iiop_out_ports, domain, ip_address, + nat_ip_address, giop_version, iiop_timeout, iiop_connection_timeout, + iiop_setup_connection_timeout, iiop_in_connection_timeout, iiop_acl, + iiop_max_fragments, iiop_max_in_requests, iiop_max_in_connections, + iiop_backlog, objectkeys_gc_time, orbInitRef, orbDefaultInitRef, + interceptors, local_interceptors, lightweight, ip_address_local, + secure, iiop_ssl_ip_address_local, iiop_ssl_backlog, + iiop_ssl_port, nat_iiop_ssl_port, ssl_server_certfile, + ssl_client_certfile, ssl_server_verify, ssl_client_verify, ssl_server_depth, + ssl_client_depth, ssl_server_cacertfile, ssl_client_cacertfile, + ssl_client_password, ssl_server_password, ssl_client_keyfile, + ssl_server_keyfile, ssl_client_ciphers, ssl_server_ciphers, + ssl_client_cachetimeout, ssl_server_cachetimeout, orber_debug_level, + iiop_packet_size, iiop_in_keepalive, iiop_out_keepalive, + iiop_ssl_in_keepalive, iiop_ssl_out_keepalive, iiop_ssl_accept_timeout]). + +%% The 'flags' parameter must be first in the list. +%-define(ENV_KEYS, +% [{flags, ?ORB_ENV_INIT_FLAGS}, {iiop_port, 4001}, nat_iiop_port, +% {iiop_out_ports, 0}, {domain, "ORBER"}, ip_address, nat_ip_address, +% {giop_version, {1, 1}}, {iiop_timeout, infinity}, +% {iiop_connection_timeout, infinity}, {iiop_setup_connection_timeout, infinity}, +% {iiop_in_connection_timeout, infinity}, {iiop_acl, []}, +% {iiop_max_fragments, infinity}, {iiop_max_in_requests, infinity}, +% {iiop_max_in_connections, infinity}, {iiop_backlog, 5}, +% {objectkeys_gc_time, infinity}, +% {orbInitRef, undefined}, {orbDefaultInitRef, undefined}, +% {interceptors, false}, {local_interceptors, false}, {lightweight, false}, +% {secure, no}, {iiop_ssl_backlog, 5}, {iiop_ssl_port, 4002}, +% nat_iiop_ssl_port, {ssl_server_certfile, []}, {ssl_client_certfile, []}, +% {ssl_server_verify, 0}, {ssl_client_verify, 0}, {ssl_server_depth, 1}, +% {ssl_client_depth, 1}, {ssl_server_cacertfile, []}, +% {ssl_client_cacertfile, []}, {ssl_client_password, []}, +% {ssl_server_password, []}, {ssl_client_keyfile, []}, +% {ssl_server_keyfile, []}, {ssl_client_ciphers, []}, +% {ssl_server_ciphers, []}, {ssl_client_cachetimeout, infinity}, +% {ssl_server_cachetimeout, infinity}, {orber_debug_level, 0}]). + +-record(parameters, {key, value, flags = 0}). + +-record(env, {acl, parameters, flags = 0}). + + +%%----------------------------------------------------------------- +%% External functions +%%----------------------------------------------------------------- +%%----------------------------------------------------------------- +%% function : +%% Arguments: +%% Returns : +%% Exception: +%% Effect : +%%----------------------------------------------------------------- +start(Opts) -> + gen_server:start_link({local, orber_env}, ?MODULE, Opts, []). + +%%----------------------------------------------------------------- +%% function : get_keys +%% Arguments: +%% Returns : +%% Exception: +%% Effect : +%%----------------------------------------------------------------- +get_keys() -> + ?ENV_KEYS. + +%%----------------------------------------------------------------- +%% function : get_env +%% Arguments: +%% Returns : +%% Exception: +%% Effect : +%%----------------------------------------------------------------- +get_env(Key) when is_atom(Key) -> + case catch ets:lookup(?ENV_DB, Key) of + [#parameters{value = Val}] -> + {ok, Val}; + _ -> + undefined + end. + +%%----------------------------------------------------------------- +%% function : get_env +%% Arguments: +%% Returns : +%% Exception: +%% Effect : +%%----------------------------------------------------------------- +set_env(Key, Value) when is_atom(Key) -> + case catch ets:insert(?ENV_DB, #parameters{key = Key, value = Value}) of + true -> + ok; + _ -> + undefined + end. + + +%%----------------------------------------------------------------- +%% function : info +%% Arguments: IoDervice - info_msg | string | io | {io, Dev} +%% Returns : +%% Exception: +%% Effect : +%%----------------------------------------------------------------- +info() -> + info(info_msg). + +info(IoDevice) -> + Info = + case orber_tb:is_running() of + true -> + Info1 = create_main_info(), + Info2 = create_flag_info(Info1), + create_security_info(secure(), Info2); + _ -> + lists:flatten( + io_lib:format("======= Orber Execution Environment ======~n" + " *** Orber-~s is not running ***~n" + "==========================================~n", + [?ORBVSN])) + end, + case IoDevice of + info_msg -> + error_logger:info_msg(Info); + string -> + Info; + io -> + io:format("~s", [Info]); + {io, Dev} -> + io:format(Dev, "~s", [Info]); + _ -> + exit("Bad parameter") + end. + +create_main_info() -> + {Major, Minor} = giop_version(), + [io_lib:format("======= Orber Execution Environment ======~n" + "Orber version.................: ~s~n" + "Orber domain..................: ~s~n" + "IIOP port number..............: ~p~n" + "IIOP NAT port number..........: ~p~n" + "Interface(s)..................: ~p~n" + "Interface(s) NAT..............: ~p~n" + "Local Interface (default).....: ~p~n" + "Nodes in domain...............: ~p~n" + "GIOP version (default)........: ~p.~p~n" + "IIOP out timeout..............: ~p msec~n" + "IIOP out connection timeout...: ~p msec~n" + "IIOP setup connection timeout.: ~p msec~n" + "IIOP out ports................: ~p~n" + "IIOP out connections..........: ~p~n" + "IIOP out connections (pending): ~p~n" + "IIOP out keepalive............: ~p~n" + "IIOP in connections...........: ~p~n" + "IIOP in connection timeout....: ~p msec~n" + "IIOP in keepalive.............: ~p~n" + "IIOP max fragments............: ~p~n" + "IIOP max in requests..........: ~p~n" + "IIOP max in connections.......: ~p~n" + "IIOP backlog..................: ~p~n" + "IIOP ACL......................: ~p~n" + "IIOP maximum packet size......: ~p~n" + "Object Keys GC interval.......: ~p~n" + "Using Interceptors............: ~p~n" + "Using Local Interceptors......: ~p~n" + "Debug Level...................: ~p~n" + "orbInitRef....................: ~p~n" + "orbDefaultInitRef.............: ~p~n", + [?ORBVSN, domain(), iiop_port(), nat_iiop_port(), host(), + nat_host(), ip_address_local(), + orber:orber_nodes(), Major, Minor, + iiop_timeout(), iiop_connection_timeout(), + iiop_setup_connection_timeout(), iiop_out_ports(), + orber:iiop_connections(out), orber:iiop_connections_pending(), + iiop_out_keepalive(), orber:iiop_connections(in), + iiop_in_connection_timeout(), iiop_in_keepalive(), + iiop_max_fragments(), iiop_max_in_requests(), + iiop_max_in_connections(), iiop_backlog(), iiop_acl(), + iiop_packet_size(), objectkeys_gc_time(), get_interceptors(), + get_local_interceptors(), get_debug_level(), get_ORBInitRef(), + get_ORBDefaultInitRef()])]. + +create_flag_info(Info) -> + case get_flags() of + ?ORB_ENV_INIT_FLAGS -> + [Info, "System Flags Set..............: -\n"]; + Flags -> + FlagData = check_flags(?ORB_ENV_FLAGS, Flags, []), + [Info, "System Flags Set..............: \n", FlagData, "\n"] + end. + +check_flags([], _, Acc) -> + Acc; +check_flags([{Flag, Txt}|T], Flags, Acc) when ?ORB_FLAG_TEST(Flags, Flag) -> + check_flags(T, Flags, [" - ", Txt, "\n"|Acc]); +check_flags([_|T], Flags, Acc) -> + check_flags(T, Flags, Acc). + + +create_security_info(no, Info) -> + lists:flatten([Info, "=========================================\n"]); +create_security_info(ssl, Info) -> + lists:flatten([Info, + io_lib:format("ORB security..................: ssl~n" + "SSL generation................: ~p~n" + "SSL IIOP in keepalive.........: ~p~n" + "SSL IIOP out keepalive........: ~p~n" + "SSL IIOP port number..........: ~p~n" + "SSL IIOP NAT port number......: ~p~n" + "SSL IIOP accept timeout.......: ~p~n" + "SSL IIOP backlog..............: ~p~n" + "SSL IIOP Local Interface......: ~p~n" + "SSL server certfile...........: ~p~n" + "SSL server verification type..: ~p~n" + "SSL server verification depth.: ~p~n" + "SSL server cacertfile.........: ~p~n" + "SSL server keyfile............: ~p~n" + "SSL server password...........: ~p~n" + "SSL server ciphers............: ~p~n" + "SSL server cachetimeout.......: ~p~n" + "SSL client certfile...........: ~p~n" + "SSL client verification type..: ~p~n" + "SSL client verification depth.: ~p~n" + "SSL client cacertfile.........: ~p~n" + "SSL client keyfile............: ~p~n" + "SSL client password...........: ~p~n" + "SSL client ciphers............: ~p~n" + "SSL client cachetimeout.......: ~p~n" + "=========================================~n", + [ssl_generation(), iiop_ssl_port(), + iiop_ssl_in_keepalive(), iiop_ssl_out_keepalive(), + nat_iiop_ssl_port(), iiop_ssl_accept_timeout(), + iiop_ssl_backlog(), iiop_ssl_ip_address_local(), + ssl_server_certfile(), ssl_server_verify(), + ssl_server_depth(), ssl_server_cacertfile(), + ssl_server_keyfile(), ssl_server_password(), + ssl_server_ciphers(), ssl_server_cachetimeout(), + ssl_client_certfile(), ssl_client_verify(), + ssl_client_depth(), ssl_client_cacertfile(), + ssl_client_keyfile(), ssl_client_password(), + ssl_client_ciphers(), ssl_client_cachetimeout()])]). + + +%%----------------------------------------------------------------- +%% function : iiop_acl +%% Arguments: +%% Returns : +%% Exception: +%% Effect : +%%----------------------------------------------------------------- +iiop_acl() -> + case application:get_env(orber, iiop_acl) of + {ok, ACL} when is_list(ACL) -> + ACL; + _ -> + [] + end. + +iiop_packet_size() -> + case application:get_env(orber, iiop_packet_size) of + {ok, Max} when is_integer(Max) andalso Max > 0 -> + Max; + _ -> + infinity + end. + + +iiop_port() -> + case application:get_env(orber, iiop_port) of + {ok, Port} when is_integer(Port) andalso Port >= 0 -> + Port; + _ -> + 4001 + end. + +nat_iiop_port() -> + case application:get_env(orber, nat_iiop_port) of + {ok, Port} when is_integer(Port) andalso Port > 0 -> + Port; + {ok, {local, Default, _NATList}} -> + Default; + _ -> + iiop_port() + end. + +nat_iiop_port(LocalPort) -> + case application:get_env(orber, nat_iiop_port) of + {ok, Port} when is_integer(Port) andalso Port > 0 -> + Port; + {ok, {local, Default, NATList}} -> + orber_tb:keysearch(LocalPort, NATList, Default); + _ -> + iiop_port() + end. + +iiop_out_ports() -> + case application:get_env(orber, iiop_out_ports) of + {ok, {Min, Max}} when is_integer(Min) andalso is_integer(Max) andalso Min =< Max -> + {Min, Max}; + {ok, {Max, Min}} when is_integer(Min) andalso is_integer(Max) andalso Min < Max -> + {Min, Max}; + _ -> + 0 + end. + +domain() -> + case application:get_env(orber, domain) of + {ok, Domain} when is_list(Domain) -> + Domain; + {ok, Domain} when is_atom(Domain) -> + atom_to_list(Domain); + _ -> + "ORBER" + end. + +ip_address_variable_defined() -> + case application:get_env(orber, ip_address) of + undefined -> + false; + {ok,{multiple, _}} -> + false; + _ -> + [Host] = host(), + Host + end. + +nat_host() -> + case application:get_env(orber, nat_ip_address) of + {ok,I} when is_list(I) -> + [I]; + {ok,{multiple, [I|_] = IList}} when is_list(I) -> + IList; + {ok,{local, Default, _NATList}} -> + [Default]; + _ -> + host() + end. + +nat_host([Host]) -> + case application:get_env(orber, nat_ip_address) of + {ok,I} when is_list(I) -> + [I]; + {ok,{multiple, [I|_] = IList}} when is_list(I) -> + IList; + {ok,{local, Default, NATList}} -> + [orber_tb:keysearch(Host, NATList, Default)]; + _ -> + host() + end. + + +host() -> + case application:get_env(orber, ip_address) of + {ok,I} when is_list(I) -> + [I]; + {ok,{multiple, [I|_] = IList}} when is_list(I) -> + IList; + %% IPv4. For IPv6 we only accept a string, but we must support this format + %% for IPv4 + {ok, {A1, A2, A3, A4}} when is_integer(A1+A2+A3+A4) -> + [integer_to_list(A1) ++ "." ++ integer_to_list(A2) ++ "." ++ integer_to_list(A3) + ++ "." ++ integer_to_list(A4)]; + _ -> + Flags = get_flags(), + case ?ORB_FLAG_TEST(Flags, ?ORB_ENV_HOSTNAME_IN_IOR) of + true -> + {ok, Hostname} = inet:gethostname(), + [Hostname]; + _ -> + case ?ORB_FLAG_TEST(Flags, ?ORB_ENV_USE_IPV6) of + false -> + [ip_address(inet)]; + true -> + [ip_address(inet6)] + end + end + end. + +ip_address_local() -> + case application:get_env(orber, ip_address_local) of + {ok,I} when is_list(I) -> + [I]; + _ -> + [] + end. + + +ip_address() -> + ip_address(ip_version()). + +ip_address(inet) -> + {ok, Hostname} = inet:gethostname(), + {ok, {A1, A2, A3, A4}} = inet:getaddr(Hostname, inet), + integer_to_list(A1) ++ "." ++ integer_to_list(A2) ++ "." ++ integer_to_list(A3) + ++ "." ++ integer_to_list(A4); +ip_address(inet6) -> + {ok, Hostname} = inet:gethostname(), + {ok, {A1, A2, A3, A4, A5, A6, A7, A8}} = inet:getaddr(Hostname, inet6), + int16_to_hex(A1) ++ ":" ++int16_to_hex(A2) ++ ":" ++ + int16_to_hex(A3) ++ ":" ++ int16_to_hex(A4) ++ ":" ++ + int16_to_hex(A5) ++ ":" ++ int16_to_hex(A6) ++ ":" ++ + int16_to_hex(A7) ++ ":" ++ int16_to_hex(A8). + +getaddrstr(Hostname, inet) -> + {ok, {A1, A2, A3, A4}} = inet:getaddr(Hostname, inet), + integer_to_list(A1) ++ "." ++ integer_to_list(A2) ++ "." ++ integer_to_list(A3) + ++ "." ++ integer_to_list(A4); +getaddrstr(Hostname, inet6) -> + {ok, {A1, A2, A3, A4, A5, A6, A7, A8}} = inet:getaddr(Hostname, inet6), + int16_to_hex(A1) ++ ":" ++int16_to_hex(A2) ++ ":" ++ + int16_to_hex(A3) ++ ":" ++ int16_to_hex(A4) ++ ":" ++ + int16_to_hex(A5) ++ ":" ++ int16_to_hex(A6) ++ ":" ++ + int16_to_hex(A7) ++ ":" ++ int16_to_hex(A8). + +addr2str({A1, A2, A3, A4}) -> + integer_to_list(A1) ++ "." ++ integer_to_list(A2) ++ "." ++ integer_to_list(A3) + ++ "." ++ integer_to_list(A4); +addr2str({A1, A2, A3, A4, A5, A6, A7, A8}) -> + int16_to_hex(A1) ++ ":" ++int16_to_hex(A2) ++ ":" ++ + int16_to_hex(A3) ++ ":" ++ int16_to_hex(A4) ++ ":" ++ + int16_to_hex(A5) ++ ":" ++ int16_to_hex(A6) ++ ":" ++ + int16_to_hex(A7) ++ ":" ++ int16_to_hex(A8). + + +int16_to_hex(0) -> + [$0]; +int16_to_hex(I) -> + N1 = ((I bsr 8) band 16#ff), + N2 = (I band 16#ff), + [code_character(N1 div 16), code_character(N1 rem 16), + code_character(N2 div 16), code_character(N2 rem 16)]. + +code_character(N) when N < 10 -> + $0 + N; +code_character(N) -> + $A + (N - 10). + +giop_version() -> + case application:get_env(orber, giop_version) of + {ok, {Major, Minor}} -> + {Major, Minor}; + _ -> + {1, 1} + end. + +iiop_timeout() -> + case application:get_env(orber, iiop_timeout) of + {ok, Int} when is_integer(Int) -> + if + Int > 1000000 -> + error_logger:error_msg("Orber 'iiop_timeout' badly configured.~n" + "Time to large (>1000000 sec), swithed to 'infinity'~n"), + infinity; + true -> + %% Convert to msec. + Int*1000 + end; + _ -> + infinity + end. + +iiop_connection_timeout() -> + case application:get_env(orber, iiop_connection_timeout) of + {ok, Int} when is_integer(Int) -> + if + Int > 1000000 -> + error_logger:error_msg("Orber 'iiop_connection_timeout' badly configured.~n" + "Time to large (>1000000 sec), swithed to 'infinity'~n"), + infinity; + true -> + %% Convert to msec. + Int*1000 + end; + _ -> + infinity + end. + +iiop_setup_connection_timeout() -> + case application:get_env(orber, iiop_setup_connection_timeout) of + {ok, Int} when is_integer(Int) -> + %% Convert to msec. + Int*1000; + _ -> + infinity + end. + +iiop_in_connection_timeout() -> + case application:get_env(orber, iiop_in_connection_timeout) of + {ok, Int} when is_integer(Int) -> + if + Int > 1000000 -> + error_logger:error_msg("Orber 'iiop_connection_timeout' badly configured.~n" + "Time to large (>1000000 sec), swithed to 'infinity'~n"), + infinity; + true -> + %% Convert to msec. + Int*1000 + end; + _ -> + infinity + end. + +iiop_max_fragments() -> + case application:get_env(orber, iiop_max_fragments) of + {ok, Max} when is_integer(Max) andalso Max > 0 -> + Max; + _ -> + infinity + end. + +iiop_max_in_requests() -> + case application:get_env(orber, iiop_max_in_requests) of + {ok, Max} when is_integer(Max) andalso Max > 0 -> + Max; + _ -> + infinity + end. + +iiop_max_in_connections() -> + case application:get_env(orber, iiop_max_in_connections) of + {ok, Max} when is_integer(Max) andalso Max > 0 -> + Max; + _ -> + infinity + end. + +iiop_backlog() -> + case application:get_env(orber, iiop_backlog) of + {ok, Int} when is_integer(Int) andalso Int >= 0 -> + Int; + _ -> + 5 + end. + +iiop_in_keepalive() -> + case application:get_env(orber, iiop_in_keepalive) of + {ok, true} -> + true; + _ -> + false + end. + +iiop_out_keepalive() -> + case application:get_env(orber, iiop_out_keepalive) of + {ok, true} -> + true; + _ -> + false + end. + + + +get_flags() -> + case get(oe_orber_flags) of + undefined -> + case application:get_env(orber, flags) of + undefined -> + put(oe_orber_flags, ?ORB_ENV_INIT_FLAGS), + ?ORB_ENV_INIT_FLAGS; + {ok, Flags} -> + put(oe_orber_flags, Flags), + Flags + end; + Flags when is_integer(Flags) -> + Flags + end. + +typechecking() -> + ?ORB_FLAG_TEST(get_flags(), ?ORB_ENV_LOCAL_TYPECHECKING). + +exclude_codeset_ctx() -> + ?ORB_FLAG_TEST(get_flags(), ?ORB_ENV_EXCLUDE_CODESET_CTX). + +exclude_codeset_component() -> + ?ORB_FLAG_TEST(get_flags(), ?ORB_ENV_EXCLUDE_CODESET_COMPONENT). + +partial_security() -> + ?ORB_FLAG_TEST(get_flags(), ?ORB_ENV_PARTIAL_SECURITY). + +use_CSIv2() -> + ?ORB_FLAG_TEST(get_flags(), ?ORB_ENV_USE_CSIV2). + +use_FT() -> + ?ORB_FLAG_TEST(get_flags(), ?ORB_ENV_USE_FT). + +ip_version() -> + case ?ORB_FLAG_TEST(get_flags(), ?ORB_ENV_USE_IPV6) of + false -> + inet; + true -> + inet6 + end. + +light_ifr() -> + ?ORB_FLAG_TEST(get_flags(), ?ORB_ENV_LIGHT_IFR). + +bidir_context() -> + Flags = get_flags(), + if + ?ORB_FLAG_TEST(Flags, ?ORB_ENV_USE_BI_DIR_IIOP) -> + [#'IOP_ServiceContext' + {context_id=?IOP_BI_DIR_IIOP, + context_data = + #'IIOP_BiDirIIOPServiceContext'{listen_points = + [#'IIOP_ListenPoint'{host=host(), + port=iiop_port()}]}}]; + true -> + [] + end. + +objectkeys_gc_time() -> + case application:get_env(orber, objectkeys_gc_time) of + {ok, Int} when is_integer(Int) -> + if + Int > 1000000 -> + error_logger:error_msg("Orber 'objectkeys_gc_time' badly configured.~n" + "Time to large (>1000000 sec), swithed to 'infinity'~n"), + infinity; + true -> + Int + end; + _ -> + infinity + end. + +get_ORBInitRef() -> + case application:get_env(orber, orbInitRef) of + {ok, Ref} when is_list(Ref) -> + Ref; + _ -> + undefined + end. + +get_ORBDefaultInitRef() -> + case application:get_env(orber, orbDefaultInitRef) of + {ok, Ref} when is_list(Ref) -> + Ref; + _ -> + undefined + end. + +get_debug_level() -> + case application:get_env(orber, orber_debug_level) of + {ok, Level} when is_integer(Level) -> + Level; + _ -> + 0 + end. + + +%%----------------------------------------------------------------- +%% Interceptor opertaions (see orber_pi.erl) +%%----------------------------------------------------------------- +get_interceptors() -> + case application:get_env(orber, interceptors) of + {ok, {native, PIs}} when is_list(PIs) -> + {native, PIs}; + {ok, {portable, PIs}} when is_list(PIs) -> + {portable, PIs}; + _ -> + false + end. + +get_local_interceptors() -> + case application:get_env(orber, local_interceptors) of + {ok, {native, PIs}} when is_list(PIs) -> + {native, PIs}; + {ok, {portable, PIs}} when is_list(PIs) -> + {portable, PIs}; + _ -> + false + end. + + +get_cached_interceptors() -> + case get(oe_orber_interceptor_cache) of + undefined -> + PIs = case application:get_env(orber, local_interceptors) of + {ok, {native, LPIs}} when is_list(LPIs) -> + {native, LPIs}; + {ok, {portable, LPIs}} when is_list(LPIs) -> + {portable, LPIs}; + _ -> + get_interceptors() + end, + put(oe_orber_interceptor_cache, PIs), + PIs; + PIs -> + PIs + end. + + +set_interceptors({Type, InterceptorList}) when is_list(InterceptorList) -> + configure(interceptors, {Type, InterceptorList}); +set_interceptors(_) -> + exit({error, "Usage: {Type, ModuleList}"}). + + +%%----------------------------------------------------------------- +%% Light weight Orber operations +%%----------------------------------------------------------------- +is_lightweight() -> + case application:get_env(orber, lightweight) of + {ok, L} when is_list(L) -> + true; + _ -> + false + end. +get_lightweight_nodes() -> + case application:get_env(orber, lightweight) of + {ok, L} when is_list(L) -> + L; + _ -> + false + end. + + +%%----------------------------------------------------------------- +%% Security access operations (SSL) +%%----------------------------------------------------------------- +secure() -> + case application:get_env(orber, secure) of + {ok, V} -> + V; + _ -> + no + end. + +ssl_generation() -> + case application:get_env(orber, ssl_generation) of + {ok, V} -> + V; + _ -> + 2 + end. + +iiop_ssl_ip_address_local() -> + case application:get_env(orber, iiop_ssl_ip_address_local) of + {ok,I} when is_list(I) -> + [I]; + _ -> + [] + end. + +iiop_ssl_backlog() -> + case application:get_env(orber, iiop_ssl_backlog) of + {ok, Int} when is_integer(Int), Int >= 0 -> + Int; + _ -> + 5 + end. + +iiop_ssl_in_keepalive() -> + case application:get_env(orber, iiop_ssl_in_keepalive) of + {ok, true} -> + true; + _ -> + false + end. + +iiop_ssl_out_keepalive() -> + case application:get_env(orber, iiop_ssl_out_keepalive) of + {ok, true} -> + true; + _ -> + false + end. + +iiop_ssl_accept_timeout() -> + case application:get_env(orber, iiop_ssl_accept_timeout) of + {ok, N} when is_integer(N) -> + N * 1000; + _ -> + infinity + end. + +iiop_ssl_port() -> + case application:get_env(orber, secure) of + {ok, ssl} -> + case application:get_env(orber, iiop_ssl_port) of + {ok, Port} when is_integer(Port) -> + Port; + _ -> + 4002 + end; + _ -> + -1 + end. + +nat_iiop_ssl_port() -> + case application:get_env(orber, secure) of + {ok, ssl} -> + case application:get_env(orber, nat_iiop_ssl_port) of + {ok, Port} when is_integer(Port) andalso Port > 0 -> + Port; + {ok, {local, Default, _NATList}} -> + Default; + _ -> + iiop_ssl_port() + end; + _ -> + -1 + end. + +nat_iiop_ssl_port(LocalPort) -> + case application:get_env(orber, secure) of + {ok, ssl} -> + case application:get_env(orber, nat_iiop_ssl_port) of + {ok, Port} when is_integer(Port) andalso Port > 0 -> + Port; + {ok, {local, Default, NATList}} -> + orber_tb:keysearch(LocalPort, NATList, Default); + _ -> + iiop_ssl_port() + end; + _ -> + -1 + end. + +ssl_server_certfile() -> + case application:get_env(orber, ssl_server_certfile) of + {ok, V1} when is_list(V1) -> + V1; + {ok, V2} when is_atom(V2) -> + atom_to_list(V2); + _ -> + [] + end. + +ssl_client_certfile() -> + case get(ssl_client_certfile) of + undefined -> + case application:get_env(orber, ssl_client_certfile) of + {ok, V1} when is_list(V1) -> + V1; + {ok, V2} when is_atom(V2) -> + atom_to_list(V2); + _ -> + [] + end; + V -> + V + end. + +set_ssl_client_certfile(Value) when is_list(Value) -> + put(ssl_client_certfile, Value). + +ssl_server_verify() -> + Verify = case application:get_env(orber, ssl_server_verify) of + {ok, V} when is_integer(V) -> + V; + _ -> + 0 + end, + if + Verify =< 2, Verify >= 0 -> + Verify; + true -> + 0 + end. + +ssl_client_verify() -> + Verify = case get(ssl_client_verify) of + undefined -> + case application:get_env(orber, ssl_client_verify) of + {ok, V1} when is_integer(V1) -> + V1; + _ -> + 0 + end; + V2 -> + V2 + end, + if + Verify =< 2, Verify >= 0 -> + Verify; + true -> + 0 + end. + +set_ssl_client_verify(Value) when is_integer(Value) andalso Value =< 2 andalso Value >= 0 -> + put(ssl_client_verify, Value), ok. + +ssl_server_depth() -> + case application:get_env(orber, ssl_server_depth) of + {ok, V1} when is_integer(V1) -> + V1; + _ -> + 1 + end. + +ssl_client_depth() -> + case get(ssl_client_depth) of + undefined -> + case application:get_env(orber, ssl_client_depth) of + {ok, V1} when is_integer(V1) -> + V1; + _ -> + 1 + end; + V2 -> + V2 + end. + +set_ssl_client_depth(Value) when is_integer(Value) -> + put(ssl_client_depth, Value), ok. + + + +ssl_server_cacertfile() -> + case application:get_env(orber, ssl_server_cacertfile) of + {ok, V1} when is_list(V1) -> + V1; + {ok, V2} when is_atom(V2) -> + atom_to_list(V2); + _ -> + [] + end. + +ssl_client_cacertfile() -> + case get(ssl_client_cacertfile) of + undefined -> + case application:get_env(orber, ssl_client_cacertfile) of + {ok, V1} when is_list(V1) -> + V1; + {ok, V2} when is_atom(V2) -> + atom_to_list(V2); + _ -> + [] + end; + V3 -> + V3 + end. + +set_ssl_client_cacertfile(Value) when is_list(Value) -> + put(ssl_client_cacertfile, Value), ok. + + +ssl_client_password() -> + case application:get_env(orber, ssl_client_password) of + {ok, V1} when is_list(V1) -> + V1; + _ -> + [] + end. + +ssl_server_password() -> + case application:get_env(orber, ssl_server_password) of + {ok, V1} when is_list(V1) -> + V1; + _ -> + [] + end. + +ssl_client_keyfile() -> + case application:get_env(orber, ssl_client_keyfile) of + {ok, V1} when is_list(V1) -> + V1; + _ -> + [] + end. + +ssl_server_keyfile() -> + case application:get_env(orber, ssl_server_keyfile) of + {ok, V1} when is_list(V1) -> + V1; + _ -> + [] + end. + +ssl_client_ciphers() -> + case application:get_env(orber, ssl_client_ciphers) of + {ok, V1} when is_list(V1) -> + V1; + _ -> + [] + end. + +ssl_server_ciphers() -> + case application:get_env(orber, ssl_server_ciphers) of + {ok, V1} when is_list(V1) -> + V1; + _ -> + [] + end. + +ssl_client_cachetimeout() -> + case application:get_env(orber, ssl_client_cachetimeout) of + {ok, V1} when is_integer(V1) -> + V1; + _ -> + infinity + end. + +ssl_server_cachetimeout() -> + case application:get_env(orber, ssl_server_cachetimeout) of + {ok, V1} when is_integer(V1) -> + V1; + _ -> + infinity + end. + +%%----------------------------------------------------------------- +%% function : configure +%% Arguments: +%% Returns : +%% Exception: +%% Effect : +%%----------------------------------------------------------------- +configure(Key, Value) when is_atom(Key) -> + configure(Key, Value, check); +configure(Key, _) -> + ?EFORMAT("Given key (~p) not an atom.", [Key]). + +configure_override(Key, Value) when is_atom(Key) -> + configure(Key, Value, loaded); +configure_override(Key, _) -> + ?EFORMAT("Given key (~p) not an atom.", [Key]). + +%%----------------------------------------------------------------- +%% function : multi_configure +%% Arguments: +%% Returns : +%% Exception: +%% Effect : +%%----------------------------------------------------------------- +multi_configure(KeyValueList) when is_list(KeyValueList) -> + case orber_tb:is_loaded() of + false -> + application:load(orber), + multi_configure_helper(KeyValueList, loaded); + true -> + case orber_tb:is_running() of + false -> + multi_configure_helper(KeyValueList, loaded); + true -> + multi_configure_helper(KeyValueList, running) + end + end; +multi_configure(KeyValueList) -> + ?EFORMAT("Given configuration parameters not a Key-Value-pair list: ~p", + [KeyValueList]). + +multi_configure_helper([], _) -> + ok; +multi_configure_helper([{Key, Value}|T], Status) -> + configure(Key, Value, Status), + multi_configure_helper(T, Status); +multi_configure_helper([What|_], _) -> + ?EFORMAT("Incorrect configuration parameters supplied: ~p", [What]). + + +%%------ Keys we can update at any time ----- +%% Initial Services References +configure(orbDefaultInitRef, String, Status) when is_list(String) -> + do_configure(orbDefaultInitRef, String, Status); +configure(orbDefaultInitRef, undefined, Status) -> + do_configure(orbDefaultInitRef, undefined, Status); +configure(orbInitRef, String, Status) when is_list(String) -> + do_configure(orbInitRef, String, Status); +configure(orbInitRef, undefined, Status) -> + do_configure(orbInitRef, undefined, Status); +%% IIOP-version +configure(giop_version, {1, 0}, Status) -> + do_configure(giop_version, {1, 0}, Status); +configure(giop_version, {1, 1}, Status) -> + do_configure(giop_version, {1, 1}, Status); +configure(giop_version, {1, 2}, Status) -> + do_configure(giop_version, {1, 2}, Status); +%% configure 'iiop_timout' will only have effect on new requests. +configure(iiop_timeout, infinity, Status) -> + do_configure(iiop_timeout, infinity, Status); +configure(iiop_timeout, Value, Status) when is_integer(Value) andalso Value =< 1000000 -> + do_configure(iiop_timeout, Value, Status); +%% Backlog +configure(iiop_backlog, Value, Status) when is_integer(Value) andalso Value >= 0 -> + do_configure(iiop_backlog, Value, Status); +%% configure 'iiop_in_keepalive' will only have effect on new connections. +configure(iiop_in_keepalive, true, Status) -> + do_configure(iiop_in_keepalive, true, Status); +configure(iiop_in_keepalive, false, Status) -> + do_configure(iiop_in_keepalive, false, Status); +%% configure 'iiop_out_keepalive' will only have effect on new connections. +configure(iiop_out_keepalive, true, Status) -> + do_configure(iiop_out_keepalive, true, Status); +configure(iiop_out_keepalive, false, Status) -> + do_configure(iiop_out_keepalive, false, Status); +%% configure 'iiop_connection_timout' will only have effect on new connections. +configure(iiop_connection_timeout, infinity, Status) -> + do_configure(iiop_connection_timeout, infinity, Status); +configure(iiop_connection_timeout, Value, Status) when is_integer(Value) andalso Value =< 1000000 -> + do_configure(iiop_connection_timeout, Value, Status); +%% configure 'iiop_in_connection_timout' will only have effect on new connections. +configure(iiop_in_connection_timeout, infinity, Status) -> + do_configure(iiop_in_connection_timeout, infinity, Status); +configure(iiop_in_connection_timeout, Value, Status) when is_integer(Value) andalso Value =< 1000000 -> + do_configure(iiop_in_connection_timeout, Value, Status); +%% configure 'iiop_setup_connection_timeout' will only have effect on new connections. +configure(iiop_setup_connection_timeout, infinity, Status) -> + do_configure(iiop_setup_connection_timeout, infinity, Status); +configure(iiop_setup_connection_timeout, Value, Status) when is_integer(Value) -> + do_configure(iiop_setup_connection_timeout, Value, Status); +%% configure 'iiop_max_fragments' will only have effect on new connections. +configure(iiop_max_fragments, infinity, Status) -> + do_configure(iiop_max_fragments, infinity, Status); +configure(iiop_max_fragments, Value, Status) when is_integer(Value) andalso Value > 0 -> + do_configure(iiop_max_fragments, Value, Status); +%% configure 'iiop_max_in_requests' will only have effect on new connections. +configure(iiop_max_in_requests, infinity, Status) -> + do_configure(iiop_max_in_requests, infinity, Status); +configure(iiop_max_in_requests, Value, Status) when is_integer(Value) andalso Value > 0 -> + do_configure(iiop_max_in_requests, Value, Status); +%% configure 'iiop_max_in_connections' will only have effect on new connections. +configure(iiop_max_in_connections, infinity, Status) -> + do_configure(iiop_max_in_connections, infinity, Status); +configure(iiop_max_in_connections, Value, Status) when is_integer(Value) andalso Value > 0 -> + do_configure(iiop_max_in_connections, Value, Status); +%% Garbage Collect the object keys DB. +configure(objectkeys_gc_time, infinity, Status) -> + do_configure(objectkeys_gc_time, infinity, Status); +configure(objectkeys_gc_time, Value, Status) when is_integer(Value) andalso Value =< 1000000 -> + do_configure(objectkeys_gc_time, Value, Status); +%% Orber debug printouts +configure(orber_debug_level, Value, Status) when is_integer(Value) -> + do_configure(orber_debug_level, Value, Status); + +%%------ Keys we cannot change if Orber is running ----- +%% Set the listen port +configure(iiop_port, Value, Status) when is_integer(Value) -> + do_safe_configure(iiop_port, Value, Status); +%% Set the NAT listen port +configure(nat_iiop_port, Value, Status) when is_integer(Value) andalso Value > 0 -> + do_safe_configure(nat_iiop_port, Value, Status); +configure(nat_iiop_port, {local, Value1, Value2}, Status) when is_integer(Value1) andalso + Value1 > 0 andalso + is_list(Value2) -> + do_safe_configure(nat_iiop_port, {local, Value1, Value2}, Status); +%% Set Maximum Packet Size +configure(iiop_packet_size, Max, Status) when is_integer(Max) andalso Max > 0 -> + do_safe_configure(iiop_packet_size, Max, Status); +%% IIOP interceptors +configure(interceptors, Value, Status) when is_tuple(Value) -> + do_safe_configure(interceptors, Value, Status); +%% Local interceptors +configure(local_interceptors, Value, Status) when is_tuple(Value) -> + do_safe_configure(local_interceptors, Value, Status); +%% Orber Domain +configure(domain, Value, Status) when is_list(Value) -> + do_safe_configure(domain, Value, Status); +%% Set the IP-address we should use +configure(ip_address, Value, Status) when is_list(Value) -> + do_safe_configure(ip_address, Value, Status); +configure(ip_address, {multiple, Value}, Status) when is_list(Value) -> + do_safe_configure(ip_address, {multiple, Value}, Status); +configure(ip_address_local, Value, Status) when is_list(Value) -> + do_safe_configure(ip_address_local, Value, Status); +%% Set the NAT IP-address we should use +configure(nat_ip_address, Value, Status) when is_list(Value) -> + do_safe_configure(nat_ip_address, Value, Status); +configure(nat_ip_address, {multiple, Value}, Status) when is_list(Value) -> + do_safe_configure(nat_ip_address, {multiple, Value}, Status); +configure(nat_ip_address, {local, Value1, Value2}, Status) when is_list(Value1) andalso + is_list(Value2) -> + do_safe_configure(nat_ip_address, {local, Value1, Value2}, Status); +%% Set the range of ports we may use on this machine when connecting to a server. +configure(iiop_out_ports, {Min, Max}, Status) when is_integer(Min) andalso is_integer(Max) -> + do_safe_configure(iiop_out_ports, {Min, Max}, Status); +%% Set the lightweight option. +configure(lightweight, Value, Status) when is_list(Value) -> + do_safe_configure(lightweight, Value, Status); +%% Configre the System Flags +configure(flags, Value, Status) when is_integer(Value) -> + do_safe_configure(flags, Value, Status); +%% Configre the ACL +configure(iiop_acl, Value, Status) when is_list(Value) -> + do_safe_configure(iiop_acl, Value, Status); + +%% SSL settings +%% configure 'iiop_in_keepalive' will only have effect on new connections. +configure(iiop_ssl_in_keepalive, true, Status) -> + do_configure(iiop_ssl_in_keepalive, true, Status); +configure(iiop_ssl_in_keepalive, false, Status) -> + do_configure(iiop_ssl_in_keepalive, false, Status); +%% configure 'iiop_ssl_out_keepalive' will only have effect on new connections. +configure(iiop_ssl_out_keepalive, true, Status) -> + do_configure(iiop_ssl_out_keepalive, true, Status); +configure(iiop_ssl_out_keepalive, false, Status) -> + do_configure(iiop_ssl_out_keepalive, false, Status); +configure(iiop_ssl_accept_timeout, infinity, Status) -> + do_configure(iiop_ssl_accept_timeout, infinity, Status); +configure(iiop_ssl_accept_timeout, Value, Status) when is_integer(Value) andalso Value >= 0 -> + do_configure(iiop_ssl_accept_timeout, Value, Status); +configure(ssl_generation, Generation, Status) when is_integer(Generation) andalso Generation >= 2 -> + do_safe_configure(ssl_generation, Generation, Status); +configure(secure, ssl, Status) -> + do_safe_configure(secure, ssl, Status); +configure(iiop_ssl_ip_address_local, Value, Status) when is_list(Value) -> + do_safe_configure(iiop_ssl_ip_address_local, Value, Status); +configure(iiop_ssl_backlog, Value, Status) when is_integer(Value) andalso Value >= 0 -> + do_safe_configure(iiop_ssl_backlog, Value, Status); +configure(nat_iiop_ssl_port, Value, Status) when is_integer(Value) andalso Value > 0 -> + do_safe_configure(nat_iiop_ssl_port, Value, Status); +configure(nat_iiop_ssl_port, {local, Value1, Value2}, Status) when is_integer(Value1) andalso + Value1 > 0 andalso + is_list(Value2) -> + do_safe_configure(nat_iiop_ssl_port, {local, Value1, Value2}, Status); +configure(iiop_ssl_port, Value, Status) when is_integer(Value) -> + do_safe_configure(iiop_ssl_port, Value, Status); +configure(ssl_server_certfile, Value, Status) when is_list(Value) -> + do_safe_configure(ssl_server_certfile, Value, Status); +configure(ssl_server_certfile, Value, Status) when is_atom(Value) -> + do_safe_configure(ssl_server_certfile, atom_to_list(Value), Status); +configure(ssl_client_certfile, Value, Status) when is_list(Value) -> + do_safe_configure(ssl_client_certfile, Value, Status); +configure(ssl_client_certfile, Value, Status) when is_atom(Value) -> + do_safe_configure(ssl_client_certfile, atom_to_list(Value), Status); +configure(ssl_server_verify, Value, Status) when is_integer(Value) -> + do_safe_configure(ssl_server_verify, Value, Status); +configure(ssl_client_verify, Value, Status) when is_integer(Value) -> + do_safe_configure(ssl_client_verify, Value, Status); +configure(ssl_server_depth, Value, Status) when is_integer(Value) -> + do_safe_configure(ssl_server_depth, Value, Status); +configure(ssl_client_depth, Value, Status) when is_integer(Value) -> + do_safe_configure(ssl_client_depth, Value, Status); +configure(ssl_server_cacertfile, Value, Status) when is_list(Value) -> + do_safe_configure(ssl_server_cacertfile, Value, Status); +configure(ssl_server_cacertfile, Value, Status) when is_atom(Value) -> + do_safe_configure(ssl_server_cacertfile, atom_to_list(Value), Status); +configure(ssl_client_cacertfile, Value, Status) when is_list(Value) -> + do_safe_configure(ssl_client_cacertfile, Value, Status); +configure(ssl_client_cacertfile, Value, Status) when is_atom(Value) -> + do_safe_configure(ssl_client_cacertfile, atom_to_list(Value), Status); +configure(ssl_client_password, Value, Status) when is_list(Value) -> + do_safe_configure(ssl_client_password, Value, Status); +configure(ssl_client_password, Value, Status) when is_atom(Value) -> + do_safe_configure(ssl_client_password, atom_to_list(Value), Status); +configure(ssl_client_keyfile, Value, Status) when is_list(Value) -> + do_safe_configure(ssl_client_keyfile, Value, Status); +configure(ssl_client_keyfile, Value, Status) when is_atom(Value) -> + do_safe_configure(ssl_client_keyfile, atom_to_list(Value), Status); +configure(ssl_server_password, Value, Status) when is_list(Value) -> + do_safe_configure(ssl_server_password, Value, Status); +configure(ssl_client_password, Value, Status) when is_atom(Value) -> + do_safe_configure(ssl_server_password, atom_to_list(Value), Status); +configure(ssl_server_keyfile, Value, Status) when is_list(Value) -> + do_safe_configure(ssl_server_keyfile, Value, Status); +configure(ssl_server_keyfile, Value, Status) when is_atom(Value) -> + do_safe_configure(ssl_server_keyfile, atom_to_list(Value), Status); +configure(ssl_server_ciphers, Value, Status) when is_list(Value) -> + do_safe_configure(ssl_server_ciphers, Value, Status); +configure(ssl_server_ciphers, Value, Status) when is_atom(Value) -> + do_safe_configure(ssl_server_ciphers, atom_to_list(Value), Status); +configure(ssl_client_ciphers, Value, Status) when is_list(Value) -> + do_safe_configure(ssl_client_ciphers, Value, Status); +configure(ssl_client_ciphers, Value, Status) when is_atom(Value) -> + do_safe_configure(ssl_client_ciphers, atom_to_list(Value), Status); +configure(ssl_client_cachetimeout, Value, Status) when is_integer(Value) andalso Value > 0 -> + do_safe_configure(ssl_client_cachetimeout, Value, Status); +configure(ssl_server_cachetimeout, Value, Status) when is_integer(Value) andalso Value > 0 -> + do_safe_configure(ssl_server_cachetimeout, Value, Status); + +configure(Key, Value, _) -> + ?EFORMAT("Bad configuration parameter: {~p, ~p}", [Key, Value]). + +%% This function may be used as long as it is safe to change a value at any time. +do_configure(Key, Value, check) -> + case orber_tb:is_loaded() of + false -> + application:load(orber), + application:set_env(orber, Key, Value); + true -> + application:set_env(orber, Key, Value) + end; +do_configure(Key, Value, _) -> + application:set_env(orber, Key, Value). + +%% This function MUST(!!) be used when we cannot change a value if Orber is running. +do_safe_configure(_, _, running) -> + exit("Orber already running, the given key may not be updated!"); +do_safe_configure(Key, Value, check) -> + case orber_tb:is_loaded() of + false -> + application:load(orber), + application:set_env(orber, Key, Value); + true -> + case orber_tb:is_running() of + false -> + application:set_env(orber, Key, Value); + true -> + ?EFORMAT("Orber already running. {~p, ~p} may not be updated!", + [Key, Value]) + end + end; +do_safe_configure(Key, Value, loaded) -> + application:set_env(orber, Key, Value). + + +%%----------------------------------------------------------------- +%% Internal functions +%%----------------------------------------------------------------- +%%----------------------------------------------------------------- +%% Server functions +%%----------------------------------------------------------------- +init(_Opts) -> + {ok, #env{acl = orber_acl:init_acl(iiop_acl()), + parameters = init_env()}}. + +terminate(_Reason, _State) -> + ok. + +handle_call(_, _From, State) -> + {reply, ok, State}. + +handle_cast(_, State) -> + {noreply, State}. + +handle_info(_, State) -> + {noreply, State}. + +code_change(_OldVsn, State, _Extra) -> + {ok, State}. + +%%----------------------------------------------------------------- +%% function : env +%% Arguments: +%% Returns : +%% Exception: +%% Effect : Used when Key always exists (Default Value) +%%----------------------------------------------------------------- +env(Key) -> + [#parameters{value = Val}] = ets:lookup(?ENV_DB, Key), + Val. + +%%----------------------------------------------------------------- +%% function : init_env +%% Arguments: +%% Returns : +%% Exception: +%% Effect : +%%----------------------------------------------------------------- +init_env() -> + application:load(orber), + DB = ets:new(?ENV_DB, [set, public, named_table, {keypos, 2}]), +% init_env(?ENV_KEYS), + DB. + +%init_env([{H,D}|T]) -> +% case application:get_env(orber, H) of +% {ok, V} -> +% ets:insert(?ENV_DB, #parameters{key = H, value = V, flags = 0}), +% init_env(T); +% _ -> +% ets:insert(?ENV_DB, #parameters{key = H, value = D, flags = 0}), +% init_env(T) +% end; +%init_env([H|T]) -> +% case application:get_env(orber, H) of +% {ok, V} -> +% ets:insert(?ENV_DB, #parameters{key = H, value = V, flags = 0}), +% init_env(T); +% _ -> +% ets:insert(?ENV_DB, #parameters{key = H, value = undefined, flags = 0}), +% init_env(T) +% end; +%init_env([]) -> +% ok. + +%%----------------------------------------------------------------- +%%------------- END OF MODULE ------------------------------------- +%%----------------------------------------------------------------- |