DevTools: rename AsyncCallChainMap to AsyncOperationMap

Source/core/inspector/AsyncCallTracker.cpp

 /*
  * Copyright (C) 2013 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions are
  * met:
  *
  *     * Redistributions of source code must retain the above copyright
  * notice, this list of conditions and the following disclaimer.
  *     * Redistributions in binary form must reproduce the above
@@ skipping 18 matching lines @@
  */
 
 #include "config.h"
 #include "core/inspector/AsyncCallTracker.h"
 
 #include "core/dom/ContextLifecycleObserver.h"
 #include "core/dom/ExecutionContext.h"
 #include "core/dom/ExecutionContextTask.h"
 #include "core/events/Event.h"
 #include "core/events/EventTarget.h"
-#include "core/inspector/AsyncCallChain.h"
-#include "core/inspector/AsyncCallChainMap.h"
+#include "core/inspector/AsyncOperationMap.h"
 #include "core/inspector/InspectorDebuggerAgent.h"
 #include "core/xmlhttprequest/XMLHttpRequest.h"
 #include "core/xmlhttprequest/XMLHttpRequestUpload.h"
 #include "wtf/text/StringBuilder.h"
 #include "wtf/text/StringHash.h"
-#include <v8.h>
 
 namespace {
 
 static const char setTimeoutName[] = "setTimeout";
 static const char setIntervalName[] = "setInterval";
 static const char requestAnimationFrameName[] = "requestAnimationFrame";
 static const char xhrSendName[] = "XMLHttpRequest.send";
 static const char enqueueMutationRecordName[] = "Mutation";
 
 }
 
 namespace blink {
 
 class AsyncCallTracker::ExecutionContextData final : public NoBaseWillBeGarbageCollectedFinalized<ExecutionContextData>, public ContextLifecycleObserver {
     WILL_BE_USING_GARBAGE_COLLECTED_MIXIN(AsyncCallTracker::ExecutionContextData);
     WTF_MAKE_FAST_ALLOCATED_WILL_BE_REMOVED;
 public:
     ExecutionContextData(AsyncCallTracker* tracker, ExecutionContext* executionContext)
         : ContextLifecycleObserver(executionContext)
         , m_tracker(tracker)
         , m_timerCallChains(tracker->m_debuggerAgent)
         , m_animationFrameCallChains(tracker->m_debuggerAgent)
         , m_eventCallChains(tracker->m_debuggerAgent)
         , m_xhrCallChains(tracker->m_debuggerAgent)
         , m_mutationObserverCallChains(tracker->m_debuggerAgent)
         , m_executionContextTaskCallChains(tracker->m_debuggerAgent)
-        , m_asyncOperationCallChains(tracker->m_debuggerAgent)
+        , m_asyncOperations(tracker->m_debuggerAgent)
     {
     }
 
     virtual void contextDestroyed() override
     {
         ASSERT(executionContext());
         OwnPtrWillBeRawPtr<ExecutionContextData> self = m_tracker->m_executionContextDataMap.take(executionContext());
         ASSERT_UNUSED(self, self == this);
         ContextLifecycleObserver::contextDestroyed();
         clearLifecycleContext();
         disposeCallChains();
     }
 
     void unobserve()
     {
         disposeCallChains();
         dispose();
     }
 
     virtual void trace(Visitor* visitor) override
     {
         visitor->trace(m_tracker);
 #if ENABLE(OILPAN)
         visitor->trace(m_timerCallChains);
         visitor->trace(m_animationFrameCallChains);
         visitor->trace(m_eventCallChains);
         visitor->trace(m_xhrCallChains);
         visitor->trace(m_mutationObserverCallChains);
         visitor->trace(m_executionContextTaskCallChains);
-        visitor->trace(m_asyncOperationCallChains);
+        visitor->trace(m_asyncOperations);
 #endif
         ContextLifecycleObserver::trace(visitor);
     }
 
     RawPtrWillBeMember<AsyncCallTracker> m_tracker;
     HashSet<int> m_intervalTimerIds;
-    AsyncCallChainMap<int> m_timerCallChains;
-    AsyncCallChainMap<int> m_animationFrameCallChains;
-    AsyncCallChainMap<RawPtrWillBeMember<Event> > m_eventCallChains;
-    AsyncCallChainMap<RawPtrWillBeMember<EventTarget> > m_xhrCallChains;
-    AsyncCallChainMap<RawPtrWillBeMember<MutationObserver> > m_mutationObserverCallChains;
-    AsyncCallChainMap<ExecutionContextTask*> m_executionContextTaskCallChains;
-    AsyncCallChainMap<int> m_asyncOperationCallChains;
+    AsyncOperationMap<int> m_timerCallChains;
+    AsyncOperationMap<int> m_animationFrameCallChains;
+    AsyncOperationMap<RawPtrWillBeMember<Event> > m_eventCallChains;
+    AsyncOperationMap<RawPtrWillBeMember<EventTarget> > m_xhrCallChains;
+    AsyncOperationMap<RawPtrWillBeMember<MutationObserver> > m_mutationObserverCallChains;
+    AsyncOperationMap<ExecutionContextTask*> m_executionContextTaskCallChains;
+    AsyncOperationMap<int> m_asyncOperations;
 
 private:
     void disposeCallChains()
     {
         m_timerCallChains.dispose();
         m_animationFrameCallChains.dispose();
         m_eventCallChains.dispose();
         m_xhrCallChains.dispose();
         m_mutationObserverCallChains.dispose();
         m_executionContextTaskCallChains.dispose();
-        m_asyncOperationCallChains.dispose();
+        m_asyncOperations.dispose();
     }
 };
 
 static XMLHttpRequest* toXmlHttpRequest(EventTarget* eventTarget)
 {
     const AtomicString& interfaceName = eventTarget->interfaceName();
     if (interfaceName == EventTargetNames::XMLHttpRequest)
         return static_cast<XMLHttpRequest*>(eventTarget);
     if (interfaceName == EventTargetNames::XMLHttpRequestUpload)
         return static_cast<XMLHttpRequestUpload*>(eventTarget)->xmlHttpRequest();
     return nullptr;
 }
 
 AsyncCallTracker::AsyncCallTracker(InspectorDebuggerAgent* debuggerAgent, InstrumentingAgents* instrumentingAgents)
     : m_debuggerAgent(debuggerAgent)
     , m_instrumentingAgents(instrumentingAgents)
 {
     m_debuggerAgent->addAsyncCallTrackingListener(this);
 }
 
 AsyncCallTracker::~AsyncCallTracker()
 {
 }
 
 void AsyncCallTracker::asyncCallTrackingStateChanged(bool tracking)
 {
     m_instrumentingAgents->setAsyncCallTracker(tracking ? this : nullptr);
 }
 
-void AsyncCallTracker::resetAsyncCallChains()
+void AsyncCallTracker::resetAsyncOperations()
 {
     for (auto& it : m_executionContextDataMap)
         it.value->unobserve();
     m_executionContextDataMap.clear();
 }
 
 void AsyncCallTracker::didInstallTimer(ExecutionContext* context, int timerId, int timeout, bool singleShot)
 {
     ASSERT(context);
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
@@ skipping 18 matching lines @@
     data->m_timerCallChains.remove(timerId);
 }
 
 bool AsyncCallTracker::willFireTimer(ExecutionContext* context, int timerId)
 {
     ASSERT(context);
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
     ASSERT(timerId > 0);
     ASSERT(!m_debuggerAgent->currentAsyncCallChain());
     if (ExecutionContextData* data = m_executionContextDataMap.get(context)) {
-        setCurrentAsyncCallChain(context, data->m_timerCallChains.get(timerId));
+        willFireAsyncCall(data->m_timerCallChains.get(timerId));
         if (!data->m_intervalTimerIds.contains(timerId))
             data->m_timerCallChains.remove(timerId);
     } else {
-        setCurrentAsyncCallChain(context, InspectorDebuggerAgent::unknownAsyncOperationId);
+        willFireAsyncCall(InspectorDebuggerAgent::unknownAsyncOperationId);
     }
     return true;
 }
 
 void AsyncCallTracker::didRequestAnimationFrame(ExecutionContext* context, int callbackId)
 {
     ASSERT(context);
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
     int operationId = m_debuggerAgent->traceAsyncOperationStarting(requestAnimationFrameName);
     ASSERT(callbackId > 0);
@@ skipping 11 matching lines @@
         data->m_animationFrameCallChains.remove(callbackId);
 }
 
 bool AsyncCallTracker::willFireAnimationFrame(ExecutionContext* context, int callbackId)
 {
     ASSERT(context);
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
     ASSERT(callbackId > 0);
     ASSERT(!m_debuggerAgent->currentAsyncCallChain());
     if (ExecutionContextData* data = m_executionContextDataMap.get(context)) {
-        setCurrentAsyncCallChain(context, data->m_animationFrameCallChains.get(callbackId));
+        willFireAsyncCall(data->m_animationFrameCallChains.get(callbackId));
         data->m_animationFrameCallChains.remove(callbackId);
     } else {
-        setCurrentAsyncCallChain(context, InspectorDebuggerAgent::unknownAsyncOperationId);
+        willFireAsyncCall(InspectorDebuggerAgent::unknownAsyncOperationId);
     }
     return true;
 }
 
 void AsyncCallTracker::didEnqueueEvent(EventTarget* eventTarget, Event* event)
 {
     ASSERT(eventTarget->executionContext());
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
     int operationId = m_debuggerAgent->traceAsyncOperationStarting(event->type());
     ExecutionContextData* data = createContextDataIfNeeded(eventTarget->executionContext());
@@ skipping 10 matching lines @@
 
 void AsyncCallTracker::willHandleEvent(EventTarget* eventTarget, Event* event, EventListener* listener, bool useCapture)
 {
     ASSERT(eventTarget->executionContext());
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
     if (XMLHttpRequest* xhr = toXmlHttpRequest(eventTarget)) {
         willHandleXHREvent(xhr, event);
     } else {
         ExecutionContext* context = eventTarget->executionContext();
         if (ExecutionContextData* data = m_executionContextDataMap.get(context))
-            setCurrentAsyncCallChain(context, data->m_eventCallChains.get(event));
+            willFireAsyncCall(data->m_eventCallChains.get(event));
         else
-            setCurrentAsyncCallChain(context, InspectorDebuggerAgent::unknownAsyncOperationId);
+            willFireAsyncCall(InspectorDebuggerAgent::unknownAsyncOperationId);
     }
 }
 
 void AsyncCallTracker::willLoadXHR(XMLHttpRequest* xhr, ThreadableLoaderClient*, const AtomicString&, const KURL&, bool async, PassRefPtr<FormData>, const HTTPHeaderMap&, bool)
 {
     ASSERT(xhr->executionContext());
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
     if (!async)
         return;
     int operationId = m_debuggerAgent->traceAsyncOperationStarting(xhrSendName);
     ExecutionContextData* data = createContextDataIfNeeded(xhr->executionContext());
     data->m_xhrCallChains.set(xhr, operationId);
 }
 
 void AsyncCallTracker::didDispatchXHRLoadendEvent(XMLHttpRequest* xhr)
 {
     ASSERT(xhr->executionContext());
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
     if (ExecutionContextData* data = m_executionContextDataMap.get(xhr->executionContext()))
         data->m_xhrCallChains.remove(xhr);
 }
 
 void AsyncCallTracker::willHandleXHREvent(XMLHttpRequest* xhr, Event* event)
 {
     ExecutionContext* context = xhr->executionContext();
     ASSERT(context);
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
     if (ExecutionContextData* data = m_executionContextDataMap.get(context))
-        setCurrentAsyncCallChain(context, data->m_xhrCallChains.get(xhr));
+        willFireAsyncCall(data->m_xhrCallChains.get(xhr));
     else
-        setCurrentAsyncCallChain(context, InspectorDebuggerAgent::unknownAsyncOperationId);
+        willFireAsyncCall(InspectorDebuggerAgent::unknownAsyncOperationId);
 }
 
 void AsyncCallTracker::didEnqueueMutationRecord(ExecutionContext* context, MutationObserver* observer)
 {
     ASSERT(context);
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
     ExecutionContextData* data = createContextDataIfNeeded(context);
     if (data->m_mutationObserverCallChains.contains(observer))
         return;
     int operationId = m_debuggerAgent->traceAsyncOperationStarting(enqueueMutationRecordName);
     data->m_mutationObserverCallChains.set(observer, operationId);
 }
 
 void AsyncCallTracker::didClearAllMutationRecords(ExecutionContext* context, MutationObserver* observer)
 {
     ASSERT(context);
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
     if (ExecutionContextData* data = m_executionContextDataMap.get(context))
         data->m_mutationObserverCallChains.remove(observer);
 }
 
 void AsyncCallTracker::willDeliverMutationRecords(ExecutionContext* context, MutationObserver* observer)
 {
     ASSERT(context);
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
     if (ExecutionContextData* data = m_executionContextDataMap.get(context)) {
-        setCurrentAsyncCallChain(context, data->m_mutationObserverCallChains.get(observer));
+        willFireAsyncCall(data->m_mutationObserverCallChains.get(observer));
         data->m_mutationObserverCallChains.remove(observer);
     } else {
-        setCurrentAsyncCallChain(context, InspectorDebuggerAgent::unknownAsyncOperationId);
+        willFireAsyncCall(InspectorDebuggerAgent::unknownAsyncOperationId);
     }
 }
 
 void AsyncCallTracker::didPostExecutionContextTask(ExecutionContext* context, ExecutionContextTask* task)
 {
     ASSERT(context);
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
     if (task->taskNameForInstrumentation().isEmpty())
         return;
     int operationId = m_debuggerAgent->traceAsyncOperationStarting(task->taskNameForInstrumentation());
     ExecutionContextData* data = createContextDataIfNeeded(context);
     data->m_executionContextTaskCallChains.set(task, operationId);
 }
 
 void AsyncCallTracker::didKillAllExecutionContextTasks(ExecutionContext* context)
 {
     ASSERT(context);
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
     if (ExecutionContextData* data = m_executionContextDataMap.get(context))
         data->m_executionContextTaskCallChains.clear();
 }
 
 void AsyncCallTracker::willPerformExecutionContextTask(ExecutionContext* context, ExecutionContextTask* task)
 {
     ASSERT(context);
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
     if (ExecutionContextData* data = m_executionContextDataMap.get(context)) {
-        setCurrentAsyncCallChain(context, data->m_executionContextTaskCallChains.get(task));
+        willFireAsyncCall(data->m_executionContextTaskCallChains.get(task));
         data->m_executionContextTaskCallChains.remove(task);
     } else {
-        setCurrentAsyncCallChain(context, InspectorDebuggerAgent::unknownAsyncOperationId);
+        willFireAsyncCall(InspectorDebuggerAgent::unknownAsyncOperationId);
     }
 }
 
 int AsyncCallTracker::traceAsyncOperationStarting(ExecutionContext* context, const String& operationName, int prevOperationId)
 {
     ASSERT(context);
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
     if (prevOperationId)
         traceAsyncOperationCompleted(context, prevOperationId);
     int operationId = m_debuggerAgent->traceAsyncOperationStarting(operationName);
     ExecutionContextData* data = createContextDataIfNeeded(context);
-    data->m_asyncOperationCallChains.set(operationId, operationId);
+    data->m_asyncOperations.set(operationId, operationId);
     return operationId;
 }
 
 void AsyncCallTracker::traceAsyncOperationCompleted(ExecutionContext* context, int operationId)
 {
     ASSERT(context);
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
     if (operationId <= 0)
         return;
     if (ExecutionContextData* data = m_executionContextDataMap.get(context))
-        data->m_asyncOperationCallChains.remove(operationId);
+        data->m_asyncOperations.remove(operationId);
 }
 
 void AsyncCallTracker::traceAsyncOperationCompletedCallbackStarting(ExecutionContext* context, int operationId)
 {
     traceAsyncCallbackStarting(context, operationId);
     traceAsyncOperationCompleted(context, operationId);
 }
 
+bool AsyncCallTracker::isKnownAsyncOperationId(ExecutionContext* context, int operationId) const
+{
+    if (operationId <= 0)
+        return false;
+    if (ExecutionContextData* data = m_executionContextDataMap.get(context))
+        return data->m_asyncOperations.contains(operationId);
+    return false;
+}
+
 void AsyncCallTracker::traceAsyncCallbackStarting(ExecutionContext* context, int operationId)
 {
     ASSERT(context);
     ASSERT(m_debuggerAgent->trackingAsyncCalls());
-    if (ExecutionContextData* data = m_executionContextDataMap.get(context))
-        setCurrentAsyncCallChain(context, operationId > 0 ? data->m_asyncOperationCallChains.get(operationId) : InspectorDebuggerAgent::unknownAsyncOperationId);
-    else
-        setCurrentAsyncCallChain(context, InspectorDebuggerAgent::unknownAsyncOperationId);
+    ASSERT(operationId <= 0 || isKnownAsyncOperationId(context, operationId));
+    willFireAsyncCall(operationId > 0 ? operationId : InspectorDebuggerAgent::unknownAsyncOperationId);
 }
 
 void AsyncCallTracker::didFireAsyncCall()
 {
     m_debuggerAgent->traceAsyncCallbackCompleted();
 }
 
-void AsyncCallTracker::setCurrentAsyncCallChain(ExecutionContext* context, int operationId)
+void AsyncCallTracker::willFireAsyncCall(int operationId)
 {
-    m_debuggerAgent->traceAsyncCallbackStarting(toIsolate(context), operationId);
+    m_debuggerAgent->traceAsyncCallbackStarting(operationId);
 }
 
 AsyncCallTracker::ExecutionContextData* AsyncCallTracker::createContextDataIfNeeded(ExecutionContext* context)
 {
     ExecutionContextData* data = m_executionContextDataMap.get(context);
     if (!data) {
         data = m_executionContextDataMap.set(context, adoptPtrWillBeNoop(new AsyncCallTracker::ExecutionContextData(this, context)))
             .storedValue->value.get();
     }
     return data;
 }
 
 void AsyncCallTracker::trace(Visitor* visitor)
 {
 #if ENABLE(OILPAN)
     visitor->trace(m_executionContextDataMap);
     visitor->trace(m_debuggerAgent);
     visitor->trace(m_instrumentingAgents);
 #endif
     InspectorDebuggerAgent::AsyncCallTrackingListener::trace(visitor);
 }
 
 } // namespace blink