Changeset 27148 for lang/erlang

Show
Ignore:
Timestamp:
12/21/08 16:28:13 (6 years ago)
Author:
kuenishi
Message:

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

Location:
lang/erlang
Files:
3 modified

Legend:

Unmodified
Added
Removed
  • lang/erlang/performer.erl

    r27145 r27148  
    6161              ). 
    6262 
    63 join_all(1)-> ok; 
     63join_all(0)-> ok; 
    6464join_all(N)-> 
    6565    receive 
  • lang/erlang/ptest.erl

    r27145 r27148  
    2525loop(_Argv)-> 
    2626    {Key, Value} = {gen_atom(12), gen_atom(128)}, 
    27     qnesia:write(Key, Value).% keykeykey, "asaaaaaaaaaaaaaaaaaaaaaaaaaaaa" ). 
     27    qnesia:write('a@localhost', {Key, Value}).% keykeykey, "asaaaaaaaaaaaaaaaaaaaaaaaaaaaa" ). 
    2828 
    2929run()-> 
  • lang/erlang/qnesia.erl

    r27145 r27148  
    1111 
    1212-export([ start/1, stop/1, 
    13          write/2, read/1 ]). 
     13         write/1, read/1, 
     14         write/2, read/2 
     15         ]). 
    1416 
    1517-export([ 
     
    2426    qnesia:start([node(), 'b@localhost']). 
    2527 
    26 % write test :  n> qnesia:write_test().  
    27 % @spec   write({Key, Value}) -> ok | ng 
    28 write(Key, Value)-> 
     28write(RemoteNode, {Key, Value})-> 
    2929    Data = #data{key=Key, value=Value}, 
    30     coordinator ! {write, Data , self() }, 
     30    {coordinator, RemoteNode} ! {write, Data , self() }, 
    3131    receive 
    3232        {ok, Result}-> 
    3333            Result; 
    3434        Result-> 
    35 %           io:format("write test: ~p~n", [Result]) %とりあえず失敗する 
     35%           io:format("write test: ~p~n", [Result]), %とりあえず失敗する 
    3636            Result 
    3737    end. 
     38              
     39% @spec   write({Key, Value}) -> ok | ng 
     40write({Key, Value})-> 
     41    write(node(), {Key, Value}). 
     42 
     43read(Key)-> 
     44    read(node(), Key). 
    3845 
    3946% @spec   read(Key) -> DataList 
    40 read(Key)-> 
    41     coordinator ! {read, Key, self()}, 
     47read(RemoteNode, Key)-> 
     48    {coordinator , RemoteNode} ! {read, Key, self()}, 
    4249    receive 
    4350        {ok, DataList}->