shaba/lvm2
1
0
Fork 0
mirror of git://sourceware.org/git/lvm2.git synced 2024-10-27 18:55:19 +03:00
Code Releases Activity

readahead support completed - untested

Browse Source
This commit is contained in:
Alasdair Kergon 2007-11-30 16:42:26 +00:00
parent 2d1eead2e8
commit e81af2f3fe
1 changed files with 68 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

70
libdm/libdm-common.c
View File

@ -21,9 +21,14 @@
#include <stdarg.h> #include <stdarg.h>
#include <sys/param.h> #include <sys/param.h>
#include <fcntl.h>
#include <linux/dm-ioctl.h> #include <linux/dm-ioctl.h>
#ifdef linux
# include <linux/fs.h>
#endif
#ifdef HAVE_SELINUX #ifdef HAVE_SELINUX
# include <selinux/selinux.h> # include <selinux/selinux.h>
#endif #endif
@ -356,16 +361,61 @@ static int _rm_dev_node(const char *dev_name)
return 1; return 1;
} }
#ifdef linux
static int _open_dev_node(const char *dev_name)
{
int fd = -1;
char path[PATH_MAX];
_build_dev_path(path, sizeof(path), dev_name);
if ((fd = open(path, O_RDONLY, 0)) < 0)
log_sys_error("open", path);
return fd;
}
int get_dev_node_read_ahead(const char *dev_name, uint32_t *read_ahead) int get_dev_node_read_ahead(const char *dev_name, uint32_t *read_ahead)
{ {
int r = 1;
int fd;
if ((fd = _open_dev_node(dev_name)) < 0)
; // return_0;
*read_ahead = 0; *read_ahead = 0;
return 1; if (!ioctl(fd, BLKRAGET, read_ahead)) {
log_sys_error("BLKRAGET", dev_name);
r = 0;
} else
log_debug("%s: read ahead is %" PRIu32, dev_name, *read_ahead);
if (!close(fd))
stack;
return r;
} }
static int _set_read_ahead(const char *dev_name, uint32_t read_ahead) static int _set_read_ahead(const char *dev_name, uint32_t read_ahead)
{ {
return 1; int r = 1;
int fd;
if ((fd = _open_dev_node(dev_name)) < 0)
return_0;
log_debug("%s: Setting read ahead to %" PRIu32, dev_name, read_ahead);
if (ioctl(fd, BLKRASET, read_ahead)) {
log_sys_error("BLKRASET", dev_name);
r = 0;
}
if (!close(fd))
stack;
return r;
} }
static int _set_dev_node_read_ahead(const char *dev_name, uint32_t read_ahead, static int _set_dev_node_read_ahead(const char *dev_name, uint32_t read_ahead,
@ -394,6 +444,22 @@ static int _set_dev_node_read_ahead(const char *dev_name, uint32_t read_ahead,
return _set_read_ahead(dev_name, read_ahead); return _set_read_ahead(dev_name, read_ahead);
} }
#else
int get_dev_node_read_ahead(const char *dev_name, uint32_t *read_ahead)
{
*read_ahead = 0;
return 1;
}
static int _set_dev_node_read_ahead(const char *dev_name, uint32_t read_ahead,
uint32_t read_ahead_flags)
{
return 1;
}
#endif
typedef enum { typedef enum {
NODE_ADD, NODE_ADD,
NODE_DEL, NODE_DEL,