| 519 | } |
| 520 | |
| 521 | void IdoMysqlConnection::AsyncQuery(const String& query, const std::function<void (const IdoMysqlResult&)>& callback) |
| 522 | { |
| 523 | AssertOnWorkQueue(); |
| 524 | |
| 525 | IdoAsyncQuery aq; |
| 526 | aq.Query = query; |
| 527 | /* XXX: Important: The callback must not immediately execute a query, but enqueue it! |
| 528 | * See https://github.com/Icinga/icinga2/issues/4603 for details. |
| 529 | */ |
| 530 | aq.Callback = callback; |
| 531 | m_AsyncQueries.emplace_back(std::move(aq)); |
| 532 | } |
| 533 | |
| 534 | void IdoMysqlConnection::FinishAsyncQueries() |
| 535 | { |
nothing calls this directly
no outgoing calls
no test coverage detected