SyncMData.hh

 
#ifndef GRAMODS_NETWORK_SYNCMDATA
#define GRAMODS_NETWORK_SYNCMDATA
 
#include <gmNetwork/SyncData.hh>
#include <gmCore/InvalidArgument.hh>
 
BEGIN_NAMESPACE_GMNETWORK;
 
template<class TYPE>
class SyncMData
  : public SyncData {
 
public:
 
  SyncMData() {}
 
  SyncMData(std::vector<TYPE> val) { back = front = val; }
 
  SyncMData(SyncMData<TYPE> &&s) {
    back = s.back;
    front = s.front;
  }
 
  operator std::vector<TYPE> () const {
    std::vector<TYPE> retval;
    {
      std::lock_guard<std::mutex> guard(const_cast<SyncMData<TYPE>*>(this)->lock);
      retval = front;
    }
    return retval;
  }
 
  TYPE operator[] (size_t idx) const {
    TYPE retval;
    {
      std::lock_guard<std::mutex> guard(const_cast<SyncMData<TYPE>*>(this)->lock);
      retval = front[idx];
    }
    return retval;
  }
 
  SyncMData<TYPE>& operator= (std::vector<TYPE> val) {
    {
      std::lock_guard<std::mutex> guard(lock);
      back = val;
    }
    SyncData::pushValue();
    return *this;
  }
 
protected:
 
  void encode(std::vector<char> &d) override {
    std::lock_guard<std::mutex> guard(lock);
 
    d.resize(1 + back.size() * sizeof(TYPE));
 
    char * m = reinterpret_cast<char*>(&back[0]);
 
    for (size_t idx = 0; idx < back.size() * sizeof(TYPE); ++idx) {
      d[idx + 1] = m[idx];
    }
  }
 
  void decode(std::vector<char> d) override {
    std::lock_guard<std::mutex> guard(lock);
 
    if ((d.size() - 1)%sizeof(TYPE) != 0)
      throw gmCore::InvalidArgument("incorrect data size for decoding");
 
    size_t vector_size = (d.size() - 1)/sizeof(TYPE);
 
    std::vector<TYPE> value;
    value.resize(vector_size);
    char * m = reinterpret_cast<char*>(&value[0]);
 
    for (size_t idx = 0; idx < vector_size * sizeof(TYPE); ++idx)
      m[idx] = d[idx + 1];
 
    back = std::move(value);
  }
 
  void update() override {
    std::lock_guard<std::mutex> guard(lock);
    front = back;
  }
 
private:
 
  std::vector<TYPE> front;
 
  std::vector<TYPE> back;
 
  std::mutex lock;
 
};
 
typedef SyncMData<char> SyncMBool;
typedef SyncMData<int32_t> SyncMInt32;
typedef SyncMData<int64_t> SyncMInt64;
typedef SyncMData<float> SyncMFloat32;
typedef SyncMData<double> SyncMFloat64;
 
END_NAMESPACE_GMNETWORK;
 
#endif