From: sage Date: Sat, 2 Jul 2005 18:56:56 +0000 (+0000) Subject: weird X-Git-Tag: v0.1~1999 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=cb8e50d6a326bebeea9c983f10e74a51eb5dd217;p=ceph.git weird git-svn-id: https://ceph.svn.sf.net/svnroot/ceph@382 29311d96-e01e-0410-9327-a35deaab8ce9 --- diff --git a/ceph/include/buffer.h b/ceph/include/buffer.h index c35f01e7106b8..933d41e72bec7 100644 --- a/ceph/include/buffer.h +++ b/ceph/include/buffer.h @@ -196,6 +196,7 @@ class bufferptr { // assignment operator bufferptr& operator=(const bufferptr& other) { + assert(0); // discard old discard_buffer(); diff --git a/ceph/include/bufferlist.h b/ceph/include/bufferlist.h index b726cb2db6b80..94a1729bc2451 100644 --- a/ceph/include/bufferlist.h +++ b/ceph/include/bufferlist.h @@ -32,18 +32,21 @@ class bufferlist { bdbout(1) << "bufferlist.cons " << this << endl; } bufferlist(bufferlist& bl) : _len(0) { - bdbout(1) << "bufferlist.cons " << this << endl; + bdbout(1) << "bufferlist.cons " << this << endl; // O(n) and stupid! _buffers = bl._buffers; _len = bl._len; } ~bufferlist() { bdbout(1) << "bufferlist.des " << this << endl; } - /* + bufferlist& operator=(bufferlist& bl) { - assert(0); // actually, this should be fine. + assert(0); // actually, this should be fine, just slow (O(n)) and stupid. + _buffers = bl._buffers; + _len = bl._len; + return *this; } - */ + // accessors list& buffers() { diff --git a/ceph/msg/TCPMessenger.cc b/ceph/msg/TCPMessenger.cc index f89412e60b92c..4cfb3c5a1c033 100644 --- a/ceph/msg/TCPMessenger.cc +++ b/ceph/msg/TCPMessenger.cc @@ -349,7 +349,9 @@ int tcp_send(Message *m) m->reset_payload(); m->encode_payload(); msg_envelope_t *env = &m->get_envelope(); - bufferlist blist = m->get_payload(); + bufferlist blist; + blist.claim( m->get_payload() ); + #ifdef TCP_KEEP_CHUNKS env->nchunks = blist.buffers().size(); #else diff --git a/ceph/tcpsyn.cc b/ceph/tcpsyn.cc index 1b2281eaea9b1..c80e8f0e224fc 100644 --- a/ceph/tcpsyn.cc +++ b/ceph/tcpsyn.cc @@ -93,7 +93,7 @@ int main(int oargc, char **oargv) { int world = tcpmessenger_world(); //cerr << "horrible hack remove me" << endl; - //if (myrank == 0) g_conf.debug_filer = 15; + //if (myrank == 0) g_conf.debug = 10; if (myrank == 0)