anchor.diff:      etorrent_peer_communication:complete_handshake_header(Socket,
   						 S#state.info_hash,
   						 S#state.local_peer_id),
  -    enable_socketorrent_messages(Socket),
  +    enable_socket_messages(Socket),
       {ok, SendPid} =
   	etorrent_t_peer_send:start_link(Socket,
   				     S#state.file_system_pid,
  
positive.code: 		{ok, NQ} ->
  		    {ok, S#state{request_queue = NQ}};
  		false ->
  		    % Bastard sent us something out of band, kill!
  		    error_logger:error_msg("Out of band request!~n"),
  		    stop
  	    end
      end.
  
  getorrent_requests(S) ->
      lists:flatten(lists:map(fun({Index, _, _}) ->
  					  io_lib:format("|~B|", [Index])
  				  end,
  				  S#state.piece_request)).
  
  getorrent_queues(S) ->
      lists:flatten(lists:map(
  		    fun({Index, Offset, Len}) ->
  			    io_lib:format("|~p|", [{Index, Offset, Len}])
  
negative.code: %% Description: Make the socket active and configure it to bittorrent
  %%   specifications.
  %%--------------------------------------------------------------------
  enable_socket_messages(Socket) ->
      inet:setopts(Socket, [binary, {active, true}, {packet, 4}]).
  
  %%--------------------------------------------------------------------
  %% Function: unqueue_all_pieces/1
  %% Description: Unqueue all queued pieces at the other end. We place
  %%   the earlier queued items at the end to compensate for quick
  %%   choke/unchoke problems and live data.
  %%--------------------------------------------------------------------
  unqueue_all_pieces(S) ->
      Requests = sets:to_list(S#state.remote_request_set),
      Q = S#state.request_queue,
      NQ = queue:join(Q, queue:from_list(Requests)),
      S#state{remote_request_set = sets:new(),
  	     request_queue = NQ}.
  
  