Source

riak / src / riak_put_fsm.erl

Diff from to

File src/riak_put_fsm.erl

             case DW of
                 0 ->
                     send_key_update(RObj),
-                    gen_server:reply(Client,ok),
+                    gen_server2:reply(Client,ok),
                     riak_eventer:notify(riak_put_fsm, put_fsm_reply,
                                         {ReqID, ok}),
                     {stop,normal,StateData};
         false ->
             riak_eventer:notify(riak_put_fsm, put_fsm_reply,
                                 {ReqID, {error,too_many_fails,Replied}}),
-            gen_server:reply(Client,{error,too_many_fails}),
+            gen_server2:reply(Client,{error,too_many_fails}),
             {stop,normal,NewStateData}
     end;
 waiting_vnode_w(timeout, StateData=#state{client=Client,req_id=ReqID}) ->
     riak_eventer:notify(riak_put_fsm, put_fsm_reply,
                         {ReqID, {error,timeout}}),
-    gen_server:reply(Client,{error,timeout}),
+    gen_server2:reply(Client,{error,timeout}),
     {stop,normal,StateData}.
 
 waiting_vnode_dw({w, _Idx, ReqID},
             send_key_update(RObj),
             riak_eventer:notify(riak_put_fsm, put_fsm_reply,
                                 {ReqID, ok}),
-            gen_server:reply(Client,ok),
+            gen_server2:reply(Client,ok),
             {stop,normal,StateData};
         false ->
             NewStateData = StateData#state{replied_dw=Replied},
         false ->
             riak_eventer:notify(riak_put_fsm, put_fsm_reply,
                                 {ReqID, {error,too_many_fails,Replied}}),
-            gen_server:reply(Client,{error,too_many_fails}),
+            gen_server2:reply(Client,{error,too_many_fails}),
             {stop,normal,NewStateData}
     end;
 waiting_vnode_dw(timeout, StateData=#state{client=Client,req_id=ReqID}) ->
     riak_eventer:notify(riak_put_fsm, put_fsm_reply,
                         {ReqID, {error,timeout}}),
-    gen_server:reply(Client,{error,timeout}),
+    gen_server2:reply(Client,{error,timeout}),
     {stop,normal,StateData}.
 
 %% @private