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.cpp | 8 ++++++--
1 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/src/socket.cpp b/src/socket.cpp
index b7ef4f3..0ba195a 100644
--- a/src/socket.cpp
+++ b/src/socket.cpp
@@ -32,9 +32,13 @@
ShmSocket::ShmSocket(Shm &shm, const MQId &id, const int len) :
run_(false), mq_(id, shm, len)
{
+ Start();
}
ShmSocket::ShmSocket(bhome_shm::SharedMemory &shm, const int len) :
- run_(false), mq_(shm, len) {}
+ run_(false), mq_(shm, len)
+{
+ Start();
+}
ShmSocket::~ShmSocket()
{
@@ -44,7 +48,7 @@
bool ShmSocket::Start(int nworker, const RecvCB &onData, const IdleCB &onIdle)
{
auto ioProc = [this, onData, onIdle]() {
- auto DoSend = [this]() { return send_buffer_->TrySend(mq()); };
+ auto DoSend = [this]() { return send_buffer_.TrySend(mq()); };
auto DoRecv = [=] {
auto onRecvWithPerMsgCB = [this, onData](ShmSocket &socket, MsgI &imsg, BHMsgHead &head) {
RecvCB cb;
--
Gitblit v1.8.0