shaba/lvm2
1
0
Fork 0
mirror of git://sourceware.org/git/lvm2.git synced 2024-12-21 13:34:40 +03:00
Code Releases Activity

device: Suppress repeated reads of the same data.

Browse Source 
If the data being requested is present in last_[extra_]devbuf,
return that directly instead of reading it from disk again.

Typical LVM2 access patterns request data within two adjacent 4k blocks
so we eliminate some read() system calls by always reading at least 8k.
This commit is contained in:
Alasdair G Kergon 2018-01-10 13:19:12 +00:00
parent dcb2a5a611
commit 366493a1d1
2 changed files with 32 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
WHATS_NEW
View File

@ -1,5 +1,6 @@
Version 2.02.178 - Version 2.02.178 -
===================================== =====================================
Suppress some repeated reads of the same disk data at the device layer.
Avoid exceeding array bounds in allocation tag processing. Avoid exceeding array bounds in allocation tag processing.
Refactor metadata reading code to use callback functions. Refactor metadata reading code to use callback functions.
Move memory allocation for the key dev_reads into the device layer. Move memory allocation for the key dev_reads into the device layer.

33
lib/device/dev-io.c
View File

@ -53,6 +53,12 @@
# endif # endif
#endif #endif
/*
* Always read at least 8k from disk.
* This seems to be a good compromise for the existing LVM2 metadata layout.
*/
#define MIN_READ_SIZE (8 * 1024)
static DM_LIST_INIT(_open_devices); static DM_LIST_INIT(_open_devices);
static unsigned _dev_size_seqno = 1; static unsigned _dev_size_seqno = 1;
@ -273,6 +279,11 @@ static int _aligned_io(struct device_area *where, char *buffer,
if (!block_size) if (!block_size)
block_size = lvm_getpagesize(); block_size = lvm_getpagesize();
/* Apply minimum read size */
if (!should_write && block_size < MIN_READ_SIZE)
block_size = MIN_READ_SIZE;
mask = block_size - 1; mask = block_size - 1;
_widen_region(block_size, where, &widened); _widen_region(block_size, where, &widened);
@ -785,14 +796,32 @@ static void _dev_inc_error_count(struct device *dev)
static int _dev_read(struct device *dev, uint64_t offset, size_t len, dev_io_reason_t reason) static int _dev_read(struct device *dev, uint64_t offset, size_t len, dev_io_reason_t reason)
{ {
struct device_area where; struct device_area where;
struct device_buffer *devbuf;
uint64_t buf_end;
int ret; int ret;
if (!dev->open_count) if (!dev->open_count) {
return_0; log_error(INTERNAL_ERROR "Attempt to access device %s while closed.", dev_name(dev));
return 0;
}
if (!_dev_is_valid(dev)) if (!_dev_is_valid(dev))
return 0; return 0;
/*
* Can we satisfy this from data we stored last time we read?
*/
if ((devbuf = DEV_DEVBUF(dev, reason)) && devbuf->malloc_address) {
buf_end = devbuf->where.start + devbuf->where.size - 1;
if (offset >= devbuf->where.start && offset <= buf_end && offset + len - 1 <= buf_end) {
/* Reuse this buffer */
devbuf->data = (char *) devbuf->buf + (offset - devbuf->where.start);
log_debug_io("Cached read for %" PRIu64 " bytes at %" PRIu64 " on %s (for %s)",
len, (uint64_t) offset, dev_name(dev), _reason_text(reason));
return 1;
}
}
where.dev = dev; where.dev = dev;
where.start = offset; where.start = offset;
where.size = len; where.size = len;