Searched refs:m_queueSize (Results 1 – 12 of 12) sorted by relevance
57 m_queueSize(queueSize), in ThreadPool()60 assert(m_queueSize != 0); in ThreadPool()134 return m_queueSize < 0 || m_tasks.size() < (size_t)m_queueSize; in add()154 int64_t m_queueSize; member in untwine::ThreadPool
57 m_queueSize(queueSize), in ThreadPool()60 assert(m_queueSize != 0); in ThreadPool()137 return m_queueSize < 0 || m_tasks.size() < (size_t)m_queueSize; in add()157 int64_t m_queueSize; member in pdal::ThreadPool
34 m_queueSize = queueSize; in initializeQueues()36 m_videoQueue.reset(new sync_bounded_queue<VideoFramePtr>(m_queueSize)); in initializeQueues()37 m_audioQueue.reset(new sync_bounded_queue<AudioFramePtr>(m_queueSize)); in initializeQueues()38 m_subtitleQueue.reset(new sync_bounded_queue<SubtitleFramePtr>(m_queueSize)); in initializeQueues()
94 size_t m_queueSize = 0; variable139 bool isAudioQueueFull() { return m_audioQueue->size() == m_queueSize; } in isAudioQueueFull()147 bool isSubtitleQueueFull() { return m_subtitleQueue->size() == m_queueSize; } in isSubtitleQueueFull()151 bool isVideoQueueFull() { return m_videoQueue->size() == m_queueSize; } in isVideoQueueFull()
52 m_queueSize = (numEncodes > 1) ? X265_INPUT_QUEUE_SIZE : 1; in AbrEncoder()95 for (uint32_t idx = 0; idx < m_queueSize; idx++) in allocBuffers()104 m_analysisRead[pass] = new ThreadSafeInteger[m_queueSize]; in allocBuffers()105 m_readFlag[pass] = X265_MALLOC(int, m_queueSize); in allocBuffers()117 for (uint32_t index = 0; index < m_queueSize; index++) in destroy()294 int index = written % m_parent->m_queueSize; in copyInfo()300 int overwrite = written / m_parent->m_queueSize; in copyInfo()304 for (uint32_t i = 0; i < m_parent->m_queueSize; i++) in copyInfo()410 int readPos = ipread % m_parent->m_queueSize; in readPicture()946 int QDepth = m_parentEnc->m_parent->m_queueSize; in threadMain()[all …]
46 uint32_t m_queueSize; variable
52 m_queueSize = (numEncodes > 1) ? X265_INPUT_QUEUE_SIZE : 1; in AbrEncoder()95 for (uint32_t idx = 0; idx < m_queueSize; idx++) in allocBuffers()104 m_analysisRead[pass] = new ThreadSafeInteger[m_queueSize]; in allocBuffers()105 m_readFlag[pass] = X265_MALLOC(int, m_queueSize); in allocBuffers()115 for (uint32_t index = 0; index < m_queueSize; index++) in destroy()292 int index = written % m_parent->m_queueSize; in copyInfo()298 int overwrite = written / m_parent->m_queueSize; in copyInfo()302 for (uint32_t i = 0; i < m_parent->m_queueSize; i++) in copyInfo()408 int readPos = ipread % m_parent->m_queueSize; in readPicture()944 int QDepth = m_parentEnc->m_parent->m_queueSize; in threadMain()[all …]
31 Q_INVOKABLE int getQueueSize(){return m_queueSize;} in getQueueSize()40 int m_queueSize; variable
67 m_queueSize = maxIndex; in resetIndex()
31 m_queueSize(queueSize) in ZoneMinderDeviceSource()186 while ( m_captureQueue.size() >= m_queueSize ) { in getNextFrame()
70 unsigned int m_queueSize; variable