sdis1819-t7g02

package protocols;

import java.util.concurrent.Callable;

import channels.Message;

import service.Chunk;

import service.Cloud;

import service.Constants;

public class BackupChunkProtocol implements Callable<Object> {

        Cloud storage;

        Chunk objective;

        Message builtChunkMessage;

        int repDegree;

        public BackupChunkProtocol(Cloud c, Chunk chunksToBeStored, Message m, int replication_degree) {

                storage = c;

                objective = chunksToBeStored;

                repDegree = replication_degree;

                builtChunkMessage = m;

        }

        @Override

        public Object call() throws Exception {

                int numberOfTries = 0;

                int multiplier = 1;

                if(storage.insertAwaitingStoreFile(builtChunkMessage.getHeader())) {

                        while(numberOfTries < Constants.MAX_PUTCHUNK_MESSAGES) {

                                storage.sendBackupMessage(builtChunkMessage);

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

                                Thread.sleep(1000 * multiplier);

                                if(storage.wasTheRepDegreeMatched(objective)) {

                                        storage.addChunk(objective);

                                        System.out.println(objective.getChunkNumber() + " replication degree matched!");

                                        return true;

                                }

                                multiplier *= 2;

                                numberOfTries++;

                        }

                }

                System.out.println("ERROR: " + objective.getChunkId() + " replication degree not matched!");

                return false;

        }

}