Lines Matching refs:m_queue
49 if(m_queue.IsFull()) in Push()
70 if(!m_queue.IsEmpty()) in Push()
79 ASSERT(swt.timeStamp >= m_queue.Back().timeStamp); in Push()
82 m_queue.PushBack(swt); in Push()
92 if(m_queue.IsEmpty()) in Front()
98 *pSeg = m_queue.Front().segment; in Front()
110 while(!m_queue.IsEmpty()) in Remove()
112 const Segment &seg = m_queue.Front().segment; in Remove()
117 m_queue.PopFront(); in Remove()
119 if(m_queue.IsEmpty()) in Remove()
137 if(m_queue.IsEmpty()) in IsResendRequired()
143 return m_queue.Front().IsTimeOut(); in IsResendRequired()
151 for(size_t i= 0; i<m_queue.Size(); ++i) in GetTotalDataSize()
153 ret += m_queue.At(i).segment.GetDataLength(); in GetTotalDataSize()
162 m_queue.Clear(); in Clear()
173 struct SegmentWithTime s = m_queue.Front(); in TryAgain()
174 m_queue.PopFront(); in TryAgain()
183 m_queue.PushBack(s); in TryAgain()
185 if(m_queue.Front().resendMark) in TryAgain()
189 m_queue.Front().resendMark = false; in TryAgain()
203 …LOG("Number of ResendQueue elements: %d, total data size is %d bytes.\n", m_queue.Size(), GetTotal… in PrintDebugInfo()
230 CU_ASSERT(r.m_queue.Size()==1); in Test()
232 CU_ASSERT(r.m_queue.Size()==1); // Should be no changes in Test()
235 CU_ASSERT(r.m_queue.Size()==1); // Should still be no changes in Test()
238 CU_ASSERT(r.m_queue.Size()==0); // Should be removed in Test()
242 CU_ASSERT(r.m_queue.Size()==2); in Test()
245 CU_ASSERT(r.m_queue.Size()==2); in Test()
248 CU_ASSERT(r.m_queue.Size()==2); in Test()
251 CU_ASSERT(r.m_queue.Size()==0); in Test()
258 CU_ASSERT(r.m_queue.Size()==1); in Test()
265 CU_ASSERT(r.m_queue.Size()==1); in Test()
271 CU_ASSERT(r.m_queue.Size()==3); in Test()
275 CU_ASSERT(r.m_queue.Size()==1); in Test()
281 CU_ASSERT(r.m_queue.Size()==0); in Test()
295 CU_ASSERT(r.m_queue.Size()==3); in Test()