sdis1819-t7g02

package protocols;

import java.util.Random;

import channels.Message;

import service.Cloud;

import service.Constants;

public class recoverChunkRepDegreeProtocol extends Thread {

        Cloud father;

        Message toSend;

        String fileId;

        String chunkNo;

        public recoverChunkRepDegreeProtocol(Cloud c, Message m) {

                father = c;

                toSend = m;

                fileId = m.getHeader().getFileId();

                chunkNo = m.getHeader().getChunkNumber();

        }

        @Override

        public void run () {

                int numberOfTries = 0, multiplier = 1;

                try {

                        waitRandomTime();

                        while(numberOfTries < Constants.MAX_PUTCHUNK_MESSAGES) {

                                father.sendBackupMessage(toSend);

                                Thread.sleep(1000 * multiplier);

                                if(father.getChunkCurrentRepDegree(fileId, chunkNo) >= Integer.parseInt(toSend.getHeader().getDegree())) {

                                        System.out.println("replication degree for " + chunkNo + " restored.");

                                        return;

                                }

                                multiplier *= 2;

                                numberOfTries++;

                        }                        

                }

                catch(InterruptedException e) {

                        System.out.println(e.getMessage());

                        return;

                }

        }

        public void waitRandomTime() throws InterruptedException {

                Random r = new Random();

                int low = 1;

                int high = 401;

                int result = r.nextInt(high-low) + low;

                Thread.sleep(result);

        }

}