%%%-------------------------------------------------------------------
%%% @author Dan Gudmundsson <[email protected]>
%%% @copyright (C) 2010, Dan Gudmundsson
%%% @doc start server with -proto_dist inet_proxy and net_kernel:start([s@faenor, shortnames]).
%%%
%%% @end
%%% Created : 22 Jun 2010 by Dan Gudmundsson <[email protected]>
%%%-------------------------------------------------------------------
-module(proxy_server).
-export([init/1, start_link/0, handle_call/3, handle_cast/2, handle_info/2,
terminate/2, code_change/3]).
-include_lib("kernel/src/net_address.hrl").
-include_lib("kernel/src/dist.hrl").
-include_lib("kernel/src/dist_util.hrl").
-record(state,
{listen,
accept_loop
}).
start_link() ->
gen_server:start_link({local, proxy_server}, proxy_server, [], []).
init([]) ->
io:format("~p: init~n",[self()]),
process_flag(priority, max),
{ok, #state{}}.
handle_call(What = {listen, Name}, _From, State) ->
io:format("~p: call listen ~p~n",[self(), What]),
case gen_tcp:listen(0, [{active, false}, {packet,2}]) of
{ok, Socket} ->
{ok, World} = gen_tcp:listen(0, [{active, false}, binary, {packet,2}]),
TcpAddress = get_tcp_address(Socket),
WorldTcpAddress = get_tcp_address(World),
{_,Port} = WorldTcpAddress#net_address.address,
{ok, Creation} = erl_epmd:register_node(Name, Port),
{reply, {ok, {Socket, TcpAddress, Creation}},
State#state{listen={Socket, World}}};
Error ->
{reply, Error, State}
end;
handle_call(What = {accept, Listen}, {From, _}, State = #state{listen={_, World}}) ->
io:format("~p: call accept ~p~n",[self(), What]),
Self = self(),
ErtsPid = spawn_link(fun() -> accept_loop(Self, erts, Listen, From) end),
WorldPid = spawn_link(fun() -> accept_loop(Self, world, World, Listen) end),
{reply, ErtsPid, State#state{accept_loop={ErtsPid, WorldPid}}};
handle_call({connect, Ip, Port}, {From, _}, State) ->
Me = self(),
Pid = spawn_link(fun() -> setup_proxy(Ip, Port, Me) end),
receive
{Pid, go_ahead, LPort} ->
Res = {ok, Socket} = try_connect(LPort),
ok = gen_tcp:controlling_process(Socket, From),
{reply, Res, State};
{Pid, Error} ->
{reply, Error, State}
end;
handle_call({get_remote_id, {Socket,_Node}}, _From, State) ->
Address = get_tcp_address(Socket),
io:format("~p: get_remote_id ~p~n",[self(), Address]),
{reply, Address, State};
handle_call(What, _From, State) ->
io:format("~p: call ~p~n",[self(), What]),
{reply, ok, State}.
handle_cast(What, State) ->
io:format("~p: cast ~p~n",[self(), What]),
{noreply, State}.
handle_info(What, State) ->
io:format("~p: info ~p~n",[self(), What]),
{noreply, State}.
terminate(_Reason, _St) ->
ok.
code_change(_OldVsn, St, _Extra) ->
{ok, St}.
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
get_tcp_address(Socket) ->
{ok, Address} = inet:sockname(Socket),
{ok, Host} = inet:gethostname(),
#net_address{
address = Address,
host = Host,
protocol = proxy,
family = inet
}.
accept_loop(Proxy, Type, Listen, Extra) ->
process_flag(priority, max),
case gen_tcp:accept(Listen) of
{ok, Socket} ->
case Type of
erts ->
io:format("~p: erts accept~n",[self()]),
Extra ! {accept,self(),Socket,inet,proxy},
receive
{_Kernel, controller, Pid} ->
ok = gen_tcp:controlling_process(Socket, Pid),
Pid ! {self(), controller};
{_Kernel, unsupported_protocol} ->
exit(unsupported_protocol)
end;
_ ->
io:format("~p: world accept~n",[self()]),
PairHandler = spawn(fun() -> setup_connection(Socket, Extra) end),
ok = gen_tcp:controlling_process(Socket, PairHandler)
end,
accept_loop(Proxy, Type, Listen, Extra);
Error ->
exit(Error)
end.
try_connect(Port) ->
case gen_tcp:connect({127,0,0,1}, Port, [{active, false}, {packet,2}]) of
R = {ok, _S} ->
R;
{error, _R} ->
io:format("Failed ~p~n",[_R]),
try_connect(Port)
end.
setup_proxy(Ip, Port, Parent) ->
case gen_tcp:connect(Ip, Port, [{active, true}, binary, {packet,2}]) of
{ok, World} ->
{ok, ErtsL} = gen_tcp:listen(0, [{active, true}, binary, {packet,2}]),
#net_address{address={_,LPort}} = get_tcp_address(ErtsL),
Parent ! {self(), go_ahead, LPort},
case gen_tcp:accept(ErtsL) of
{ok, Erts} ->
%% gen_tcp:close(ErtsL),
io:format("World ~p Erts ~p~n",[World, Erts]),
loop_conn_setup(World, Erts);
Err ->
Parent ! {self(), Err}
end;
Err ->
Parent ! {self(), Err}
end.
setup_connection(World, ErtsListen) ->
io:format("Setup connection ~n",[]),
TcpAddress = get_tcp_address(ErtsListen),
{_Addr,Port} = TcpAddress#net_address.address,
{ok, Erts} = gen_tcp:connect({127,0,0,1}, Port, [{active, true}, binary, {packet,2}]),
inet:setopts(World, [{active,true}, {packet, 2}]),
io:format("~p ~n",[?LINE]),
loop_conn_setup(World, Erts).
loop_conn_setup(World, Erts) ->
receive
{tcp, World, Data = <<a, _/binary>>} ->
gen_tcp:send(Erts, Data),
io:format("Handshake finished World -> Erts ~p ~c~n",[size(Data), a]),
inet:setopts(World, [{packet, 4}]),
inet:setopts(Erts, [{packet, 4}]),
loop_conn(World, Erts);
{tcp, Erts, Data = <<a, _/binary>>} ->
gen_tcp:send(World, Data),
io:format("Handshake finished Erts -> World ~p ~c~n",[size(Data), a]),
inet:setopts(World, [{packet, 4}]),
inet:setopts(Erts, [{packet, 4}]),
loop_conn(World, Erts);
{tcp, World, Data = <<H, _/binary>>} ->
gen_tcp:send(Erts, Data),
io:format("Handshake World -> Erts ~p ~c~n",[size(Data), H]),
loop_conn_setup(World, Erts);
{tcp, Erts, Data = <<H, _/binary>>} ->
gen_tcp:send(World, Data),
io:format("Handshake Erts -> World ~p ~c~n",[size(Data), H]),
loop_conn_setup(World, Erts);
{tcp, World, Data} ->
gen_tcp:send(Erts, Data),
io:format("World -> Erts ~p <<>>~n",[size(Data)]),
loop_conn(World, Erts);
{tcp, Erts, Data} ->
gen_tcp:send(World, Data),
io:format("Erts -> World ~p <<>>~n",[size(Data)]),
loop_conn(World, Erts);
Other ->
io:format("~p ~p~n",[?LINE, Other])
end.
loop_conn(World, Erts) ->
receive
{tcp, World, Data = <<H, _/binary>>} ->
gen_tcp:send(Erts, Data),
io:format("World -> Erts ~p ~c~n",[size(Data), H]),
loop_conn(World, Erts);
{tcp, Erts, Data = <<H, _/binary>>} ->
gen_tcp:send(World, Data),
io:format("Erts -> World ~p ~c~n",[size(Data), H]),
loop_conn(World, Erts);
{tcp, World, Data} ->
gen_tcp:send(Erts, Data),
io:format("World -> Erts ~p <<>>~n",[size(Data)]),
loop_conn(World, Erts);
{tcp, Erts, Data} ->
gen_tcp:send(World, Data),
io:format("Erts -> World ~p <<>>~n",[size(Data)]),
loop_conn(World, Erts);
Other ->
io:format("~p ~p~n",[?LINE, Other])
end.
