Compare commits
1 Commits
slicing
...
fixingConn
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
3a66b22c93 |
@@ -57,7 +57,7 @@ class Main
|
|||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
private static ArrayList<String> prepareArray(BufferedImage image, int xOffset, int yOffset) {
|
private static String[] prepareArray(BufferedImage image, int xOffset, int yOffset) {
|
||||||
|
|
||||||
int width = image.getWidth();
|
int width = image.getWidth();
|
||||||
int height = image.getHeight();
|
int height = image.getHeight();
|
||||||
@@ -79,26 +79,13 @@ class Main
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
/*String[] payloadArray = new String[pixelArray.size()];
|
String[] payloadArray = new String[pixelArray.size()];
|
||||||
for(int i = 0; i < payloadArray.length; i++)
|
for(int i = 0; i < payloadArray.length; i++)
|
||||||
{
|
{
|
||||||
payloadArray[i] = pixelArray.get(i);
|
payloadArray[i] = pixelArray.get(i);
|
||||||
}
|
}
|
||||||
|
|
||||||
return payloadArray;*/
|
return payloadArray;
|
||||||
return pixelArray;
|
|
||||||
}
|
|
||||||
|
|
||||||
public static String[] prepareThreadArray(ArrayList<String> fullArray, int threadNumber, int threadCount)
|
|
||||||
{
|
|
||||||
String[] threadArray = new String[fullArray.size()/threadCount];
|
|
||||||
int count = 0;
|
|
||||||
for(int i = (threadNumber*fullArray.size())/threadCount; i < ((threadNumber+1)*fullArray.size())/threadCount; i++)
|
|
||||||
{
|
|
||||||
threadArray[count] = fullArray.get(i);
|
|
||||||
count++;
|
|
||||||
}
|
|
||||||
return threadArray;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
//Syntax blabla.jar x y Hostname Port Image.png
|
//Syntax blabla.jar x y Hostname Port Image.png
|
||||||
@@ -107,23 +94,41 @@ class Main
|
|||||||
final String HOSTNAME = args[2];
|
final String HOSTNAME = args[2];
|
||||||
final int xOffset = Integer.parseInt(args[0]);
|
final int xOffset = Integer.parseInt(args[0]);
|
||||||
final int yOffset = Integer.parseInt(args[1]);
|
final int yOffset = Integer.parseInt(args[1]);
|
||||||
int threadCount = Integer.parseInt(args[4]);
|
final String imageName = args[4];
|
||||||
final String imageName = args[5];
|
|
||||||
|
|
||||||
// Read the PNG file
|
// Read the PNG file
|
||||||
BufferedImage image = processImage(imageName);
|
BufferedImage image = processImage(imageName);
|
||||||
ArrayList<String> fullArray = prepareArray(image, xOffset, yOffset);
|
String[] pixelArray = prepareArray(image, xOffset, yOffset);
|
||||||
ArrayList<Worker> workerList = new ArrayList<>();
|
|
||||||
|
|
||||||
for(int i = 0; i < threadCount; i++)
|
Worker worker0 = new Worker(HOSTNAME, PORT, pixelArray);
|
||||||
{
|
Worker worker1 = new Worker(HOSTNAME, PORT, pixelArray);
|
||||||
String[] threadArray = prepareThreadArray(fullArray, i, threadCount);
|
Worker worker2 = new Worker(HOSTNAME, PORT, pixelArray);
|
||||||
workerList.add(new Worker(HOSTNAME, PORT, threadArray));
|
Worker worker3 = new Worker(HOSTNAME, PORT, pixelArray);
|
||||||
}
|
Worker worker4 = new Worker(HOSTNAME, PORT, pixelArray);
|
||||||
|
Worker worker5 = new Worker(HOSTNAME, PORT, pixelArray);
|
||||||
|
Worker worker6 = new Worker(HOSTNAME, PORT, pixelArray);
|
||||||
|
Worker worker7 = new Worker(HOSTNAME, PORT, pixelArray);
|
||||||
|
|
||||||
for(int i = 0; i < threadCount; i++)
|
|
||||||
{
|
worker0.start();
|
||||||
workerList.get(i).start();
|
worker1.start();
|
||||||
|
worker2.start();
|
||||||
|
worker3.start();
|
||||||
|
worker4.start();
|
||||||
|
worker5.start();
|
||||||
|
worker6.start();
|
||||||
|
worker7.start();
|
||||||
|
|
||||||
|
/*try {
|
||||||
|
Socket socket = new Socket(HOSTNAME, PORT);
|
||||||
|
while(true) {
|
||||||
|
for(int i = 0; i < pixelArray.length; i++) {
|
||||||
|
byte[] payload = pixelArray[i].getBytes();
|
||||||
|
socket.getOutputStream().write(payload);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
} catch (IOException e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
}*/
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user