RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-20 18:21:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

os/bluestore/BlueFS: _flush_bdev -> flush_bdev

Browse Source 
It is safe to call without a lock.

Signed-off-by: Sage Weil <sage@redhat.com>
This commit is contained in:
Sage Weil 2016-06-23 09:48:21 -04:00
parent 4ec1724892
commit 9b10f8edea
2 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -277,7 +277,7 @@ int BlueFS::mkfs(uuid_d osd_uuid)
// write supers
super.log_fnode = log_file->fnode;
_write_super();
_flush_bdev();
flush_bdev();
// clean up
super = bluefs_super_t();
@ -1003,7 +1003,7 @@ void BlueFS::_compact_log()
super.log_fnode = log_file->fnode;
++super.version;
_write_super();
_flush_bdev();
flush_bdev();
dout(10) << __func__ << " release old log extents " << old_extents << dendl;
for (auto& r : old_extents) {
@ -1054,11 +1054,11 @@ int BlueFS::_flush_and_sync_log()
log_t.clear();
log_t.seq = 0; // just so debug output is less confusing
_flush_bdev();
flush_bdev();
int r = _flush(log_writer, true);
assert(r == 0);
wait_for_aio(log_writer);
_flush_bdev();
flush_bdev();
// clean dirty files
dout(20) << __func__ << " log_seq_stable " << seq << dendl;
@ -1309,8 +1309,9 @@ void BlueFS::_fsync(FileWriter *h)
}
}
void BlueFS::_flush_bdev()
void BlueFS::flush_bdev()
{
// NOTE: this is safe to call without a lock.
dout(20) << __func__ << dendl;
for (auto p : bdev) {
if (p)

2
src/os/bluestore/BlueFS.h
View File

@ -243,7 +243,7 @@ private:
//void _aio_finish(void *priv);
void _flush_bdev();
void flush_bdev(); // this is safe to call without a lock
int _preallocate(FileRef f, uint64_t off, uint64_t len);
int _truncate(FileWriter *h, uint64_t off);