%% %% %CopyrightBegin% %% %% Copyright Ericsson AB 2008-2011. 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% %% -module(ssl_payload_SUITE). %% Note: This directive should only be used in test suites. -compile(export_all). -include_lib("common_test/include/ct.hrl"). -define(TIMEOUT, 600000). %% Test server callback functions %%-------------------------------------------------------------------- %% Function: init_per_suite(Config) -> Config %% Config - [tuple()] %% A list of key/value pairs, holding the test case configuration. %% Description: Initialization before the whole suite %% %% Note: This function is free to add any key/value pairs to the Config %% variable, but should NOT alter/remove any existing entries. %%-------------------------------------------------------------------- init_per_suite(Config) -> try crypto:start() of ok -> application:start(public_key), ssl:start(), make_certs:all(?config(data_dir, Config), ?config(priv_dir, Config)), ssl_test_lib:cert_options(Config) catch _:_ -> {skip, "Crypto did not start"} end. %%-------------------------------------------------------------------- %% Function: end_per_suite(Config) -> _ %% Config - [tuple()] %% A list of key/value pairs, holding the test case configuration. %% Description: Cleanup after the whole suite %%-------------------------------------------------------------------- end_per_suite(_Config) -> ssl:stop(), application:stop(crypto). %%-------------------------------------------------------------------- %% Function: init_per_testcase(TestCase, Config) -> Config %% Case - atom() %% Name of the test case that is about to be run. %% Config - [tuple()] %% A list of key/value pairs, holding the test case configuration. %% %% Description: Initialization before each test case %% %% Note: This function is free to add any key/value pairs to the Config %% variable, but should NOT alter/remove any existing entries. %% Description: Initialization before each test case %%-------------------------------------------------------------------- init_per_testcase(_TestCase, Config0) -> Config = lists:keydelete(watchdog, 1, Config0), Dog = ssl_test_lib:timetrap(?TIMEOUT), [{watchdog, Dog} | Config]. %%-------------------------------------------------------------------- %% Function: end_per_testcase(TestCase, Config) -> _ %% Case - atom() %% Name of the test case that is about to be run. %% Config - [tuple()] %% A list of key/value pairs, holding the test case configuration. %% Description: Cleanup after each test case %%-------------------------------------------------------------------- end_per_testcase(_TestCase, Config) -> Dog = ?config(watchdog, Config), case Dog of undefined -> ok; _ -> test_server:timetrap_cancel(Dog) end. %%-------------------------------------------------------------------- %% Function: all(Clause) -> TestCases %% Clause - atom() - suite | doc %% TestCases - [Case] %% Case - atom() %% Name of a test case. %% Description: Returns a list of all test cases in this test suite %%-------------------------------------------------------------------- suite() -> [{ct_hooks,[ts_install_cth]}]. all() -> [server_echos_passive_small, server_echos_active_once_small, server_echos_active_small, client_echos_passive_small, client_echos_active_once_small, client_echos_active_small, server_echos_passive_big, server_echos_active_once_big, server_echos_active_big, client_echos_passive_big, client_echos_active_once_big, client_echos_active_big, server_echos_passive_huge, server_echos_active_once_huge, server_echos_active_huge, client_echos_passive_huge, client_echos_active_once_huge, client_echos_active_huge]. groups() -> []. init_per_group(_GroupName, Config) -> Config. end_per_group(_GroupName, Config) -> Config. %% Test cases starts here. %%-------------------------------------------------------------------- server_echos_passive_small(doc) -> ["Client sends 1000 bytes in passive mode to server, that receives them, " "sends them back, and closes."]; server_echos_passive_small(suite) -> []; server_echos_passive_small(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", server_echos_passive(Str, 1000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- server_echos_active_once_small(doc) -> ["Client sends 1000 bytes in active once mode to server, that receives " " them, sends them back, and closes."]; server_echos_active_once_small(suite) -> []; server_echos_active_once_small(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", server_echos_active_once(Str, 1000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- server_echos_active_small(doc) -> ["Client sends 1000 bytes in active mode to server, that receives them, " "sends them back, and closes."]; server_echos_active_small(suite) -> []; server_echos_active_small(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", server_echos_active(Str, 1000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- client_echos_passive_small(doc) -> ["Server sends 1000 bytes in passive mode to client, that receives them, " "sends them back, and closes."]; client_echos_passive_small(suite) -> []; client_echos_passive_small(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", client_echos_passive(Str, 1000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- client_echos_active_once_small(doc) -> ["Server sends 1000 bytes in active once mode to client, that receives " "them, sends them back, and closes."]; client_echos_active_once_small(suite) -> []; client_echos_active_once_small(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", client_echos_active_once(Str, 1000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- client_echos_active_small(doc) -> ["Server sends 1000 bytes in active mode to client, that receives them, " "sends them back, and closes."]; client_echos_active_small(suite) -> []; client_echos_active_small(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", client_echos_active(Str, 1000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- server_echos_passive_big(doc) -> ["Client sends 50000 bytes to server in passive mode, that receives them, " "sends them back, and closes."]; server_echos_passive_big(suite) -> []; server_echos_passive_big(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", server_echos_passive(Str, 50000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- server_echos_active_once_big(doc) -> ["Client sends 50000 bytes to server in active once mode, that receives " "them, sends them back, and closes."]; server_echos_active_once_big(suite) -> []; server_echos_active_once_big(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", server_echos_active_once(Str, 50000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- server_echos_active_big(doc) -> ["Client sends 50000 bytes to server in active once mode, that receives " " them, sends them back, and closes."]; server_echos_active_big(suite) -> []; server_echos_active_big(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", server_echos_active(Str, 50000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- client_echos_passive_big(doc) -> ["Server sends 50000 bytes to client in passive mode, that receives them, " "sends them back, and closes."]; client_echos_passive_big(suite) -> []; client_echos_passive_big(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", client_echos_passive(Str, 50000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- client_echos_active_once_big(doc) -> ["Server sends 50000 bytes to client in active once mode, that receives" " them, sends them back, and closes."]; client_echos_active_once_big(suite) -> []; client_echos_active_once_big(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", client_echos_active_once(Str, 50000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- client_echos_active_big(doc) -> ["Server sends 50000 bytes to client in active mode, that receives them, " "sends them back, and closes."]; client_echos_active_big(suite) -> []; client_echos_active_big(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", client_echos_active(Str, 50000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- server_echos_passive_huge(doc) -> ["Client sends 500000 bytes to server in passive mode, that receives " " them, sends them back, and closes."]; server_echos_passive_huge(suite) -> []; server_echos_passive_huge(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", server_echos_passive(Str, 500000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- server_echos_active_once_huge(doc) -> ["Client sends 500000 bytes to server in active once mode, that receives " "them, sends them back, and closes."]; server_echos_active_once_huge(suite) -> []; server_echos_active_once_huge(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", server_echos_active_once(Str, 500000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- server_echos_active_huge(doc) -> ["Client sends 500000 bytes to server in active mode, that receives them, " "sends them back, and closes."]; server_echos_active_huge(suite) -> []; server_echos_active_huge(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", server_echos_active(Str, 500000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- client_echos_passive_huge(doc) -> ["Server sends 500000 bytes to client in passive mode, that receives " "them, sends them back, and closes."]; client_echos_passive_huge(suite) -> []; client_echos_passive_huge(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", client_echos_passive(Str, 500000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- client_echos_active_once_huge(doc) -> ["Server sends 500000 bytes to client in active once mode, that receives " "them, sends them back, and closes."]; client_echos_active_once_huge(suite) -> []; client_echos_active_once_huge(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", client_echos_active_once(Str, 500000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- client_echos_active_huge(doc) -> ["Server sends 500000 bytes to client in active mode, that receives them, " "sends them back, and closes."]; client_echos_active_huge(suite) -> []; client_echos_active_huge(Config) when is_list(Config) -> ClientOpts = ?config(client_opts, Config), ServerOpts = ?config(server_opts, Config), {ClientNode, ServerNode, Hostname} = ssl_test_lib:run_where(Config), Str = "1234567890", client_echos_active(Str, 500000, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname). %%-------------------------------------------------------------------- server_echos_passive(Data, Length, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname) -> Server = ssl_test_lib:start_server([{node, ServerNode}, {port, 0}, {from, self()}, {mfa, {?MODULE, echoer, [Data, Length]}}, {options, [{active, false},{mode, binary} | ServerOpts]}]), Port = ssl_test_lib:inet_port(Server), Client = ssl_test_lib:start_client([{node, ClientNode}, {port, Port}, {host, Hostname}, {from, self()}, {mfa, {?MODULE, sender, [Data, Length]}}, {options, [{active, false}, {mode, binary} | ClientOpts]}]), ssl_test_lib:check_result(Server, ok, Client, ok), ssl_test_lib:close(Server), ssl_test_lib:close(Client). server_echos_active_once(Data, Length, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname) -> Server = ssl_test_lib:start_server([{node, ServerNode}, {port, 0}, {from, self()}, {mfa, {?MODULE, echoer_once, [Data, Length]}}, {options, [{active, once}, {mode, binary}| ServerOpts]}]), Port = ssl_test_lib:inet_port(Server), Client = ssl_test_lib:start_client([{node, ClientNode}, {port, Port}, {host, Hostname}, {from, self()}, {mfa, {?MODULE, sender_once, [Data, Length]}}, {options, [{active, once}, {mode, binary} | ClientOpts]}]), ssl_test_lib:check_result(Server, ok, Client, ok), ssl_test_lib:close(Server), ssl_test_lib:close(Client). server_echos_active(Data, Length, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname) -> Server = ssl_test_lib:start_server([{node, ServerNode}, {port, 0}, {from, self()}, {mfa, {?MODULE, echoer_active, [Data, Length]}}, {options, [{active, true}, {mode, binary} | ServerOpts]}]), Port = ssl_test_lib:inet_port(Server), Client = ssl_test_lib:start_client([{node, ClientNode}, {port, Port}, {host, Hostname}, {from, self()}, {mfa, {?MODULE, sender_active, [Data, Length]}}, {options, [{active, true}, {mode, binary} | ClientOpts]}]), ssl_test_lib:check_result(Server, ok, Client, ok), ssl_test_lib:close(Server), ssl_test_lib:close(Client). client_echos_passive(Data, Length, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname) -> Server = ssl_test_lib:start_server([{node, ServerNode}, {port, 0}, {from, self()}, {mfa, {?MODULE, sender, [Data, Length]}}, {options, [{active, false}, {mode, binary} | ServerOpts]}]), Port = ssl_test_lib:inet_port(Server), Client = ssl_test_lib:start_client([{node, ClientNode}, {port, Port}, {host, Hostname}, {from, self()}, {mfa, {?MODULE, echoer, [Data, Length]}}, {options, [{active, false}, {mode, binary} | ClientOpts]}]), ssl_test_lib:check_result(Server, ok, Client, ok), ssl_test_lib:close(Server), ssl_test_lib:close(Client). client_echos_active_once(Data, Length, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname) -> Server = ssl_test_lib:start_server([{node, ServerNode}, {port, 0}, {from, self()}, {mfa, {?MODULE, sender_once, [Data, Length]}}, {options, [{active, once}, {mode, binary} | ServerOpts]}]), Port = ssl_test_lib:inet_port(Server), Client = ssl_test_lib:start_client([{node, ClientNode}, {port, Port}, {host, Hostname}, {from, self()}, {mfa, {?MODULE, echoer_once, [Data, Length]}}, {options,[{active, once}, {mode, binary} | ClientOpts]}]), ssl_test_lib:check_result(Server, ok, Client, ok), ssl_test_lib:close(Server), ssl_test_lib:close(Client). client_echos_active(Data, Length, ClientOpts, ServerOpts, ClientNode, ServerNode, Hostname) -> Server = ssl_test_lib:start_server([{node, ServerNode}, {port, 0}, {from, self()}, {mfa, {?MODULE, sender_active, [Data, Length]}}, {options, [{active, true}, {mode, binary} | ServerOpts]}]), Port = ssl_test_lib:inet_port(Server), Client = ssl_test_lib:start_client([{node, ClientNode}, {port, Port}, {host, Hostname}, {from, self()}, {mfa, {?MODULE, echoer_active, [Data, Length]}}, {options, [{active, true}, {mode, binary} | ClientOpts]}]), ssl_test_lib:check_result(Server, ok, Client, ok), ssl_test_lib:close(Server), ssl_test_lib:close(Client). send(_, _, _, 0,_) -> ok; send(Socket, Data, Size, Repeate,F) -> NewData = lists:duplicate(Size div 10, Data), ssl:send(Socket, NewData), F(), send(Socket, Data, Size, Repeate - 1,F). sender(Socket, Data, Size) -> ok = send(Socket, Data, Size, 100, fun() -> do_recv(Socket, Data, Size, <<>>, false) end), test_server:format("Sender recv: ~p~n", [ssl:getopts(Socket, [active])]), ok. sender_once(Socket, Data, Size) -> send(Socket, Data, Size, 100, fun() -> do_active_once(Socket, Data, Size, <<>>, false) end), test_server:format("Sender active once: ~p~n", [ssl:getopts(Socket, [active])]), ok. sender_active(Socket, Data, Size) -> F = fun() -> do_active(Socket, Data, Size, <<>>, false) end, send(Socket, Data, Size, 100, F), test_server:format("Sender active: ~p~n", [ssl:getopts(Socket, [active])]), ok. echoer(Socket, Data, Size) -> test_server:format("Echoer recv: ~p~n", [ssl:getopts(Socket, [active])]), echo(fun() -> do_recv(Socket, Data, Size, <<>>, true) end, 100). echoer_once(Socket, Data, Size) -> test_server:format("Echoer active once: ~p ~n", [ssl:getopts(Socket, [active])]), echo(fun() -> do_active_once(Socket, Data, Size, <<>>, true) end, 100). echoer_active(Socket, Data, Size) -> test_server:format("Echoer active: ~p~n", [ssl:getopts(Socket, [active])]), echo(fun() -> do_active(Socket, Data, Size, <<>>, true) end, 100). echo(_Fun, 0) -> ok; echo(Fun, N) -> Fun(), echo(Fun, N-1). do_recv(_Socket, _Data, 0, _Acc, true) -> ok; do_recv(_Socket, Data, 0, Acc, false) -> Data = lists:sublist(binary_to_list(Acc), 10); do_recv(Socket, Data, Size, Acc, Echo) -> {ok, NewData} = ssl:recv(Socket, 0), NewSize = size(NewData), case Echo of true -> ssl:send(Socket, NewData), NewSize = size(NewData), do_recv(Socket, Data, Size - NewSize, [], Echo); false -> case size(Acc) < 10 of true -> do_recv(Socket, Data, Size - NewSize, <>, Echo); false -> do_recv(Socket, Data, Size - NewSize, Acc, Echo) end end. do_active_once(_Socket, _Data, 0, _Acc, true) -> ok; do_active_once(_Socket, Data, 0, Acc, false) -> Data = lists:sublist(binary_to_list(Acc), 10); do_active_once(Socket, Data, Size, Acc, Echo) -> receive {ssl, Socket, NewData} -> NewSize = size(NewData), case Echo of true -> ssl:send(Socket, NewData), ssl:setopts(Socket, [{active, once}]), do_active_once(Socket, Data, Size - NewSize, [], Echo); false -> case size(Acc) < 10 of true -> ssl:setopts(Socket, [{active, once}]), do_active_once(Socket, Data, Size - NewSize, <>, Echo); false -> ssl:setopts(Socket, [{active, once}]), do_active_once(Socket, Data, Size - NewSize, Acc, Echo) end end end. do_active(_Socket, _Data, 0, _Acc, true) -> ok; do_active(_Socket, Data, 0, Acc, false) -> Data = lists:sublist(binary_to_list(Acc), 10); do_active(Socket, Data, Size, Acc, Echo) -> receive {ssl, Socket, NewData} -> NewSize = size(NewData), case Echo of true -> ssl:send(Socket, NewData), do_active(Socket, Data, Size - NewSize, [], Echo); false -> case size(Acc) < 10 of true -> do_active(Socket, Data, Size - NewSize, <>, Echo); false -> do_active(Socket, Data, Size - NewSize, Acc, Echo) end end end.