struct AnonConnection : public Connection {
AnonConnection(CephContext *cct) : Connection(cct, NULL) {}
- int send_message(Message *m) {
+ int send_message(Message *m) override {
assert(!"send_message on anonymous connection");
}
- void send_keepalive() {
+ void send_keepalive() override {
assert(!"send_keepalive on anonymous connection");
}
- void mark_down() {
+ void mark_down() override {
// silently ignore
}
- void mark_disposable() {
+ void mark_disposable() override {
// silengtly ignore
}
- bool is_connected() { return false; }
+ bool is_connected() override { return false; }
};
//extract the original message and put it into the regular dispatch function
ostream& _conn_prefix(std::ostream *_dout);
- bool is_connected() {
+ bool is_connected() override {
Mutex::Locker l(lock);
return state >= STATE_OPEN && state <= STATE_OPEN_TAG_CLOSE;
}
}
// Only call when AsyncConnection first construct
void accept(int sd);
- int send_message(Message *m);
+ int send_message(Message *m) override;
- void send_keepalive();
- void mark_down();
- void mark_disposable() {
+ void send_keepalive() override;
+ void mark_down() override;
+ void mark_disposable() override {
Mutex::Locker l(lock);
policy.lossy = true;
}
void reset_pipe(Pipe* p);
- bool is_connected();
+ bool is_connected() override;
- int send_message(Message *m);
- void send_keepalive();
- void mark_down();
- void mark_disposable();
+ int send_message(Message *m) override;
+ void send_keepalive() override;
+ void mark_down() override;
+ void mark_disposable() override;
}; /* PipeConnection */
xio_connection_destroy(conn);
}
- bool is_connected() { return connected.read(); }
+ bool is_connected() override { return connected.read(); }
- int send_message(Message *m);
- void send_keepalive() {}
- virtual void mark_down();
+ int send_message(Message *m) override;
+ void send_keepalive() override {}
+ void mark_down() override;
int _mark_down(uint32_t flags);
- virtual void mark_disposable();
- int _mark_disposable(uint32_t flags);
+ virtual void mark_disposable() override;
+ int _mark_disposable(uint32_t flags) override;
const entity_inst_t& get_peer() const { return peer; }
return static_cast<XioLoopbackConnection*>(RefCountedObject::get());
}
- virtual bool is_connected() { return true; }
+ bool is_connected() override { return true; }
- int send_message(Message *m);
- void send_keepalive() {}
- void mark_down() {}
- void mark_disposable() {}
+ int send_message(Message *m) override;
+ void send_keepalive()i override {}
+ void mark_down() override {}
+ void mark_disposable() override {}
uint32_t get_seq() {
return seq.read();