]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
*** empty log message ***
authorsage <sage@29311d96-e01e-0410-9327-a35deaab8ce9>
Sun, 3 Jul 2005 17:23:39 +0000 (17:23 +0000)
committersage <sage@29311d96-e01e-0410-9327-a35deaab8ce9>
Sun, 3 Jul 2005 17:23:39 +0000 (17:23 +0000)
git-svn-id: https://ceph.svn.sf.net/svnroot/ceph@390 29311d96-e01e-0410-9327-a35deaab8ce9

ceph/msg/MPIMessenger.cc

index d5aea92b4b4106926e346942212a76e5ea2233a3..4754b966eb34e5c70422af8280e77419e0d647e0 100644 (file)
@@ -243,9 +243,7 @@ int mpi_send(Message *m, int tag)
   if (m->empty_payload())
        m->encode_payload();
   msg_envelope_t *env = &m->get_envelope();
-  bufferlist blist;
-  blist.claim( m->get_payload() );
-  env->nchunks = blist.buffers().size();
+  env->nchunks = m->get_payload().buffers().size();
 
   dout(7) << "sending " << *m << " to " << MSG_ADDR_NICE(env->dest) << " (rank " << rank << ")" << endl;
 
@@ -264,8 +262,8 @@ int mpi_send(Message *m, int tag)
 
   // payload
   int i = 0;
-  for (list<bufferptr>::iterator it = blist.buffers().begin();
-          it != blist.buffers().end();
+  for (list<bufferptr>::iterator it = m->get_payload().buffers().begin();
+          it != m->get_payload().buffers().end();
           it++) {
        dout(DBLVL) << "mpi_sending frag " << i << " len " << (*it).length() << endl;
        MPI_Request *req = new MPI_Request;