Skip to content

Commit

Permalink
Rename gen_server2 to riak_core_gen_server
Browse files Browse the repository at this point in the history
  • Loading branch information
rzezeski committed Aug 24, 2012
1 parent 0da5893 commit db17f87
Showing 1 changed file with 7 additions and 6 deletions.
13 changes: 7 additions & 6 deletions src/riak_kv_map_master.erl
Expand Up @@ -23,7 +23,7 @@
-module(riak_kv_map_master).
-include_lib("riak_kv_js_pools.hrl").

-behaviour(gen_server2).
-behaviour(riak_core_gen_server).

%% API
-export([start_link/0,
Expand All @@ -47,17 +47,18 @@
next}).

new_mapper({_, Node}=VNode, QTerm, MapInputs, PhasePid) ->
gen_server2:pcall({?SERVER, Node}, 5, {new_mapper, VNode,
QTerm, MapInputs, PhasePid}, infinity).
riak_core_gen_server:pcall({?SERVER, Node}, 5,
{new_mapper, VNode, QTerm, MapInputs, PhasePid},
infinity).

queue_depth() ->
Nodes = [node()|nodes()],
[{Node, gen_server2:pcall({?SERVER, Node}, 0, queue_depth,
infinity)} || Node <- Nodes].
[{Node, riak_core_gen_server:pcall({?SERVER, Node}, 0, queue_depth,
infinity)} || Node <- Nodes].


start_link() ->
gen_server2:start_link({local, ?SERVER}, ?MODULE, [], []).
riak_core_gen_server:start_link({local, ?SERVER}, ?MODULE, [], []).

init([]) ->
process_flag(trap_exit, true),
Expand Down

0 comments on commit db17f87

Please sign in to comment.