Tried using CrossThreadPersistent for workerDebuggerAgents

Source/core/inspector/WorkerDebuggerAgent.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 28 matching lines @@
 namespace WebCore {
 
 namespace {
 
 Mutex& workerDebuggerAgentsMutex()
 {
     AtomicallyInitializedStatic(Mutex&, mutex = *new Mutex);
     return mutex;
 }
 
-typedef HashMap<WorkerThread*, WorkerDebuggerAgent*> WorkerDebuggerAgents;
+typedef CrossThreadPersistent<HeapHashMap<WorkerThread*, Member<WorkerDebuggerAgent> > > WorkerDebuggerAgents;
 
 WorkerDebuggerAgents& workerDebuggerAgents()
 {
-    DEFINE_STATIC_LOCAL(WorkerDebuggerAgents, agents, ());
+    DEFINE_STATIC_LOCAL(WorkerDebuggerAgents, agents, (new HeapHashMap<WorkerThread*, Member<WorkerDebuggerAgent> >()));
     return agents;
 }
 
+#if ENABLE(OILPAN)
+class WorkerDebuggerAgentRemover {
+public:
+    WorkerDebuggerAgentRemover(WorkerThread* thread)
+    {printf("WorkerDebuggerAgentRemover %p\n", this);
+        m_thread = thread;
+    }
+    ~WorkerDebuggerAgentRemover()
+    {printf("~WorkerDebuggerAgentRemover %p\n", this);
+        MutexLocker lock(workerDebuggerAgentsMutex());
+        ASSERT(workerDebuggerAgents()->contains(m_thread));
+        workerDebuggerAgents()->remove(m_thread);
+    }
+
+private:
+    WorkerThread* m_thread;
+};
+
+typedef CrossThreadPersistent<HeapHashMap<WeakMember<WorkerDebuggerAgent>, OwnPtr<WorkerDebuggerAgentRemover> > > WorkerDebuggerAgentRemovers;
+
+WorkerDebuggerAgentRemovers& workerDebuggerAgentRemovers()
+{
+    DEFINE_STATIC_LOCAL(WorkerDebuggerAgentRemovers, removers, (new HeapHashMap<WeakMember<WorkerDebuggerAgent>, OwnPtr<WorkerDebuggerAgentRemover> >()));
+    return removers;
+}
+#endif
 
 class RunInspectorCommandsTask FINAL : public ScriptDebugServer::Task {
 public:
     explicit RunInspectorCommandsTask(WorkerThread* thread)
         : m_thread(thread) { }
     virtual ~RunInspectorCommandsTask() { }
     virtual void run() OVERRIDE
     {
         // Process all queued debugger commands. WorkerThread is certainly
         // alive if this task is being executed.
         while (MessageQueueMessageReceived == m_thread->runLoop().runDebuggerTask(WorkerRunLoop::DontWaitForMessage)) { }
     }
 
 private:
     WorkerThread* m_thread;
 };
 
 } // namespace
 
-PassOwnPtr<WorkerDebuggerAgent> WorkerDebuggerAgent::create(WorkerScriptDebugServer* scriptDebugServer, WorkerGlobalScope* inspectedWorkerGlobalScope, InjectedScriptManager* injectedScriptManager)
+PassOwnPtrWillBeRawPtr<WorkerDebuggerAgent> WorkerDebuggerAgent::create(WorkerScriptDebugServer* scriptDebugServer, WorkerGlobalScope* inspectedWorkerGlobalScope, InjectedScriptManager* injectedScriptManager)
 {
-    return adoptPtr(new WorkerDebuggerAgent(scriptDebugServer, inspectedWorkerGlobalScope, injectedScriptManager));
+    return adoptPtrWillBeNoop(new WorkerDebuggerAgent(scriptDebugServer, inspectedWorkerGlobalScope, injectedScriptManager));
 }
 
 WorkerDebuggerAgent::WorkerDebuggerAgent(WorkerScriptDebugServer* scriptDebugServer, WorkerGlobalScope* inspectedWorkerGlobalScope, InjectedScriptManager* injectedScriptManager)
     : InspectorDebuggerAgent(injectedScriptManager)
     , m_scriptDebugServer(scriptDebugServer)
     , m_inspectedWorkerGlobalScope(inspectedWorkerGlobalScope)
-{
+{printf("WorkerDebuggerAgent::WorkerDebuggerAgent %p\n", this);
     MutexLocker lock(workerDebuggerAgentsMutex());
-    workerDebuggerAgents().set(inspectedWorkerGlobalScope->thread(), this);
+    WorkerThread* thread = inspectedWorkerGlobalScope->thread();
+    ASSERT(!workerDebuggerAgents()->contains(thread));
+    ASSERT(!workerDebuggerAgentRemovers()->contains(this));
+    workerDebuggerAgents()->add(thread, this);
+    // workerDebuggerAgentRemovers()->add(this, adoptPtr(new WorkerDebuggerAgentRemover(thread)));
 }
 
 WorkerDebuggerAgent::~WorkerDebuggerAgent()
+{printf("WorkerDebuggerAgent::~WorkerDebuggerAgent %p\n", this);
+#if !ENABLE(OILPAN)
+    MutexLocker lock(workerDebuggerAgentsMutex());
+    ASSERT(workerDebuggerAgents()->contains(m_inspectedWorkerGlobalScope->thread()));
+    workerDebuggerAgents()->remove(m_inspectedWorkerGlobalScope->thread());
+#endif
+}
+
+void WorkerDebuggerAgent::trace(Visitor* visitor)
 {
-    MutexLocker lock(workerDebuggerAgentsMutex());
-    ASSERT(workerDebuggerAgents().contains(m_inspectedWorkerGlobalScope->thread()));
-    workerDebuggerAgents().remove(m_inspectedWorkerGlobalScope->thread());
+    visitor->trace(m_inspectedWorkerGlobalScope);
+    InspectorDebuggerAgent::trace(visitor);
 }
 
 void WorkerDebuggerAgent::interruptAndDispatchInspectorCommands(WorkerThread* thread)
 {
     MutexLocker lock(workerDebuggerAgentsMutex());
-    WorkerDebuggerAgent* agent = workerDebuggerAgents().get(thread);
+    WorkerDebuggerAgent* agent = workerDebuggerAgents()->get(thread);
     if (agent)
         agent->m_scriptDebugServer->interruptAndRunTask(adoptPtr(new RunInspectorCommandsTask(thread)));
 }
 
 void WorkerDebuggerAgent::startListeningScriptDebugServer()
 {
     scriptDebugServer().addListener(this);
 }
 
 void WorkerDebuggerAgent::stopListeningScriptDebugServer()
@@ skipping 19 matching lines @@
 {
     // We don't need to mute console for workers.
 }
 
 void WorkerDebuggerAgent::unmuteConsole()
 {
     // We don't need to mute console for workers.
 }
 
 } // namespace WebCore