fix sn tmp file flush thread not running in unittest
This commit is contained in:
parent
ae0a7453a0
commit
4d81ba0b8c
@ -183,6 +183,7 @@ public:
|
||||
tenant_ctx.set(tf_mgr);
|
||||
|
||||
ObTenantEnv::set_tenant(&tenant_ctx);
|
||||
SERVER_STORAGE_META_SERVICE.is_started_ = true;
|
||||
}
|
||||
|
||||
cell_cnt_ = COLS;
|
||||
|
@ -88,6 +88,7 @@ public:
|
||||
tenant_ctx.set(tf_mgr);
|
||||
|
||||
ObTenantEnv::set_tenant(&tenant_ctx);
|
||||
SERVER_STORAGE_META_SERVICE.is_started_ = true;
|
||||
}
|
||||
|
||||
row_.count_ = COLS;
|
||||
|
@ -343,6 +343,7 @@ void TestBackupIndexMerger::SetUp()
|
||||
tenant_ctx.set(tf_mgr);
|
||||
|
||||
ObTenantEnv::set_tenant(&tenant_ctx);
|
||||
SERVER_STORAGE_META_SERVICE.is_started_ = true;
|
||||
inner_init_();
|
||||
}
|
||||
|
||||
|
@ -138,6 +138,7 @@ void TestBackupIndexIterator::SetUp()
|
||||
tenant_ctx.set(tf_mgr);
|
||||
|
||||
ObTenantEnv::set_tenant(&tenant_ctx);
|
||||
SERVER_STORAGE_META_SERVICE.is_started_ = true;
|
||||
inner_init_();
|
||||
ASSERT_EQ(OB_SUCCESS, bandwidth_throttle_.init(1024 * 1024 * 60));
|
||||
}
|
||||
|
@ -214,6 +214,7 @@ void TestBackupMacroIndexMerger::SetUp()
|
||||
tenant_ctx.set(tf_mgr);
|
||||
|
||||
ObTenantEnv::set_tenant(&tenant_ctx);
|
||||
SERVER_STORAGE_META_SERVICE.is_started_ = true;
|
||||
inner_init_();
|
||||
}
|
||||
|
||||
|
@ -282,6 +282,7 @@ void TestBackupExternalSort::SetUp()
|
||||
tenant_ctx.set(tf_mgr);
|
||||
|
||||
ObTenantEnv::set_tenant(&tenant_ctx);
|
||||
SERVER_STORAGE_META_SERVICE.is_started_ = true;
|
||||
}
|
||||
|
||||
void TestBackupExternalSort::TearDown()
|
||||
|
@ -146,7 +146,7 @@ TEST_F(TestBlockManager, test_mark_and_sweep)
|
||||
EXPECT_EQ(OB_SUCCESS, tf_mgr->start());
|
||||
tenant_ctx.set(tf_mgr);
|
||||
ObTenantEnv::set_tenant(&tenant_ctx);
|
||||
|
||||
SERVER_STORAGE_META_SERVICE.is_started_ = true;
|
||||
ASSERT_EQ(0, OB_SERVER_BLOCK_MGR.block_map_.count());
|
||||
|
||||
const int blk_cnt = 100;
|
||||
|
@ -224,7 +224,7 @@ void TestCompactChunk::SetUp()
|
||||
tf_mgr->get_sn_file_manager().page_cache_controller_.write_buffer_pool_.default_wbp_memory_limit_ = 40*1024*1024;
|
||||
EXPECT_EQ(OB_SUCCESS, tf_mgr->start());
|
||||
tenant_ctx.set(tf_mgr);
|
||||
|
||||
SERVER_STORAGE_META_SERVICE.is_started_ = true;
|
||||
ObTenantEnv::set_tenant(&tenant_ctx);
|
||||
}
|
||||
|
||||
|
@ -174,6 +174,7 @@ void TestIndexBlockWriter::SetUp()
|
||||
tenant_ctx.set(tf_mgr);
|
||||
|
||||
ObTenantEnv::set_tenant(&tenant_ctx);
|
||||
SERVER_STORAGE_META_SERVICE.is_started_ = true;
|
||||
}
|
||||
|
||||
void TestIndexBlockWriter::TearDown()
|
||||
|
Loading…
x
Reference in New Issue
Block a user