Lines Matching refs:currentTs
195 bool DepthCompositeStream::getNextReadyInputLocked(int64_t *currentTs /*inout*/) { in getNextReadyInputLocked() argument
196 if (currentTs == nullptr) { in getNextReadyInputLocked()
203 (it.second.jpegBuffer.data != nullptr) && (it.first < *currentTs)) { in getNextReadyInputLocked()
204 *currentTs = it.first; in getNextReadyInputLocked()
212 int64_t DepthCompositeStream::getNextFailingInputLocked(int64_t *currentTs /*inout*/) { in getNextFailingInputLocked() argument
214 if (currentTs == nullptr) { in getNextFailingInputLocked()
219 if (it.second.error && !it.second.errorNotified && (it.first < *currentTs)) { in getNextFailingInputLocked()
220 *currentTs = it.first; in getNextFailingInputLocked()
393 void DepthCompositeStream::releaseInputFramesLocked(int64_t currentTs) { in releaseInputFramesLocked() argument
396 if (it->first <= currentTs) { in releaseInputFramesLocked()
406 int64_t currentTs = INT64_MAX; in threadLoop() local
416 releaseInputFramesLocked(currentTs); in threadLoop()
422 newInputAvailable = getNextReadyInputLocked(¤tTs); in threadLoop()
424 auto failingFrameNumber = getNextFailingInputLocked(¤tTs); in threadLoop()
432 releaseInputFrameLocked(&mPendingInputFrames[currentTs]); in threadLoop()
433 currentTs = INT64_MAX; in threadLoop()
448 auto res = processInputFrame(currentTs, mPendingInputFrames[currentTs]); in threadLoop()
452 currentTs, strerror(-res), res); in threadLoop()
453 mPendingInputFrames[currentTs].error = true; in threadLoop()
456 releaseInputFramesLocked(currentTs); in threadLoop()