Lines Matching refs:info

607     FlushJobInfo info{};  in NotifyOnFlushBegin()  local
608 info.cf_id = cfd->GetID(); in NotifyOnFlushBegin()
609 info.cf_name = cfd->GetName(); in NotifyOnFlushBegin()
613 info.file_path = in NotifyOnFlushBegin()
615 info.file_number = file_number; in NotifyOnFlushBegin()
616 info.thread_id = env_->GetThreadID(); in NotifyOnFlushBegin()
617 info.job_id = job_id; in NotifyOnFlushBegin()
618 info.triggered_writes_slowdown = triggered_writes_slowdown; in NotifyOnFlushBegin()
619 info.triggered_writes_stop = triggered_writes_stop; in NotifyOnFlushBegin()
620 info.smallest_seqno = file_meta->fd.smallest_seqno; in NotifyOnFlushBegin()
621 info.largest_seqno = file_meta->fd.largest_seqno; in NotifyOnFlushBegin()
622 info.flush_reason = cfd->GetFlushReason(); in NotifyOnFlushBegin()
624 listener->OnFlushBegin(this, info); in NotifyOnFlushBegin()
659 for (auto& info : *flush_jobs_info) { in NotifyOnFlushCompleted()
660 info->triggered_writes_slowdown = triggered_writes_slowdown; in NotifyOnFlushCompleted()
661 info->triggered_writes_stop = triggered_writes_stop; in NotifyOnFlushCompleted()
663 listener->OnFlushCompleted(this, *info); in NotifyOnFlushCompleted()
1166 CompactionJobInfo info{}; in NotifyOnCompactionBegin() local
1167 info.cf_name = cfd->GetName(); in NotifyOnCompactionBegin()
1168 info.status = st; in NotifyOnCompactionBegin()
1169 info.thread_id = env_->GetThreadID(); in NotifyOnCompactionBegin()
1170 info.job_id = job_id; in NotifyOnCompactionBegin()
1171 info.base_input_level = c->start_level(); in NotifyOnCompactionBegin()
1172 info.output_level = c->output_level(); in NotifyOnCompactionBegin()
1173 info.stats = job_stats; in NotifyOnCompactionBegin()
1174 info.table_properties = c->GetOutputTableProperties(); in NotifyOnCompactionBegin()
1175 info.compaction_reason = c->compaction_reason(); in NotifyOnCompactionBegin()
1176 info.compression = c->output_compression(); in NotifyOnCompactionBegin()
1183 info.input_files.push_back(fn); in NotifyOnCompactionBegin()
1184 info.input_file_infos.push_back(CompactionFileInfo{ in NotifyOnCompactionBegin()
1186 if (info.table_properties.count(fn) == 0) { in NotifyOnCompactionBegin()
1190 info.table_properties[fn] = tp; in NotifyOnCompactionBegin()
1199 info.output_files.push_back(TableFileName( in NotifyOnCompactionBegin()
1201 info.output_file_infos.push_back(CompactionFileInfo{ in NotifyOnCompactionBegin()
1205 listener->OnCompactionBegin(this, info); in NotifyOnCompactionBegin()
1240 CompactionJobInfo info{}; in NotifyOnCompactionCompleted() local
1242 &info); in NotifyOnCompactionCompleted()
1244 listener->OnCompactionCompleted(this, info); in NotifyOnCompactionCompleted()