Details
-
Bug
-
Status: Resolved
-
Trivial
-
Resolution: Not A Bug
-
None
-
None
Description
The current implementation only checks that one queue is empty and not all queues are empty.
boolean haveDelivered() { for (BlockingQueue<ByteBuffer> queue : queueSendMap.values()) { final int queueSize = queue.size(); LOG.debug("Queue size: {}", queueSize); if (queueSize == 0) { return true; } } return false; }
Perhaps it could be:
boolean haveDelivered() { for (BlockingQueue<ByteBuffer> queue : queueSendMap.values()) { final int queueSize = queue.size(); LOG.debug("Queue size: {}", queueSize); if (queueSize != 0) { return false; } } return true; }
Attachments
Issue Links
- links to