Searched refs:SpanStatus (Results 1 – 4 of 4) sorted by relevance
1421 SpanStatus targetStatus = SpanStatus::SPAN_WRITE_DONE; in RecordPrepareCurrent()1422 while (!curReadSpan->spanStatus.compare_exchange_strong(targetStatus, SpanStatus::SPAN_READING) in RecordPrepareCurrent()1426 if (curReadSpan->spanStatus.load() == SpanStatus::SPAN_READING) { in RecordPrepareCurrent()1430 targetStatus = SpanStatus::SPAN_WRITE_DONE; in RecordPrepareCurrent()1449 SpanStatus targetStatus = SpanStatus::SPAN_READING; in RecordFinishHandleCurrent()1450 … if (!curReadSpan->spanStatus.compare_exchange_strong(targetStatus, SpanStatus::SPAN_READ_DONE)) { in RecordFinishHandleCurrent()1481 SpanStatus targetStatus = SpanStatus::SPAN_READ_DONE; in PrepareCurrent()1482 …while (!tempSpan->spanStatus.compare_exchange_strong(targetStatus, SpanStatus::SPAN_WRITTING) && t… in PrepareCurrent()1486 targetStatus = SpanStatus::SPAN_READ_DONE; in PrepareCurrent()1515 SpanStatus targetStatus = SpanStatus::SPAN_WRITTING; in FinishHandleCurrent()[all …]
85 enum SpanStatus : uint32_t { enum96 std::atomic<SpanStatus> spanStatus;
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()1552 SpanStatus targetStatus = SpanStatus::SPAN_WRITE_DONE; in GetAllReadyProcessData()1553 … if (curReadSpan->spanStatus.compare_exchange_strong(targetStatus, SpanStatus::SPAN_READING)) { in GetAllReadyProcessData()1746 SpanStatus targetStatus = SpanStatus::SPAN_READING; in PrepareNextLoop()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 …]
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()