Erlang пропущенные сообщения - PullRequest
1 голос
/ 16 ноября 2010

Я запускаю следующий код с dbg:p(client, r):

-module(client).
-export([start/0, start/2, send/1, net_client/1]).

start() ->
    start("localhost", 7000).

start(Host, Port) ->
    io:format("Client connecting to ~p:~p.~n", [Host, Port]),
    register(ui, spawn(fun() -> gui_control([]) end)),
    case gen_tcp:connect(Host, Port, [binary, {packet, 0}]) of
        {ok, Socket} ->
            Pid = spawn(client, net_client, [Socket]),
            register(client, Pid),
            gen_tcp:controlling_process(Socket, Pid);
        Error ->
            io:format("Error connecting to server: ~p~n", [Error]),
            erlang:error("Could not connect to server.")
    end,
    ok.

send(Msg) ->
    client!{send, Msg}.


%% Forwards messages to either the GUI controller or the server.
net_client(Socket) ->
    receive
        {tcp, Socket, Message} ->
            Msg = binary_to_term(Message),
            io:format("Received TCP message on ~p: ~p~n", [Socket, Msg]),
            ui!{server, Msg};
        {send, Message} ->
            io:format("Sending ~p.~n", [Message]),
            gen_tcp:send(Socket, term_to_binary(Message));
        close ->
            gen_tcp:close(Socket),
            exit(normal);
        {tcp_closed, Socket} ->
            io:format("Server terminated connection.~n"),
            exit(normal); %% Reconnect?
        timeout -> %% This
            io:format("Timed out?~n");
        {inet_reply, Socket, Message} -> %% and this never happen.
            io:format("inet_reply: ~p~n", Message);
        Error ->
            io:format("Net client got bad message: ~p.~n", [Error])
    after 10000 ->
            refresh %% gen_tcp:send(Socket, term_to_binary(keepalive))
    end,
    ?MODULE:net_client(Socket).


gui_control(Data) ->
    receive
        %% This will hang the gui until the sync is done. Not sure if
        %% that's okay.
        {server, {sync, Datum}} -> % Resync command from server.
            gui_control(resync([Datum]));
        {client, refresh} -> % Refresh request from display.
            display:update(Data);
        {server, Msg} ->
            io:format("UI Rx: ~p~n", [Msg])
    end,
    gui_control(Data).

resync(Data) ->
    receive
        {server, {sync, Datum}} ->
            resync([Datum|Data]);
        {server, {done, Num}} ->
            case length(Data) of
                Num ->
                    Data;
                _ ->
                    io:format("Got done before all the data were received.~n"),
                    send({sync})
            end
    after 5000 ->
            io:format("Timed out waiting for data.~n"),
            send({sync})
    end.

Он связывается с сервером, который я написал с gen_tcp и gen_server, после this .Моя главная проблема в том, что я не могу получать все свои сообщения.Иногда я получаю

(<0.2.0>) << {tcp,#Port<0.517>,
                  <<131,104,6,100,0,4,99,97,114,100,100,0,7,117,110,107,110,
                    111,119,110,100,0,7,117,110,107,110,111,119,110,106,106,
                    104,3,107,0,6,83,101,99,111,110,100,100,0,4,100,114,97,
                    119,97,2,131,104,6,100,0,4,99,97,114,100,100,0,7,117,110,
                    107,110,111,119,110,100,0,7,117,110,107,110,111,119,110,
                    106,106,104,3,107,0,6,83,101,99,111,110,100,100,0,4,100,
                    114,97,119,97,3,131,104,6,100,0,4,99,97,114,100,100,0,7,
                    117,110,107,110,111,119,110,100,0,7,117,110,107,110,111,
                    119,110,106,106,104,3,107,0,5,70,105,114,115,116,100,0,4,
                    100,114,97,119,97,0>>}

из результатов отладки, но не соответствующее сообщение Received TCP message on #Port<0.517>:....Я также увижу такие вещи:

(<0.2.0>) << {io_reply,<0.24.0>,ok}
(<0.2.0>) << timeout
(<0.2.0>) << {io_reply,<0.24.0>,ok}
(<0.2.0>) << timeout
(<0.2.0>) << {io_reply,<0.24.0>,ok}

, но ничего от net_client не получат.Я наблюдал за сетевым трафиком с помощью wireshark, и я знаю, что пакеты достигают того места, куда они должны идти, и получают ACK ed.Что я делаю не так?

Редактировать: Я вызываю это с erl -smp enable -eval "client:start()." на случай, если это имеет значение.

Ответы [ 3 ]

1 голос
/ 17 ноября 2010

Также я рекомендую использовать redbug (часть eper) https://github.com/massemanet/eper при трассировке. Он защищает вас от утопления в системе при выводе трассировки и обеспечивает простой простой синтаксис, например: redbug: start («mymod: foo -> return», [{msgs, 10}]). отслеживайте все вызовы mymod: foo и возвращайте эти вызовы, но дайте мне не более 10 сообщений трассировки.

1 голос
/ 18 ноября 2010

Оказывается {packet, 0} была моей проблемой. Замените это на {packet, 2} и все хорошо.

1 голос
/ 16 ноября 2010

Я полагаю, что основная проблема заключается в том, что net_client должен порождаться как отдельный процесс.

В методе запуска измените

register(client, self()),
net_client(Socket);

на

register(client, fun() -> net_client(Socket) end);

, который должен это решить ..

...