virtual bool is_connected() = 0;
- Messenger *get_messenger() {
+ Messenger *get_messenger() const {
return msgr;
}
virtual void mark_disposable() = 0;
- int get_peer_type() { return peer_type; }
+ int get_peer_type() const { return peer_type; }
void set_peer_type(int t) { peer_type = t; }
- bool peer_is_mon() { return peer_type == CEPH_ENTITY_TYPE_MON; }
- bool peer_is_mds() { return peer_type == CEPH_ENTITY_TYPE_MDS; }
- bool peer_is_osd() { return peer_type == CEPH_ENTITY_TYPE_OSD; }
- bool peer_is_client() { return peer_type == CEPH_ENTITY_TYPE_CLIENT; }
+ bool peer_is_mon() const { return peer_type == CEPH_ENTITY_TYPE_MON; }
+ bool peer_is_mds() const { return peer_type == CEPH_ENTITY_TYPE_MDS; }
+ bool peer_is_osd() const { return peer_type == CEPH_ENTITY_TYPE_OSD; }
+ bool peer_is_client() const { return peer_type == CEPH_ENTITY_TYPE_CLIENT; }
- const entity_addr_t& get_peer_addr() { return peer_addr; }
+ const entity_addr_t& get_peer_addr() const { return peer_addr; }
void set_peer_addr(const entity_addr_t& a) { peer_addr = a; }
uint64_t get_features() const { return features; }
void set_features(uint64_t f) { features = f; }
void set_feature(uint64_t f) { features |= f; }
- void post_rx_buffer(ceph_tid_t tid, bufferlist& bl) {
+ void post_rx_buffer(ceph_tid_t tid, const bufferlist& bl) {
Mutex::Locker l(lock);
++rx_buffers_version;
rx_buffers[tid] = pair<bufferlist,int>(bl, rx_buffers_version);
int32_t m_preferred;
pg_t() : m_pool(0), m_seed(0), m_preferred(-1) {}
- pg_t(ps_t seed, uint64_t pool, int pref=-1) {
- m_seed = seed;
- m_pool = pool;
- m_preferred = pref;
- }
+ pg_t(ps_t seed, uint64_t pool, int pref=-1) :
+ m_pool(pool), m_seed(seed), m_preferred(pref) {}
+ pg_t(const ceph_pg& cpg) :
+ m_pool(cpg.pool), m_seed(cpg.ps), m_preferred((__s16)cpg.preferred) {}
- pg_t(const ceph_pg& cpg) {
- m_pool = cpg.pool;
- m_seed = cpg.ps;
- m_preferred = (__s16)cpg.preferred;
+ pg_t(const old_pg_t& opg) {
+ *this = opg.v;
}
+
old_pg_t get_old_pg() const {
old_pg_t o;
assert(m_pool < 0xffffffffull);
o.v.preferred = (__s16)m_preferred;
return o;
}
- pg_t(const old_pg_t& opg) {
- *this = opg.v;
- }
ps_t ps() const {
return m_seed;