DevTools: Async call stacks for FileSystem API part 2.

Source/core/fileapi/FileReader.cpp

 /*
  * Copyright (C) 2010 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 21 matching lines @@
 #include "core/fileapi/FileReader.h"
 
 #include "bindings/core/v8/ExceptionState.h"
 #include "core/dom/CrossThreadTask.h"
 #include "core/dom/Document.h"
 #include "core/dom/ExceptionCode.h"
 #include "core/dom/ExecutionContext.h"
 #include "core/events/ProgressEvent.h"
 #include "core/fileapi/File.h"
 #include "core/frame/LocalFrame.h"
+#include "core/inspector/InspectorInstrumentation.h"
 #include "core/workers/WorkerClients.h"
 #include "core/workers/WorkerGlobalScope.h"
 #include "platform/Logging.h"
 #include "platform/Supplementable.h"
 #include "wtf/ArrayBuffer.h"
 #include "wtf/CurrentTime.h"
 #include "wtf/Deque.h"
 #include "wtf/HashSet.h"
 #include "wtf/text/CString.h"
 
@@ skipping 59 matching lines @@
     ~ThrottlingController() { }
 
     enum FinishReaderType { DoNotRunPendingReaders, RunPendingReaders };
 
     static void pushReader(ExecutionContext* context, FileReader* reader)
     {
         ThrottlingController* controller = from(context);
         if (!controller)
             return;
 
+        reader->m_asyncOperationId = InspectorInstrumentation::traceAsyncOperationStarting(context, "FileReader");
         controller->pushReader(reader);
     }
 
     static FinishReaderType removeReader(ExecutionContext* context, FileReader* reader)
     {
         ThrottlingController* controller = from(context);
         if (!controller)
             return DoNotRunPendingReaders;
 
         return controller->removeReader(reader);
     }
 
     static void finishReader(ExecutionContext* context, FileReader* reader, FinishReaderType nextStep)
     {
+        InspectorInstrumentation::traceAsyncOperationCompleted(context, reader->m_asyncOperationId);
+
         ThrottlingController* controller = from(context);
         if (!controller)
             return;
 
         controller->finishReader(reader, nextStep);
     }
 
     void trace(Visitor* visitor)
     {
 #if ENABLE(OILPAN)
@@ skipping 70 matching lines @@
     fileReader->suspendIfNeeded();
     return fileReader.release();
 }
 
 FileReader::FileReader(ExecutionContext* context)
     : ActiveDOMObject(context)
     , m_state(EMPTY)
     , m_loadingState(LoadingStateNone)
     , m_readType(FileReaderLoader::ReadAsBinaryString)
     , m_lastProgressNotificationTimeMS(0)
+    , m_asyncOperationId(0)
 {
     ScriptWrappable::init(this);
 }
 
 FileReader::~FileReader()
 {
     terminate();
 }
 
 const AtomicString& FileReader::interfaceName() const
@@ skipping 218 matching lines @@
 
     fireEvent(EventTypeNames::error);
     fireEvent(EventTypeNames::loadend);
 
     // All possible events have fired and we're done, no more pending activity.
     ThrottlingController::finishReader(executionContext(), this, finalStep);
 }
 
 void FileReader::fireEvent(const AtomicString& type)
 {
+    InspectorInstrumentationCookie cookie = InspectorInstrumentation::traceAsyncCallbackStarting(executionContext(), m_asyncOperationId);
     if (!m_loader) {
         dispatchEvent(ProgressEvent::create(type, false, 0, 0));
+        InspectorInstrumentation::traceAsyncCallbackCompleted(cookie);
         return;
     }
 
     if (m_loader->totalBytes() >= 0)
         dispatchEvent(ProgressEvent::create(type, true, m_loader->bytesLoaded(), m_loader->totalBytes()));
     else
         dispatchEvent(ProgressEvent::create(type, false, m_loader->bytesLoaded(), 0));
+
+    InspectorInstrumentation::traceAsyncCallbackCompleted(cookie);
 }
 
 PassRefPtr<ArrayBuffer> FileReader::arrayBufferResult() const
 {
     if (!m_loader || m_error)
         return nullptr;
     return m_loader->arrayBufferResult();
 }
 
 String FileReader::stringResult()
 {
     if (!m_loader || m_error)
         return String();
     return m_loader->stringResult();
 }
 
 void FileReader::trace(Visitor* visitor)
 {
     visitor->trace(m_error);
     EventTargetWithInlineData::trace(visitor);
 }
 
 } // namespace blink