Lines Matching refs:m_inputQueues
34 m_inputQueues.reserve(m_threshold);
70 m_inputQueues.push_back(MessageQueue());
93 lword size = m_inputQueues[i].MaxRetrievable();
94 m_inputQueues[i].Put(inString, length);
104 m_inputQueues[i].MessageEnd();
105 if (m_inputQueues[i].NumberOfMessages() == 1)
112 m_channelsReady += m_inputQueues[i].AnyRetrievable();
123 return i < m_threshold ? m_inputQueues[i].MaxRetrievable() : 0;
169 MessageQueue &queue = m_inputQueues[i];
207 inputQueues.swap(m_inputQueues);