Boost-users

boost-users@lists.boost.org

September 2010

222 participants
262 discussions

Re: [Boost-users] Boost.Serialization: Restoringobjectstate(preventcreation of a new object)?
by ray＠maya-studio.com 01 Sep '10

01 Sep '10

I've ended up with the following solution: #include <fstream> #include <iostream> #include <boost/archive/xml_iarchive.hpp> #include <boost/archive/xml_oarchive.hpp> #include <boost/archive/text_iarchive.hpp> #include <boost/archive/text_oarchive.hpp> #include <boost/serialization/export.hpp> #include <boost/foreach.hpp> #define _SERIALIZATION_FUNC(CLASS_NAME, ARCH_TYPE) \ public: \ virtual void Serialize(ARCH_TYPE& ar) \ { \ CLASS_NAME& x = *static_cast<CLASS_NAME*>(this); \ ar & BOOST_SERIALIZATION_NVP(x); \ } #define SERIALIZATION(CLASS_NAME) \ public: \ _SERIALIZATION_FUNC(CLASS_NAME, boost::archive::text_iarchive) \ _SERIALIZATION_FUNC(CLASS_NAME, boost::archive::text_oarchive) \ _SERIALIZATION_FUNC(CLASS_NAME, boost::archive::xml_iarchive) \ _SERIALIZATION_FUNC(CLASS_NAME, boost::archive::xml_oarchive) \ private: \ friend class boost::serialization::access; \ template<typename TArchive> \ void serialize(TArchive & ar, const unsigned int version /*file_version*/) class A { public: A() : m_a(0) {} protected: int m_a; private: SERIALIZATION(A) { ar & BOOST_SERIALIZATION_NVP(m_a); } }; class B : public A { public: B() : m_b(0) {} protected: int m_b; private: SERIALIZATION(B) { ar & BOOST_SERIALIZATION_BASE_OBJECT_NVP(A); ar & BOOST_SERIALIZATION_NVP(m_b); } }; BOOST_CLASS_EXPORT(B) int main(int argc, char* argv[]) { // ... A a; B b; std::list<A*> lst; // List of A* pointers lst.push_back(&a); // Base class lst.push_back(&b); // Derived //... // Save { std::ofstream ofs("c:/test.xml"); boost::archive::xml_oarchive oa(ofs); BOOST_FOREACH(A* pA, lst) { pA->Serialize(oa); } } //... // Restore { std::ifstream is("c:/test.xml"); boost::archive::xml_iarchive ia(is); BOOST_FOREACH(A* pA, lst ) { pA->Serialize(ia); } } //... } Everything works as expected (my classes can live with a few additional virtual functions :). And thank you for creating this excellent serialization library! Ray

1 0

Using Boost.MPI with gather , data becomes overwritten after gather operation
by hgc-01134＠hkedcity.net wong 01 Sep '10

01 Sep '10

Hi, I am trying to use Boost.MPI to do a very simple program that 1. Processes from different ranks do a gather operation 2. The gather operation will gather the CoProcessInfo ( which is just a data structure of rank# and hostname) into a vector 3. After the gather operation, Rank 0 will print the CoProcessInfo one by one in the vector. ------------------------------------------------------------------------------------------------------------------------------------------------------ My testing environment consists of TWO virtual machine ( each of the machine has two cores ): Centos 5.5 mpich2 Boost.mpich2 Boost 1.41 mpiexec ------------------------------------------------------------------------------------------------------------------------------------------------------ The expected output of the program should be something like ( just an example order of ranks ): Host VM1, Rank 0 Host VM1, Rank 1 Host VM2, Rank 2 Host VM2, Rank 3 ---------------------------------------------------------------------------------------------------------------------------------------------------------- However, I got something like: ( just an example order of ranks ), the hostname is incorrect after gather operation ( three VM2 appears!) Host VM1, Rank 0 Host VM2, Rank 1 Host VM2, Rank 2 Host VM2, Rank 3 I found that each process CAN correctly found out the hostname and rank#, however, the data will become a bit like overwritten, after the gather operation. Thank you very much. ------------------------------------------- Source Code ------------------------------------------------------------------- #include <boost/asio/ip/host_name.hpp> #include <iostream> #include <vector> #include <string> #include <boost/mpi/environment.hpp> #include <boost/mpi/communicator.hpp> #include <boost/mpi.hpp> #include <boost/archive/text_oarchive.hpp> #include <boost/archive/text_iarchive.hpp> #include <sstream> #include <fstream> using namespace std; namespace mpi = boost::mpi; class CoProcessInfo { private: string hostname; int rank; friend class boost::serialization::access; template<class Archive> void serialize(Archive & ar, const unsigned int /* version */) { ar & hostname & rank; } public: CoProcessInfo() { hostname = boost::asio::ip::host_name(); rank = 0; } void setRank(int _rank) { rank = _rank; } string getHostname() const { return hostname; } int getRank() const { return rank; } }; int main(int argc, char* argv[]) { int myrank; mpi::environment env(argc, argv); mpi::communicator world; myrank = world.rank(); CoProcessInfo localInfo; localInfo.setRank( myrank ); std::vector<CoProcessInfo> coProcInfo; mpi::gather(world, localInfo, coProcInfo, 0); if( myrank == 0 ){ for (std::vector<CoProcessInfo>::const_iterator it = coProcInfo.begin(); it !=coProcInfo.end(); ++it) { cout << endl << " Host : " << it->getHostname() << " , Rank : " << it->getRank() << endl; } } return 0; } ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- Regards, Joseph

2 1

Jump to page: