Darkress/PixelFloodClient
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

some try catching #1

Merged
Darkress merged 1 commits from fixingConnectionResetByPeer into main 2023-06-10 16:44:43 +02:00
Conversation 0 Commits 1 Files Changed 1 +15 -5
1 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
de/darkress/pixelfood/Main.java
View File

@@ -9,9 +9,13 @@ import java.util.ArrayList;
class Worker extends Thread { class Worker extends Thread {
String HOSTNAME;
int PORT;
Socket socket; Socket socket;
String[] pixelArray; String[] pixelArray;
public Worker(String HOSTNAME, int PORT, String[] pixelArray) { public Worker(String HOSTNAME, int PORT, String[] pixelArray) {
this.HOSTNAME = HOSTNAME;
this.PORT = PORT;
try { try {
this.socket = new Socket(HOSTNAME, PORT); this.socket = new Socket(HOSTNAME, PORT);
} catch (IOException e) { } catch (IOException e) {
@@ -20,15 +24,21 @@ class Worker extends Thread {
this.pixelArray = pixelArray; this.pixelArray = pixelArray;
} }
@Override
public void run() { public void run() {
while(true) { while(true) {
for(int i = 0; i < pixelArray.length; i++) { try {
byte[] payload = pixelArray[i].getBytes(); for(int i = 0; i < pixelArray.length; i++) {
try { byte[] payload = pixelArray[i].getBytes();
socket.getOutputStream().write(payload); socket.getOutputStream().write(payload);
} catch (IOException e) {
throw new RuntimeException(e);
} }
} catch (IOException e) {
try {
this.socket = new Socket(HOSTNAME, PORT);
} catch (IOException i) {
i.printStackTrace();
}
System.out.println(this.getId() + "just dies. Trying again...");
} }
} }
} }