diff options
Diffstat (limited to 'src/main/java/derms/frontend')
| -rw-r--r-- | src/main/java/derms/frontend/DERMSServerImpl.java | 6 | ||||
| -rw-r--r-- | src/main/java/derms/frontend/FE.java | 1 |
2 files changed, 6 insertions, 1 deletions
diff --git a/src/main/java/derms/frontend/DERMSServerImpl.java b/src/main/java/derms/frontend/DERMSServerImpl.java index 663bc47..fda6717 100644 --- a/src/main/java/derms/frontend/DERMSServerImpl.java +++ b/src/main/java/derms/frontend/DERMSServerImpl.java @@ -171,7 +171,11 @@ public class DERMSServerImpl implements DERMSInterface { Response res3 = null; Response res4 = null; for (Response response :responses) { - if (response.getSequenceID() == request.getSequenceNumber()) { + System.out.println("Response: " + response.getResponse()); + System.out.println("Response ID: " + response.getRequestId()); + System.out.println("Request ID: " + request.getId()); + System.out.println("Response RM number: " + response.getRmNumber()); + if (response.getRequestId() == request.getId()) { switch (response.getRmNumber()) { case 1: res1 = response; diff --git a/src/main/java/derms/frontend/FE.java b/src/main/java/derms/frontend/FE.java index 2665116..8d6fc59 100644 --- a/src/main/java/derms/frontend/FE.java +++ b/src/main/java/derms/frontend/FE.java @@ -100,6 +100,7 @@ public class FE { private static int sendUnicastToSequencer(Request requestFromClient) { int sequenceID = sequenceIDGenerator.incrementAndGet(); + requestFromClient.setId(sequenceID); try { sequencerSock.send(requestFromClient); } catch (IOException e) { |