使用 boost::asio 丢弃数据

发布于 2024-11-30 23:06:59 字数 305 浏览 1 评论 0原文

我在异步模式下使用 boost::asio，并且我想跳过/丢弃/删除通过 TCP 发送给我的消息。我想这样做是因为我已经阅读了该消息的标题，并且我知道我对此不感兴趣。该消息可能很大，因此我宁愿不为其分配空间，甚至最好根本不将其传输到用户空间。

我看到 boost::asio::null_buffers 但它似乎不适用于此处（请参阅 https ://svn.boost.org/trac/boost/ticket/3627）。

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

绮烟 2024-12-07 23:06:59

据我所知，BSD 套接字接口不提供此功能。你总是必须读入缓冲区。现在，为了不分配巨大的缓冲区，您可以做的就是在循环中读入较小的缓冲区。像这样的事情：

void skip_impl(tcp::socket& s, int n, boost::function<void(error_code const&)> h
    , char* buf, error_code const& ec, std::size_t bytes_transferred)
{
    assert(bytes_transferred <= n);
    n -= bytes_transferred;
    if (ec || n == 0) {
        delete[] buf;
        h(ec);
        return;
    }

    s.async_read_some(boost::asio::buffer(temp, std::min(4096, n))
        , boost::bind(&skip_impl, boost::ref(s), n, h, temp, _1, _2));
}

void async_skip_bytes(tcp::socket& s, int n, boost::function<void(error_code const&)> h)
{
    char* temp = new char[4096];
    s.async_read_some(boost::asio::buffer(temp, std::min(4096, n))
        , boost::bind(&skip_impl, boost::ref(s), n, h, temp, _1, _2));
}

这还没有通过编译器传递，因此可能存在愚蠢的拼写错误，但它应该说明这一点。

As far as I know, the BSD socket interface doesn't give you this functionality. You always have to read into a buffer. Now, what you can do in order to not allocate a huge buffer is to read into a smaller buffer in a loop. Something like this:

void skip_impl(tcp::socket& s, int n, boost::function<void(error_code const&)> h
    , char* buf, error_code const& ec, std::size_t bytes_transferred)
{
    assert(bytes_transferred <= n);
    n -= bytes_transferred;
    if (ec || n == 0) {
        delete[] buf;
        h(ec);
        return;
    }

    s.async_read_some(boost::asio::buffer(temp, std::min(4096, n))
        , boost::bind(&skip_impl, boost::ref(s), n, h, temp, _1, _2));
}

void async_skip_bytes(tcp::socket& s, int n, boost::function<void(error_code const&)> h)
{
    char* temp = new char[4096];
    s.async_read_some(boost::asio::buffer(temp, std::min(4096, n))
        , boost::bind(&skip_impl, boost::ref(s), n, h, temp, _1, _2));
}

This has not been passed through a compiler, so there might be silly typos, but it should illustrate the point.

回复收藏 0 原文