]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
rgw/services: remove unused RGWOTPCtl
authorCasey Bodley <cbodley@redhat.com>
Fri, 1 Dec 2023 21:51:11 +0000 (16:51 -0500)
committerCasey Bodley <cbodley@redhat.com>
Thu, 12 Sep 2024 20:54:58 +0000 (16:54 -0400)
Signed-off-by: Casey Bodley <cbodley@redhat.com>
src/rgw/driver/rados/rgw_otp.cc
src/rgw/driver/rados/rgw_otp.h
src/rgw/driver/rados/rgw_service.cc
src/rgw/driver/rados/rgw_service.h

index 07cc14f113b5fa432ab6f2f397d7ac69778e7f97..7ad279106ee808c10e6338d7a3d4a2f54b25d6e1 100644 (file)
@@ -55,7 +55,6 @@ public:
 
 
 class RGWOTPMetadataHandler : public RGWOTPMetadataHandlerBase {
-  friend class RGWOTPCtl;
 
   struct Svc {
     RGWSI_Zone *zone;
@@ -157,54 +156,6 @@ public:
   string get_type() override { return "otp"; }
 };
 
-
-RGWOTPCtl::RGWOTPCtl(RGWSI_Zone *zone_svc,
-                    RGWSI_OTP *otp_svc)
-{
-  svc.zone = zone_svc;
-  svc.otp = otp_svc;
-}
-
-
-void RGWOTPCtl::init(RGWOTPMetadataHandler *_meta_handler)
-{
-  meta_handler = _meta_handler;
-  be_handler = meta_handler->get_be_handler();
-}
-
-int RGWOTPCtl::read_all(const rgw_user& uid,
-                        RGWOTPInfo *info,
-                        optional_yield y,
-                        const DoutPrefixProvider *dpp,
-                        const GetParams& params)
-{
-  info->uid = uid;
-  return meta_handler->call([&](RGWSI_OTP_BE_Ctx& ctx) {
-    return svc.otp->read_all(ctx, uid, &info->devices, params.mtime, params.objv_tracker, y, dpp);
-  });
-}
-
-int RGWOTPCtl::store_all(const DoutPrefixProvider *dpp, 
-                         const RGWOTPInfo& info,
-                         optional_yield y,
-                         const PutParams& params)
-{
-  return meta_handler->call([&](RGWSI_OTP_BE_Ctx& ctx) {
-    return svc.otp->store_all(dpp, ctx, info.uid, info.devices, params.mtime, params.objv_tracker, y);
-  });
-}
-
-int RGWOTPCtl::remove_all(const DoutPrefixProvider *dpp,
-                          const rgw_user& uid,
-                          optional_yield y,
-                          const RemoveParams& params)
-{
-  return meta_handler->call([&](RGWSI_OTP_BE_Ctx& ctx) {
-    return svc.otp->remove_all(dpp, ctx, uid, params.objv_tracker, y);
-  });
-}
-
-
 RGWMetadataHandler *RGWOTPMetaHandlerAllocator::alloc()
 {
   return new RGWOTPMetadataHandler();
index 885e8abb8e1d74d0f93fba05734f0120d33abddc..1fca8d0b5c7d72d469e6b4f68dc9a07c022b6b17 100644 (file)
@@ -30,81 +30,3 @@ class RGWOTPMetaHandlerAllocator {
 public:
   static RGWMetadataHandler *alloc();
 };
-
-struct RGWOTPInfo {
-  rgw_user uid;
-  otp_devices_list_t devices;
-};
-
-
-class RGWOTPCtl
-{
-  struct Svc {
-    RGWSI_Zone *zone{nullptr};
-    RGWSI_OTP *otp{nullptr};
-  } svc;
-
-  RGWOTPMetadataHandler *meta_handler;
-  RGWSI_MetaBackend_Handler *be_handler;
-  
-public:
-  RGWOTPCtl(RGWSI_Zone *zone_svc,
-           RGWSI_OTP *otp_svc);
-
-  void init(RGWOTPMetadataHandler *_meta_handler);
-
-  struct GetParams {
-    RGWObjVersionTracker *objv_tracker{nullptr};
-    ceph::real_time *mtime{nullptr};
-
-    GetParams() {}
-
-    GetParams& set_objv_tracker(RGWObjVersionTracker *_objv_tracker) {
-      objv_tracker = _objv_tracker;
-      return *this;
-    }
-
-    GetParams& set_mtime(ceph::real_time *_mtime) {
-      mtime = _mtime;
-      return *this;
-    }
-  };
-
-  struct PutParams {
-    RGWObjVersionTracker *objv_tracker{nullptr};
-    ceph::real_time mtime;
-
-    PutParams() {}
-
-    PutParams& set_objv_tracker(RGWObjVersionTracker *_objv_tracker) {
-      objv_tracker = _objv_tracker;
-      return *this;
-    }
-
-    PutParams& set_mtime(const ceph::real_time& _mtime) {
-      mtime = _mtime;
-      return *this;
-    }
-  };
-
-  struct RemoveParams {
-    RGWObjVersionTracker *objv_tracker{nullptr};
-
-    RemoveParams() {}
-
-    RemoveParams& set_objv_tracker(RGWObjVersionTracker *_objv_tracker) {
-      objv_tracker = _objv_tracker;
-      return *this;
-    }
-  };
-
-  int read_all(const rgw_user& uid, RGWOTPInfo *info, optional_yield y,
-               const DoutPrefixProvider *dpp,
-               const GetParams& params = {});
-  int store_all(const DoutPrefixProvider *dpp, 
-                const RGWOTPInfo& info, optional_yield y,
-                const PutParams& params = {});
-  int remove_all(const DoutPrefixProvider *dpp, 
-                 const rgw_user& user, optional_yield y,
-                 const RemoveParams& params = {});
-};
index 5e7dd81c7162f873ad88108de1255cd6ca77b629..7aa6552278d3bab44bfa62ced2a1f98825802083 100644 (file)
@@ -404,7 +404,6 @@ int RGWCtlDef::init(RGWServices& svc, rgw::sal::Driver* driver,
                                 svc.bucket,
                                 svc.bucket_sync,
                                 svc.bi, svc.user));
-  otp.reset(new RGWOTPCtl(svc.zone, svc.otp));
 
   RGWBucketMetadataHandlerBase *bucket_meta_handler = static_cast<RGWBucketMetadataHandlerBase *>(meta.bucket.get());
   RGWBucketInstanceMetadataHandlerBase *bi_meta_handler = static_cast<RGWBucketInstanceMetadataHandlerBase *>(meta.bucket_instance.get());
@@ -429,8 +428,6 @@ int RGWCtlDef::init(RGWServices& svc, rgw::sal::Driver* driver,
               svc.datalog_rados,
                dpp);
 
-  otp->init((RGWOTPMetadataHandler *)meta.otp.get());
-
   return 0;
 }
 
