3

Erlang を学習しようとしていますが、別のノードにメッセージを送信するときに問題があります。このプログラムは、このように動作する非常に単純なピンポンです。ノード m1@ASUS-N55SF でプログラムを開始します。プロセスを作成し、ノード m2 でプロセスを正常に生成します。したがって、{PidPing, PidPong} タプルを含む Pid を取得します。PidPing と PidPong は、<0.X.0> と <YZ0> のようなプロセス ID です。
その後、ps5:start_pinging(Pids) 関数を呼び出すと、エラーが発生します。

Pinging started
Ping received 0 on <0.53.0>
{ping,{<0.53.0>,<6807.43.0>},0}
Nodes: 'm1@ASUS-N55SF' 'm2@ASUS-N55SF'
(m1@ASUS-N55SF)8> 
=ERROR REPORT==== 1-Dec-2012::15:27:18 ===
Error in process <0.53.0> on node 'm1@ASUS-N55SF' with exit
value: {badarg,[{ps5,loop_ping,0,[{file,"ps5.erl"},{line,33}]}]}

したがって、最初のメッセージは PidPing と loop_ping receive に到達し、正常に一致しますが、別のノードにメッセージを送信できません。この最初のメッセージが同じノードで送信されるため、これは成功します。

PidPing ! {pong, {PidPing, PidPong}, 0}.

メッセージを別のノードに送信することを理解したので、次のようなメッセージを送信する必要があります。

{PidPong, ?NODE_TP} ! {pong, {PidPing, PidPong}, Number + 1},

しかし、それはbadargを返します。ノードは接続され、同じ Cookie で開始され、同じマシンで実行され、互いに ping を実行して表示できます。それらは同じフォルダーで開始されるため、同じ ps5.erl ファイルを参照します。別のフォルダーでも試しましたが、どちらも機能しません。別のノードでスポーンを削除し、同じノードでプロセスを作成するだけで、コードが seme ノードで実行される場合に機能します。

コードは次のとおりです。

-module(ps5).
-define(NODE_AS, 'm1@ASUS-N55SF').
-define(NODE_TP, 'm2@ASUS-N55SF').
%-define(NODE_TP, 'm2@ThinkPad-Z60m').

-compile(export_all).
start() ->
  PidPing = ps5:start_ping(),
  PidPong = ps5:start_pong(),
  Pids = {PidPing, PidPong}.

start_ping() ->
  Pid = spawn(?NODE_AS, ps5, loop_ping, []).

start_pong() ->
  Pid = spawn(?NODE_TP, ps5, loop_pong, []).

start_pinging({PidPing, PidPong}) ->
  io:format("Pinging started ~n", []),
   PidPing ! {ping, {PidPing, PidPong}, 0}.

stop({PidPing, PidPong}) ->
  exit(PidPing, normal),
  exit(PidPong, normal).

loop_ping() ->
  receive
    {ping, {PidPing, PidPong}, Number} when Number < 10  ->
      io:format("Ping received ~p on ~p~n", [Number, PidPing]),
      io:format("Nodes: ~p ~p ~n", [?NODE_AS, ?NODE_TP]),
      {PidPong, ?NODE_TP} ! {pong, {PidPing, PidPong}, Number + 1},
      io:format("Ping sent ping ~p to ~p~n", [Number, PidPong]),
      ps5:loop_ping();
    {ping, {PidPing, PidPong}, Number} when Number >= 10->
      io:format("Ping received ~p on ~p~n and closing.~n", [Number, PidPing]);
    Oops ->
      io:format("Oops received: ~p~n", [Oops]),
      ps5:loop_ping()
  end.

loop_pong() ->
  receive
   {pong, {PidPing, PidPong}, Number} when Number < 10  ->
     io:format("Pong received ~p on ~p~n", [Number, PidPong]),
     io:format("Nodes: ~p ~p ~n", [?NODE_AS, ?NODE_TP]),
     {PidPing, ?NODE_AS} ! {ping, {PidPing, PidPong}, Number + 1},
     io:format("Pong sent ping ~p to ~p~n", [Number, PidPing]),
     ps5:loop_pong();
   {pong, {PidPing, PidPong}, Number} when Number >= 10->
     io:format("Pong received ~p on ~p~n and closing.~n", [Number, PidPing]);
   Oops ->
     io:format("Oops received: ~p~n", [Oops]),
     ps5:loop_pong()
  end.

コンパイル中にいくつかの警告が表示されますが、それらはこの問題とは関係ありません (少なくとも私はそう信じています)。

4

1 に答える 1

8

この構造は、PID がわからないリモートの登録{Registered_process_name, Erlang_node} ! Some_message済みプロセスにメッセージを送信するために使用されます。

あなたの場合、あなたはpidを知っています（そしてプロセスは登録されていません）。つまり、使用するの{name, node} ! messageではなく、PID ! message変更する必要があります。

{PidPong, ?NODE_TP} ! {pong, {PidPing, PidPong}, Number + 1},

に

PidPong ! {pong, {PidPing, PidPong}, Number + 1},

と

{PidPing, ?NODE_AS} ! {ping, {PidPing, PidPong}, Number + 1},

に

PidPing ! {ping, {PidPing, PidPong}, Number + 1},
于 2012-12-01T15:44:31.117 に答える