Commit f2cd6735 authored by Alex Wenckus's avatar Alex Wenckus Committed by alex

Removed some last request id setting.

git-svn-id: http://svn.igniterealtime.org/svn/repos/wildfire/trunk@7136 b35dd754-fafc-0310-a699-88a17e54d16e
parent 99399789
...@@ -330,9 +330,6 @@ public class HttpSession extends ClientSession { ...@@ -330,9 +330,6 @@ public class HttpSession extends ClientSession {
public String getResponse(long requestID) throws HttpBindException { public String getResponse(long requestID) throws HttpBindException {
for (HttpConnection connection : connectionQueue) { for (HttpConnection connection : connectionQueue) {
if (connection.getRequestId() == requestID) { if (connection.getRequestId() == requestID) {
if (requestID > lastRequestID + 1) {
throw new HttpBindException("Invalid RID error.", true, 404);
}
if (requestID > lastRequestID) { if (requestID > lastRequestID) {
lastRequestID = connection.getRequestId(); lastRequestID = connection.getRequestId();
} }
...@@ -438,7 +435,6 @@ public class HttpSession extends ClientSession { ...@@ -438,7 +435,6 @@ public class HttpSession extends ClientSession {
== lastRequestID + 1)) { == lastRequestID + 1)) {
try { try {
deliver(connection, pendingElements); deliver(connection, pendingElements);
lastRequestID = connection.getRequestId();
pendingElements.clear(); pendingElements.clear();
} }
catch (HttpConnectionClosedException he) { catch (HttpConnectionClosedException he) {
...@@ -508,7 +504,6 @@ public class HttpSession extends ClientSession { ...@@ -508,7 +504,6 @@ public class HttpSession extends ClientSession {
if (connection.getRequestId() <= lastRequestID + 1) { if (connection.getRequestId() <= lastRequestID + 1) {
deliver(connection, deliverable); deliver(connection, deliverable);
delivered = true; delivered = true;
lastRequestID = connection.getRequestId();
break; break;
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment