summaryrefslogtreecommitdiff
path: root/src/tls/tls.erl
diff options
context:
space:
mode:
authorChristophe Romain <christophe.romain@process-one.net>2008-03-21 14:44:16 +0000
committerChristophe Romain <christophe.romain@process-one.net>2008-03-21 14:44:16 +0000
commitb2bd9759c815557166d38df1ab7778dc874317a0 (patch)
treecbd2df2d63ecf5a993fa8aec6ea8684c5ab7601c /src/tls/tls.erl
parent* doc/guide.tex: Improve explanation of how to start ejabberd when (diff)
Rewrite io:format calls to loglevel macros (EJAB-555)
SVN Revision: 1239
Diffstat (limited to '')
-rw-r--r--src/tls/tls.erl30
1 files changed, 16 insertions, 14 deletions
diff --git a/src/tls/tls.erl b/src/tls/tls.erl
index e8b8557b..3e45b2f7 100644
--- a/src/tls/tls.erl
+++ b/src/tls/tls.erl
@@ -49,6 +49,8 @@
code_change/3,
terminate/2]).
+-include("ejabberd.hrl").
+
-define(SET_CERTIFICATE_FILE_ACCEPT, 1).
-define(SET_CERTIFICATE_FILE_CONNECT, 2).
-define(SET_ENCRYPTED_INPUT, 3).
@@ -166,7 +168,7 @@ recv_data1(#tlssock{tcpsock = TCPSocket, tlsport = Port}, Packet) ->
<<0, Out/binary>> ->
case gen_tcp:send(TCPSocket, Out) of
ok ->
- %io:format("IN: ~p~n", [{TCPSocket, binary_to_list(In)}]),
+ %?PRINT("IN: ~p~n", [{TCPSocket, binary_to_list(In)}]),
{ok, In};
Error ->
Error
@@ -184,7 +186,7 @@ recv_data1(#tlssock{tcpsock = TCPSocket, tlsport = Port}, Packet) ->
send(#tlssock{tcpsock = TCPSocket, tlsport = Port}, Packet) ->
case port_control(Port, ?SET_DECRYPTED_OUTPUT, Packet) of
<<0>> ->
- %io:format("OUT: ~p~n", [{TCPSocket, lists:flatten(Packet)}]),
+ %?PRINT("OUT: ~p~n", [{TCPSocket, lists:flatten(Packet)}]),
case port_control(Port, ?GET_ENCRYPTED_OUTPUT, []) of
<<0, Out/binary>> ->
gen_tcp:send(TCPSocket, Out);
@@ -243,50 +245,50 @@ test() ->
{error, already_loaded} -> ok
end,
Port = open_port({spawn, tls_drv}, [binary]),
- io:format("open_port: ~p~n", [Port]),
+ ?PRINT("open_port: ~p~n", [Port]),
PCRes = port_control(Port, ?SET_CERTIFICATE_FILE_ACCEPT,
"./ssl.pem" ++ [0]),
- io:format("port_control: ~p~n", [PCRes]),
+ ?PRINT("port_control: ~p~n", [PCRes]),
{ok, ListenSocket} = gen_tcp:listen(1234, [binary,
{packet, 0},
{active, true},
{reuseaddr, true},
{nodelay, true}]),
- io:format("listen: ~p~n", [ListenSocket]),
+ ?PRINT("listen: ~p~n", [ListenSocket]),
{ok, Socket} = gen_tcp:accept(ListenSocket),
- io:format("accept: ~p~n", [Socket]),
+ ?PRINT("accept: ~p~n", [Socket]),
loop(Port, Socket).
loop(Port, Socket) ->
receive
{tcp, Socket, Data} ->
- %io:format("read: ~p~n", [Data]),
+ %?PRINT("read: ~p~n", [Data]),
Res = port_control(Port, ?SET_ENCRYPTED_INPUT, Data),
- io:format("SET_ENCRYPTED_INPUT: ~p~n", [Res]),
+ ?PRINT("SET_ENCRYPTED_INPUT: ~p~n", [Res]),
DIRes = port_control(Port, ?GET_DECRYPTED_INPUT, Data),
- io:format("GET_DECRYPTED_INPUT: ~p~n", [DIRes]),
+ ?PRINT("GET_DECRYPTED_INPUT: ~p~n", [DIRes]),
case DIRes of
<<0, In/binary>> ->
- io:format("input: ~s~n", [binary_to_list(In)]);
+ ?PRINT("input: ~s~n", [binary_to_list(In)]);
<<1, DIError/binary>> ->
- io:format("GET_DECRYPTED_INPUT error: ~p~n", [binary_to_list(DIError)])
+ ?PRINT("GET_DECRYPTED_INPUT error: ~p~n", [binary_to_list(DIError)])
end,
EORes = port_control(Port, ?GET_ENCRYPTED_OUTPUT, Data),
- io:format("GET_ENCRYPTED_OUTPUT: ~p~n", [EORes]),
+ ?PRINT("GET_ENCRYPTED_OUTPUT: ~p~n", [EORes]),
case EORes of
<<0, Out/binary>> ->
gen_tcp:send(Socket, Out);
<<1, EOError/binary>> ->
- io:format("GET_ENCRYPTED_OUTPUT error: ~p~n", [binary_to_list(EOError)])
+ ?PRINT("GET_ENCRYPTED_OUTPUT error: ~p~n", [binary_to_list(EOError)])
end,
loop(Port, Socket);
Msg ->
- io:format("receive: ~p~n", [Msg]),
+ ?PRINT("receive: ~p~n", [Msg]),
loop(Port, Socket)
end.