Changeset 27148 for lang/erlang

Timestamp:

12/21/08 16:28:13 (4 years ago)

Author:

kuenishi

Message:

lang/erlang/qnesia 性能が測れるようになってきた

Location:

lang/erlang

Files:

• performer.erl (modified) (1 diff)
• ptest.erl (modified) (1 diff)
• qnesia.erl (modified) (2 diffs)

lang/erlang/performer.erl

@@ -61 +61 @@
               ).
 
-join_all(1)-> ok;
+join_all(0)-> ok;
 join_all(N)->
     receive

lang/erlang/ptest.erl

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

lang/erlang/qnesia.erl

@@ -11 +11 @@
 
 -export([ start/1, stop/1,
-         write/2, read/1 ]).
+         write/1, read/1,
+         write/2, read/2
+         ]).
 
 -export([
@@ -24 +26 @@
     qnesia:start([node(), 'b@localhost']).
 
-% write test :  n> qnesia:write_test(). 
-% @spec   write({Key, Value}) -> ok | ng
-write(Key, Value)->
+write(RemoteNode, {Key, Value})->
     Data = #data{key=Key, value=Value},
-    coordinator ! {write, Data , self() },
+    {coordinator, RemoteNode} ! {write, Data , self() },
     receive
         {ok, Result}->
             Result;
         Result->
-%           io:format("write test: ~p~n", [Result]) %とりあえず失敗する
+%           io:format("write test: ~p~n", [Result]), %とりあえず失敗する
             Result
     end.
+             
+% @spec   write({Key, Value}) -> ok | ng
+write({Key, Value})->
+    write(node(), {Key, Value}).
+
+read(Key)->
+    read(node(), Key).
 
 % @spec   read(Key) -> DataList
-read(Key)->
-    coordinator ! {read, Key, self()},
+read(RemoteNode, Key)->
+    {coordinator , RemoteNode} ! {read, Key, self()},
     receive
         {ok, DataList}->