MCPcopy Create free account
hub / github.com/Icinga/icinga2 / EnqueueCallback

Method EnqueueCallback

lib/icingadb/redisconnection.cpp:231–237  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

229}
230
231void RedisConnection::EnqueueCallback(const std::function<void(boost::asio::yield_context&)>& callback)
232{
233 asio::post(m_Strand, [this, callback, ctime = Utility::GetTime()]() {
234 m_Queues.Push(WriteQueueItem{callback, ctime, {}}, false);
235 m_QueuedWrites.Set();
236 });
237}
238
239/**
240 * Puts a no-op command with a result at the end of the queue and wait for the result,

Callers 1

Calls 2

PushMethod · 0.45
SetMethod · 0.45

Tested by

no test coverage detected