Cfrgtkky

So, I'm working on a chat with file transfer funcionality. It's kind of close to be done but I'm struggling to make the transfer like I need to.
I need to achieve the following:

if file "A" is located ONLY in client "2", then client "2" should send 100% of the file to client "1"

if file "A" is located in client "2" and client "3" also has file "A", then client "2" should send 50% of the file to client "1" and client "3" should send the other 50%.

(if the file is located in 4 clients i should be 25% each....and so it goes...)

So, I managed to make the one-to-one (100%) transfer, but now I can't make the shared many-to-one transfer.
I was trying to adapt these methods I found on the internet (I've already made a few modifications to the methods) so I could use tha variable "pos" to control how many chunks would a client send, and then I would create a dinamic int variable to keep the quantity of clients I had to share the file with and use it to control the transfer.

private static void writeFile(File file, OutputStream outStream, long fileSize) {

    FileInputStream reader = null;

    try {

        reader = new FileInputStream(file);

        byte buffer = new byte[CHUNK_SIZE];

        int pos = 0;

        int bytesRead;

        while ((bytesRead = reader.read(buffer, 0, CHUNK_SIZE)) >= 0) {

            outStream.write(buffer, 0, bytesRead);

            outStream.flush();

            pos += bytesRead;

            System.out.println(pos + " bytes (" + bytesRead + " bytes read)");



        }

    } catch (IndexOutOfBoundsException e) {

        System.err.println("Error while reading file");

        e.printStackTrace();

    } catch (IOException e) {

        System.err.println("Error while writing " + file.toString() + " to output stream");

        e.printStackTrace();

    } finally {

        if (reader != null) {

            try {

                reader.close();

            } catch (IOException e) {

                e.printStackTrace();

            }

        }

    }

    }





private static void saveFile(File file, InputStream inStream, long fileSize) {

    FileOutputStream fileOut = null;

    try {

        fileOut = new FileOutputStream(file);

        byte buffer = new byte[CHUNK_SIZE];

        int bytesRead;

        int pos = 0;

        while ((bytesRead = inStream.read(buffer, 0, CHUNK_SIZE)) >= 0) {



            pos += bytesRead;

            System.out.println(pos + " bytes (" + bytesRead + " bytes read)");

            fileOut.write(buffer, 0, bytesRead);



            if (pos == fileSize) {

                break;

            }

        }

    } catch (IOException e) {

        e.printStackTrace();

    } finally {

        if (fileOut != null) {

            try {

                fileOut.close();

            } catch (IOException e) {

                e.printStackTrace();

            }

        }

    }

    System.out.println("Finished, filesize = " + file.length());

}

But that idea seems to only work for the first transfer. I changed the "while" loop in saveFile like this, so it would only save 50% of the file from the first client, and as expected I got half of the .png i was using to test.

while ((bytesRead = inStream.read(buffer, 0, CHUNK_SIZE)) >= 0) {

            pos += bytesRead;

            System.out.println(pos + " bytes (" + bytesRead + " bytes read)");

            fileOut.write(buffer, 0, bytesRead);



            if (pos >= fileSize/2) {

                break;

            }

        }

But I know I can't complete the .png! The second client can't send the the chuks where "(pos >= sizeFile/2)" and I get the following error when I try to do so:

java.net.ConnectException: Connection refused: connect

at java.net.DualStackPlainSocketImpl.connect0(Native Method)

at java.net.DualStackPlainSocketImpl.socketConnect(Unknown Source)

at java.net.AbstractPlainSocketImpl.doConnect(Unknown Source)

at java.net.AbstractPlainSocketImpl.connectToAddress(Unknown Source)

at java.net.AbstractPlainSocketImpl.connect(Unknown Source)

at java.net.PlainSocketImpl.connect(Unknown Source)

at java.net.SocksSocketImpl.connect(Unknown Source)

at java.net.Socket.connect(Unknown Source)

at java.net.Socket.connect(Unknown Source)

at java.net.Socket.<init>(Unknown Source)

at java.net.Socket.<init>(Unknown Source)

at tor.Client.run(Client.java:109)

Line 109 is:

Socket requester = new Socket("192.168.3.114", 2007);

Can anyone bring some light to me over this problem?