56unsigned int ZMQParent::poll(
const std::vector<zmq::socket_t*>& socketList,
int timeout)
58 B2ASSERT(
"Only allow to poll on maximal 8 sockets at the same time!", socketList.size() <= 8);
59 std::bitset<8> return_bitmask;
60 std::vector<zmq::pollitem_t> items(socketList.size());
62 for (
unsigned int i = 0; i < socketList.size(); i++) {
63 items[i].socket =
static_cast<void*
>(*socketList[i]);
64 items[i].events = ZMQ_POLLIN;
69 zmq::poll(items.data(), socketList.size(), timeout);
71 for (
unsigned int i = 0; i < socketList.size(); i++) {
72 return_bitmask[i] =
static_cast<bool>(items[i].revents & ZMQ_POLLIN);
74 return return_bitmask.to_ulong();
75 }
catch (zmq::error_t& error) {
76 if (error.num() == EINTR) {