MCPcopy Create free account
hub / github.com/ceph/ceph / flush

Method flush

src/log/Log.cc:271–287  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

269}
270
271void Log::flush()
272{
273 std::scoped_lock lock1(m_flush_mutex);
274 m_flush_mutex_holder = pthread_self();
275
276 {
277 std::scoped_lock lock2(m_queue_mutex);
278 m_queue_mutex_holder = pthread_self();
279 assert(m_flush.empty());
280 m_flush.swap(m_new);
281 m_cond_loggers.notify_all();
282 m_queue_mutex_holder = 0;
283 }
284
285 _flush(m_flush, false);
286 m_flush_mutex_holder = 0;
287}
288
289void Log::_log_safe_write(std::string_view sv)
290{

Callers 15

SyncFunction · 0.45
f_perfFunction · 0.45
f_statusFunction · 0.45
mainFunction · 0.45
dump_imagesFunction · 0.45
get_primary_osdMethod · 0.45
get_shard_osdMethod · 0.45

Calls 4

assertFunction · 0.85
emptyMethod · 0.45
swapMethod · 0.45
notify_allMethod · 0.45

Tested by 3

logMethod · 0.36
TESTFunction · 0.36
do_segvFunction · 0.36