]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
osd/PG: kill __queue_query__ 24072/head
authorxie xingguo <xie.xingguo@zte.com.cn>
Fri, 14 Sep 2018 05:33:47 +0000 (13:33 +0800)
committerxie xingguo <xie.xingguo@zte.com.cn>
Fri, 14 Sep 2018 05:33:47 +0000 (13:33 +0800)
which has no consumbers...

Signed-off-by: xie xingguo <xie.xingguo@zte.com.cn>
src/osd/PG.cc
src/osd/PG.h

index a2466a99cb7d330a112f13ec098356e06ce3752a..e71a8ee2f5660142668f0a9a46f3d97fdc5fb95c 100644 (file)
@@ -6542,18 +6542,6 @@ void PG::queue_null(epoch_t msg_epoch,
                                         NullEvt())));
 }
 
-void PG::queue_query(epoch_t msg_epoch,
-                    epoch_t query_epoch,
-                    pg_shard_t from, const pg_query_t& q)
-{
-  dout(10) << "handle_query " << q << " from replica " << from << dendl;
-  queue_peering_event(
-    PGPeeringEventRef(
-      std::make_shared<PGPeeringEvent>(
-       msg_epoch, query_epoch,
-       MQuery(info.pgid, from, q, query_epoch))));
-}
-
 void PG::find_unfound(epoch_t queued, RecoveryCtx *rctx)
 {
   /*
index dc14dfb63ba7f650bca3c38baddb4cf37ccff0e3..faea29644843cf3206a2f155fbc859642c98e7e1 100644 (file)
@@ -414,8 +414,6 @@ public:
 
   void queue_peering_event(PGPeeringEventRef evt);
   void do_peering_event(PGPeeringEventRef evt, RecoveryCtx *rcx);
-  void queue_query(epoch_t msg_epoch, epoch_t query_epoch,
-                  pg_shard_t from, const pg_query_t& q);
   void queue_null(epoch_t msg_epoch, epoch_t query_epoch);
   void queue_flushed(epoch_t started_at);
   void handle_advance_map(