Untitled

package protocols;

import java.io.BufferedInputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.io.FileInputStream;
import java.io.IOException;

import utilities.Utils;
import rmi.Peer;

public class BackupProtocol implements Runnable{
	private Peer peer;
	private String pathName;
	private String fileId;
	private String version;
	private String address;
	private int port;
	private int replicationDegree;

	public BackupProtocol(Peer ProtocolPeer, String version, String pathName, int repDeg, String addr, int port){
		this.peer = ProtocolPeer;
		this.pathName = pathName;
		this.replicationDegree = repDeg;
		this.fileId = Utils.hash(pathName);
		this.version = version;
		this.address = addr;
		this.port = port;

		System.out.println("Backup protocol is being started!");
	}


	//PUTCHUNK <Version> <SenderId> <FileId> <ChunkNo> <ReplicationDeg> <CRLF><CRLF><Body>
	public String createHeader(int chunkNumber) {
		String header="";

		header = "PUTCHUNK "+ version + " " + peer.getId() + " " + fileId + " " + Integer.toString(chunkNumber)+ " " + replicationDegree + " " +"\r\n\r\n";

		return header;
	}


	@Override
	public void run(){


		File f = new File(pathName);

		int chunkNumber = 0;
		int chunkSize=64000;

		byte[] buffer = new byte[chunkSize];

		int counterNumber = 0;
			try {
				FileInputStream fis = new FileInputStream(f);
				BufferedInputStream bis= new BufferedInputStream(fis);

				int c;
				while ((c = bis.read(buffer)) > 0) {
					chunkNumber++;
					String header = createHeader(chunkNumber);

					byte[] headerBytes = header.getBytes();
					ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
					outputStream.write(headerBytes);
					outputStream.write(buffer,0,c);

					System.out.println("Msg Sent: "+ header);
					byte msg[] = outputStream.toByteArray();
					outputStream.close();

					//sending the message
					InetAddress address = InetAddress.getByName("224.0.0.1");
					DatagramSocket socket = new DatagramSocket();

					DatagramPacket packet = new DatagramPacket(msg, msg.length, address, port);
					socket.send(packet);

					long timeout = (long) (1000 * Math.pow(2, counterNumber));
					Thread.sleep(timeout);

					//verificacao do numero de counters;

				}
			}
			catch (IOException e1) {
				System.out.println("Error Reading The File.");
				e1.printStackTrace();
			} catch (InterruptedException e) {
				e.printStackTrace();
				return;
			}
	}
}