From fa95ddd1a294ebad47cabf9e149ee7d789271044 Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期三, 14 四月 2021 19:45:09 +0800
Subject: [PATCH] use 2 buf to speed up sendq; socket auto start.
---
src/socket.h | 7 +++++--
1 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/src/socket.h b/src/socket.h
index 9b47e42..0b0b880 100644
--- a/src/socket.h
+++ b/src/socket.h
@@ -38,7 +38,9 @@
{
bool SendImpl(const void *valid_remote, const MsgI &imsg, SendQ::OnMsgEvent onExpire = SendQ::OnMsgEvent())
{
- send_buffer_->Append(*static_cast<const MQId *>(valid_remote), imsg, onExpire);
+ // if (!mq().TrySend(*(MQId *) valid_remote, imsg)) {
+ send_buffer_.Append(*static_cast<const MQId *>(valid_remote), imsg, onExpire);
+ // }
return true;
}
@@ -170,7 +172,8 @@
};
Synced<AsyncCBs> per_msg_cbs_;
- Synced<SendQ> send_buffer_;
+ SendQ send_buffer_;
+ // Synced<SendQ> send_buffer_;
};
#endif // end of include guard: SOCKET_GWTJHBPO
--
Gitblit v1.8.0