- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
我有下一个片段:
void TcpConnection::Send(const std::vector<uint8_t>& buffer) {
std::shared_ptr<std::vector<uint8_t>> bufferCopy = std::make_shared<std::vector<uint8_t>>(buffer);
auto socket = m_socket;
m_socket->async_send(asio::buffer(bufferCopy->data(), bufferCopy->size()), [socket, bufferCopy](const boost::system::error_code& err, size_t bytesSent)
{
if (err)
{
logwarning << "clientcomms_t::sendNext encountered error: " << err.message();
// Assume that the communications path is no longer
// valid.
socket->close();
}
});
}
这段代码会导致内存泄漏。如果注释了 m_socket->async_send 调用,则没有内存泄漏。我不明白为什么在调度回调后 bufferCopy 没有被释放。我做错了什么?使用 Windows。
最佳答案
由于您没有显示任何相关代码,并且显示的代码不包含严格的问题,所以我将从代码味道中假设。
气味是你有一个TcpConnection
类不是 enable_shared_from_this<TcpConnection>
衍生的。这让我怀疑你没有提前计划,因为没有
可能
合理的方法在任何异步操作完成后继续使用实例(比如 async_send
)。
这让我怀疑您遇到了一个极其简单的问题,即您的完成处理程序从未运行过。只有一种情况可以解释这一点,这让我假设你永远不会 run()
ios_service
实例
现场情况如下:
靠 Coliru 生存
#include <boost/asio.hpp>
namespace asio = boost::asio;
using asio::ip::tcp;
#include <iostream>
auto& logwarning = std::clog;
struct TcpConnection {
using Buffer = std::vector<uint8_t>;
void Send(Buffer const &);
TcpConnection(asio::io_service& svc) : m_socket(std::make_shared<tcp::socket>(svc)) {}
tcp::socket& socket() const { return *m_socket; }
private:
std::shared_ptr<tcp::socket> m_socket;
};
void TcpConnection::Send(Buffer const &buffer) {
auto bufferCopy = std::make_shared<Buffer>(buffer);
auto socket = m_socket;
m_socket->async_send(asio::buffer(bufferCopy->data(), bufferCopy->size()),
[socket, bufferCopy](const boost::system::error_code &err, size_t /*bytesSent*/) {
if (err) {
logwarning << "clientcomms_t::sendNext encountered error: " << err.message();
// Assume that the communications path is no longer
// valid.
socket->close();
}
});
}
int main() {
asio::io_service svc;
tcp::acceptor a(svc, tcp::v4());
a.bind({{}, 6767});
a.listen();
boost::system::error_code ec;
do {
TcpConnection conn(svc);
a.accept(conn.socket(), ec);
char const* greeting = "whale hello there!\n";
conn.Send({greeting, greeting+strlen(greeting)});
} while (!ec);
}
您会看到任何客户端、连接,例如与 netcat localhost 6767
将收到问候语,之后,令人惊讶的是连接将保持打开状态,而不是关闭。
无论哪种方式,您都希望服务器端关闭连接,因为
async_send
socket
的析构函数这将关闭连接。这清楚地证实了完成处理程序从未运行过。修复很“简单”,找到一个运行服务的地方:
int main() {
asio::io_service svc;
tcp::acceptor a(svc, tcp::v4());
a.set_option(tcp::acceptor::reuse_address());
a.bind({{}, 6767});
a.listen();
std::thread th;
{
asio::io_service::work keep(svc); // prevent service running out of work early
th = std::thread([&svc] { svc.run(); });
boost::system::error_code ec;
for (int i = 0; i < 11 && !ec; ++i) {
TcpConnection conn(svc);
a.accept(conn.socket(), ec);
char const* greeting = "whale hello there!\n";
conn.Send({greeting, greeting+strlen(greeting)});
}
}
th.join();
}
这会运行 11 个连接并无泄漏地退出。
当 accept 循环也是异步的,并且 TcpConnection
如上所示正确共享:
#include <boost/asio.hpp>
namespace asio = boost::asio;
using asio::ip::tcp;
#include <memory>
#include <thread>
#include <iostream>
auto& logwarning = std::clog;
struct TcpConnection : std::enable_shared_from_this<TcpConnection> {
using Buffer = std::vector<uint8_t>;
TcpConnection(asio::io_service& svc) : m_socket(svc) {}
void start() {
char const* greeting = "whale hello there!\n";
Send({greeting, greeting+strlen(greeting)});
}
void Send(Buffer);
private:
friend struct Server;
Buffer m_output;
tcp::socket m_socket;
};
struct Server {
Server(unsigned short port) {
_acceptor.set_option(tcp::acceptor::reuse_address());
_acceptor.bind({{}, port});
_acceptor.listen();
do_accept();
}
~Server() {
keep.reset();
_svc.post([this] { _acceptor.cancel(); });
if (th.joinable())
th.join();
}
private:
void do_accept() {
auto conn = std::make_shared<TcpConnection>(_svc);
_acceptor.async_accept(conn->m_socket, [this,conn](boost::system::error_code ec) {
if (ec)
logwarning << "accept failed: " << ec.message() << "\n";
else {
conn->start();
do_accept();
}
});
}
asio::io_service _svc;
// prevent service running out of work early:
std::unique_ptr<asio::io_service::work> keep{std::make_unique<asio::io_service::work>(_svc)};
std::thread th{[this]{_svc.run();}}; // TODO handle handler exceptions
tcp::acceptor _acceptor{_svc, tcp::v4()};
};
void TcpConnection::Send(Buffer buffer) {
m_output = std::move(buffer);
auto self = shared_from_this();
m_socket.async_send(asio::buffer(m_output),
[self](const boost::system::error_code &err, size_t /*bytesSent*/) {
if (err) {
logwarning << "clientcomms_t::sendNext encountered error: " << err.message() << "\n";
// not holding on to `self` means the socket gets closed
}
// do more with `self` which points to the TcpConnection instance...
});
}
int main() {
Server server(6868);
std::this_thread::sleep_for(std::chrono::seconds(3));
}
关于c++ - asio async_send 内存泄漏,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48977606/
[免责声明] 我是 boost 新手。 研究 boost::asio 并尝试创建一个具有以下功能的简单异步 TCP 服务器: 监听端口 13 上的连接 连接后,接收数据 如果收到的数据 == 时间,则
我有下一个片段: void TcpConnection::Send(const std::vector& buffer) { std::shared_ptr> bufferCopy = std::ma
以下使用 boost::asio 的代码将无法编译: #pragma once #include #include #include #include #include #include
尝试为一种行为类似于回显服务器的服务器编写客户端。当我尝试发送内容时,它会发出哔哔声。我发现问题出现在 win_iocp_socket_service_base.ipp 文件的第 356 行(在我的编
我将 Boost.Asio 用于我正在编写的服务器应用程序。 async_send 要求调用方保留对正在发送的数据的所有权,直到数据发送成功。这意味着我的代码(如下所示)将失败,而且确实如此,因为 d
我做了一个静态库。我在中创建了这三个类 连接类 #ifndef _CONNECTION_H_ #define _CONNECTION_H_ #include #include #include
我刚才才注意到boost::asio中的async_write_some和async_send(第二次重载)函数是完全一样的: async_write_some 定义: ... template
我知道调用 boost::asio::ip::tcp::socket::async_receive(或 boost::asio::ip::tcp::socket::async_send) 两次可能会导
当 error_code 不为 0 时,连接是否正式“失效”? 当 error_code 不为 0 时,读取处理程序的 bytesReceived 参数是否可能为 0 以外的任何值?如果可能,是否应该
我是一名优秀的程序员,十分优秀!