sdis1819-t7g05

import java.io.IOException;

import java.net.DatagramSocket;

import java.util.concurrent.ConcurrentHashMap;

/**

 * StateTask

 */

public class StateTask implements Runnable {

    private Peer peer;

    StateTask(Peer peer) {

        peer.getMCaddress();

        peer.getMCport();

        this.peer = peer;

    }

    @Override

    public void run() {

        try {

            DatagramSocket socket = new DatagramSocket();

            System.out.println("FILES:");

            for (String i : this.peer.fileMap.keySet()) {

                System.out.println("Pathname: " + i);

                System.out.println("Backup service id: " + this.peer.fileMap.get(i).getFileId());

                System.out.println("Desired replication degree: " + this.peer.fileMap.get(i).getDesiredReplicationDegree());

                System.out.println();

                System.out.println("Chunks: ");

                System.out.println();

                ConcurrentHashMap<Integer, Chunk> currentChunkMap = this.peer.fileMap.get(i).getChunksMap();

                for (Integer j : currentChunkMap.keySet()) {

                    System.out.println("Id: " + j);

                    System.out.println("Perceived replication degree: " + this.peer.repDegMap.get(this.peer.fileMap.get(i).getFileId()).get(j));

                    System.out.println();

                }

                System.out.println();

              }

            System.out.println();

            System.out.println();

            System.out.println("STORED CHUNKS: ");

            for (String k : this.peer.chunksMap.keySet()){

                System.out.println("FileId: " + k);

                for(Integer j: this.peer.chunksMap.get(k).getChunksMap().keySet()) {

                        System.out.println("Id: " + j);

                        System.out.println("Size: " + this.peer.chunksMap.get(k).getChunksMap().get(j).getSize());

                        if(this.peer.repDegMap.containsKey(k))

                                System.out.println("Perceived replication degree: " + this.peer.repDegMap.get(k).get(j));

                        else

                                System.out.println("Perceived replication degree: Unknown");

                               System.out.println();

                }

            System.out.println();

            }

                System.out.println("PEER " + this.peer.getSenderId() + "'S STORAGE CAPACITY: " + this.peer.getStorageCapacity());        

            System.out.println("PEER " + this.peer.getSenderId() + "'S STORAGE USED: " + this.peer.getStorageUsed());

            System.out.println();

            socket.close();

            this.peer.print("STATE protocol finished");

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

}