2013-08-14 3 views
3

Я пытаюсь использовать boost :: mpi :: broadcast для отправки производного класса ко всем узлам с помощью указателя базового класса. Для этого я использую библиотеку boost :: serialization для сериализации моих классов. Мой код, однако, не компилируется, и я получаю ошибки «class boost :: mpi :: package_skeleton_iarchive» не имеет имени с именем «append», а «class boost :: mpi :: package_skeleton_iarchive» не имеет члена с именем «reset». "Boost :: serialization и boost :: mpi для передачи производного класса с помощью указателя базового класса

Вот грубый исходный код программы:

// Base.hpp 
#include <boost/serialization/serialization.hpp> 

class Base 
{ 
    public: 
     Base() {} 
     virtual ~Base() {} 

     virtual void foo() = 0; 
    private: 
     friend class boost::serialization::access; 

     template<class Archive> 
     void serialize(Archive& /*ar*/, const unsigned int /*version*/) {} 
} 

// Derived.hpp 
#include <boost/serialization/serialization.hpp> 
#include <boost/serialization/shared_ptr.hpp> 
#include <boost/serialization/vector.hpp> 
#include <boost/serialization/base_object.hpp> 
#include <boost/serialization/export.hpp> 
#include <boost/shared_ptr.hpp> 
#include <vector> 

#include "Base.hpp" 

class Derived : public Base 
{ 
    public: 
     Derived(int param); 
     virtual ~Derived(); 

     void foo(); 
    private: 
     int param_; 
     std::vector<boost::shared_ptr> bar_; 

     friend class boost::serialization::access; 

     template<class Archive> 
     void serialize(Archive& ar, const unsigned int /*version*/) 
     { 
      ar & param_; 
      ar & bar_; 

      ar & boost::serialization::base_object<Base>(*this); 
     } 
} 

namespace boost 
{ 
    namespace serialization 
    { 
     template<class Archive> 
     void load_construct_data(Archive& /*ar*/, Derived* d, 
      const unsigned int /*v*/) 
     { 
      ::new(d) Derived(0); 
     } 
    } 
} 

BOOST_CLASS_EXPORT_KEY(Derived) 

// Derived.cpp 
#include "Derived.hpp" 

Derived::Derived(int param) : param_(param) {} 
Derived::~Derived(){} 

Derived::foo() 
{ 
    // some stuff 
} 

BOOST_CLASS_EXPORT_IMPLEMENT(Derived) 

// Main.cpp 
#include <boost/mpi.hpp> 
#include <boost/serialization/serialization.hpp> 
#include <boost/shared_ptr.hpp> 

#include "Derived.hpp" 

int main(int argc, char* argv[]) 
{ 
    boost::shared_ptr<Base> sp; 

    if (world.rank() == 0) 
    { 
     sp = boost::shared_ptr<Base>(new Derived(5)); 

     boost::mpi::broadcast(world, sp, 0); 

     // produce some stuff 
    } else 
    { 
     while (1) 
     { 
      // consume some stuff 
     } 
    } 

    return 0; 
} 

BOOST_SERIALIZATION_ASSUME_ABSTRACT(Base) 

Я нашел только один Google Groups обсуждение этой проблемы, но не решение до сих пор https://groups.google.com/forum/#!msg/boost-developers-archive/Ee9_ilEDO7s/cJTy-8v5lEcJ. Как я могу получить это для компиляции? Я использую openmpi 1.2.8-17.4, gcc 4.5.1 и boost 1.54.

ответ

1

Я с благодарностью смог ответить на свой вопрос (я думаю.) Boost не обрабатывает сериализацию базового указателя правильно в сочетании с boost :: mpi :: packet_skeleton_iarchive. Затем решение должно использовать другой вид архива, например. text_iarchive/text_oarchive, вместо этого.

Например, вещать:

std::ostringstream oss; 
boost::archive::text_oarchive oa(oss); 
oa << value; 
std::string s = oss.str(); 
boost::mpi::broadcast(comm, s, root); 

И получить:

std::string s; 
boost::mpi::broadcast(comm, s, root); 
std::istringstream iss(s); 
boost::archive::text_iarchive ia(iss); 
ia >> value; 

 Смежные вопросы

  • Нет связанных вопросов^_^