Skip to content

Commit

Permalink
Address Jordan's review comments
Browse files Browse the repository at this point in the history
  • Loading branch information
slfritchie committed May 17, 2013
1 parent a23dec8 commit 15fb639
Showing 1 changed file with 13 additions and 13 deletions.
26 changes: 13 additions & 13 deletions src/riak_kv_vnode.erl
Expand Up @@ -1013,7 +1013,7 @@ perform_put({true, Obj},
bkey={Bucket, Key}, bkey={Bucket, Key},
reqid=ReqID, reqid=ReqID,
index_specs=IndexSpecs}) -> index_specs=IndexSpecs}) ->
case encode_and_Mod_put(Obj, Mod, Bucket, Key, IndexSpecs, ModState) of case encode_and_put(Obj, Mod, Bucket, Key, IndexSpecs, ModState) of
{{ok, UpdModState}, EncodedVal} -> {{ok, UpdModState}, EncodedVal} ->
update_hashtree(Bucket, Key, EncodedVal, State), update_hashtree(Bucket, Key, EncodedVal, State),
case RB of case RB of
Expand Down Expand Up @@ -1130,15 +1130,15 @@ do_get_term({Bucket, Key}, Mod, ModState) ->
end. end.


do_get_binary(Bucket, Key, Mod, ModState) -> do_get_binary(Bucket, Key, Mod, ModState) ->
case mod_capability_uses_r_object(Mod, ModState, Bucket) of case uses_r_object(Mod, ModState, Bucket) of
true -> true ->
Mod:get_object(Bucket, Key, true, ModState); Mod:get_object(Bucket, Key, true, ModState);
false -> false ->
Mod:get(Bucket, Key, ModState) Mod:get(Bucket, Key, ModState)
end. end.


do_get_object(Bucket, Key, Mod, ModState) -> do_get_object(Bucket, Key, Mod, ModState) ->
case mod_capability_uses_r_object(Mod, ModState, Bucket) of case uses_r_object(Mod, ModState, Bucket) of
true -> true ->
Mod:get_object(Bucket, Key, false, ModState); Mod:get_object(Bucket, Key, false, ModState);
false -> false ->
Expand Down Expand Up @@ -1330,8 +1330,8 @@ do_diffobj_put({Bucket, Key}, DiffObj,
false -> false ->
IndexSpecs = [] IndexSpecs = []
end, end,
case encode_and_Mod_put(DiffObj, Mod, Bucket, Key, case encode_and_put(DiffObj, Mod, Bucket, Key,
IndexSpecs, ModState) of IndexSpecs, ModState) of
{{ok, _UpdModState} = InnerRes, EncodedVal} -> {{ok, _UpdModState} = InnerRes, EncodedVal} ->
update_hashtree(Bucket, Key, EncodedVal, StateData), update_hashtree(Bucket, Key, EncodedVal, StateData),
update_index_write_stats(IndexBackend, IndexSpecs), update_index_write_stats(IndexBackend, IndexSpecs),
Expand All @@ -1355,8 +1355,8 @@ do_diffobj_put({Bucket, Key}, DiffObj,
false -> false ->
IndexSpecs = [] IndexSpecs = []
end, end,
case encode_and_Mod_put(AMObj, Mod, Bucket, Key, case encode_and_put(AMObj, Mod, Bucket, Key,
IndexSpecs, ModState) of IndexSpecs, ModState) of
{{ok, _UpdModState} = InnerRes, EncodedVal} -> {{ok, _UpdModState} = InnerRes, EncodedVal} ->
update_hashtree(Bucket, Key, EncodedVal, StateData), update_hashtree(Bucket, Key, EncodedVal, StateData),
update_index_write_stats(IndexBackend, IndexSpecs), update_index_write_stats(IndexBackend, IndexSpecs),
Expand Down Expand Up @@ -1541,14 +1541,14 @@ object_info({Bucket, _Key}=BKey) ->
Hash = riak_core_util:chash_key(BKey), Hash = riak_core_util:chash_key(BKey),
{Bucket, Hash}. {Bucket, Hash}.
-spec encode_and_Mod_put( -spec encode_and_put(
Obj::riak_object:riak_object(), Mod::term(), Bucket::riak_object:bucket(), Obj::riak_object:riak_object(), Mod::term(), Bucket::riak_object:bucket(),
Key::riak_object:key(), IndexSpecs::list(), ModState::term()) -> Key::riak_object:key(), IndexSpecs::list(), ModState::term()) ->
{{ok, UpdModState::term()}, EncodedObj::binary()} | {{ok, UpdModState::term()}, EncodedObj::binary()} |
{{error, Reason::term(), UpdModState::term()}, EncodedObj::binary()}. {{error, Reason::term(), UpdModState::term()}, EncodedObj::binary()}.
encode_and_Mod_put(Obj, Mod, Bucket, Key, IndexSpecs, ModState) -> encode_and_put(Obj, Mod, Bucket, Key, IndexSpecs, ModState) ->
case mod_capability_uses_r_object(Mod, ModState, Bucket) of case uses_r_object(Mod, ModState, Bucket) of
true -> true ->
Mod:put_object(Bucket, Key, IndexSpecs, Obj, ModState); Mod:put_object(Bucket, Key, IndexSpecs, Obj, ModState);
false -> false ->
Expand All @@ -1557,7 +1557,7 @@ encode_and_Mod_put(Obj, Mod, Bucket, Key, IndexSpecs, ModState) ->
{Mod:put(Bucket, Key, IndexSpecs, EncodedVal, ModState), EncodedVal} {Mod:put(Bucket, Key, IndexSpecs, EncodedVal, ModState), EncodedVal}
end. end.
mod_capability_uses_r_object(Mod, ModState, Bucket) -> uses_r_object(Mod, ModState, Bucket) ->
{ok, Capabilities} = Mod:capabilities(Bucket, ModState), {ok, Capabilities} = Mod:capabilities(Bucket, ModState),
lists:member(uses_r_object, Capabilities). lists:member(uses_r_object, Capabilities).
Expand Down

0 comments on commit 15fb639

Please sign in to comment.