Searched refs:spanStatus (Results 1 – 8 of 8) sorted by relevance
321 spanInfo->spanStatus = SPAN_WRITE_DONE; in InitAudiobuffer()323 spanInfo->spanStatus = SPAN_READ_DONE; in InitAudiobuffer()464 …if (curWriteSpan->spanStatus == SpanStatus::SPAN_WRITE_DONE || curWriteFrame < dstSpanSizeInframe_… in GetProcLastWriteDoneInfo()690 curWriteSpan->spanStatus.store(SpanStatus::SPAN_WRITTING); in WriteToSpecialProcBuf()706 curWriteSpan->spanStatus.store(SpanStatus::SPAN_WRITE_DONE); in WriteToSpecialProcBuf()
879 spanInfo->spanStatus = SPAN_WRITE_DONE; in InitAudiobuffer()881 spanInfo->spanStatus = SPAN_READ_DONE; in InitAudiobuffer()949 nextReadSapn->spanStatus = SpanStatus::SPAN_WRITE_DONE; in RecordReSyncPosition()974 nextWriteSapn->spanStatus = SpanStatus::SPAN_READ_DONE; in ReSyncPosition()1341 if (curReadSpan == nullptr || curReadSpan->spanStatus != SpanStatus::SPAN_WRITE_DONE) { in CheckAllBufferReady()1553 … if (curReadSpan->spanStatus.compare_exchange_strong(targetStatus, SpanStatus::SPAN_READING)) { in GetAllReadyProcessData()1906 curWriteSpan->spanStatus.store(SpanStatus::SPAN_WRITTING); in WriteToSpecialProcBuf()1931 curWriteSpan->spanStatus.store(SpanStatus::SPAN_READ_DONE); in WriteToSpecialProcBuf()1934 curWriteSpan->spanStatus.store(SpanStatus::SPAN_WRITE_DONE); in WriteToSpecialProcBuf()1991 curReadSpan->spanStatus.store(SpanStatus::SPAN_READING); in ReadFromEndpoint()[all …]
366 spanInfo->spanStatus = SPAN_READ_DONE; in InitBufferStatus()
109 spanInfo->spanStatus = SPAN_READ_DONE; in InitBufferStatus()
125 spanInfo->spanStatus = SPAN_READ_DONE; in InitBufferStatus()
1171 spanInfo->spanStatus = SPAN_READ_DONE; in ResetAudioBuffer()1422 while (!curReadSpan->spanStatus.compare_exchange_strong(targetStatus, SpanStatus::SPAN_READING) in RecordPrepareCurrent()1425 __func__, curReadPos, curReadSpan->spanStatus.load()); in RecordPrepareCurrent()1426 if (curReadSpan->spanStatus.load() == SpanStatus::SPAN_READING) { in RecordPrepareCurrent()1450 … if (!curReadSpan->spanStatus.compare_exchange_strong(targetStatus, SpanStatus::SPAN_READ_DONE)) { in RecordFinishHandleCurrent()1452 __func__, curReadPos, curReadSpan->spanStatus.load()); in RecordFinishHandleCurrent()1482 …while (!tempSpan->spanStatus.compare_exchange_strong(targetStatus, SpanStatus::SPAN_WRITTING) && t… in PrepareCurrent()1516 if (tempSpan->spanStatus.load() == targetStatus) { in FinishHandleCurrent()1520 tempSpan->spanStatus.store(SpanStatus::SPAN_WRITE_DONE); in FinishHandleCurrent()
96 std::atomic<SpanStatus> spanStatus; member
294 spanInfoList_[i].spanStatus.store(SPAN_INVALID); in Init()