#include "PGPeeringEvent.h"
#include "common/dout.h"
#include "PeeringState.h"
-#include "PG.h"
#include "OSD.h"
#include "messages/MOSDPGRemove.h"
const PGPool &_pool,
OSDMapRef curmap,
DoutPrefixProvider *dpp,
- PeeringListener *pl,
- PG *pg)
- : state_history(pg),
- machine(this, cct, spgid, dpp, pl, pg, &state_history), cct(cct),
+ PeeringListener *pl)
+ : state_history(pl),
+ machine(this, cct, spgid, dpp, pl, &state_history), cct(cct),
spgid(spgid),
dpp(dpp),
pl(pl),
- pg(pg),
orig_ctx(0),
osdmap_ref(curmap),
pool(_pool),
#define psdout(x) ldout(context< PeeringMachine >().cct, x)
#define DECLARE_LOCALS \
- PG *pg = context< PeeringMachine >().pg; \
- std::ignore = pg; \
PeeringState *ps = context< PeeringMachine >().state; \
std::ignore = ps; \
PeeringListener *pl = context< PeeringMachine >().pl; \
#include "MissingLoc.h"
#include "common/LogClient.h"
-class PG;
-
struct PGPool {
CephContext* cct;
epoch_t cached_epoch;
spg_t spgid;
DoutPrefixProvider *dpp;
PeeringListener *pl;
- PG *pg;
utime_t event_time;
uint64_t event_count;
spg_t spgid,
DoutPrefixProvider *dpp,
PeeringListener *pl,
- PG *pg,
PGStateHistory *state_history) :
state(state),
state_history(state_history),
cct(cct), spgid(spgid),
dpp(dpp), pl(pl),
- pg(pg), event_count(0) {}
+ event_count(0) {}
/* Accessor functions for state methods */
ObjectStore::Transaction* get_cur_transaction() {
spg_t spgid;
DoutPrefixProvider *dpp;
PeeringListener *pl;
- PG *pg;
/// context passed in by state machine caller
PeeringCtx *orig_ctx;
const PGPool &pool,
OSDMapRef curmap,
DoutPrefixProvider *dpp,
- PeeringListener *pl,
- PG *pg);
+ PeeringListener *pl);
void set_backend_predicates(
IsPGReadablePredicate *is_readable,