sync.h

Go to the documentation of this file.

#pragma once
#include "./base.h"
#include "webcface/common/encoding.h"
#include <unordered_map>
#include <chrono>
 
#ifndef MSGPACK_DEFINE_MAP
#define MSGPACK_DEFINE_MAP(...)
#endif
 
WEBCFACE_NS_BEGIN
namespace message {
 
struct SyncInit : public MessageBase<MessageKind::sync_init> {
    SharedString member_name;
    unsigned int member_id;
    std::string lib_name;
    std::string lib_ver;
    std::string addr;
 
    MSGPACK_DEFINE_MAP(MSGPACK_NVP("M", member_name),
                       MSGPACK_NVP("m", member_id), MSGPACK_NVP("l", lib_name),
                       MSGPACK_NVP("v", lib_ver), MSGPACK_NVP("a", addr))
};
 
struct SyncInitEnd : public MessageBase<MessageKind::sync_init_end> {
    std::string svr_name;
    std::string ver;
    unsigned int member_id;
    std::string hostname;
    MSGPACK_DEFINE_MAP(MSGPACK_NVP("n", svr_name), MSGPACK_NVP("v", ver),
                       MSGPACK_NVP("m", member_id), MSGPACK_NVP("h", hostname))
};
struct Ping : public MessageBase<MessageKind::ping> {
    Ping() = default;
};
struct PingStatus : public MessageBase<MessageKind::ping_status> {
    std::shared_ptr<std::unordered_map<unsigned int, int>> status;
    MSGPACK_DEFINE_MAP(MSGPACK_NVP("s", status))
};
struct PingStatusReq : public MessageBase<MessageKind::ping_status_req> {
    PingStatusReq() = default;
};
struct Sync : public MessageBase<MessageKind::sync> {
    unsigned int member_id; 
    std::uint64_t time;
    Sync(unsigned int member_id,
         const std::chrono::system_clock::time_point &time)
        : member_id(member_id),
          time(std::chrono::duration_cast<std::chrono::milliseconds>(
                   time.time_since_epoch())
                   .count()) {}
    Sync() : Sync(0, std::chrono::system_clock::now()) {}
    Sync(const std::chrono::system_clock::time_point &time) : Sync(0, time) {}
    std::chrono::system_clock::time_point getTime() const {
        return std::chrono::system_clock::time_point(
            std::chrono::milliseconds(time));
    }
    MSGPACK_DEFINE_MAP(MSGPACK_NVP("m", member_id), MSGPACK_NVP("t", time))
};
 
} // namespace message
WEBCFACE_NS_END