| | |
| | | } |
| | | |
| | | auto SendData = [&](Data &d) { |
| | | auto TryLoop = [&](auto &&data) { |
| | | for (int i = 0; i < 1; ++i) { |
| | | if (mq.TrySend(remote, data)) { |
| | | return true; |
| | | } |
| | | } |
| | | return false; |
| | | }; |
| | | bool r = false; |
| | | if (d.index() == 0) { |
| | | auto &msg = boost::variant2::get<0>(pos->data().data_); |
| | | r = TryLoop(msg); |
| | | if (r) { |
| | | msg.Release(); |
| | | } |
| | | } else { |
| | | auto command = boost::variant2::get<1>(pos->data().data_); |
| | | r = TryLoop(command); |
| | | } |
| | | return r; |
| | | auto TrySend = [&](auto &&data) { return mq.TrySend(remote, data); }; |
| | | return boost::variant2::visit(TrySend, pos->data().data_); |
| | | }; |
| | | |
| | | while (pos != arr.end() && SendData(pos->data().data_)) { |