7

当我运行以下代码时,我在第一次调用时收到错误zmq_poll(即它返回-1)。zmq_errno()返回和调用返回128。我已经在 C++ 中使用 ZMQ 一段时间了,没有任何问题,但是无论多么简单,我都无法接到工作的电话。zmr_strerror(128)"Unknown error"zmq_poll

调用zmq::version显示我使用的是 ZMQ 版本 2.1.10。

有谁知道为什么zmq_poll会失败?

#include <zmq/zmq.hpp>

int main(int argc, char* argv[])
{
    zmq::context_t context(1);
    zmq::socket_t repA(context, ZMQ_REP);
    zmq::socket_t repB(context, ZMQ_REP);
    repA.bind("tcp://127.0.0.1:5555");
    repB.bind("tcp://127.0.0.1:5556");
    zmq::pollitem_t items[] =
    {
        { &repA, 0, ZMQ_POLLIN, 0 },
        { &repB, 0, ZMQ_POLLIN, 0 }
    };
    while (true)
    {
        int rc = zmq_poll(items, 2, 1000);
        if (rc < 0)
        {
            int code = zmq_errno(); //code = 128
            auto message = zmq_strerror(code); //message = "Unknown error"
        }
    }
}
4

1 回答 1

9

要获得用于 zmq_pollitem_t 结构的 ØMQ 套接字,您应该将 socket_t 类的实例强制转换为 (void *)。

所以应该是

zmq::pollitem_t items[] =
{
    { repA, 0, ZMQ_POLLIN, 0 },
    { repB, 0, ZMQ_POLLIN, 0 }
};

没有&.

于 2013-05-07T23:27:05.910 回答