Commits

jus...@basho.com  committed fb804b2

remove dbg

  • Participants
  • Parent commits 146e373

Comments (0)

Files changed (3)

File apps/riak/src/riak_handoff_receiver.erl

 process_message(0, MsgData, State) ->
     <<Partition:160/integer>> = MsgData,
     {ok, VNode} = gen_server2:call(riak_vnode_master, {get_vnode, Partition}),  
-    io:format("got partition: ~p vnode=~p~n", [Partition, VNode]),
     State#state{partition=Partition, vnode=VNode};
 process_message(1, MsgData, State=#state{vnode=VNode}) ->
     % header of 1 is a riakobject_pb
     RO_PB = riakserver_pb:decode_riakobject_pb(zlib:unzip(MsgData)),
-    io:format("got a 1 ~p ~p~n",
-              [RO_PB#riakobject_pb.bucket,RO_PB#riakobject_pb.key]),
     BKey = {RO_PB#riakobject_pb.bucket,RO_PB#riakobject_pb.key},
     ok = gen_fsm:sync_send_all_state_event(VNode, {diffobj, {BKey, RO_PB#riakobject_pb.val}}, 60000),
     State;
 process_message(2, _MsgData, State=#state{sock=Socket}) ->
-    io:format("got a 2~n"),
     ok = gen_tcp:send(Socket, <<2:8,"sync">>),
-    io:format("sent sync~n"),
     State.
 
 handle_call(_Request, _From, State) -> {reply, ok, State}.

File apps/riak/src/riak_handoff_sender.erl

     M = <<2:8,"sync">>,
     ok = gen_tcp:send(Socket, M),
     inet:setopts(Socket, [{active, false}]),
-    io:format("flow control start~n"),
     {ok,[2|<<"sync">>]} = gen_tcp:recv(Socket, 0),
-    io:format("flow control end~n"),
     inet:setopts(Socket, [{active, once}]),
     visit_item({B,K}, V, {Socket, ParentPid, 0});
 visit_item({B,K}, V, {Socket, ParentPid, Acc}) ->

File apps/riak/src/riak_vnode.erl

 do_handoff(TargetNode, StateData=#state{idx=Idx, mod=Mod, modstate=ModState}) ->
     case Mod:is_empty(ModState) of
         true ->
-            io:format("dh delete and exit~n"),
             delete_and_exit(StateData);
         false ->
-            io:format("dh go~n"),
             riak_handoff_sender:start_link(TargetNode, Idx, all),
             {next_state,active,StateData#state{handoff_q=[]},?TIMEOUT}
     end.
 do_list_handoff(TargetNode, BKeyList, StateData=#state{idx=Idx}) ->
     case BKeyList of
         [] ->
-            io:format("dlh delete and exit~n"),
             delete_and_exit(StateData);
         _ ->
-            io:format("dlh go ~p~n",[BKeyList]),
             riak_handoff_sender:start_link(TargetNode, Idx, BKeyList),
             {next_state,active,StateData#state{handoff_q=[]},?TIMEOUT}
     end.
 %% @private
 delete_and_exit(StateData=#state{mod=Mod, modstate=ModState}) ->
     ok = Mod:drop(ModState),
-    io:format("deleted, exiting~n"),
     {stop, normal, StateData}.
 
 %%%%%%%%%% in active state, we process normal client requests