ceph/src/rgw/driver/rados/rgw_sync_module.cc

   1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
   2 // vim: ts=8 sw=2 smarttab ft=cpp
   3
   4 #include "rgw_common.h"
   5 #include "rgw_coroutine.h"
   6 #include "rgw_cr_rados.h"
   7 #include "rgw_sync_module.h"
   8 #include "rgw_data_sync.h"
   9 #include "rgw_bucket.h"
  10
  11 #include "rgw_sync_module_log.h"
  12 #include "rgw_sync_module_es.h"
  13 #include "rgw_sync_module_aws.h"
  14
  15 #include <boost/asio/yield.hpp>
  16
  17 #define dout_subsys ceph_subsys_rgw
  18
  19 RGWMetadataHandler *RGWSyncModuleInstance::alloc_bucket_meta_handler()
  20 {
  21   return RGWBucketMetaHandlerAllocator::alloc();
  22 }
  23
  24 RGWBucketInstanceMetadataHandlerBase* RGWSyncModuleInstance::alloc_bucket_instance_meta_handler(rgw::sal::Driver* driver)
  25 {
  26   return RGWBucketInstanceMetaHandlerAllocator::alloc(driver);
  27 }
  28
  29 RGWStatRemoteObjCBCR::RGWStatRemoteObjCBCR(RGWDataSyncCtx *_sc,
  30                        rgw_bucket& _src_bucket, rgw_obj_key& _key) : RGWCoroutine(_sc->cct),
  31                                                           sc(_sc), sync_env(_sc->env),
  32                                                           src_bucket(_src_bucket), key(_key) {
  33 }
  34
  35 RGWCallStatRemoteObjCR::RGWCallStatRemoteObjCR(RGWDataSyncCtx *_sc,
  36                                                rgw_bucket& _src_bucket, rgw_obj_key& _key) : RGWCoroutine(_sc->cct),
  37                                                                                                  sc(_sc), sync_env(_sc->env),
  38                                                                                                  src_bucket(_src_bucket), key(_key) {
  39 }
  40
  41 int RGWCallStatRemoteObjCR::operate(const DoutPrefixProvider *dpp) {
  42   reenter(this) {
  43     yield {
  44       call(new RGWStatRemoteObjCR(sync_env->async_rados, sync_env->driver,
  45                                   sc->source_zone,
  46                                   src_bucket, key, &mtime, &size, &etag, &attrs, &headers));
  47     }
  48     if (retcode < 0) {
  49       ldpp_dout(dpp, 10) << "RGWStatRemoteObjCR() returned " << retcode << dendl;
  50       return set_cr_error(retcode);
  51     }
  52     ldpp_dout(dpp, 20) << "stat of remote obj: z=" << sc->source_zone
  53                              << " b=" << src_bucket << " k=" << key
  54                              << " size=" << size << " mtime=" << mtime << dendl;
  55     yield {
  56       RGWStatRemoteObjCBCR *cb = allocate_callback();
  57       if (cb) {
  58         cb->set_result(mtime, size, etag, std::move(attrs), std::move(headers));
  59         call(cb);
  60       }
  61     }
  62     if (retcode < 0) {
  63       ldpp_dout(dpp, 10) << "RGWStatRemoteObjCR() callback returned " << retcode << dendl;
  64       return set_cr_error(retcode);
  65     }
  66     return set_cr_done();
  67   }
  68   return 0;
  69 }
  70
  71 void rgw_register_sync_modules(RGWSyncModulesManager *modules_manager)
  72 {
  73   RGWSyncModuleRef default_module(std::make_shared<RGWDefaultSyncModule>());
  74   modules_manager->register_module("rgw", default_module, true);
  75
  76   RGWSyncModuleRef archive_module(std::make_shared<RGWArchiveSyncModule>());
  77   modules_manager->register_module("archive", archive_module);
  78
  79   RGWSyncModuleRef log_module(std::make_shared<RGWLogSyncModule>());
  80   modules_manager->register_module("log", log_module);
  81
  82   RGWSyncModuleRef es_module(std::make_shared<RGWElasticSyncModule>());
  83   modules_manager->register_module("elasticsearch", es_module);
  84
  85   RGWSyncModuleRef aws_module(std::make_shared<RGWAWSSyncModule>());
  86   modules_manager->register_module("cloud", aws_module);
  87 }