sdis1819-t7g02

package protocols;

import java.util.Random;

import channels.Message;

import channels.MessageHeader;

import service.Chunk;

import service.Cloud;

import service.Constants;

public class SendChunkMessageProtocol extends Thread {

        Cloud father;

        Chunk toSend;

        public SendChunkMessageProtocol (Chunk c, Cloud f) {

                father = f;

                toSend = c;

        }

        @Override

        public void run() {

                String[] headerElements = new String[Constants.CHUNK_N_ARGS];

                Message m;

                MessageHeader h;

                headerElements[0] = Constants.CHUNK;

                    headerElements[1] = father.getProtocolVersion();

                    headerElements[2] = Integer.toString(father.getID());

                    headerElements[3] = toSend.getChunkId();

                    headerElements[4] = toSend.getChunkNumber();

                    try {

                            h = new MessageHeader(headerElements.clone());

                            m = new Message(h, toSend.getChunkContent());

                            waitRandomTime();

                        father.restoreCh.sendMessage(m);

                } catch (InterruptedException e) {

                        System.out.println("Error in send message protocol -> " + e.getMessage());

                }

        }

        public void waitRandomTime() throws InterruptedException {

                Random r = new Random();

                int low = 1;

                int high = 401;

                int result = r.nextInt(high-low) + low;

                Thread.sleep(result);

        }

}