DevTools: Connect worker cpu profiles to worker tracing threads.

Source/core/inspector/InspectorWorkerAgent.cpp

 /*
  * Copyright (C) 2011 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 188 matching lines @@
 void InspectorWorkerAgent::setAutoconnectToWorkers(ErrorString*, bool value)
 {
     m_state->setBoolean(WorkerAgentState::autoconnectToWorkers, value);
 }
 
 void InspectorWorkerAgent::setTracingSessionId(const String& sessionId)
 {
     m_tracingSessionId = sessionId;
     if (sessionId.isEmpty())
         return;
-    for (WorkerIds::iterator it = m_workerIds.begin(); it != m_workerIds.end(); ++it)
-        it->key->writeTimelineStartedEvent(sessionId);
+    for (WorkerChannels::iterator it = m_idToChannel.begin(); it != m_idToChannel.end(); ++it)
+        it->value->proxy()->writeTimelineStartedEvent(it->key, sessionId);

[yurys, 2014/11/14 13:25:26]

This will not write events for workers without connected front-end.

[alph, 2014/11/14 15:01:59]

Done.

 }
 
 bool InspectorWorkerAgent::shouldPauseDedicatedWorkerOnStart()
 {
     return m_state->getBoolean(WorkerAgentState::autoconnectToWorkers);
 }
 
 void InspectorWorkerAgent::didStartWorker(WorkerInspectorProxy* workerInspectorProxy, const KURL& url)
 {
     m_workerIds.set(workerInspectorProxy, url.string());
     if (m_frontend && m_state->getBoolean(WorkerAgentState::workerInspectionEnabled))
         createWorkerFrontendChannel(workerInspectorProxy, url.string());
-    if (!m_tracingSessionId.isEmpty())
-        workerInspectorProxy->writeTimelineStartedEvent(m_tracingSessionId);
 }
 
 void InspectorWorkerAgent::workerTerminated(WorkerInspectorProxy* proxy)
 {
     m_workerIds.remove(proxy);
     for (WorkerChannels::iterator it = m_idToChannel.begin(); it != m_idToChannel.end(); ++it) {
         if (proxy == it->value->proxy()) {
             m_frontend->workerTerminated(it->key);
             delete it->value;
             m_idToChannel.remove(it);
@@ skipping 20 matching lines @@
 void InspectorWorkerAgent::createWorkerFrontendChannel(WorkerInspectorProxy* workerInspectorProxy, const String& url)
 {
     WorkerFrontendChannel* channel = new WorkerFrontendChannel(m_frontend, workerInspectorProxy);
     m_idToChannel.set(channel->id(), channel);
 
     ASSERT(m_frontend);
     bool autoconnectToWorkers = m_state->getBoolean(WorkerAgentState::autoconnectToWorkers);
     if (autoconnectToWorkers)
         channel->connectToWorker();
     m_frontend->workerCreated(channel->id(), url, autoconnectToWorkers);
+    if (!m_tracingSessionId.isEmpty())
+        workerInspectorProxy->writeTimelineStartedEvent(channel->id(), m_tracingSessionId);
 }
 
 } // namespace blink