ceph/src/rgw/rgw_object_expirer.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 <errno.h>
   5 #include <iostream>
   6 #include <sstream>
   7 #include <string>
   8
   9
  10 #include "auth/Crypto.h"
  11
  12 #include "common/armor.h"
  13 #include "common/ceph_json.h"
  14 #include "common/config.h"
  15 #include "common/ceph_argparse.h"
  16 #include "common/Formatter.h"
  17 #include "common/errno.h"
  18
  19 #include "global/global_init.h"
  20
  21 #include "include/utime.h"
  22 #include "include/str_list.h"
  23
  24 #include "rgw_user.h"
  25 #include "rgw_bucket.h"
  26 #include "rgw_acl.h"
  27 #include "rgw_acl_s3.h"
  28 #include "rgw_log.h"
  29 #include "rgw_formats.h"
  30 #include "rgw_usage.h"
  31 #include "rgw_object_expirer_core.h"
  32
  33 #define dout_subsys ceph_subsys_rgw
  34
  35 static rgw::sal::Driver* driver = NULL;
  36
  37 class StoreDestructor {
  38   rgw::sal::Driver* driver;
  39
  40 public:
  41   explicit StoreDestructor(rgw::sal::Driver* _s) : driver(_s) {}
  42   ~StoreDestructor() {
  43     if (driver) {
  44       DriverManager::close_storage(driver);
  45     }
  46   }
  47 };
  48
  49 static void usage()
  50 {
  51   generic_server_usage();
  52 }
  53
  54 int main(const int argc, const char **argv)
  55 {
  56   auto args = argv_to_vec(argc, argv);
  57   if (args.empty()) {
  58     std::cerr << argv[0] << ": -h or --help for usage" << std::endl;
  59     exit(1);
  60   }
  61   if (ceph_argparse_need_usage(args)) {
  62     usage();
  63     exit(0);
  64   }
  65
  66   auto cct = global_init(NULL, args, CEPH_ENTITY_TYPE_CLIENT,
  67                          CODE_ENVIRONMENT_DAEMON,
  68                          CINIT_FLAG_UNPRIVILEGED_DAEMON_DEFAULTS);
  69
  70   for (std::vector<const char *>::iterator i = args.begin(); i != args.end(); ) {
  71     if (ceph_argparse_double_dash(args, i)) {
  72       break;
  73     }
  74   }
  75
  76   if (g_conf()->daemonize) {
  77     global_init_daemonize(g_ceph_context);
  78   }
  79
  80   common_init_finish(g_ceph_context);
  81
  82   const DoutPrefix dp(cct.get(), dout_subsys, "rgw object expirer: ");
  83   DriverManager::Config cfg;
  84   cfg.store_name = "rados";
  85   cfg.filter_name = "none";
  86   driver = DriverManager::get_storage(&dp, g_ceph_context, cfg, false, false, false, false, false);
  87   if (!driver) {
  88     std::cerr << "couldn't init storage provider" << std::endl;
  89     return EIO;
  90   }
  91
  92   /* Guard to not forget about closing the rados driver. */
  93   StoreDestructor store_dtor(driver);
  94
  95   RGWObjectExpirer objexp(driver);
  96   objexp.start_processor();
  97
  98   const utime_t interval(g_ceph_context->_conf->rgw_objexp_gc_interval, 0);
  99   while (true) {
 100     interval.sleep();
 101   }
 102
 103   /* unreachable */
 104
 105   return EXIT_SUCCESS;
 106 }