Untitled

-module(tcp_listener).

%%--------------------------------------------------------------------
%% External exports
-export([start_link/1]).

%% Internal exports
-export([init/1,init/0,do_recv/2]).


%% Even though this is not a gen_server
%% it is started and returns in the same fashion
start_link(Port) ->
    {ok, proc_lib:spawn_link(?MODULE, init, [Port])}.



%%--------------------------------------------------------------------

%% Open a socket on Port. If it fails, try again.
%% Then go into accept-loop (see loop/1)
init () ->
    init(17000).
init(Port) ->
    Response = gen_tcp:listen(Port, [list, {packet, 0},
                                     {active, false}]),
    case Response of
        {ok, LSock} ->
            io:format("tcp_listener: socket opened on port ~p~n", [Port]),
            loop(LSock);
        {error, Reason} ->
            io:format("tcp_listener: listen failed with reason ~p~n", [Reason]),
            io:format("tcp_listener: Will try again in 5 seconds...~n"),
            timer:sleep(5000),
            init(Port);
        _ ->
            io:format("tcp_listener: listen returned wierd.~n")
    end.


%% Accepts incoming connections, and creates a new session when a socket
%% is established. Nothing is read from the socket.
loop(LSock) ->
%%    io:format("in tcp_listener loop~n"),
    case gen_tcp:accept(LSock) of
        {ok, Sock} ->
            %%{ok, _Pid} = ho_controller:create_session(Sock),
            %%{ok, _Pid} = io:format("tcp_listener: connection received on port ~p~n", [Port]),
            %%{ok, _Pid} = io:format("tcp_listener: connection received on port ~p ",Sock),
            io:format("tcp_listener: connection received on port ~n"),
            io:fwrite("tcp_listener: running in pid ~p\n", [self()]),
            {ok,Bin} = gen_tcp:do_recv(Sock,[]),
            io:format("tcp_listner: read ~p ~n",Bin),
            gen_tcp:send(Sock,"999999"),
            loop(LSock);
        {error, closed} ->
            io:format("tcp_listener: going down!~n");
        X ->
            io:format("tcp_listener: got unhandled message ~p~n", [X])
    end.

do_recv(Sock, Bs) ->
        case gen_tcp:recv(Sock, 0) of
             {ok, B} ->
             do_recv(Sock, [Bs, B]);
              {error, closed} ->
             {ok, list_to_binary(Bs)}
            end.