Lines Matching defs:fragmentQueue
46 private BufferQueue fragmentQueue = new BufferQueue();
66 synchronized(fragmentQueue) {
69 fragmentQueue.notify();
78 synchronized (fragmentQueue) {
89 fragmentQueue.enqueue(bbwi);
91 fragmentQueue.notify();
103 synchronized (fragmentQueue) {
109 while (fragmentQueue.size() == 0) {
117 fragmentQueue.wait(FRAGMENT_TIMEOUT);
122 if (!interrupted && fragmentQueue.size() == 0) {
131 result = fragmentQueue.dequeue();
185 // release ByteBuffers on fragmentQueue
186 if (fragmentQueue != null)
188 synchronized (fragmentQueue)
204 while (fragmentQueue.size() != 0)
206 abbwi = fragmentQueue.dequeue();
216 sb.append("close() - fragmentQueue is ")
228 fragmentQueue = null;
340 synchronized(fragmentQueue) {
342 fragmentQueue.push((ByteBufferWithInfo)iter.next());