data_store1.h

Go to the documentation of this file.

#pragma once
#include <mutex>
#include <optional>
#include <chrono>
#include "webcface/common/encoding.h"
#include "webcface/common/internal/map.h"
#include "webcface/field.h"
 
WEBCFACE_NS_BEGIN
namespace internal {
template <typename T>
class SyncDataStore1 {
    StrMap1<T> data_recv;
    StrMap1<bool> req;
    StrMap1<bool> req_send;
    StrSet1 entry;
 
  public:
    SharedString self_member_name;
    std::recursive_mutex mtx;
 
    explicit SyncDataStore1(const SharedString &name);
 
 
    bool addReq(const SharedString &member);
 
 
    bool clearReq(const SharedString &member);
 
    bool isSelf(const SharedString &member) const;
 
    void setRecv(const SharedString &member, const T &data);
 
    void clearEntry(const SharedString &from);
    void setEntry(const SharedString &from);
 
    bool getEntry(const SharedString &from);
    bool getEntry(const FieldBase &base);
 
    std::optional<T> getRecv(const SharedString &member);
    StrMap1<bool> transferReq();
};
 
#if WEBCFACE_SYSTEM_DLLEXPORT
extern template class SyncDataStore1<std::string>; // test用
extern template class SyncDataStore1<std::chrono::system_clock::time_point>;
#endif
 
} // namespace internal
WEBCFACE_NS_END