summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorAdam Kocoloski <adam@cloudant.com>2010-06-30 16:26:53 -0400
committerAdam Kocoloski <adam@cloudant.com>2010-08-12 01:22:50 -0400
commit301e2345a51355fedb60f1668996ce43964f0801 (patch)
tree5de2808b2aa043234e6c19382ccf0a9945e70106 /src
parent48c8fde34591f782be7af77575eaa02dab8659b3 (diff)
update to new vclock module name
Diffstat (limited to 'src')
-rw-r--r--src/mem3_server.erl10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/mem3_server.erl b/src/mem3_server.erl
index 863e752f..addcb591 100644
--- a/src/mem3_server.erl
+++ b/src/mem3_server.erl
@@ -329,7 +329,7 @@ int_join(ExtNodes, #mem{nodes=Nodes, clock=Clock} = State) ->
[New|AccIn]
end, Nodes, ExtNodes),
NewNodes1 = lists:sort(NewNodes),
- NewClock = vector_clock:increment(node(), Clock),
+ NewClock = mem3_vclock:increment(node(), Clock),
NewState = State#mem{nodes=NewNodes1, clock=NewClock},
install_new_state(NewState),
{ok, NewState}.
@@ -347,10 +347,10 @@ get_pingnode_state(PingNode) ->
%% @doc handle the gossip messages
-%% We're not using vector_clock:resolve b/c we need custom merge strategy
+%% We're not using mem3_vclock:resolve b/c we need custom merge strategy
handle_gossip(From, RemoteState=#mem{clock=RemoteClock},
LocalState=#mem{clock=LocalClock}) ->
- case vector_clock:compare(RemoteClock, LocalClock) of
+ case mem3_vclock:compare(RemoteClock, LocalClock) of
equal ->
{reply, ok, LocalState};
less ->
@@ -379,7 +379,7 @@ handle_gossip(From, RemoteState=#mem{clock=RemoteClock},
merge_states(#mem{clock=RemoteClock, nodes=RemoteNodes} = _RemoteState,
#mem{clock=LocalClock, nodes=LocalNodes} = LocalState) ->
- MergedClock = vector_clock:merge(RemoteClock, LocalClock),
+ MergedClock = mem3_vclock:merge(RemoteClock, LocalClock),
MergedNodes = merge_nodes(RemoteNodes, LocalNodes),
LocalState#mem{clock=MergedClock, nodes=MergedNodes}.
@@ -547,7 +547,7 @@ get_remote_states(NodeList) ->
%% return match | {bad_state_match, Node, NodesThatDontMatch}
compare_state_with_rest(#mem{clock=Clock} = _State, States) ->
Results = lists:map(fun({Node, #mem{clock=Clock1}}) ->
- {vector_clock:equals(Clock, Clock1), Node}
+ {mem3_vclock:equals(Clock, Clock1), Node}
end, States),
BadResults = lists:foldl(fun({true, _N}, AccIn) -> AccIn;
({false, N}, AccIn) -> [N | AccIn]