Permalink
Browse files

WIP: Fix forwarding spec

  • Loading branch information...
rzezeski committed Sep 7, 2012
1 parent 3b1d8de commit 6c949e915273b7fde3f7e7cd138f4b2adddb38fa
Showing with 6 additions and 2 deletions.
  1. +1 −0 include/riak_core.hrl
  2. +1 −1 src/riak_core_ring.erl
  3. +4 −1 src/riak_core_vnode_manager.erl
View
@@ -0,0 +1 @@
+-type orddict(K,V) :: [{Key::K, Value::V}].
View
@@ -109,7 +109,7 @@
is_primary/2,
chash/1]).
--export_type([riak_core_ring/0]).
+-export_type([pending_change/0, riak_core_ring/0]).
-ifdef(TEST).
-include_lib("eunit/include/eunit.hrl").
@@ -35,6 +35,7 @@
%% Field debugging
-export([get_tab/0]).
+-include("riak_core.hrl").
-ifdef(TEST).
-include_lib("eunit/include/eunit.hrl").
-endif.
@@ -58,8 +59,10 @@
-type repair() :: #repair{}.
-type repairs() :: [repair()].
+-type mod_idx() :: {module(), integer()}.
+-type forwarding() :: orddict(mod_idx(), riak_core_ring:pending_change()).
-record(state, {idxtab,
- forwarding :: [pid()],
+ forwarding :: forwarding(),
handoff :: [{term(), integer(), pid(), node()}],
known_modules :: [term()],
never_started :: [{integer(), term()}],

0 comments on commit 6c949e9

Please sign in to comment.