Code Review
/
openflowjava.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
| inline |
side by side
BUG-3219: clear queue array before stashing
[openflowjava.git]
/
openflow-protocol-impl
/
src
/
main
/
java
/
org
/
opendaylight
/
openflowjava
/
protocol
/
impl
/
core
/
connection
/
OutboundQueueManager.java
diff --git
a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/OutboundQueueManager.java
b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/OutboundQueueManager.java
index 609e23c16acf52616d113eda51dbc6423f185970..f2a4b0e551b9e84162aad8118a2651e11984a5d5 100644
(file)
--- a/
openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/OutboundQueueManager.java
+++ b/
openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/OutboundQueueManager.java
@@
-109,6
+109,7
@@
final class OutboundQueueManager<T extends OutboundQueueHandler> extends Channel
private void retireQueue(final OutboundQueueImpl queue) {
if (queueCache.offer(queue)) {
+ queue.retire();
LOG.trace("Saving queue {} for later reuse", queue);
} else {
LOG.trace("Queue {} thrown away", queue);