src/ebin/eunit/autoload.beam src/ebin/eunit/code_monitor.beam src/ebin/eunit/eunit.beam src/ebin/eunit/eunit_autoexport.beam src/ebin/eunit/eunit_data.beam src/ebin/eunit/eunit_lib.beam src/ebin/eunit/eunit_proc.beam src/ebin/eunit/eunit_serial.beam src/ebin/eunit/eunit_server.beam src/ebin/eunit/eunit_striptests.beam src/ebin/eunit/eunit_test.beam src/ebin/eunit/eunit_tests.beam src/ebin/eunit/eunit_tty.beam src/ebin/eunit/file_monitor.beam src/etest/membership_test.erl @@ -1 +1,3 @@ -This is dynamite +This is dynomite. It is a clone of the amazon dynamo key value store written in Erlang. + +http://www.allthingsdistributed.com/2007/10/amazons_dynamo.html \ No newline at end of file README @@ -9,7 +9,7 @@ %%% @since 2008-03-30 by Cliff Moon %%%------------------------------------------------------------------- -module(membership). --author(''). +-author('Cliff Moon'). -behaviour(gen_server). @@ -25,9 +25,9 @@ -record(membership, {hash_ring, member_table}). -%testing -% -compile(export_all). - +-ifdef(TEST). +-include("etest/membership_test.erl"). +-endif. %%==================================================================== %% API @@ -62,10 +62,7 @@ server_for_key(Key) -> %% @end %%-------------------------------------------------------------------- init([]) -> - VirtualNodes = virtual_nodes(node()), - Table = map_nodes_to_table(VirtualNodes, node(), dict:new()), - HashRing = add_nodes_to_ring(VirtualNodes, []), - {ok, #membership{hash_ring = HashRing, member_table = Table}}. + {ok, create_membership_state([node()])}. %%-------------------------------------------------------------------- %% @spec @@ -131,6 +128,19 @@ code_change(_OldVsn, State, _Extra) -> %%-------------------------------------------------------------------- %%% Internal functions %%-------------------------------------------------------------------- + +create_membership_state(Nodes) -> + create_membership_state(Nodes, [], dict:new()). + +create_membership_state([], HashRing, Table) -> + {ok, #membership{hash_ring=HashRing,member_table=Table}}; + +create_membership_state([Node|Tail], HashRing, Table) -> + VirtualNodes = virtual_nodes(Node), + create_membership_state(Tail, + add_nodes_to_ring(VirtualNodes, HashRing), + map_nodes_to_table(VirtualNodes, Node, Table)). + int_join_ring(Node, State) -> case dict:is_key(Node, State#membership.member_table) of true -> {reply, duplicate, State}; @@ -177,4 +187,12 @@ nearest_server(Code, [ServerKey|Tail]) -> false -> nearest_server(Code, Tail) end; -nearest_server(_Code, []) -> first. \ No newline at end of file +nearest_server(_Code, []) -> first. + +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% +% TESTES +%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% + +% int_join_ring_test() -> +% State = create_membership_state([one, two, three]). + src/elibs/membership.erl src/ebin/eunit/eunit/autoload.beam src/ebin/eunit/eunit/code_monitor.beam src/ebin/eunit/eunit/eunit.beam src/ebin/eunit/eunit/eunit_autoexport.beam src/ebin/eunit/eunit/eunit_data.beam src/ebin/eunit/eunit/eunit_lib.beam src/ebin/eunit/eunit/eunit_proc.beam src/ebin/eunit/eunit/eunit_serial.beam src/ebin/eunit/eunit/eunit_server.beam src/ebin/eunit/eunit/eunit_striptests.beam src/ebin/eunit/eunit/eunit_test.beam src/ebin/eunit/eunit/eunit_tests.beam src/ebin/eunit/eunit/eunit_tty.beam src/ebin/eunit/eunit/file_monitor.beam 3d9bc9a4ddff875bf24f4359f61eaf504028c681 Cliff Moon cliff@galva.desk.hq.powerset.com http://github.com/cliffmoon/dynomite/commit/c7a7de6629e89a2d2b9c552cca42b4dd621805c6 c7a7de6629e89a2d2b9c552cca42b4dd621805c6 2008-04-02T11:48:42-07:00 2008-04-02T11:48:42-07:00 fixes to bad beam path for eunit f0e3e8eb56b4545db867eb6d2585310c3904ae6c Cliff Moon cliff@galva.desk.hq.powerset.com