Lines Matching refs:currentTs

217 bool DepthCompositeStream::getNextReadyInputLocked(int64_t *currentTs /*inout*/) {  in getNextReadyInputLocked()  argument
218 if (currentTs == nullptr) { in getNextReadyInputLocked()
225 (it.second.jpegBuffer.data != nullptr) && (it.first < *currentTs)) { in getNextReadyInputLocked()
226 *currentTs = it.first; in getNextReadyInputLocked()
234 int64_t DepthCompositeStream::getNextFailingInputLocked(int64_t *currentTs /*inout*/) { in getNextFailingInputLocked() argument
236 if (currentTs == nullptr) { in getNextFailingInputLocked()
241 if (it.second.error && !it.second.errorNotified && (it.first < *currentTs)) { in getNextFailingInputLocked()
242 *currentTs = it.first; in getNextFailingInputLocked()
407 void DepthCompositeStream::releaseInputFramesLocked(int64_t currentTs) { in releaseInputFramesLocked() argument
410 if (it->first <= currentTs) { in releaseInputFramesLocked()
420 int64_t currentTs = INT64_MAX; in threadLoop() local
430 releaseInputFramesLocked(currentTs); in threadLoop()
436 newInputAvailable = getNextReadyInputLocked(&currentTs); in threadLoop()
438 auto failingFrameNumber = getNextFailingInputLocked(&currentTs); in threadLoop()
446 releaseInputFrameLocked(&mPendingInputFrames[currentTs]); in threadLoop()
447 currentTs = INT64_MAX; in threadLoop()
462 auto res = processInputFrame(mPendingInputFrames[currentTs]); in threadLoop()
466 currentTs, strerror(-res), res); in threadLoop()
467 mPendingInputFrames[currentTs].error = true; in threadLoop()
470 releaseInputFramesLocked(currentTs); in threadLoop()