RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-23 11:07:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

librbd/cache/pwl: revert patch 76f4d29d92.

Browse Source 
In fact, After BlockGuard to fix flush reorder issue, patch
76f4d29d9 don't need. So revert.

Signed-off-by: Jianpeng Ma <jianpeng.ma@intel.com>
This commit is contained in:
Jianpeng Ma 2021-11-28 13:00:14 +08:00
parent 8e8f3ef516
commit cc8dae1d89
4 changed files with 0 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/librbd/cache/pwl/AbstractWriteLog.cc vendored
View File

@ -1745,10 +1745,6 @@ void AbstractWriteLog<I>::process_writeback_dirty_entries() {
break;
}
if (m_flush_ops_will_send) {
ldout(cct, 20) << "Previous flush-ops is still not sent" << dendl;
break;
}
auto candidate = m_dirty_log_entries.front();
bool flushable = can_flush_entry(candidate);
if (flushable) {
@ -1765,7 +1761,6 @@ void AbstractWriteLog<I>::process_writeback_dirty_entries() {
m_lowest_flushing_sync_gen = candidate->ram_entry.sync_gen_number;
}
m_flush_ops_in_flight += 1;
m_flush_ops_will_send += 1;
/* For write same this is the bytes affected by the flush op, not the bytes transferred */
m_flush_bytes_in_flight += candidate->ram_entry.write_bytes;
}

1
src/librbd/cache/pwl/AbstractWriteLog.h vendored
View File

@ -296,7 +296,6 @@ protected:
std::atomic<int> m_async_flush_ops = {0};
std::atomic<int> m_async_append_ops = {0};
std::atomic<int> m_flush_ops_will_send = {0};
/* Acquire locks in order declared here */
mutable ceph::mutex m_log_retire_lock;

1
src/librbd/cache/pwl/rwl/WriteLog.cc vendored
View File

@ -596,7 +596,6 @@ void WriteLog<I>::construct_flush_entries(pwl::GenericLogEntries entries_to_flus
ldout(m_image_ctx.cct, 15) << "flushing:" << log_entry
<< " " << *log_entry << dendl;
log_entry->writeback(this->m_image_writeback, ctx);
this->m_flush_ops_will_send -= 1;
}), 0);
});
}

3
src/librbd/cache/pwl/ssd/WriteLog.cc vendored
View File

@ -565,7 +565,6 @@ void WriteLog<I>::construct_flush_entries(pwl::GenericLogEntries entries_to_flus
ldout(m_image_ctx.cct, 15) << "flushing:" << log_entry
<< " " << *log_entry << dendl;
log_entry->writeback(this->m_image_writeback, ctx);
this->m_flush_ops_will_send -= 1;
}), 0);
});
}
@ -614,7 +613,6 @@ void WriteLog<I>::construct_flush_entries(pwl::GenericLogEntries entries_to_flus
<< " " << *log_entry << dendl;
log_entry->writeback_bl(this->m_image_writeback, ctx,
std::move(captured_entry_bl));
this->m_flush_ops_will_send -= 1;
}), 0);
});
} else {
@ -627,7 +625,6 @@ void WriteLog<I>::construct_flush_entries(pwl::GenericLogEntries entries_to_flus
ldout(m_image_ctx.cct, 15) << "flushing:" << log_entry
<< " " << *log_entry << dendl;
log_entry->writeback(this->m_image_writeback, ctx);
this->m_flush_ops_will_send -= 1;
}), 0);
});
}