| | |
| | | import java.util.Collection; |
| | | import java.util.Iterator; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.concurrent.ConcurrentHashMap; |
| | | import java.util.concurrent.atomic.AtomicLong; |
| | | import java.util.concurrent.atomic.AtomicReference; |
| | |
| | | { |
| | | try |
| | | { |
| | | for (int msgID : operationsInProgress.keySet()) |
| | | for (Map.Entry<Integer, Operation> entry : operationsInProgress.entrySet()) |
| | | { |
| | | int msgID = entry.getKey(); |
| | | if (msgID == messageID) |
| | | { |
| | | continue; |
| | | } |
| | | |
| | | Operation o = operationsInProgress.get(msgID); |
| | | Operation o = entry.getValue(); |
| | | if (o != null) |
| | | { |
| | | try |