Thread local without num limit

apache · Jul 2, 2023 · 4c9f1de · 4c9f1de
1 parent dc5a8ce
commit 4c9f1de
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 10 deletions.
diff --git a/src/butil/thread_key.cpp b/src/butil/thread_key.cpp
@@ -17,7 +17,6 @@
 
 #include "thread_key.h"
 #include "pthread.h"
-#include <errno.h>
 #include <deque>
 #include "butil/thread_local.h"
 

diff --git a/src/butil/thread_key.h b/src/butil/thread_key.h
@@ -163,7 +163,6 @@ T* ThreadLocal<T>::get() {
         }
         int rc = thread_setspecific(_key, ptr);
         if (rc != 0) {
-            errno = rc;
             DefaultDtor(ptr);
             return NULL;
         }

diff --git a/test/thread_key_unittest.cpp b/test/thread_key_unittest.cpp
@@ -53,7 +53,6 @@ TEST(ThreadLocalTest, sanity) {
             std::unique_ptr<int> data(new int(1));
             int *raw_data = data.get();
             ASSERT_EQ(0, butil::thread_key_create(key, NULL));
-            ASSERT_NE(0, butil::thread_key_create(key, NULL));
 
             ASSERT_EQ(NULL, butil::thread_getspecific(key));
             ASSERT_EQ(0, butil::thread_setspecific(key, (void *)raw_data));
@@ -130,7 +129,7 @@ TEST(ThreadLocalTest, thread_key_create_and_delete) {
     }
 }
 
-void* ThreadLocalFun(void* arg) {
+void* ThreadLocalFunc(void* arg) {
     auto thread_locals = (std::vector<ThreadLocal<int>*>*)arg;
     std::vector<int> expects(thread_locals->size(), 0);
     for (auto tl : *thread_locals) {
@@ -148,7 +147,7 @@ void* ThreadLocalFun(void* arg) {
     }
 }
 
-void TestThreadLocalMultiThread() {
+TEST(ThreadLocalTest, thread_local_multi_thread) {
     g_stopped = false;
     int thread_local_num = 20480;
     std::vector<ThreadLocal<int>*> args(thread_local_num, NULL);
@@ -159,7 +158,7 @@ void TestThreadLocalMultiThread() {
     const int thread_num = 8;
     pthread_t threads[thread_num];
     for (int i = 0; i < thread_num; ++i) {
-        ASSERT_EQ(0, pthread_create(&threads[i], NULL, ThreadLocalFun, &args));
+        ASSERT_EQ(0, pthread_create(&threads[i], NULL, ThreadLocalFunc, &args));
     }
 
     sleep(5);
@@ -172,10 +171,6 @@ void TestThreadLocalMultiThread() {
     }
 }
 
-TEST(ThreadLocalTest, thread_local_multi_thread) {
-    TestThreadLocalMultiThread();
-}
-
 struct BAIDU_CACHELINE_ALIGNMENT ThreadKeyArg {
     std::vector<ThreadKey*> thread_keys;
     bool ready_delete = false;