]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson: remove ms_get_authorizer() and friends
authorKefu Chai <kchai@redhat.com>
Thu, 25 Apr 2019 05:48:04 +0000 (13:48 +0800)
committerKefu Chai <kchai@redhat.com>
Sun, 28 Apr 2019 16:12:57 +0000 (00:12 +0800)
Signed-off-by: Kefu Chai <kchai@redhat.com>
src/crimson/common/auth_service.h [deleted file]
src/crimson/mon/MonClient.cc
src/crimson/mon/MonClient.h
src/crimson/net/Dispatcher.h
src/crimson/osd/chained_dispatchers.cc
src/crimson/osd/chained_dispatchers.h
src/crimson/osd/heartbeat.cc
src/crimson/osd/heartbeat.h
src/test/crimson/test_alien_echo.cc

diff --git a/src/crimson/common/auth_service.h b/src/crimson/common/auth_service.h
deleted file mode 100644 (file)
index 94c256d..0000000
+++ /dev/null
@@ -1,16 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-
-#pragma once
-
-#include "crimson/net/Fwd.h"
-
-class AuthAuthorizer;
-
-namespace ceph::common {
-class AuthService {
-public:
-  virtual AuthAuthorizer* get_authorizer(peer_type_t peer) const = 0;
-  virtual ~AuthService() = default;
-};
-}
index 235b4a56c86f8cecc053bcb258700d31cf86f371..de90d43da94cec5c880176e055d63936bcfb6141 100644 (file)
@@ -481,20 +481,6 @@ seastar::future<> Client::ms_handle_reset(ceph::net::ConnectionRef conn)
   }
 }
 
