sdis1819-t4g11

package peer.protocols.backup;

import java.io.IOException;

import chunk.Chunk;

import disk.ChunkManagement;

import message.Message;

import peer.Peer;

/**

 * BackupChunk

 */

public class BackupChunk implements Runnable {

	public static final int backupTries = 10;

	private Chunk chunk;

	private Peer peer;

	public BackupChunk(Peer peer, Chunk chunk) {

		this.chunk = chunk;

		this.peer = peer;

	}

	public void sendPutChunk() {

		Message message = Message.parsePutChunkMessage(chunk, peer);

		try {

			peer.sendToMdb(message);

		} catch (IOException e) {

			e.printStackTrace();

		}

	}

	public boolean backupChunk() {

		sendPutChunk();

		try {

			Thread.sleep(400);

		} catch (InterruptedException e) {

			e.printStackTrace();

		}

		if (ChunkManagement.getInstance().getStores(chunk.getFileID(), chunk.getChunkNo()) >= chunk.getRepDegree()) {

			return true;

		}

		return false;

	}

	@Override

	public void run() {

		try {

			Thread.sleep(400 * chunk.getChunkNo());

		} catch (InterruptedException e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		}

		boolean done = false;

		int tries = 0;

		while(!done) {

			done = backupChunk();

			if (!done) {

				tries++;

				if (tries > backupTries) {

					break;

				}

			}

		}

	}