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

os/bluestore: Optimizing the lock of bluestore writing process

Browse Source 
Unlock global lock and use FileWriter lock to improve performance and tail latency

Signed-off-by: Yin Congmin <congmin.yin@intel.com>
This commit is contained in:
Yin Congmin 2020-03-23 10:27:55 +08:00
parent ec362f4499
commit e80d3f7a89
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/os/bluestore/BlueFS.cc
View File

@ -703,6 +703,7 @@ void BlueFS::umount()
int BlueFS::prepare_new_device(int id, const bluefs_layout_t& layout)
{
std::unique_lock l(lock);
dout(1) << __func__ << dendl;
if(id == BDEV_NEWDB) {
@ -1551,6 +1552,7 @@ int BlueFS::device_migrate_to_existing(
int dev_target,
const bluefs_layout_t& layout)
{
std::unique_lock l(lock);
vector<byte> buf;
bool buffered = cct->_conf->bluefs_buffered_io;
@ -1691,6 +1693,7 @@ int BlueFS::device_migrate_to_new(
int dev_target,
const bluefs_layout_t& layout)
{
std::unique_lock l(lock);
vector<byte> buf;
bool buffered = cct->_conf->bluefs_buffered_io;
@ -2813,11 +2816,15 @@ int BlueFS::_flush_range(FileWriter *h, uint64_t offset, uint64_t length)
uint64_t x_len = std::min(p->length - x_off, length);
bufferlist t;
t.substr_of(bl, bloff, x_len);
h->lock.lock();
lock.unlock();
if (cct->_conf->bluefs_sync_write) {
bdev[p->bdev]->write(p->offset + x_off, t, buffered, h->write_hint);
} else {
bdev[p->bdev]->aio_write(p->offset + x_off, t, h->iocv[p->bdev], buffered, h->write_hint);
}
lock.lock();
h->lock.unlock();
h->dirty_devs[p->bdev] = true;
if (p->bdev == BDEV_SLOW) {
bytes_written_slow += t.length();