]>
Commit | Line | Data |
---|---|---|
11fdf7f2 | 1 | // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- |
9f95a23c | 2 | // vim: ts=8 sw=2 smarttab ft=cpp |
11fdf7f2 | 3 | |
7c673cae FG |
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" | |
11fdf7f2 | 9 | #include "rgw_bucket.h" |
7c673cae FG |
10 | |
11 | #include "rgw_sync_module_log.h" | |
12 | #include "rgw_sync_module_es.h" | |
11fdf7f2 | 13 | #include "rgw_sync_module_aws.h" |
7c673cae | 14 | |
31f18b77 FG |
15 | #include <boost/asio/yield.hpp> |
16 | ||
7c673cae FG |
17 | #define dout_subsys ceph_subsys_rgw |
18 | ||
11fdf7f2 TL |
19 | RGWMetadataHandler *RGWSyncModuleInstance::alloc_bucket_meta_handler() |
20 | { | |
21 | return RGWBucketMetaHandlerAllocator::alloc(); | |
22 | } | |
23 | ||
1e59de90 | 24 | RGWBucketInstanceMetadataHandlerBase* RGWSyncModuleInstance::alloc_bucket_instance_meta_handler(rgw::sal::Driver* driver) |
11fdf7f2 | 25 | { |
1e59de90 | 26 | return RGWBucketInstanceMetaHandlerAllocator::alloc(driver); |
11fdf7f2 TL |
27 | } |
28 | ||
9f95a23c TL |
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) { | |
7c673cae FG |
33 | } |
34 | ||
9f95a23c TL |
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) { | |
7c673cae FG |
39 | } |
40 | ||
b3b6e05e | 41 | int RGWCallStatRemoteObjCR::operate(const DoutPrefixProvider *dpp) { |
7c673cae FG |
42 | reenter(this) { |
43 | yield { | |
1e59de90 | 44 | call(new RGWStatRemoteObjCR(sync_env->async_rados, sync_env->driver, |
9f95a23c TL |
45 | sc->source_zone, |
46 | src_bucket, key, &mtime, &size, &etag, &attrs, &headers)); | |
7c673cae FG |
47 | } |
48 | if (retcode < 0) { | |
b3b6e05e | 49 | ldpp_dout(dpp, 10) << "RGWStatRemoteObjCR() returned " << retcode << dendl; |
7c673cae FG |
50 | return set_cr_error(retcode); |
51 | } | |
b3b6e05e | 52 | ldpp_dout(dpp, 20) << "stat of remote obj: z=" << sc->source_zone |
9f95a23c | 53 | << " b=" << src_bucket << " k=" << key |
a8e16298 | 54 | << " size=" << size << " mtime=" << mtime << dendl; |
7c673cae FG |
55 | yield { |
56 | RGWStatRemoteObjCBCR *cb = allocate_callback(); | |
57 | if (cb) { | |
11fdf7f2 | 58 | cb->set_result(mtime, size, etag, std::move(attrs), std::move(headers)); |
7c673cae FG |
59 | call(cb); |
60 | } | |
61 | } | |
62 | if (retcode < 0) { | |
b3b6e05e | 63 | ldpp_dout(dpp, 10) << "RGWStatRemoteObjCR() callback returned " << retcode << dendl; |
7c673cae FG |
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 | ||
11fdf7f2 TL |
76 | RGWSyncModuleRef archive_module(std::make_shared<RGWArchiveSyncModule>()); |
77 | modules_manager->register_module("archive", archive_module); | |
78 | ||
7c673cae FG |
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); | |
11fdf7f2 TL |
84 | |
85 | RGWSyncModuleRef aws_module(std::make_shared<RGWAWSSyncModule>()); | |
86 | modules_manager->register_module("cloud", aws_module); | |
7c673cae | 87 | } |