Searched refs:dupEvent (Results 1 – 1 of 1) sorted by relevance
60 std::shared_ptr<Event> dupEvent = event; in OnEventProxy() local61 auto processorSize = dupEvent->GetPendingProcessorSize(); in OnEventProxy()62 dupEvent->ResetPendingStatus(); in OnEventProxy()67 ret = OnEvent(dupEvent); in OnEventProxy()72 if (!dupEvent->IsPipelineEvent()) { in OnEventProxy()74 Audit::WriteAuditEvent(Audit::StatsEvent::QUEUE_EVENT_OUT, dupEvent->createTime_, in OnEventProxy()78 if ((!dupEvent->HasFinish() && !dupEvent->HasPending()) && in OnEventProxy()79 (processorSize == dupEvent->GetPendingProcessorSize())) { in OnEventProxy()80 dupEvent->OnContinue(); in OnEventProxy()