public:
Connection(CephContext *cct, Messenger *m)
- : RefCountedObject(cct),
+ // we are managed exlusively by ConnectionRef; make it so you can
+ // ConnectionRef foo = new Connection;
+ : RefCountedObject(cct, 0),
lock("Connection::lock"),
msgr(m),
priv(NULL),
pipe(NULL),
failed(false),
rx_buffers_version(0) {
- // we are managed exlusively by ConnectionRef; make it so you can
- // ConnectionRef foo = new Connection;
- nref.set(0);
}
~Connection() {
//generic_dout(0) << "~Connection " << this << dendl;
protected:
virtual ~Message() {
- assert(nref.read() == 0);
if (byte_throttler)
byte_throttler->put(payload.length() + middle.length() + data.length());
if (msg_throttler)