1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#pragma once
#include <iostream>
#include <seastar/core/future.hh>
#include "crimson/osd/osd_operation.h"
#include "osd/osd_types.h"
#include "osd/PGPeeringEvent.h"
#include "osd/PeeringState.h"
namespace ceph {
class Formatter;
}
namespace crimson::osd {
class OSD;
class ShardServices;
class PG;
class PeeringEvent : public OperationT<PeeringEvent> {
public:
static constexpr OperationTypeCode type = OperationTypeCode::peering_event;
class PGPipeline {
OrderedPipelinePhase await_map = {
"PeeringEvent::PGPipeline::await_map"
};
OrderedPipelinePhase process = {
"PeeringEvent::PGPipeline::process"
};
friend class PeeringEvent;
friend class PGAdvanceMap;
};
protected:
OrderedPipelinePhase::Handle handle;
PGPipeline &pp(PG &pg);
ShardServices &shard_services;
PeeringCtx ctx;
pg_shard_t from;
spg_t pgid;
float delay = 0;
PGPeeringEvent evt;
const pg_shard_t get_from() const {
return from;
}
const spg_t get_pgid() const {
return pgid;
}
const PGPeeringEvent &get_event() const {
return evt;
}
virtual void on_pg_absent();
virtual seastar::future<> complete_rctx(Ref<PG>);
virtual seastar::future<Ref<PG>> get_pg() = 0;
public:
template <typename... Args>
PeeringEvent(
ShardServices &shard_services, const pg_shard_t &from, const spg_t &pgid,
Args&&... args) :
shard_services(shard_services),
ctx{ceph_release_t::octopus},
from(from),
pgid(pgid),
evt(std::forward<Args>(args)...)
{}
template <typename... Args>
PeeringEvent(
ShardServices &shard_services, const pg_shard_t &from, const spg_t &pgid,
float delay, Args&&... args) :
shard_services(shard_services),
ctx{ceph_release_t::octopus},
from(from),
pgid(pgid),
delay(delay),
evt(std::forward<Args>(args)...)
{}
void print(std::ostream &) const final;
void dump_detail(ceph::Formatter* f) const final;
seastar::future<> start();
};
class RemotePeeringEvent : public PeeringEvent {
protected:
OSD &osd;
crimson::net::ConnectionRef conn;
void on_pg_absent() final;
seastar::future<> complete_rctx(Ref<PG> pg) override;
seastar::future<Ref<PG>> get_pg() final;
public:
class ConnectionPipeline {
OrderedPipelinePhase await_map = {
"PeeringRequest::ConnectionPipeline::await_map"
};
OrderedPipelinePhase get_pg = {
"PeeringRequest::ConnectionPipeline::get_pg"
};
friend class RemotePeeringEvent;
};
template <typename... Args>
RemotePeeringEvent(OSD &osd, crimson::net::ConnectionRef conn, Args&&... args) :
PeeringEvent(std::forward<Args>(args)...),
osd(osd),
conn(conn)
{}
private:
ConnectionPipeline &cp();
};
class LocalPeeringEvent final : public PeeringEvent {
protected:
seastar::future<Ref<PG>> get_pg() final;
Ref<PG> pg;
public:
template <typename... Args>
LocalPeeringEvent(Ref<PG> pg, Args&&... args) :
PeeringEvent(std::forward<Args>(args)...),
pg(pg)
{}
virtual ~LocalPeeringEvent();
};
}
|
