RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2024-12-19 01:46:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

osd: remove MOSDPGMissing

Browse Source 
Removed 7c414c5dab (pre-bobtail).

Signed-off-by: Sage Weil <sage@redhat.com>
This commit is contained in:
Sage Weil 2017-02-06 23:24:33 -05:00
parent baa56a6534
commit 4ab0844887
6 changed files with 1 additions and 71 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
src/messages/MOSDPGMissing.h
View File

@ -1,57 +0,0 @@
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
/*
* Ceph - scalable distributed file system
*
* Copyright (C) 2010 Dreamhost
*
* This is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License version 2.1, as published by the Free Software
* Foundation. See file COPYING.
*
*/
#ifndef CEPH_MOSDPGMISSING_H
#define CEPH_MOSDPGMISSING_H
#include "msg/Message.h"
class MOSDPGMissing : public Message {
epoch_t epoch;
public:
pg_info_t info;
pg_missing_t missing;
epoch_t get_epoch() { return epoch; }
MOSDPGMissing() : Message(MSG_OSD_PG_MISSING) {}
MOSDPGMissing(version_t mv, const pg_info_t &info_,
const pg_missing_t &missing_)
: Message(MSG_OSD_PG_MISSING), epoch(mv), info(info_),
missing(missing_) { }
private:
~MOSDPGMissing() {}
public:
const char *get_type_name() const { return "pg_missing"; }
void print(ostream& out) const {
out << "pg_missing(" << info.pgid << " e" << epoch << ")";
}
void encode_payload(uint64_t features) {
::encode(epoch, payload);
::encode(info, payload);
::encode(missing, payload);
}
void decode_payload() {
bufferlist::iterator p = payload.begin();
::decode(epoch, p);
::decode(info, p);
missing.decode(p, info.pgid.pool());
}
};
#endif

4
src/msg/Message.cc
View File

@ -77,7 +77,6 @@ using namespace std;
#include "messages/MOSDPGInfo.h"
#include "messages/MOSDPGCreate.h"
#include "messages/MOSDPGTrim.h"
#include "messages/MOSDPGMissing.h"
#include "messages/MOSDScrub.h"
#include "messages/MOSDRepScrub.h"
#include "messages/MOSDPGScan.h"
@ -501,9 +500,6 @@ Message *decode_message(CephContext *cct, int crcflags,
case MSG_REMOVE_SNAPS:
m = new MRemoveSnaps;
break;
case MSG_OSD_PG_MISSING:
m = new MOSDPGMissing;
break;
case MSG_OSD_REP_SCRUB:
m = new MOSDRepScrub;
break;

2
src/msg/Message.h
View File

@ -85,7 +85,7 @@
#define MSG_REMOVE_SNAPS 90
#define MSG_OSD_SCRUB 91
#define MSG_OSD_PG_MISSING 92
//#define MSG_OSD_PG_MISSING 92 // obsolete
#define MSG_OSD_REP_SCRUB 93
#define MSG_OSD_PG_SCAN 94

6
src/osd/OSD.cc
View File

@ -85,7 +85,6 @@
#include "messages/MOSDPGTrim.h"
#include "messages/MOSDPGScan.h"
#include "messages/MOSDPGBackfill.h"
#include "messages/MOSDPGMissing.h"
#include "messages/MBackfillReserve.h"
#include "messages/MRecoveryReserve.h"
#include "messages/MOSDECSubOpWrite.h"
@ -6384,11 +6383,6 @@ void OSD::dispatch_op(OpRequestRef op)
case MSG_OSD_PG_TRIM:
handle_pg_trim(op);
break;
case MSG_OSD_PG_MISSING:
assert(0 ==
"received MOSDPGMissing; this message is supposed to be unused!?!");
break;
case MSG_OSD_BACKFILL_RESERVE:
handle_pg_backfill_reserve(op);
break;

1
src/osd/OSD.h
View File

@ -213,7 +213,6 @@ class ObjectStore;
class FuseStore;
class OSDMap;
class MLog;
class MOSDPGMissing;
class Objecter;
class Watch;

2
src/test/encoding/types.h
View File

@ -558,8 +558,6 @@ MESSAGE(MOSDPGCreate)
MESSAGE(MOSDPGInfo)
#include "messages/MOSDPGLog.h"
MESSAGE(MOSDPGLog)
#include "messages/MOSDPGMissing.h"
MESSAGE(MOSDPGMissing)
#include "messages/MOSDPGNotify.h"
MESSAGE(MOSDPGNotify)
#include "messages/MOSDPGQuery.h"