| 59 | } |
| 60 | |
| 61 | void TearDown() override { |
| 62 | for (uint64_t i = 0; i < m_session_num; i++) { |
| 63 | if (m_cache_client_vec[i] != nullptr) { |
| 64 | m_cache_client_vec[i]->close(); |
| 65 | delete m_cache_client_vec[i]; |
| 66 | } |
| 67 | } |
| 68 | m_cache_server->stop(); |
| 69 | if (m_cache_server_thread->joinable()) { |
| 70 | m_cache_server_thread->join(); |
| 71 | } |
| 72 | delete m_cache_server; |
| 73 | delete m_cache_server_thread; |
| 74 | |
| 75 | std::remove(m_local_path.c_str()); |
| 76 | } |
| 77 | |
| 78 | CacheClient* create_session(uint64_t random_index) { |
| 79 | CacheClient* cache_client = new CacheClient(m_local_path, g_ceph_context); |