-AuthAuthorizer* Client::ms_get_authorizer(peer_type_t peer) const
-{
-  if (active_con) {
-    return active_con->get_authorizer(peer);
-  } else {
-    return nullptr;
-  }
-}
-
-AuthAuthorizer* Client::get_authorizer(peer_type_t peer) const
-{
-  return ms_get_authorizer(peer);
-}
-
 std::pair<std::vector<uint32_t>, std::vector<uint32_t>>
 Client::get_supported_auth_methods(int peer_type)
 {
index 852494db3984b5df740373db6cf98631f28b0d8f..96fa3182c7ac52db06bb83f1e3596d8d0a4719b8 100644 (file)
@@ -15,7 +15,6 @@
 
 #include "crimson/auth/AuthClient.h"
 #include "crimson/auth/AuthServer.h"
-#include "crimson/common/auth_service.h"
 #include "crimson/common/auth_handler.h"
 #include "crimson/net/Dispatcher.h"
 #include "crimson/net/Fwd.h"
@@ -43,7 +42,6 @@ namespace ceph::mon {
 class Connection;
 
 class Client : public ceph::net::Dispatcher,
-              public ceph::common::AuthService,
               public ceph::auth::AuthClient,
               public ceph::auth::AuthServer
 {
@@ -92,8 +90,6 @@ public:
   void sub_unwant(const std::string& what);
   bool sub_want_increment(const std::string& what, version_t start, unsigned flags);
   seastar::future<> renew_subs();
-  // AuthService methods
-  AuthAuthorizer* get_authorizer(peer_type_t peer) const override;
 
 private:
   // AuthServer methods
@@ -146,7 +142,6 @@ private:
   seastar::future<> ms_dispatch(ceph::net::Connection* conn,
                                MessageRef m) override;
   seastar::future<> ms_handle_reset(ceph::net::ConnectionRef conn) override;
-  AuthAuthorizer* ms_get_authorizer(peer_type_t peer) const override;
 
   seastar::future<> handle_monmap(ceph::net::Connection* conn,
                                  Ref<MMonMap> m);
index 7a725e2fccff245fbcc29c0386a6a57f90808725..8d6d9b71f9279eab308aeb63803df8d6ce40d409 100644 (file)
@@ -53,9 +53,6 @@ class Dispatcher {
                       bufferlist&) {
     return seastar::make_ready_future<msgr_tag_t, bufferlist>(0, bufferlist{});
   }
-  virtual AuthAuthorizer* ms_get_authorizer(peer_type_t) const {
-    return nullptr;
-  }
 
   // get the local dispatcher shard if it is accessed by another core
   virtual Dispatcher* get_local_shard() {
index 0473c8b00fe4b0d43946c299284c207db4a2cd5c..275e8678519b8786e9d3cdcafb96825d0cfa9ae2 100644 (file)
@@ -37,17 +37,3 @@ ChainedDispatchers::ms_handle_remote_reset(ceph::net::ConnectionRef conn) {
     return dispatcher->ms_handle_remote_reset(conn);
   });
 }
-
-AuthAuthorizer*
-ChainedDispatchers::ms_get_authorizer(peer_type_t peer_type) const
-{
-  // since dispatcher returns a nullptr if it does not have the authorizer,
-  // let's use the chain-of-responsibility pattern here.
-  for (auto dispatcher : dispatchers) {
-    if (auto auth = dispatcher->ms_get_authorizer(peer_type); auth) {
-      return auth;
-    }
-  }
-  // just give up
-  return nullptr;
-}       
index 1871e7416d04d3305784068ca4578a827d1c5114..4eda44f8111b791a0db9388f97ccee18e1e61347 100644 (file)
@@ -27,5 +27,4 @@ public:
   seastar::future<> ms_handle_connect(ceph::net::ConnectionRef conn) override;
   seastar::future<> ms_handle_reset(ceph::net::ConnectionRef conn) override;
   seastar::future<> ms_handle_remote_reset(ceph::net::ConnectionRef conn) override;
-  AuthAuthorizer* ms_get_authorizer(peer_type_t peer_type) const override;
 };
index f6c4e859e3429c42f5209951e1ce761474546ac0..9d8b1bb640c58aaa44c513e21d51ea9131c0fc31 100644 (file)
@@ -5,7 +5,6 @@
 #include "messages/MOSDPing.h"
 #include "messages/MOSDFailure.h"
 
-#include "crimson/common/auth_service.h"
 #include "crimson/common/config_proxy.h"
 #include "crimson/net/Connection.h"
 #include "crimson/net/Messenger.h"
@@ -304,11 +303,6 @@ seastar::future<> Heartbeat::handle_you_died()
   return seastar::now();
 }
 
-AuthAuthorizer* Heartbeat::ms_get_authorizer(peer_type_t peer) const
-{
-  return monc.get_authorizer(peer);
-}
-
 seastar::future<> Heartbeat::send_heartbeats()
 {
   using peers_item_t = typename peers_map_t::value_type;
index 923e26157097ff4f1da60b051b1099d89915d8ec..a066f144066f909843d260569872887879b0e53f 100644 (file)
@@ -47,7 +47,6 @@ public:
   seastar::future<> ms_dispatch(ceph::net::Connection* conn,
                                MessageRef m) override;
   seastar::future<> ms_handle_reset(ceph::net::ConnectionRef conn) override;
-  AuthAuthorizer* ms_get_authorizer(peer_type_t peer) const override;
 
 private:
   seastar::future<> handle_osd_ping(ceph::net::Connection* conn,
index 67a98c6dd3b86f9257d80b5b90882126120ba602..5b98350ca1b1824885c18d4c418ee89b3f173703 100644 (file)
@@ -58,10 +58,6 @@ struct Server {
       return seastar::make_ready_future<ceph::net::msgr_tag_t, bufferlist>(
           0, bufferlist{});
     }
-    std::unique_ptr<AuthAuthorizer> authorizer = std::make_unique<DummyAuthAuthorizer>();
-    AuthAuthorizer* ms_get_authorizer(peer_type_t) const override {
-      return authorizer.get();
-    }
   } dispatcher;
   Server(ceph::net::Messenger& msgr)
     : byte_throttler(ceph::net::conf.osd_client_message_size_cap),