From 4a97a0c31363b293cb69ddacb3b5441d5ebf0297 Mon Sep 17 00:00:00 2001
From: meiyangbigswitch <mei.yang@bigswitch.com>
Date: Mon, 10 Jun 2013 13:08:17 -0700
Subject: [PATCH] add debug info
---
.../flowcache/PriorityPendingQueue.java | 15 +++++++--------
1 file changed, 7 insertions(+), 8 deletions(-)
diff --git a/src/main/java/net/floodlightcontroller/flowcache/PriorityPendingQueue.java b/src/main/java/net/floodlightcontroller/flowcache/PriorityPendingQueue.java
index c56510c24..5f90a24e5 100644
--- a/src/main/java/net/floodlightcontroller/flowcache/PriorityPendingQueue.java
+++ b/src/main/java/net/floodlightcontroller/flowcache/PriorityPendingQueue.java
@@ -1,11 +1,10 @@
package net.floodlightcontroller.flowcache;
-import java.util.concurrent.ArrayBlockingQueue;
+import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;
-
/**
* PriorityPendingQueue class - This class is a variant implementation for PriorityBlockingQueue
* PriorityBlockingQueue implementation has two problems:
@@ -25,9 +24,9 @@ import java.util.concurrent.locks.ReentrantLock;
*
*/
public class PriorityPendingQueue<E> {
- private ArrayBlockingQueue<E> highPriorityQueue;
- private ArrayBlockingQueue<E> mediumPriorityQueue;
- private ArrayBlockingQueue<E> lowPriorityQueue;
+ private LinkedBlockingQueue<E> highPriorityQueue;
+ private LinkedBlockingQueue<E> mediumPriorityQueue;
+ private LinkedBlockingQueue<E> lowPriorityQueue;
private final AtomicInteger count = new AtomicInteger(0);
private final ReentrantLock takeLock = new ReentrantLock();
private final Condition notEmpty = takeLock.newCondition();
@@ -40,9 +39,9 @@ public class PriorityPendingQueue<E> {
LOW,
}
public PriorityPendingQueue() {
- highPriorityQueue= new ArrayBlockingQueue<E>(1000);
- mediumPriorityQueue= new ArrayBlockingQueue<E>(1000);
- lowPriorityQueue= new ArrayBlockingQueue<E>(5000);
+ highPriorityQueue= new LinkedBlockingQueue<E>();
+ mediumPriorityQueue= new LinkedBlockingQueue<E>();
+ lowPriorityQueue= new LinkedBlockingQueue<E>();
capacity= Integer.MAX_VALUE;
}
--
GitLab