diff --git a/app/src/main/java/lightcontainer/domains/client/StoreProcessor.java b/app/src/main/java/lightcontainer/domains/client/StoreProcessor.java index 642cdd8..5af0c65 100644 --- a/app/src/main/java/lightcontainer/domains/client/StoreProcessor.java +++ b/app/src/main/java/lightcontainer/domains/client/StoreProcessor.java @@ -114,6 +114,7 @@ public class StoreProcessor extends Thread implements AutoCloseable { public void executeCommand(ProtocolWriter.ProtocolResult protocolResult) { synchronized (this) { this.protocolResult = protocolResult; + System.out.println("Request wake up"); this.notify(); } } @@ -125,7 +126,6 @@ public class StoreProcessor extends Thread implements AutoCloseable { synchronized (this) { this.protocolResult = null; fileFrontEnd.onStoreAvailable(this, responseCommand); - waitAction(); } } diff --git a/app/src/main/java/lightcontainer/repository/StoreProcessorRepository.java b/app/src/main/java/lightcontainer/repository/StoreProcessorRepository.java index fd6bd4d..174b0ae 100644 --- a/app/src/main/java/lightcontainer/repository/StoreProcessorRepository.java +++ b/app/src/main/java/lightcontainer/repository/StoreProcessorRepository.java @@ -74,6 +74,7 @@ public class StoreProcessorRepository implements AutoCloseable, MulticastSPR { @Override public void assignTask(String stor, Task task) { StoreProcessor handler = findSBE(task); + System.out.println("Find stor : " + handler); handler.executeCommand(task.getCommand()); }