Lines Matching refs:m_queue

51     if(m_queue.IsFull())  in Push()
72 if(!m_queue.IsEmpty()) in Push()
81 ASSERT(swt.timeStamp >= m_queue.Back().timeStamp); in Push()
84 m_queue.PushBack(swt); in Push()
94 if(m_queue.IsEmpty()) in Front()
100 *pSeg = m_queue.Front().segment; in Front()
112 while(!m_queue.IsEmpty()) in Remove()
114 const Segment &seg = m_queue.Front().segment; in Remove()
119 m_queue.PopFront(); in Remove()
121 if(m_queue.IsEmpty()) in Remove()
139 if(m_queue.IsEmpty()) in IsResendRequired()
145 return m_queue.Front().IsTimeOut(); in IsResendRequired()
153 for(size_t i= 0; i<m_queue.Size(); ++i) in GetTotalDataSize()
155 ret += m_queue.At(i).segment.GetDataLength(); in GetTotalDataSize()
164 m_queue.Clear(); in Clear()
175 struct SegmentWithTime s = m_queue.Front(); in TryAgain()
176 m_queue.PopFront(); in TryAgain()
185 m_queue.PushBack(s); in TryAgain()
187 if(m_queue.Front().resendMark) in TryAgain()
191 m_queue.Front().resendMark = false; in TryAgain()
205 …LOG("Number of ResendQueue elements: %d, total data size is %d bytes.\n", m_queue.Size(), GetTotal… in PrintDebugInfo()
232 CU_ASSERT(r.m_queue.Size()==1); in Test()
234 CU_ASSERT(r.m_queue.Size()==1); // 変化はないはず in Test()
237 CU_ASSERT(r.m_queue.Size()==1); // まだ変化はないはず in Test()
240 CU_ASSERT(r.m_queue.Size()==0); // 取り除かれるはず in Test()
244 CU_ASSERT(r.m_queue.Size()==2); in Test()
247 CU_ASSERT(r.m_queue.Size()==2); in Test()
250 CU_ASSERT(r.m_queue.Size()==2); in Test()
253 CU_ASSERT(r.m_queue.Size()==0); in Test()
260 CU_ASSERT(r.m_queue.Size()==1); in Test()
267 CU_ASSERT(r.m_queue.Size()==1); in Test()
273 CU_ASSERT(r.m_queue.Size()==3); in Test()
277 CU_ASSERT(r.m_queue.Size()==1); in Test()
283 CU_ASSERT(r.m_queue.Size()==0); in Test()
297 CU_ASSERT(r.m_queue.Size()==3); in Test()