delete archive service

Co-authored-by: hnwyllmm <hnwyllmm@users.noreply.github.com>

Author: obdev

mittest/logservice/archiveservice/CMakeLists.txt

@@ -4,7 +4,6 @@
 #log_unittest(test_archive_file_utils)
 
 set(ARCHIVE_TEST_SRCS
-    basic_archive.cpp
     fake_archive_piece_mgr.cpp)
 
 add_library(archive_test ${ARCHIVE_TEST_SRCS})

src/logservice/CMakeLists.txt

@@ -210,26 +210,9 @@ ob_set_subtarget(ob_logservice logrouteservice
 ob_set_subtarget(ob_logservice archiveservice
   archiveservice/dynamic_buffer.cpp
   archiveservice/large_buffer_pool.cpp
-  archiveservice/ob_archive_allocator.cpp
   archiveservice/ob_archive_define.cpp
-  archiveservice/ob_archive_fetcher.cpp
   archiveservice/ob_archive_file_utils.cpp
-  archiveservice/ob_archive_io.cpp
-  archiveservice/ob_archive_persist_mgr.cpp
-  archiveservice/ob_archive_round_mgr.cpp
-  archiveservice/ob_archive_scheduler.cpp
-  archiveservice/ob_archive_sender.cpp
-  archiveservice/ob_archive_sequencer.cpp
-  archiveservice/ob_archive_service.cpp
-  archiveservice/ob_archive_task_queue.cpp
-  archiveservice/ob_archive_task.cpp
-  archiveservice/ob_archive_timer.cpp
   archiveservice/ob_archive_util.cpp
-  archiveservice/ob_ls_meta_record_task.cpp
-  archiveservice/ob_ls_meta_recorder.cpp
-  archiveservice/ob_ls_mgr.cpp
-  archiveservice/ob_ls_task.cpp
-  archiveservice/ob_start_archive_helper.cpp
 )
 
 ob_server_add_target(ob_logservice)

src/logservice/archiveservice/ob_archive_util.h

@@ -25,17 +25,6 @@ namespace archive
 {
 using oceanbase::palf::LSN;
 
-#define GET_LS_TASK_CTX(mgr, id)                             \
-    ObArchiveLSGuard guard(mgr);                                \
-    ObLSArchiveTask *ls_archive_task = NULL;                 \
-    if (OB_FAIL(mgr->get_ls_guard(id, guard))) {               \
-      ARCHIVE_LOG(WARN, "get ls guard failed", K(ret), K(id));    \
-    } else if (OB_ISNULL(ls_archive_task = guard.get_ls_task())) {  \
-      ret = OB_ERR_UNEXPECTED;                                              \
-      ARCHIVE_LOG(ERROR, "ls task is NULL", K(ret), K(id));       \
-    }                                                                       \
-    if (OB_SUCC(ret))
-
 int64_t cal_archive_file_id(const LSN &lsn, const int64_t N);
 // Not support concurrent
 struct SimpleQueue

src/logservice/restoreservice/ob_log_restore_allocator.cpp

@@ -60,7 +60,7 @@ char *ObLogRestoreAllocator::alloc_iterator_buffer(const int64_t size)
   char *data = NULL;
 
   if (OB_UNLIKELY(! inited_)) {
-    ARCHIVE_LOG_RET(WARN, OB_NOT_INIT, "ObArchiveAllocator not init");
+    ARCHIVE_LOG_RET(WARN, OB_NOT_INIT, "ObLogRestoreAllocator not init");
   } else if (OB_ISNULL(data = static_cast<char *>(iterator_buf_allocator_.acquire(size)))) {
     // alloc fail
   } else {

src/observer/omt/ob_multi_tenant.cpp

@@ -29,7 +29,6 @@
 #include "share/allocator/ob_shared_memory_allocator_mgr.h"   // ObSharedMemAllocMgr
 #include "share/ob_global_autoinc_service.h"
 #include "ob_tenant_mtl_helper.h"
-#include "logservice/archiveservice/ob_archive_service.h"
 #include "storage/concurrency_control/ob_multi_version_garbage_collector.h"
 #include "storage/tx/ob_tx_loop_worker.h"
 #include "storage/tx/ob_timestamp_service.h"
@@ -105,7 +104,6 @@ using namespace oceanbase::concurrency_control;
 using namespace oceanbase::transaction;
 using namespace oceanbase::transaction::tablelock;
 using namespace oceanbase::logservice;
-using namespace oceanbase::archive;
 using namespace oceanbase::observer;
 using namespace oceanbase::rootserver;
 using namespace oceanbase::blocksstable;
@@ -274,7 +272,6 @@ int ObMultiTenant::init(ObAddr myaddr,
     MTL_BIND2(mtl_new_default, ObTenantStorageMetaService::mtl_init, mtl_start_default, mtl_stop_default, mtl_wait_default, mtl_destroy_default);
 
     // other mtl
-    MTL_BIND2(mtl_new_default, ObArchiveService::mtl_init, mtl_start_default, mtl_stop_default, mtl_wait_default, mtl_destroy_default);
     MTL_BIND2(mtl_new_default, compaction::ObTenantTabletScheduler::mtl_init, mtl_start_default, mtl_stop_default, mtl_wait_default, mtl_destroy_default);
     MTL_BIND2(mtl_new_default, compaction::ObTenantMediumChecker::mtl_init, nullptr, nullptr, nullptr, mtl_destroy_default);
     MTL_BIND2(mtl_new_default, ObTabletTableUpdater::mtl_init, nullptr, mtl_stop_default, mtl_wait_default, mtl_destroy_default);

src/share/rc/ob_tenant_base.h

@@ -147,10 +147,6 @@ namespace datadict
 {
   class ObDataDictService;
 }
-namespace archive
-{
-  class ObArchiveService;
-}
 namespace compaction
 {
   class ObTenantCompactionProgressMgr;
@@ -335,7 +331,6 @@ using ObTableScanIteratorObjPool = common::ObServerObjectPool<oceanbase::storage
       storage::ObTenantFreezer*,                     \
       storage::checkpoint::ObCheckPointService *,    \
       storage::checkpoint::ObTabletGCService *,      \
-      archive::ObArchiveService*,                    \
       compaction::ObTenantTabletScheduler*,          \
       compaction::ObTenantMediumChecker*,            \
       storage::ObTenantCompactionMemPool*,           \

src/storage/tx_storage/ob_checkpoint_service.cpp

@@ -20,7 +20,6 @@
 #include "logservice/ob_log_service.h"
 #include "share/ob_global_stat_proxy.h"
 #include "observer/ob_server_struct.h"
-#include "logservice/archiveservice/ob_archive_service.h"
 
 namespace oceanbase
 {
@@ -159,10 +158,6 @@ void ObCheckPointService::ObCheckpointTask::runTimerTask()
       ObCheckpointExecutor *checkpoint_executor = nullptr;
       ObDataCheckpoint *data_checkpoint = nullptr;
       palf::LSN checkpoint_lsn;
-      palf::LSN archive_lsn;
-      SCN unused_archive_scn;
-      bool archive_force_wait = false;
-      bool archive_ignore = false;
       if (OB_FAIL(ls_svr->get_ls(ls->get_ls_id(), ls_handle, ObLSGetMod::APPLY_MOD))) {
         STORAGE_LOG(WARN, "get log stream failed", K(ret), K(ls->get_ls_id()));
       } else if (OB_ISNULL(ls = ls_handle.get_ls())) {
@@ -181,18 +176,8 @@ void ObCheckPointService::ObCheckpointTask::runTimerTask()
       } else if (OB_FAIL(ObGlobalStatProxy::get_change_stream_min_dep_lsn(
               *GCTX.sql_proxy_, MTL_ID(), false/*for_update*/, cs_min_dep_lsn_val))) {
         STORAGE_LOG(WARN, "get_change_stream_min_dep_lsn failed, skip constraint", KR(ret));
-      } else if (OB_FAIL(MTL(archive::ObArchiveService*)->get_ls_archive_progress(ls->get_ls_id(),
-              archive_lsn, unused_archive_scn, archive_force_wait, archive_ignore))) {
-        STORAGE_LOG(WARN, "get ls archive progress failed", K(ret), K(ls->get_ls_id()));
       } else {
         checkpoint_lsn = ls->get_clog_base_lsn();
-        if (! archive_force_wait || archive_ignore || archive_lsn >= checkpoint_lsn) {
-          // do nothing
-        } else {
-          STORAGE_LOG(TRACE, "archive_lsn small than checkpoint_lsn, set base_lsn with archive_lsn",
-              K(archive_lsn), K(checkpoint_lsn), KPC(ls));
-          checkpoint_lsn = archive_lsn;
-        }
 	palf::LSN cs_min_dep_lsn = palf::LSN(cs_min_dep_lsn_val);
 	if (cs_min_dep_lsn < checkpoint_lsn) {
           FLOG_INFO("[CHECKPOINT] constrain base_lsn by change_stream_min_dep_lsn",