Changeset 27929 for lang/erlang

Timestamp:

01/05/09 02:11:59 (4 years ago)

Author:

kuenishi

Message:

lang/erlang/qnesia パフォーマンス測定でバグ発見orz

Location:

lang/erlang/qnesia

Files:

• ChangeLog (modified) (1 diff)
• src/qnesia.erl (modified) (2 diffs)
• src/wtest.erl (modified) (1 diff)

lang/erlang/qnesia/ChangeLog

@@ -1 @@
-2009-01-02  UENISHI Kota  <uenishi.kota@lab.ntt.co.jp>
+2009-01-05  UENISHI Kota  <kuenishi@gmail.com>
+
+        * src/wtest.erl (run): performerを何度かかけてみると固まるケースが。
+        3x3だと99WPSくらいいったけど、何度目かで確実に固まる。
+        並列数などを増やすと、尚更。いったいどういうこっちゃ（来るはずのないメッセージをrecvしてるんだろなぁ）。
+
+        * src/qnesia.erl (local_write): 大分シンプルにしてみた
+        coordinatorとかややこしいプロセスは全部消して、rpc系にまとめた。
+        リモートへのレプリケーションも完了。
+        (TODO): ネットワーク切断の際にきちんと更新に失敗するのを確認すること。
+        コンフィグ情報の静的保管の仕方を調べること。
+        
+2009-01-04  UENISHI Kota  <kuenishi@gmail.com>
+
+        * src/qnesia.erl : デザインを根本から見直すことにしたので、
+        ちょっとお休み。ドキュメントをまとめるかもしれない。
+
+2009-01-03  UENISHI Kota  <kuenishi@gmail.com>
+
+        * src/qnesia.erl (mnesia_wrapper_loop): メッセージベースの作りよりも
+        RPCベースで作った方がよいと思います。というわけで ! 禁止の方向で。
+        プロセス構成ももちょっと変えて、リモートのマシンにはRPCするだけ。
+        リモートできちんとコードをstaticに持っておく
+        -> rpc:async_call, rpc:nb_yieldを使えばいいんじゃないか
+           -> 李ファクタリング必要
+
+2009-01-02  UENISHI Kota  <kuenishi@gmail.com>
 
         * qnesia.erl (read operation, mnesia_wrapper_loop): 

lang/erlang/qnesia/src/qnesia.erl

@@ -58 +58 @@
     %io:format("1. ここまできたよ~n", []),
     Keys = remote_write( Members, Data ),
-    io:format("2. ここまできたよ~p~n", [[N,W,Members,Data]]),
+    %io:format("2. ここまできたよ~p~n", [[N,W,Members,Data]]),
     case recv_ack( W, N-W+1, [] ) of
         {ok, {Remain, Ackers}}->
             %io:format("hoge: ここまできたよ~p~n", [[N,W,Members,Data,From]]),
             lists:map( fun(Node)-> Node ! {self(), { ok, do_commit }} end , Ackers ),
-            io:format("〜〜〜〜〜ここまできたよ~n", []),
+            %io:format("〜〜〜〜〜ここまできたよ~n", []),
             %{Result, {_, AckersRemain}} =   recv_ack( Remain-1, 1, [] ),
             %lists:map( fun(Node)-> Node ! {self(), { ok, do_commit }} end , AckersRemain ),
@@ -79 +79 @@
 recv_ack( 0, Remain, Ackers)-> {ok, {Remain, Ackers}};
 recv_ack( Q, Remain, Ackers)->
-    io:format( "receiving.~p~n", [[Q,Remain]]),
+    %io:format( "receiving.~p~n", [[Q,Remain]]),
     receive
         {From, {ok, _Result}}->
-            io:format( "ok: ~p.~n", [_Result]),
+            %io:format( "ok: ~p.~n", [_Result]),
             recv_ack(Q-1, Remain, [From|Ackers]);
         {From, {error, Reason}}->

lang/erlang/qnesia/src/wtest.erl

@@ -27 +27 @@
 loop(_Argv)->
     {Key, Value} = {gen_atom(12), gen_atom(128)},
-    qnesia:write({Key, Value}).% keykeykey, "asaaaaaaaaaaaaaaaaaaaaaaaaaaaa" ).
+    qnesia:write([node(), 'b@localhost'], {Key, Value}).% keykeykey, "asaaaaaaaaaaaaaaaaaaaaaaaaaaaa" ).
 
 run()->