sdis1819-t7g02

package protocols;

import java.util.concurrent.Callable;

import channels.MessageHeader;

import service.Cloud;

import service.Constants;

public class RestoreChunksProtocol implements Callable<Object>{

        Cloud cloud;

        MessageHeader message_header;

        public RestoreChunksProtocol(Cloud c, MessageHeader mh) 

        {        

                this.cloud = c;

                this.message_header = mh;

        }

        @Override

        public Object call() throws Exception {

                int numberOfTries = 0;

                int multiplier = 1;

                        while(numberOfTries < Constants.MAX_PUTCHUNK_MESSAGES) {

                                cloud.sendHeader(this.message_header);

//                                System.out.println("Trying " + multiplier + " seconds");

                                Thread.sleep(1000 * multiplier);

                                if(cloud.checkIfChunkWasRestored(this.message_header.getFileId(), this.message_header.getChunkNumber()))

                                {

                                        System.out.println(this.message_header.getChunkNumber() + " restored");

                                        return true;

                                }

                                multiplier *= 2;

                                numberOfTries++;

                        }

                System.out.println("ERROR: " + this.message_header.getChunkNumber() + " could not be restored!");

                return false;

        }

}