ClientRequestThread.java

import java.net.*;
import java.io.*;

/**
 * Hilo que atiene a un cliente
 */
public class ClientRequestThread extends Thread{
    private final byte DOWNLOAD_HEXCODE  = 0x0;
    private final byte CONSULT_HEXCODE   = 0x2;
    private final byte REACHABLE_HEXCODE = 0x3;
    private final int  NULL_HASHID       = 0xffffffff;
    private Socket client_socket;
    private P2pProtocolHandler p2pHandler;

    /**
     * 
     * @param cs Socket por donde se establece la comunicación con el cliente.
     * @param p2ph Manejador del protocolo p2p.
     */
    public ClientRequestThread(Socket cs, P2pProtocolHandler p2ph){
	client_socket = cs;
        p2pHandler = p2ph;
    }
    
    /**
     * Procesa la petición del cliente.
     */
    @Override
    public void run(){
	System.out.println("Servidor procesando request de un cliente");
        P2pRequest request = p2pHandler.getRequest(client_socket);
        
        switch(request.op_code){
            case DOWNLOAD_HEXCODE:
                p2pHandler.sendSong(request, client_socket);
                break;
            case CONSULT_HEXCODE:
                p2pHandler.makeConsult(request, client_socket);
                break;
            case REACHABLE_HEXCODE:
                p2pHandler.makeReachable(request, client_socket);
                break;
            case NULL_HASHID:
        }
        try{
	    client_socket.close();
	}
	catch(IOException e) {}

	System.out.println("Request procesado");
	System.out.println("");
	return;
    }
}