| | |
| | | } |
| | | |
| | | 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 = mq.TrySend(remote, msg); |
| | | r = TryLoop(msg); |
| | | if (r) { |
| | | msg.Release(); |
| | | } |
| | | } else { |
| | | auto &content = boost::variant2::get<1>(pos->data().data_); |
| | | MsgI msg; |
| | | if (msg.Make(content)) { |
| | | DEFER1(msg.Release();); |
| | | r = mq.TrySend(remote, msg); |
| | | } |
| | | auto command = boost::variant2::get<1>(pos->data().data_); |
| | | r = TryLoop(command); |
| | | } |
| | | return r; |
| | | }; |