SyncSData.hh

 
#ifndef GRAMODS_NETWORK_SYNCSDATA
#define GRAMODS_NETWORK_SYNCSDATA
 
#include <gmNetwork/SyncData.hh>
#include <gmCore/InvalidArgument.hh>
 
BEGIN_NAMESPACE_GMNETWORK;
 
template<class TYPE>
class SyncSData
  : public SyncData {
 
public:
 
  SyncSData() { back = front = {}; }
 
  SyncSData(TYPE val) { back = front = val; }
 
  SyncSData(SyncSData<TYPE> &&s) {
    back = s.back;
    front = s.front;
  }
 
  operator TYPE () const {
    TYPE retval;
    {
      std::lock_guard<std::mutex> guard(const_cast<SyncSData<TYPE>*>(this)->lock);
      retval = front;
    }
    return retval;
  }
 
  TYPE operator*() const {
    TYPE retval;
    {
      std::lock_guard<std::mutex> guard(const_cast<SyncSData<TYPE>*>(this)->lock);
      retval = front;
    }
    return retval;
  }
 
  SyncSData<TYPE>& operator= (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 + sizeof(TYPE));
 
    char * m = reinterpret_cast<char*>(&back);
 
    for (size_t idx = 0; idx < 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))
      throw gmCore::InvalidArgument("incorrect data size for decoding");
 
    TYPE value;
    char * m = reinterpret_cast<char*>(&value);
 
    for (size_t idx = 0; idx < sizeof(TYPE); ++idx)
      m[idx] = d[idx + 1];
 
    back = value;
  }
 
  void update() override {
    std::lock_guard<std::mutex> guard(lock);
    front = back;
  }
 
private:
 
  TYPE front;
 
  TYPE back;
 
  std::mutex lock;
 
};
 
typedef SyncSData<bool> SyncSBool;
typedef SyncSData<int32_t> SyncSInt32;
typedef SyncSData<uint32_t> SyncSUInt32;
typedef SyncSData<int64_t> SyncSInt64;
typedef SyncSData<uint64_t> SyncSUInt64;
typedef SyncSData<float> SyncSFloat32;
typedef SyncSData<double> SyncSFloat64;
 
END_NAMESPACE_GMNETWORK;
 
#endif