diff --git a/lib/rocksdb/env_spdk.cc b/lib/rocksdb/env_spdk.cc index 088e5c1ab..59f9f5aba 100644 --- a/lib/rocksdb/env_spdk.cc +++ b/lib/rocksdb/env_spdk.cc @@ -59,11 +59,7 @@ thread_local SpdkThreadCtx g_sync_args; static void set_channel() { - struct spdk_thread *thread; - if (g_fs != NULL && g_sync_args.channel == NULL) { - thread = spdk_thread_create("spdk_rocksdb", NULL); - spdk_set_thread(thread); g_sync_args.channel = spdk_fs_alloc_thread_ctx(g_fs); } } @@ -610,14 +606,10 @@ public: */ void SpdkInitializeThread(void) { - struct spdk_thread *thread; - if (g_fs != NULL) { if (g_sync_args.channel) { spdk_fs_free_thread_ctx(g_sync_args.channel); } - thread = spdk_thread_create("spdk_rocksdb", NULL); - spdk_set_thread(thread); g_sync_args.channel = spdk_fs_alloc_thread_ctx(g_fs); } }