sdis1819-t4g11

package peer.protocols.backup;

import java.io.IOException;

import chunk.Chunk;

import disk.ChunkManagement;

import message.Message;

import peer.Peer;

/**

 * Store

 */

public class Store implements Runnable {

	private Peer peer;

	private Chunk chunk;

	public Store(Peer peer, Chunk chunk) {

		this.peer = peer;

		this.chunk = chunk;

	}

	public void sendStored() {

		Message storedMessage = Message.parseStoredMessage(chunk, peer);

		try {

			peer.sendToMc(storedMessage);

		} catch (IOException e) {

			e.printStackTrace();

		}

	}

	public boolean storeChunk() {

		try {

			Thread.sleep((long) (Math.random() * 400 + 1));

		} catch (InterruptedException e) {

			e.printStackTrace();

		}

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

			if (peer.getDisk().storeChunk(chunk)) {

				sendStored();

				return true;

			}

		}

		return false;

	}

	@Override

	public void run() {

		storeChunk();

	}