Lines Matching refs:m

2409       ManualCompactionState* m = prepicked_compaction->manual_compaction_state;  in BackgroundCallCompaction()  local
2410 assert(m); in BackgroundCallCompaction()
2412 m->cfd->GetName().c_str(), job_context.job_id); in BackgroundCallCompaction()
2543 ManualCompactionState* m = manual_compaction; in BackgroundCompaction() local
2544 assert(m->in_progress); in BackgroundCompaction()
2546 m->done = true; in BackgroundCompaction()
2547 m->manual_end = nullptr; in BackgroundCompaction()
2551 m->cfd->GetName().c_str(), m->input_level, in BackgroundCompaction()
2552 (m->begin ? m->begin->DebugString().c_str() : "(begin)"), in BackgroundCompaction()
2553 (m->end ? m->end->DebugString().c_str() : "(end)")); in BackgroundCompaction()
2557 m->cfd, *(c->inputs()), &sfm_reserved_compact_space, log_buffer); in BackgroundCompaction()
2571 m->cfd->GetName().c_str(), m->input_level, c->output_level(), in BackgroundCompaction()
2572 (m->begin ? m->begin->DebugString().c_str() : "(begin)"), in BackgroundCompaction()
2573 (m->end ? m->end->DebugString().c_str() : "(end)"), in BackgroundCompaction()
2574 ((m->done || m->manual_end == nullptr) in BackgroundCompaction()
2576 : m->manual_end->DebugString().c_str())); in BackgroundCompaction()
2907 ManualCompactionState* m = manual_compaction; in BackgroundCompaction() local
2909 m->status = status; in BackgroundCompaction()
2910 m->done = true; in BackgroundCompaction()
2925 if (m->manual_end == nullptr) { in BackgroundCompaction()
2926 m->done = true; in BackgroundCompaction()
2928 if (!m->done) { in BackgroundCompaction()
2932 assert(m->cfd->ioptions()->compaction_style != in BackgroundCompaction()
2934 m->cfd->ioptions()->num_levels > 1); in BackgroundCompaction()
2935 assert(m->cfd->ioptions()->compaction_style != kCompactionStyleFIFO); in BackgroundCompaction()
2936 m->tmp_storage = *m->manual_end; in BackgroundCompaction()
2937 m->begin = &m->tmp_storage; in BackgroundCompaction()
2938 m->incomplete = true; in BackgroundCompaction()
2940 m->in_progress = false; // not being processed anymore in BackgroundCompaction()
2950 void DBImpl::AddManualCompaction(DBImpl::ManualCompactionState* m) { in AddManualCompaction() argument
2951 manual_compaction_dequeue_.push_back(m); in AddManualCompaction()
2954 void DBImpl::RemoveManualCompaction(DBImpl::ManualCompactionState* m) { in RemoveManualCompaction() argument
2959 if (m == (*it)) { in RemoveManualCompaction()
2969 bool DBImpl::ShouldntRunManualCompaction(ManualCompactionState* m) { in ShouldntRunManualCompaction() argument
2975 if (m->exclusive) { in ShouldntRunManualCompaction()
2983 if (m == (*it)) { in ShouldntRunManualCompaction()
2987 } else if (MCOverlap(m, (*it)) && (!seen && !(*it)->in_progress)) { in ShouldntRunManualCompaction()
3029 bool DBImpl::MCOverlap(ManualCompactionState* m, ManualCompactionState* m1) { in MCOverlap() argument
3030 if ((m->exclusive) || (m1->exclusive)) { in MCOverlap()
3033 if (m->cfd != m1->cfd) { in MCOverlap()