Lines Matching refs:signal_
107 signal_ = make_shared<VDecSignal>();
108 cb_ = make_unique<VDecDemoCallback>(signal_);
141 unique_lock<mutex> inLock(signal_->inMutex_);
142 signal_->inQueue_.push(INDEX_CONSTANT);
143 signal_->inCond_.notify_all();
151 unique_lock<mutex> outLock(signal_->outMutex_);
152 signal_->outQueue_.push(INDEX_CONSTANT);
153 signal_->outCond_.notify_all();
235 unique_lock<mutex> lock(signal_->inMutex_);
236 signal_->inCond_.wait(
237 lock, [this]() { return signal_->inQueue_.size() > 0 && signal_->availableInputBufferQueue_.size() > 0; });
243 uint32_t index = signal_->inQueue_.front();
244 std::shared_ptr<Media::AVSharedMemory> buffer = signal_->availableInputBufferQueue_.front();
277 signal_->inQueue_.pop();
278 signal_->availableInputBufferQueue_.pop();
296 unique_lock<mutex> lock(signal_->outMutex_);
297 signal_->outCond_.wait(lock, [this]() { return signal_->outQueue_.size() > 0; });
303 uint32_t index = signal_->outQueue_.front();
309 signal_->outQueue_.pop();
326 unique_lock<mutex> lock(signal_->inMutex_);
327 signal_->inQueue_.push(index);
328 signal_->availableInputBufferQueue_.push(buffer);
329 signal_->inCond_.notify_all();
336 unique_lock<mutex> lock(signal_->outMutex_);
337 signal_->outQueue_.push(index);
338 signal_->outCond_.notify_all();