sdis1819-t7g05

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.util.Random;

/**

 * RemovedTask

 */

public class RemovedTask implements Runnable {

    private static final String CRLF = Integer.toHexString(0xD) + Integer.toHexString(0xA);

    private Peer peer;

    private String fileId;

    private int chunkNo;

    private MCListener mc;

    private String version;

    // REMOVED <Version> <SenderId> <FileId> <ChunkNo> <CRLF><CRLF>

    RemovedTask(Peer peer, String[] args, MCListener mc) {

        this.peer = peer;

        this.fileId = args[3];

        this.version = args[1];

        this.chunkNo = Integer.parseInt(args[4]);

        this.mc = mc;

        this.mc.print("starting REMOVED protocol: [fileId] " + fileId + "[chunkNo] " + chunkNo);

    }

    @Override

    public void run() {

        this.peer.repDegMap.get(this.fileId).put(this.chunkNo, this.peer.repDegMap.get(this.fileId).get(this.chunkNo)-1);

        try{

        if(this.peer.repDegMap.get(this.fileId).get(chunkNo) < this.peer.chunksMap.get(fileId).getDesiredReplicationDegree()){

            Random random = new Random();

            //Random delay between [0-400] ms to avoid overlapping messages

            Thread.sleep(random.nextInt(401));

            if(this.peer.repDegMap.get(this.fileId).get(chunkNo) >= this.peer.chunksMap.get(fileId).getDesiredReplicationDegree()){

                return; //já outro peer tem o chunk

            }

            byte[] chunk = this.peer.chunksMap.get(fileId).getChunksMap().get(chunkNo).getData();

            String message = "PUTCHUNK " + version + " " + peer.getSenderId() + " " + fileId + " " + chunkNo + " "

                    + this.peer.chunksMap.get(fileId).getDesiredReplicationDegree() + " " + CRLF + CRLF;

            byte[] packetData = new byte[message.getBytes().length + chunk.length];

            System.arraycopy(message.getBytes(), 0, packetData, 0, message.getBytes().length);

            System.arraycopy(chunk, 0, packetData, message.getBytes().length, chunk.length);

            DatagramSocket socket = new DatagramSocket();

            DatagramPacket packet = new DatagramPacket(packetData, packetData.length, this.peer.getMDBaddress(), this.peer.getMDBport());

            int interval = 1000;

            while (interval <= 31000) { //31 = 1+2+4+8+16

                this.peer.print("sending PUTCHUNK message");

                socket.send(packet);

                Thread.sleep(interval);

                if (this.peer.repDegMap.containsKey(fileId) && this.peer.repDegMap.get(fileId).get(chunkNo) >= this.peer.chunksMap.get(fileId).getDesiredReplicationDegree())

                    break;

                interval *= 2;

            }

            socket.close();

        }

        this.mc.print("REMOVED protocol finished");

    }

    catch (InterruptedException | IOException e)

    {

        e.printStackTrace();

    }

    }    

}