boost::asio::strand 在 Ubuntu 11.04 (boost_all_dev 1.42) 上是否损坏

Question

我有一个使用 io_service 和多个线程的程序。

它实例化了一些套接字对象。这些对象每个都有一个同步链。所有对 async_read()、async_write() 和类似函数的调用都通过 strand_.wrap(boost::bind(...))。每个对象还有一个 int interlock_ 变量，初始化为 0。

在这些函数之一（on-data-receive 回调）中，我执行以下操作：

Class::startRead(...)
{
...
    boost::asio::async_read(socket_, boost::asio::buffer(ptr, 16384), boost::asio::transfer_at_least(1),
        strand_.wrap(boost::bind(&EagerConnection::on_read, this, placeholders::error, placeholders::bytes_transferred)));
}

Class::on_read(...)
{
...
    startRead();
    assert(0 == __sync_fetch_and_add(&interlock_, 1));
    onData_();
    assert(1 == __sync_fetch_and_add(&interlock_, -1));
}

因为一切都是通过链同步的，所以第一个断言永远不应该触发。不过，确实火了！当我在 GDB 中查看值时，interlock_ 的最终值为 2，这意味着对 on_read() 的两个单独调用同时处于活动状态。

这是否意味着 boost::asio::strand 坏了？ （我已经检查过我在完成函数中没有任何重入——onData_ 信号处理程序不会重新调用 on_data()）。

“早期”的 startRead 会以某种方式导致立即重新进入吗？ （async_x 和 strand 的语义似乎都表明它不能）

如果您真的非常想查看课程的完整内容，可以将其作为要点：https://gist.github.com/979212

Answer 1

我发现了一些小问题（？）：

• Minor：切换interlock_和strand_的初始化顺序。通过声明 interlock_ _after_ strand_ 成员来修复它；

• readIn 函数不返回任何值（未初始化的数据）。您可能打算返回n？

---

好消息：

• 使用 valgrind 运行结果清晰。
• 使用 helgrind 运行很明显（但是：我猜我在最小示例中没有使用线程；不知道 boost::asio 和 boost::signals 内部结构）。

Answer 2

我正在尝试重现事物，但执行此操作时我的安装未能引发断言。

我在要点末尾添加了以下片段：

int split(std::string const &src, char ch, std::string &oLeft, std::string &oRight)
{
    std::size_t pos = src.find(ch);
    if (pos == std::string::npos)
    {
        oLeft = src;
        oRight.clear();
        return 1;
    } else
    {
        oLeft = src.substr(0, pos);
        oRight = src.substr(pos+1);
        return 2;
    }
}

namespace {

    boost::asio::io_service svc;
    EagerConnection c(svc);

    void onconnect()
    {
        std::cout << "ONCONNECT" << std::endl;
        const char data[] = "GET / HTTP/1.0\r\n\r\n"; 
        c.writeOut(data, sizeof(data));
    }

    void ondata()
    {
        std::cout << "ONDATA" << std::endl;
        std::ostringstream oss;
        char buf[1024];
        int read;
        while ((read = c.readIn(buf, 1024)))
            oss.write(buf, read);
        std::cout << "response: " << oss.str() << std::endl;
    }

    void ondisconnect()
    {
        std::cout << "ON__DIS__CONNECT" << std::endl;
    }

}

int main(int argc, char* argv[])
{
    if (argc>1 && argv[1])
    {
        c.onConnect_.connect(&onconnect);
        c.onData_.connect(&ondata);
        c.onDisconnect_.connect(&ondisconnect);


        c.open(argv[1]);
        svc.run();
    }

    return 0;
}

如您所见，我真的在尝试做 SimplestThingThatCouldPossiblyWork。我的连接/重新连接运行良好（包括增加的退避时间）。

我用这个编译

strand: strand.cpp
    g++ -Wall -Werror -o $@ $^ -g -O0 -lboost_system -lboost_thread -lboost_signals -lpthread

然后调用它

./strand 127.0.0.1:6767

我有一个响应脚本坐在那里（基本上）

netcat -l -p 6767 -e rev

另一件需要注意的事情：写缓冲区似乎从未真正被发送/刷新直到我打断了strand 测试器（客户端）。不管我做多大的data，都会发生这种情况...这可能是由于我缺少一个步骤？

编辑：

在

上测试相同

• ubuntu meerkat，gcc 4.4.5，boost 1.42.0
• debian sid，gcc 4.5.2-8，boost 1.46.1