Commit bb66b3ae authored by Andre Freyssinet's avatar Andre Freyssinet

Minor changes.

parent 15d48888
......@@ -323,19 +323,20 @@ public class RequestMultiplexer {
}
/**
* Aborts all running requests.
* Used by:
* 1- close()
* 2- the connector layer (OutboundConnection.cleanup())
*/
public void cleanup() {
// Create first a copy of the current keys
// registered into the requests table.
// Create first a copy of the current keys registered into the requests table.
Integer[] requestIds;
synchronized (requestsTable) {
Set keySet = requestsTable.keySet();
requestIds = new Integer[keySet.size()];
keySet.toArray(requestIds);
}
for (int i = 0; i < requestIds.length; i++) {
ReplyListener rl = (ReplyListener) requestsTable.get(requestIds[i]);
// The listener may be null because the table
......
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