@@ -457,7 +454,6 @@ int RGWCtl::init(RGWServices *_svc, rgw::sal::Driver* driver,
 
   user = _ctl.user.get();
   bucket = _ctl.bucket.get();
-  otp = _ctl.otp.get();
 
   r = meta.user->attach(meta.mgr);
   if (r < 0) {
index ec7f73cf6eb50fb94e7b853307ea40196ac677a1..13c84af830668c56f0dc7d6efa6e96d87998c849 100644 (file)
@@ -183,7 +183,6 @@ class RGWMetadataManager;
 class RGWMetadataHandler;
 class RGWUserCtl;
 class RGWBucketCtl;
-class RGWOTPCtl;
 
 template <class T>
 class RGWChainedCacheImpl;
@@ -208,7 +207,6 @@ struct RGWCtlDef {
 
   std::unique_ptr<RGWUserCtl> user;
   std::unique_ptr<RGWBucketCtl> bucket;
-  std::unique_ptr<RGWOTPCtl> otp;
 
   RGWCtlDef();
   ~RGWCtlDef();
@@ -238,7 +236,6 @@ struct RGWCtl {
 
   RGWUserCtl *user{nullptr};
   RGWBucketCtl *bucket{nullptr};
-  RGWOTPCtl *otp{nullptr};
 
   int init(RGWServices *_svc, rgw::sal::Driver* driver,
            librados::Rados& rados, const DoutPrefixProvider *dpp);