sdis1819-t4g03

package threads;

import java.io.IOException;

import java.util.concurrent.TimeUnit;

import server.Server;

public class ManagePutchunk implements Runnable {

        private byte[] message;

    private int time;

    private String key;

    private int replicationDegree;

    private int tries;

    public ManagePutchunk(byte[] message, int time, String fileID, int chunkNr, int replicationDegree) {

        this.message = message;

        this.time = time;

        this.key = fileID + '.' + chunkNr;

        this.replicationDegree = replicationDegree;

        this.tries = 1;

    }

    @Override

    public void run() {

        int occurrences = Server.getStorage().getStoredTimes().get(this.key);

        if (occurrences < replicationDegree) { 

            try {

                                Server.getmdb().sendMessage(message);

                        } catch (IOException e) {

                                e.printStackTrace();

                        }

            System.out.println("Sent PUTCHUNK try: " + tries);

            System.out.println(key);

            this.time = 2 * this.time;

            this.tries++;

            if (this.tries < 5)

                Server.getThreadLauncher().schedule(this, this.time, TimeUnit.SECONDS);

        }

    }

}