| OLD | NEW |
| (Empty) |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "config.h" | |
| 6 #include "core/inspector/V8AsyncCallTracker.h" | |
| 7 | |
| 8 #include "bindings/core/v8/V8PerContextData.h" | |
| 9 #include "core/inspector/AsyncOperationMap.h" | |
| 10 #include "platform/heap/Handle.h" | |
| 11 #include "wtf/HashMap.h" | |
| 12 #include "wtf/text/StringBuilder.h" | |
| 13 #include "wtf/text/StringHash.h" | |
| 14 #include "wtf/text/WTFString.h" | |
| 15 | |
| 16 namespace blink { | |
| 17 | |
| 18 namespace { | |
| 19 | |
| 20 static const char v8AsyncTaskEventEnqueue[] = "enqueue"; | |
| 21 static const char v8AsyncTaskEventWillHandle[] = "willHandle"; | |
| 22 static const char v8AsyncTaskEventDidHandle[] = "didHandle"; | |
| 23 | |
| 24 } | |
| 25 | |
| 26 class V8AsyncCallTracker::V8ContextAsyncOperations final : public NoBaseWillBeGa
rbageCollectedFinalized<V8AsyncCallTracker::V8ContextAsyncOperations> { | |
| 27 WTF_MAKE_NONCOPYABLE(V8ContextAsyncOperations); | |
| 28 public: | |
| 29 explicit V8ContextAsyncOperations(V8DebuggerAgent* debuggerAgent) | |
| 30 : m_v8AsyncOperations(debuggerAgent) | |
| 31 { | |
| 32 } | |
| 33 | |
| 34 ~V8ContextAsyncOperations() | |
| 35 { | |
| 36 ASSERT(m_v8AsyncOperations.hasBeenDisposed()); | |
| 37 } | |
| 38 | |
| 39 void dispose() | |
| 40 { | |
| 41 // FIXME: get rid of the dispose method and this class altogether once A
syncOperationMap is always allocated on C++ heap. | |
| 42 m_v8AsyncOperations.dispose(); | |
| 43 } | |
| 44 | |
| 45 DEFINE_INLINE_TRACE() | |
| 46 { | |
| 47 #if ENABLE(OILPAN) | |
| 48 visitor->trace(m_v8AsyncOperations); | |
| 49 #endif | |
| 50 } | |
| 51 | |
| 52 AsyncOperationMap<String> m_v8AsyncOperations; | |
| 53 }; | |
| 54 | |
| 55 static String makeV8AsyncTaskUniqueId(const String& eventName, int id) | |
| 56 { | |
| 57 StringBuilder builder; | |
| 58 builder.append(eventName); | |
| 59 builder.append(" -> "); | |
| 60 builder.appendNumber(id); | |
| 61 return builder.toString(); | |
| 62 } | |
| 63 | |
| 64 V8AsyncCallTracker::V8AsyncCallTracker(V8DebuggerAgent* debuggerAgent) : m_debug
gerAgent(debuggerAgent) | |
| 65 { | |
| 66 m_debuggerAgent->addAsyncCallTrackingListener(this); | |
| 67 } | |
| 68 | |
| 69 V8AsyncCallTracker::~V8AsyncCallTracker() | |
| 70 { | |
| 71 ASSERT(m_contextAsyncOperationMap.isEmpty()); | |
| 72 #if !ENABLE(OILPAN) | |
| 73 m_debuggerAgent->removeAsyncCallTrackingListener(this); | |
| 74 #endif | |
| 75 } | |
| 76 | |
| 77 DEFINE_TRACE(V8AsyncCallTracker) | |
| 78 { | |
| 79 #if ENABLE(OILPAN) | |
| 80 visitor->trace(m_contextAsyncOperationMap); | |
| 81 visitor->trace(m_debuggerAgent); | |
| 82 #endif | |
| 83 V8DebuggerAgent::AsyncCallTrackingListener::trace(visitor); | |
| 84 } | |
| 85 | |
| 86 void V8AsyncCallTracker::asyncCallTrackingStateChanged(bool) | |
| 87 { | |
| 88 } | |
| 89 | |
| 90 void V8AsyncCallTracker::resetAsyncOperations() | |
| 91 { | |
| 92 for (auto& it : m_contextAsyncOperationMap) { | |
| 93 it.key->removeObserver(this); | |
| 94 it.value->dispose(); | |
| 95 } | |
| 96 m_contextAsyncOperationMap.clear(); | |
| 97 } | |
| 98 | |
| 99 void V8AsyncCallTracker::willDisposeScriptState(ScriptState* state) | |
| 100 { | |
| 101 m_contextAsyncOperationMap.remove(state); | |
| 102 } | |
| 103 | |
| 104 void V8AsyncCallTracker::didReceiveV8AsyncTaskEvent(ScriptState* state, const St
ring& eventType, const String& eventName, int id) | |
| 105 { | |
| 106 ASSERT(m_debuggerAgent->trackingAsyncCalls()); | |
| 107 if (eventType == v8AsyncTaskEventEnqueue) | |
| 108 didEnqueueV8AsyncTask(state, eventName, id); | |
| 109 else if (eventType == v8AsyncTaskEventWillHandle) | |
| 110 willHandleV8AsyncTask(state, eventName, id); | |
| 111 else if (eventType == v8AsyncTaskEventDidHandle) | |
| 112 m_debuggerAgent->traceAsyncCallbackCompleted(); | |
| 113 else | |
| 114 ASSERT_NOT_REACHED(); | |
| 115 } | |
| 116 | |
| 117 void V8AsyncCallTracker::didEnqueueV8AsyncTask(ScriptState* state, const String&
eventName, int id) | |
| 118 { | |
| 119 ASSERT(state); | |
| 120 ASSERT(m_debuggerAgent->trackingAsyncCalls()); | |
| 121 int operationId = m_debuggerAgent->traceAsyncOperationStarting(eventName); | |
| 122 if (!operationId) | |
| 123 return; | |
| 124 V8ContextAsyncOperations* contextCallChains = m_contextAsyncOperationMap.get
(state); | |
| 125 if (!contextCallChains) | |
| 126 contextCallChains = m_contextAsyncOperationMap.set(state, adoptPtrWillBe
Noop(new V8ContextAsyncOperations(m_debuggerAgent))).storedValue->value.get(); | |
| 127 contextCallChains->m_v8AsyncOperations.set(makeV8AsyncTaskUniqueId(eventName
, id), operationId); | |
| 128 } | |
| 129 | |
| 130 void V8AsyncCallTracker::willHandleV8AsyncTask(ScriptState* state, const String&
eventName, int id) | |
| 131 { | |
| 132 ASSERT(state); | |
| 133 ASSERT(m_debuggerAgent->trackingAsyncCalls()); | |
| 134 if (V8ContextAsyncOperations* contextCallChains = m_contextAsyncOperationMap
.get(state)) { | |
| 135 String taskId = makeV8AsyncTaskUniqueId(eventName, id); | |
| 136 m_debuggerAgent->traceAsyncCallbackStarting(contextCallChains->m_v8Async
Operations.get(taskId)); | |
| 137 contextCallChains->m_v8AsyncOperations.remove(taskId); | |
| 138 } else { | |
| 139 m_debuggerAgent->traceAsyncCallbackStarting(V8DebuggerAgent::unknownAsyn
cOperationId); | |
| 140 } | |
| 141 } | |
| 142 | |
| 143 } // namespace blink | |
| OLD | NEW |