From db322f33ba13592f2492317e3f1a070454c97059 Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期四, 13 五月 2021 19:34:46 +0800
Subject: [PATCH] center alloc all msgs.
---
src/sendq.h | 14 ++++----------
1 files changed, 4 insertions(+), 10 deletions(-)
diff --git a/src/sendq.h b/src/sendq.h
index 0e565d5..862a1cc 100644
--- a/src/sendq.h
+++ b/src/sendq.h
@@ -37,7 +37,8 @@
typedef MQId Remote;
typedef bhome_msg::MsgI MsgI;
typedef std::string Content;
- typedef boost::variant2::variant<MsgI, Content> Data;
+ typedef int64_t Command;
+ typedef boost::variant2::variant<MsgI, Command> Data;
typedef std::function<void(const Data &)> OnMsgEvent;
struct MsgInfo {
Data data_;
@@ -47,23 +48,16 @@
typedef TimedMsg::TimePoint TimePoint;
typedef TimedMsg::Duration Duration;
- // template <class... Rest>
- // void Append(const MQId &id, Rest &&...rest)
- // {
- // Append(std::string((const char *) &id, sizeof(id)), std::forward<decltype(rest)>(rest)...);
- // }
-
void Append(const Remote addr, const MsgI msg, OnMsgEvent onExpire = OnMsgEvent())
{
msg.AddRef();
AppendData(addr, Data(msg), DefaultExpire(), onExpire);
}
- void Append(const Remote addr, Content &&content, OnMsgEvent onExpire = OnMsgEvent())
+ void Append(const Remote addr, const Command command, OnMsgEvent onExpire = OnMsgEvent())
{
- AppendData(addr, Data(std::move(content)), DefaultExpire(), onExpire);
+ AppendData(addr, Data(command), DefaultExpire(), onExpire);
}
bool TrySend(ShmMsgQueue &mq);
- // bool empty() const { return store_.empty(); }
private:
static TimePoint Now() { return TimedMsg::Clock::now(); }
--
Gitblit v1.8.0