Searched refs:queuedBuffers (Results 1 – 11 of 11) sorted by relevance
40 if (queuedBuffers.size() > 0) in ~NetworkSimulator()41 …Simulator: Leaked %d buffers with improper NetworkSimulator teardown!", (int)queuedBuffers.size()); in ~NetworkSimulator()63 for(size_t i = 0; i < queuedBuffers.size(); ++i) in Free()64 owner->GetSocket()->AbortSend(queuedBuffers[i].buffer); in Free()65 queuedBuffers.clear(); in Free()94 queuedBuffers.push_back(b); in SubmitSendBuffer()105 queuedBuffers.push_back(b); in SubmitSendBuffer()110 for(size_t i = 0; i < queuedBuffers.size(); ++i) in Process()111 if (queuedBuffers[i].timeUntilTransfer.Test()) in Process()114 owner->GetSocket()->EndSend(queuedBuffers[i].buffer); in Process()[all …]
203 std::swap(this->queuedBuffers, remove); in ClearBufferQueue()223 BufferList::iterator it = this->queuedBuffers.begin(); in OnBufferWrittenToOutput()224 for (; it != this->queuedBuffers.end(); it++) { in OnBufferWrittenToOutput()227 this->queuedBuffers.erase(it); in OnBufferWrittenToOutput()277 if (!this->queuedBuffers.empty()) { in Play()288 auto it = this->queuedBuffers.begin(); in Play()289 while (it != this->queuedBuffers.end()) { in Play()315 this->queuedBuffers.push_back(waveBuffer); in Play()
108 BufferList queuedBuffers; variable
200 std::array<bool, kBuffersFullCount> queuedBuffers = { { false } }; member718 _data->queuedBuffers[i] = false; in clearProcessedBuffer()728 ranges::fill(_data->queuedBuffers, false); in unqueueAllBuffers()826 const auto wereQueued = _data->queuedBuffers; in processPlayoutData()840 const auto i = ranges::find(_data->queuedBuffers, false); in processPlayoutData()841 Assert(i != end(_data->queuedBuffers)); in processPlayoutData()842 const auto index = int(i - begin(_data->queuedBuffers)); in processPlayoutData()860 _data->queuedBuffers[index] = true; in processPlayoutData()879 if (!wereQueued[i] && _data->queuedBuffers[i]) { in processPlayoutData()
324 int queuedBuffers = 0; in EmptyBuffers() local325 alGetSourcei(source, AL_BUFFERS_QUEUED, &queuedBuffers); CheckError("COggStream::EmptyBuffers"); in EmptyBuffers()327 while (queuedBuffers-- > 0) { in EmptyBuffers()
83 private final Set<byte[]> queuedBuffers = new HashSet<byte[]>(); field in VideoCapturerAndroid464 queuedBuffers.clear(); in startPreviewOnCameraThread()468 queuedBuffers.add(buffer.array()); in startPreviewOnCameraThread()534 queuedBuffers.clear(); in stopCaptureOnCameraThread()603 if (!queuedBuffers.contains(data)) { in onPreviewFrame()
68 unsigned int queuedBuffers();
94 unsigned int Kwave::RecordThread::queuedBuffers() in queuedBuffers() function in Kwave::RecordThread
233 while (m_thread->queuedBuffers()) in setup()837 while (m_thread->queuedBuffers()) in enterInhibit()1178 unsigned int queued = m_thread->queuedBuffers(); in updateBufferProgressBar()1473 if (!m_thread->queuedBuffers()) return; in processBuffer()
96 std::vector<QueuedBuffer> queuedBuffers; variable
533 ALint queuedBuffers; in play() local534 alGetSourcei(source, AL_BUFFERS_QUEUED, &queuedBuffers); in play()537 for(size_t i = queuedBuffers; i < nbuffers && loadCount; i++) { in play()