Oilpan: Add ThreadState cleanup callbacks for static thread-specific persistent.

third_party/WebKit/Source/platform/heap/HeapTest.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 479 matching lines @@
     volatile int m_gcCount;
     volatile int m_threadsToFinish;
 
 private:
     static void threadFunc(void* data)
     {
         reinterpret_cast<ThreadedTesterBase*>(data)->runThread();
     }
 };
 
+// Needed to give this variable a definition (the initializer above is only a
+// declaration), so that subclasses can use it.
+const int ThreadedTesterBase::numberOfThreads;
+
 class ThreadedHeapTester : public ThreadedTesterBase {
 public:
     static void test()
     {
         ThreadedTesterBase::test(new ThreadedHeapTester);
     }
 
 protected:
     using GlobalIntWrapperPersistent = CrossThreadPersistent<IntWrapper>;
 
@@ skipping 5966 matching lines @@
 
     persistentHeapVectorIntWrapper.append(&intWrapper);
     heapVectorIntWrapper.append(&intWrapper);
     EXPECT_EQ(1u, persistentHeapVectorIntWrapper.size());
     EXPECT_EQ(1u, heapVectorIntWrapper.size());
 
     EXPECT_EQ(persistentHeapVectorIntWrapper[0], heapVectorIntWrapper[0]);
     EXPECT_EQ(33, heapVectorIntWrapper[0]->value());
 }
 
+namespace {
+
+class ThreadedClearOnShutdownTester : public ThreadedTesterBase {
+public:
+    static void test()
+    {
+        IntWrapper::s_destructorCalls = 0;
+        ThreadedTesterBase::test(new ThreadedClearOnShutdownTester);
+        EXPECT_EQ(numberOfThreads, IntWrapper::s_destructorCalls);
+    }
+
+private:
+    void runThread() override
+    {
+        ThreadState::attach();
+        EXPECT_EQ(42, threadSpecificIntWrapper().value());
+        ThreadState::detach();
+        atomicDecrement(&m_threadsToFinish);
+    }
+
+    static IntWrapper& threadSpecificIntWrapper()
+    {
+        DEFINE_THREAD_SAFE_STATIC_LOCAL(
+            ThreadSpecific<Persistent<IntWrapper>>, intWrapper,
+            new ThreadSpecific<Persistent<IntWrapper>>);
+        Persistent<IntWrapper>& handle = *intWrapper;
+        if (!handle) {
+            handle = new IntWrapper(42);
+            handle.clearOnThreadShutdown();
+        }
+        return *handle;
+    }
+};
+
+} // namespace
+
+TEST(HeapTest, TestClearOnShutdown)
+{
+    ThreadedClearOnShutdownTester::test();
+}
+
 } // namespace blink