sdis1819-t7g05

import java.util.concurrent.ConcurrentHashMap;

/**

 * StoredTask

 */

public class StoredTask implements Runnable {

    private Peer peer;

    private String fileId;

    private int chunkNo;

    private MCListener mc;

    StoredTask(Peer peer, String fileId, String version, int chunkNo, MCListener mc) {

        this.peer = peer;

        this.fileId = fileId;

        this.chunkNo = chunkNo;

        this.mc = mc;

    }

    @Override

    public void run() {

        //Update the perceived replication degree for this chunk

        if (!this.peer.repDegMap.containsKey(this.fileId))

            this.peer.repDegMap.put(this.fileId, new ConcurrentHashMap<>());

        if(!this.peer.repDegMap.get(this.fileId).containsKey(this.chunkNo))

            this.peer.repDegMap.get(this.fileId).put(this.chunkNo, 0);

        this.peer.repDegMap.get(this.fileId).put(this.chunkNo, this.peer.repDegMap.get(this.fileId).get(this.chunkNo)+1);

        this.mc.print("RepDegMap("+chunkNo+") = "+this.peer.repDegMap.get(fileId).get(chunkNo));

        this.mc.print("STORED protocol finished");

    }

}