X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Frgw%2Frgw_civetweb_frontend.cc;fp=src%2Fceph%2Fsrc%2Frgw%2Frgw_civetweb_frontend.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=8cf7a20b0dc0110f355f95ecb633a0c651de3919;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git

diff --git a/src/ceph/src/rgw/rgw_civetweb_frontend.cc b/src/ceph/src/rgw/rgw_civetweb_frontend.cc
deleted file mode 100644
index 8cf7a20..0000000
--- a/src/ceph/src/rgw/rgw_civetweb_frontend.cc
+++ /dev/null
@@ -1,96 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-
-#include <set>
-#include <string>
-
-#include <boost/utility/string_ref.hpp>
-
-#include "rgw_frontend.h"
-#include "rgw_client_io_filters.h"
-
-#define dout_subsys ceph_subsys_rgw
-
-static int civetweb_callback(struct mg_connection* conn)
-{
-  const struct mg_request_info* const req_info = mg_get_request_info(conn);
-  return static_cast<RGWCivetWebFrontend *>(req_info->user_data)->process(conn);
-}
-
-int RGWCivetWebFrontend::process(struct mg_connection*  const conn)
-{
-  /* Hold a read lock over access to env.store for reconfiguration. */
-  RWLock::RLocker lock(env.mutex);
-
-  RGWCivetWeb cw_client(conn);
-  auto real_client_io = rgw::io::add_reordering(
-                          rgw::io::add_buffering(dout_context,
-                            rgw::io::add_chunking(
-                              rgw::io::add_conlen_controlling(
-                                &cw_client))));
-  RGWRestfulIO client_io(dout_context, &real_client_io);
-
-  RGWRequest req(env.store->get_new_req_id());
-  int ret = process_request(env.store, env.rest, &req, env.uri_prefix,
-                            *env.auth_registry, &client_io, env.olog);
-  if (ret < 0) {
-    /* We don't really care about return code. */
-    dout(20) << "process_request() returned " << ret << dendl;
-  }
-
-  /* Mark as processed. */
-  return 1;
-}
-
-int RGWCivetWebFrontend::run()
-{
-  auto& conf_map = conf->get_config_map();
-  string port_str;
-
-  set_conf_default(conf_map, "num_threads",
-                   std::to_string(g_conf->rgw_thread_pool_size));
-  set_conf_default(conf_map, "decode_url", "no");
-  set_conf_default(conf_map, "enable_keep_alive", "yes");
-  set_conf_default(conf_map, "validate_http_method", "no");
-  set_conf_default(conf_map, "canonicalize_url_path", "no");
-  set_conf_default(conf_map, "enable_auth_domain_check", "no");
-  conf->get_val("port", "80", &port_str);
-  std::replace(port_str.begin(), port_str.end(), '+', ',');
-  conf_map["listening_ports"] = port_str;
-
-  /* Set run_as_user. This will cause civetweb to invoke setuid() and setgid()
-   * based on pw_uid and pw_gid obtained from pw_name. */
-  std::string uid_string = g_ceph_context->get_set_uid_string();
-  if (! uid_string.empty()) {
-    conf_map["run_as_user"] = std::move(uid_string);
-  }
-
-  /* Prepare options for CivetWeb. */
-  const std::set<boost::string_ref> rgw_opts = { "port", "prefix" };
-
-  std::vector<const char*> options;
-
-  for (const auto& pair : conf_map) {
-    if (! rgw_opts.count(pair.first)) {
-      /* CivetWeb doesn't understand configurables of the glue layer between
-       * it and RadosGW. We need to strip them out. Otherwise CivetWeb would
-       * signalise an error. */
-      options.push_back(pair.first.c_str());
-      options.push_back(pair.second.c_str());
-
-      dout(20) << "civetweb config: " << pair.first
-               << ": " << pair.second << dendl;
-    }
-  }
-
-  options.push_back(nullptr);
-  /* Initialize the CivetWeb right now. */
-  struct mg_callbacks cb;
-  memset((void *)&cb, 0, sizeof(cb));
-  cb.begin_request = civetweb_callback;
-  cb.log_message = rgw_civetweb_log_callback;
-  cb.log_access = rgw_civetweb_log_access_callback;
-  ctx = mg_start(&cb, this, options.data());
-
-  return ! ctx ? -EIO : 0;
-} /* RGWCivetWebFrontend::run */