syncConnectionCommand.h

   1 #ifndef _SYNCCONNECTIONCOMMAND_H
   2 #define _SYNCCONNECTIONCOMMAND_H
   3 #include <boost/archive/text_oarchive.hpp>
   4 #include <boost/archive/text_iarchive.hpp>
   5
   6 #include "connectionList.h"
   7 #include "threadUtils.hpp"
   8
   9 class SyncConnectionCommand
  10 {
  11 public:
  12         SyncConnectionCommand(ConnectionList & cl );
  13         SyncConnectionCommand(ConnectionList & cl ,u_int16_t mux);
  14         u_int16_t getMux() const;
  15
  16 private:
  17         SyncConnectionCommand(const SyncConnectionCommand &);
  18         ConnectionList & cl_;
  19         u_int16_t mux_;
  20   friend class boost::serialization::access;
  21   template<class Archive>
  22   void serialize(Archive & ar, const unsigned int version)
  23   {
  24                 Lock lock(cl_.getMutex());
  25     ar & mux_;
  26                 ConnectionParam & conn = cl_.getOrNewConnectionUnlocked(mux_);
  27                 ar & conn;
  28         }
  29 };
  30
  31
  32 #endif // _SYNCCOMMAND_H