Add file to checkout

vlasival · Apr 1, 2024 · c46ffda · c46ffda
1 parent b3828b1
commit c46ffda
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/task_2_1_2/app/src/main/java/org/prime/Master.java b/task_2_1_2/app/src/main/java/org/prime/Master.java
@@ -24,7 +24,7 @@ public List<InetAddress> getActiveDevices() {
         return activeDevices;
     }
 
-    public void findAndTestNodes() throws IOException {
+    public void findActiveNodes() throws IOException {
         Broadcaster broadcaster = new Broadcaster(BROADCAST_PORT);
         broadcaster.doBroadcast();
 
@@ -79,7 +79,7 @@ public static void main(String[] args) {
         Master master = new Master(8888);
         boolean result = false;
         try {
-            master.findAndTestNodes();
+            master.findActiveNodes();
             result = master.checkPrime(numbers);
         } catch (IOException e) {
             e.printStackTrace();

diff --git a/task_2_1_2/app/src/main/java/org/prime/NodeTester.java b/task_2_1_2/app/src/main/java/org/prime/NodeTester.java
@@ -20,13 +20,14 @@ public int sendTestMessageToNode(InetAddress address) {
         int time = -1;
         System.out.println("Starting test worker " + address);
         try (Socket socket = new Socket(address, port);
-             ObjectOutputStream outputStream = new ObjectOutputStream(socket.getOutputStream())) {
+             ObjectOutputStream outputStream = new ObjectOutputStream(socket.getOutputStream());
+             DataInputStream inputStream = new DataInputStream(socket.getInputStream())) {
+
             outputStream.writeObject(message);
             System.out.println("Message sent to node: " + address);
 
-            // socket.setSoTimeout(timeout);
+            socket.setSoTimeout(timeout);
 
-            DataInputStream inputStream = new DataInputStream(socket.getInputStream());
             time = (int) inputStream.readLong();
             System.out.println("Response from node: " + address + ", execution time: " + time + " ms");
         } catch (IOException e) {