Enhance the management of readahead settings.

diff --git a/WHATS_NEW b/WHATS_NEW
index e140b773e8eef596f4d56fdb9b5fd20f003c62cd..34cad1b2bca292ccca1069d3aab4318c2c8489a6 100644 (file)
--- a/WHATS_NEW
+++ b/WHATS_NEW
@@ -1,5 +1,8 @@
 Version 2.02.29 -
 ==================================
+  Add activation/readahead configuration option and FMT_RESTRICTED_READAHEAD.
+  Extend readahead arg to accept "auto" and "none".
+  Add lv_read_ahead and lv_kernel_read_ahead fields to reports.
   Prevent lvconvert -s from using same LV as origin and snapshot.
   Fix human-readable output of odd numbers of sectors.
   Add pv_mda_free and vg_mda_free fields to reports for raw text format.

diff --git a/doc/example.conf b/doc/example.conf
index 65195537df3306c90e33e464ec38400372826a19..6c37ad11057c356e1312934e6628d92ddeb7885c 100644 (file)
--- a/doc/example.conf
+++ b/doc/example.conf
@@ -291,6 +291,12 @@ activation {
     # Size (in KB) of each copy operation when mirroring
     mirror_region_size = 512
 
+    # Setting to use when there is no readahead value stored in the metadata.
+    #
+    # "none" - Disable readahead.
+    # "auto" - Use default value chosen by kernel.
+    readahead = "auto"
+
     # 'mirror_image_fault_policy' and 'mirror_log_fault_policy' define
     # how a device failure affecting a mirror is handled.
     # A mirror is composed of mirror images (copies) and a log.

diff --git a/lib/commands/toolcontext.c b/lib/commands/toolcontext.c
index 8e076ac18bf7ecc420f63dcbbab39afbd9dd18b0..97ea456b89012f5a84e947dbcbfb559112df8548 100644 (file)
--- a/lib/commands/toolcontext.c
+++ b/lib/commands/toolcontext.c
@@ -153,6 +153,7 @@ static void _init_logging(struct cmd_context *cmd)
 static int _process_config(struct cmd_context *cmd)
 {
        mode_t old_umask;
+       const char *read_ahead;
 
        /* umask */
        cmd->default_settings.umask = find_config_tree_int(cmd,
@@ -207,6 +208,16 @@ static int _process_config(struct cmd_context *cmd)
                return 0;
        }
 
+       read_ahead = find_config_tree_str(cmd, "activation/readahead", DEFAULT_READ_AHEAD);
+       if (!strcasecmp(read_ahead, "auto"))
+               cmd->default_settings.read_ahead = DM_READ_AHEAD_AUTO;
+       else if (!strcasecmp(read_ahead, "none"))
+               cmd->default_settings.read_ahead = DM_READ_AHEAD_NONE;
+       else {
+               log_error("Invalid readahead specification");
+               return 0;
+       }
+
        return 1;
 }
 

diff --git a/lib/commands/toolcontext.h b/lib/commands/toolcontext.h
index 05e88df81dca5ae3e45bea76110693d8992008eb..beaaadc377ab0be2fd8eb1514d4977c3c522f7d1 100644 (file)
--- a/lib/commands/toolcontext.h
+++ b/lib/commands/toolcontext.h
@@ -33,6 +33,7 @@ struct config_info {
        int suffix;
        int archive;            /* should we archive ? */
        int backup;             /* should we backup ? */
+       int read_ahead;         /* DM_READ_AHEAD_NONE or _AUTO */
        const char *msg_prefix;
        struct format_type *fmt;
        uint64_t unit_factor;

diff --git a/lib/config/defaults.h b/lib/config/defaults.h
index d65b95b614f9dc646dd404a6ac55fb8c3b26d4ce..5348a03ab39975a1d1eb2cb5833c76df6f126c72 100644 (file)
--- a/lib/config/defaults.h
+++ b/lib/config/defaults.h
@@ -63,6 +63,7 @@
 #define DEFAULT_PVMETADATASIZE 255
 #define DEFAULT_PVMETADATACOPIES 1
 #define DEFAULT_LABELSECTOR UINT64_C(1)
+#define DEFAULT_READ_AHEAD "auto"
 
 #define DEFAULT_MSG_PREFIX "  "
 #define DEFAULT_CMD_NAME 0

diff --git a/lib/format1/format1.c b/lib/format1/format1.c
index 89f96bd9b969d2caf563a40b464d6af42f827c57..3354968b0985d5f6c25c2a8e88c3262090694f1a 100644 (file)
--- a/lib/format1/format1.c
+++ b/lib/format1/format1.c
@@ -556,7 +556,8 @@ struct format_type *init_format(struct cmd_context *cmd)
        fmt->ops = &_format1_ops;
        fmt->name = FMT_LVM1_NAME;
        fmt->alias = NULL;
-       fmt->features = FMT_RESTRICTED_LVIDS | FMT_ORPHAN_ALLOCATABLE;
+       fmt->features = FMT_RESTRICTED_LVIDS | FMT_ORPHAN_ALLOCATABLE |
+                       FMT_RESTRICTED_READAHEAD;
        fmt->private = NULL;
 
        if (!(fmt->labeller = lvm1_labeller_create(fmt))) {

diff --git a/lib/format1/import-export.c b/lib/format1/import-export.c
index 94d5cc80b57fb64b3ee0aecc573b42438305e202..70d3e0faebba9073ba5ac70a28874ca474cbd29a 100644 (file)
--- a/lib/format1/import-export.c
+++ b/lib/format1/import-export.c
@@ -349,7 +349,11 @@ int import_lv(struct dm_pool *mem, struct logical_volume *lv, struct lv_disk *lv
        else
                lv->alloc = ALLOC_NORMAL;
 
-       lv->read_ahead = lvd->lv_read_ahead;
+       if (!lvd->lv_read_ahead)
+               lv->read_ahead = lv->vg->cmd->default_settings.read_ahead;
+       else
+               lv->read_ahead = lvd->lv_read_ahead;
+
        lv->size = lvd->lv_size;
        lv->le_count = lvd->lv_allocated_le;
 
@@ -386,7 +390,12 @@ static void _export_lv(struct lv_disk *lvd, struct volume_group *vg,
                lvd->lv_dev = MKDEV(LVM_BLK_MAJOR, lvnum_from_lvid(&lv->lvid));
        }
 
-       lvd->lv_read_ahead = lv->read_ahead;
+       if (lv->read_ahead == DM_READ_AHEAD_AUTO ||
+           lv->read_ahead == DM_READ_AHEAD_NONE)
+               lvd->lv_read_ahead = 0;
+       else
+               lvd->lv_read_ahead = lv->read_ahead;
+
        lvd->lv_stripes =
            list_item(lv->segments.n, struct lv_segment)->area_count;
        lvd->lv_stripesize =

diff --git a/lib/format_pool/import_export.c b/lib/format_pool/import_export.c
index 4abf0a257b7adfc20c243149e027d66510a91fad..6856bb2a0cf85db6855d137b3efef742d98e2643 100644 (file)
--- a/lib/format_pool/import_export.c
+++ b/lib/format_pool/import_export.c
@@ -24,6 +24,7 @@
 #include "str_list.h"
 #include "display.h"
 #include "segtype.h"
+#include "toolcontext.h"
 
 /* This file contains only imports at the moment... */
 
@@ -77,7 +78,7 @@ int import_pool_lvs(struct volume_group *vg, struct dm_pool *mem, struct list *p
        lv->size = 0;
        lv->name = NULL;
        lv->le_count = 0;
-       lv->read_ahead = 0;
+       lv->read_ahead = vg->cmd->default_settings.read_ahead;
        lv->snapshot = NULL;
        list_init(&lv->snapshot_segs);
        list_init(&lv->segments);

diff --git a/lib/format_text/export.c b/lib/format_text/export.c
index de8da38b915023e9b5e8f50790133f30ef970c5f..9c8cd15b153c9a24f9a5b0c290ff0b28b6c5c422 100644 (file)
--- a/lib/format_text/export.c
+++ b/lib/format_text/export.c
@@ -271,6 +271,19 @@ int out_hint(struct formatter *f, const char *fmt, ...)
        return r;
 }
 
+/*
+ * Appends a comment
+ */
+static int _out_comment(struct formatter *f, const char *comment, const char *fmt, ...)
+{
+       va_list ap;
+       int r;
+
+       _out_with_comment(f, comment, fmt, ap);
+
+       return r;
+}
+
 /*
  * The normal output function.
  */
@@ -546,8 +559,17 @@ static int _print_lv(struct formatter *f, struct logical_volume *lv)
                outf(f, "allocation_policy = \"%s\"",
                     get_alloc_string(lv->alloc));
 
-       if (lv->read_ahead)
+       switch (lv->read_ahead) {
+       case DM_READ_AHEAD_NONE:
+               _out_comment(f, "# None", "read_ahead = -1");
+               break;
+       case DM_READ_AHEAD_AUTO:
+               /* No output - use default */
+               break;
+       default:
                outf(f, "read_ahead = %u", lv->read_ahead);
+       }
+
        if (lv->major >= 0)
                outf(f, "major = %d", lv->major);
        if (lv->minor >= 0)

diff --git a/lib/format_text/import_vsn1.c b/lib/format_text/import_vsn1.c
index 0f2fd697efebdb9c50bfb8b32c490ac0ec626cac..0ffa53e864d1ce3cd4f3a32115d74f1f1dae8837 100644 (file)
--- a/lib/format_text/import_vsn1.c
+++ b/lib/format_text/import_vsn1.c
@@ -523,9 +523,21 @@ static int _read_lvnames(struct format_instance *fid __attribute((unused)),
                }
        }
 
-       /* read_ahead defaults to 0 */
        if (!_read_int32(lvn, "read_ahead", &lv->read_ahead))
-               lv->read_ahead = 0;
+               /* If not present, choice of auto or none is configurable */
+               lv->read_ahead = vg->cmd->default_settings.read_ahead;
+       else {
+               switch (lv->read_ahead) {
+               case 0:
+                       lv->read_ahead = DM_READ_AHEAD_AUTO;
+                       break;
+               case -1:
+                       lv->read_ahead = DM_READ_AHEAD_NONE;
+                       break;
+               default:
+                       ;
+               }
+       }
 
        lv->snapshot = NULL;
        list_init(&lv->snapshot_segs);

diff --git a/lib/metadata/lv_manip.c b/lib/metadata/lv_manip.c
index 95061843042df9e58b4b51f0b4da6a9d3786e364..6cd2777ed4c5e70d7134159a797e104d28f5211f 100644 (file)
--- a/lib/metadata/lv_manip.c
+++ b/lib/metadata/lv_manip.c
@@ -1705,7 +1705,7 @@ struct logical_volume *lv_create_empty(const char *name,
 
        lv->status = status;
        lv->alloc = alloc;
-       lv->read_ahead = 0;
+       lv->read_ahead = vg->cmd->default_settings.read_ahead;
        lv->major = -1;
        lv->minor = -1;
        lv->size = UINT64_C(0);

diff --git a/lib/metadata/metadata-exported.h b/lib/metadata/metadata-exported.h
index 396dc3b5ca4c8d49c896a1b00a08484737d6302c..909b7f8994bac3f49179c404b34c553f548ad081 100644 (file)
--- a/lib/metadata/metadata-exported.h
+++ b/lib/metadata/metadata-exported.h
@@ -82,6 +82,7 @@ struct pv_segment;
 //#define FMT_PRECOMMIT                0x00000040U     /* Supports pre-commit? */
 #define FMT_RESIZE_PV          0x00000080U     /* Supports pvresize? */
 #define FMT_UNLIMITED_STRIPESIZE 0x00000100U   /* Unlimited stripe size? */
+#define FMT_RESTRICTED_READAHEAD 0x00000200U   /* Readahead restricted to 2-120? */
 
 /* LVM2 external library flags */
 #define CORRECT_INCONSISTENT    0x00000001U /* Correct inconsistent metadata */

diff --git a/lib/report/columns.h b/lib/report/columns.h
index 58d24aac3be65739b505a95f0b0850c74122bead..e0e019e8f69c68a2b469a9758a1f2b188122a2ee 100644 (file)
--- a/lib/report/columns.h
+++ b/lib/report/columns.h
@@ -23,8 +23,10 @@ FIELD(LVS, lv, STR, "LV", lvid, 4, lvname, "lv_name", "Name.  LVs created for in
 FIELD(LVS, lv, STR, "Attr", lvid, 4, lvstatus, "lv_attr", "Various attributes - see man page.")
 FIELD(LVS, lv, NUM, "Maj", major, 3, int32, "lv_major", "Persistent major number or -1 if not persistent.")
 FIELD(LVS, lv, NUM, "Min", minor, 3, int32, "lv_minor", "Persistent minor number or -1 if not persistent.")
+FIELD(LVS, lv, NUM, "Rahead", lvid, 6, lvreadahead, "lv_read_ahead", "Read ahead setting in current units.")
 FIELD(LVS, lv, STR, "KMaj", lvid, 4, lvkmaj, "lv_kernel_major", "Currently assigned major number or -1 if LV is not active.")
 FIELD(LVS, lv, STR, "KMin", lvid, 4, lvkmin, "lv_kernel_minor", "Currently assigned minor number or -1 if LV is not active.")
+FIELD(LVS, lv, NUM, "KRahead", lvid, 7, lvkreadahead, "lv_kernel_read_ahead", "Currently-in-use read ahead setting in current units.")
 FIELD(LVS, lv, NUM, "LSize", size, 5, size64, "lv_size", "Size of LV in current units.")
 FIELD(LVS, lv, NUM, "#Seg", lvid, 4, lvsegcount, "seg_count", "Number of segments in LV.")
 FIELD(LVS, lv, STR, "Origin", lvid, 6, origin, "origin", "For snapshots, the origin device of this LV")

diff --git a/lib/report/report.c b/lib/report/report.c
index 776ed03cc0dbf6f32adf89748faef4eec30d606b..2d0add624a31fa54e5f641d75de220e30e432326 100644 (file)
--- a/lib/report/report.c
+++ b/lib/report/report.c
@@ -59,6 +59,8 @@ static char _alloc_policy_char(alloc_policy_t alloc)
        }
 }
 
+static const uint64_t _minusone = UINT64_C(-1);
+
 /*
  * Data-munging functions to prepare each data type for display and sorting
  */
@@ -224,12 +226,11 @@ static int _lvkmaj_disp(struct dm_report *rh, struct dm_pool *mem __attribute((u
 {
        const struct logical_volume *lv = (const struct logical_volume *) data;
        struct lvinfo info;
-       uint64_t minusone = UINT64_C(-1);
 
        if (lv_info(lv->vg->cmd, lv, &info, 0) && info.exists)
                return dm_report_field_int(rh, field, &info.major);
 
-       return dm_report_field_uint64(rh, field, &minusone);
+       return dm_report_field_uint64(rh, field, &_minusone);
 }
 
 static int _lvkmin_disp(struct dm_report *rh, struct dm_pool *mem __attribute((unused)),
@@ -238,12 +239,11 @@ static int _lvkmin_disp(struct dm_report *rh, struct dm_pool *mem __attribute((u
 {
        const struct logical_volume *lv = (const struct logical_volume *) data;
        struct lvinfo info;
-       uint64_t minusone = UINT64_C(-1);
 
        if (lv_info(lv->vg->cmd, lv, &info, 0) && info.exists)
                return dm_report_field_int(rh, field, &info.minor);
 
-       return dm_report_field_uint64(rh, field, &minusone);
+       return dm_report_field_uint64(rh, field, &_minusone);
 }
 
 static int _lvstatus_disp(struct dm_report *rh __attribute((unused)), struct dm_pool *mem,
@@ -561,6 +561,32 @@ static int _size64_disp(struct dm_report *rh __attribute((unused)),
        return 1;
 }
 
+static int _lvreadahead_disp(struct dm_report *rh, struct dm_pool *mem,
+                            struct dm_report_field *field,
+                            const void *data, void *private __attribute((unused)))
+{
+       const struct logical_volume *lv = (const struct logical_volume *) data;
+       uint64_t size;
+
+       if (lv->read_ahead == DM_READ_AHEAD_AUTO) {
+               dm_report_field_set_value(field, "auto", &_minusone);
+               return 1;
+       }
+
+       size = (uint64_t) lv->read_ahead;
+
+       return _size64_disp(rh, mem, field, &size, private);
+}
+
+static int _lvkreadahead_disp(struct dm_report *rh, struct dm_pool *mem,
+                             struct dm_report_field *field,
+                             const void *data,
+                             void *private __attribute((unused)))
+{
+       // FIXME after dm support is added
+       return dm_report_field_uint64(rh, field, &_minusone);
+}
+
 static int _vgsize_disp(struct dm_report *rh, struct dm_pool *mem,
                        struct dm_report_field *field,
                        const void *data, void *private)

diff --git a/man/lvchange.8 b/man/lvchange.8
index ffc1068b07ec2e4889e7ea1857ff85ad6c0641b3..86c264eba6649c377e22bc422557725fe8da1dac 100644 (file)
--- a/man/lvchange.8
+++ b/man/lvchange.8
@@ -14,7 +14,7 @@ lvchange \- change attributes of a logical volume
 [\-\-monitor {y|n}]
 [\-M/\-\-persistent y/n] [\-\-minor minor]
 [\-P/\-\-partial]
-[\-p/\-\-permission r/w] [\-r/\-\-readahead ReadAheadSectors]
+[\-p/\-\-permission r/w] [\-r/\-\-readahead ReadAheadSectors|auto|none]
 [\-\-refresh]
 [\-t/\-\-test]
 [\-v/\-\-verbose] LogicalVolumePath [LogicalVolumePath...]
@@ -72,9 +72,14 @@ Set to y to make the minor number specified persistent.
 .I \-p, \-\-permission r/w
 Change access permission to read-only or read/write.
 .TP
-.I \-r, \-\-readahead ReadAheadSectors
-Change read ahead sector count per logical between 2 and 120.
-For compatability with LVM1 only. Ignored by LVM2.
+.I \-r, \-\-readahead ReadAheadSectors|auto|none
+Set read ahead sector count of this logical volume.
+For volume groups with metadata in lvm1 format, this must
+be a value between 2 and 120.
+The default value is "auto" which allows the kernel to choose
+a suitable value automatically.
+"None" is equivalent to specifying zero.
+N.B. This setting is currently disregarded and "auto" is always used.
 .TP
 .I \-\-refresh
 If the logical volume is active, reload its metadata.

diff --git a/man/lvcreate.8 b/man/lvcreate.8
index f99d629795c1d5a64837be41a5a9009c97dbb02b..77bdbb8b258c9ec769e1fb32ab29a54ffd32a289 100644 (file)
--- a/man/lvcreate.8
+++ b/man/lvcreate.8
@@ -14,7 +14,7 @@ lvcreate \- create a logical volume in an existing volume group
 [\-m/\-\-mirrors Mirrors [\-\-nosync] [\-\-mirrorlog {disk|log}] [\-\-corelog]
 [\-R/\-\-regionsize MirrorLogRegionSize]]
 [\-n/\-\-name LogicalVolumeName]
-[\-p/\-\-permission r/rw] [\-r/\-\-readahead ReadAheadSectors]
+[\-p/\-\-permission r/rw] [\-r/\-\-readahead ReadAheadSectors|auto|none]
 [\-t/\-\-test]
 [\-v/\-\-verbose] [\-Z/\-\-zero y/n]
 VolumeGroupName [PhysicalVolumePath...]
@@ -118,9 +118,14 @@ Set access permissions to read only or read and write.
 .br
 Default is read and write.
 .TP
-.I \-r, \-\-readahead ReadAheadSectors
-Set read ahead sector count of this logical volume to a value between 2 and 120.
-Ignored by device-mapper.
+.I \-r, \-\-readahead ReadAheadSectors|auto|none
+Set read ahead sector count of this logical volume.
+For volume groups with metadata in lvm1 format, this must
+be a value between 2 and 120.
+The default value is "auto" which allows the kernel to choose
+a suitable value automatically.
+"None" is equivalent to specifying zero.
+N.B. This setting is currently disregarded and "auto" is always used.
 .TP
 .I \-R, \-\-regionsize MirrorLogRegionSize
 A mirror is divided into regions of this size (in MB), and the mirror log 

diff --git a/man/lvm.conf.5 b/man/lvm.conf.5
index 5c8b64b6ef34ae955e94cb2ca373c5f27b438ae4..c67ce94bc541b689294d96d7fd4c30daefdfe7e6 100644 (file)
--- a/man/lvm.conf.5
+++ b/man/lvm.conf.5
@@ -306,6 +306,11 @@ such devices.
 \fBmirror_region_size\fP \(em Unit size in KB for copy operations
 when mirroring.
 .IP
+\fBreadahead\fP \(em Used when there is no readahead value stored 
+in the volume group metadata.  Set to \fBnone\fP to disable
+readahead in these circumstances or \fBauto\fP to use the default
+value chosen by the kernel.
+.IP
 \fBreserved_memory\fP, \fBreserved_stack\fP \(em How many KB to reserve 
 for LVM2 to use while logical volumes are suspended.  If insufficient 
 memory is reserved before suspension, there is a risk of machine deadlock.

diff --git a/tools/args.h b/tools/args.h
index 061dab1e117acd6bb88133f34705eb7fb66af60c..5a0309c59d83f5f1c927d16fea296c943c8aac4c 100644 (file)
--- a/tools/args.h
+++ b/tools/args.h
@@ -107,7 +107,7 @@ arg(permission_ARG, 'p', "permission", permission_arg, 0)
 arg(maxphysicalvolumes_ARG, 'p', "maxphysicalvolumes", int_arg, 0)
 arg(partial_ARG, 'P', "partial", NULL, 0)
 arg(physicalvolume_ARG, 'P', "physicalvolume", NULL, 0)
-arg(readahead_ARG, 'r', "readahead", int_arg, 0)
+arg(readahead_ARG, 'r', "readahead", readahead_arg, 0)
 arg(resizefs_ARG, 'r', "resizefs", NULL, 0)
 arg(reset_ARG, 'R', "reset", NULL, 0)
 arg(regionsize_ARG, 'R', "regionsize", size_mb_arg, 0)

diff --git a/tools/commands.h b/tools/commands.h
index cebb3060e67e13a905865e884efe767f7d1f97eb..46b4e0463a5d1ebbdeb788057843b34f4cdfc4a8 100644 (file)
--- a/tools/commands.h
+++ b/tools/commands.h
@@ -71,7 +71,7 @@ xx(lvchange,
    "\t[-M|--persistent y|n] [--major major] [--minor minor]\n"
    "\t[-P|--partial] " "\n"
    "\t[-p|--permission r|rw]\n"
-   "\t[-r|--readahead ReadAheadSectors]\n"
+   "\t[-r|--readahead ReadAheadSectors|auto|none]\n"
    "\t[--refresh]\n"
    "\t[--resync]\n"
    "\t[-t|--test]\n"
@@ -126,7 +126,7 @@ xx(lvcreate,
    "\t[-m|--mirrors Mirrors [--nosync] [{--mirrorlog {disk|core}|--corelog}]]\n"
    "\t[-n|--name LogicalVolumeName]\n"
    "\t[-p|--permission {r|rw}]\n"
-   "\t[-r|--readahead ReadAheadSectors]\n"
+   "\t[-r|--readahead ReadAheadSectors|auto|none]\n"
    "\t[-R|--regionsize MirrorLogRegionSize]\n"
    "\t[-t|--test]\n"
    "\t[--type VolumeType]\n"
@@ -149,7 +149,7 @@ xx(lvcreate,
    "\t[-M|--persistent {y|n}] [--major major] [--minor minor]\n"
    "\t[-n|--name LogicalVolumeName]\n"
    "\t[-p|--permission {r|rw}]\n"
-   "\t[-r|--readahead ReadAheadSectors]\n"
+   "\t[-r|--readahead ReadAheadSectors|auto|none]\n"
    "\t[-t|--test]\n"
    "\t[-v|--verbose]\n"
    "\t[--version]\n"

diff --git a/tools/lvchange.c b/tools/lvchange.c
index d2f473a117444d5c54017ba7b44039711191c288..152cd2d46165869431f2dc66bf6daa2ddd04765d 100644 (file)
--- a/tools/lvchange.c
+++ b/tools/lvchange.c
@@ -375,12 +375,12 @@ static int lvchange_readahead(struct cmd_context *cmd,
 
        read_ahead = arg_uint_value(cmd, readahead_ARG, 0);
 
-/******* FIXME Ranges?
-       if (read_ahead < LVM_MIN_READ_AHEAD || read_ahead > LVM_MAX_READ_AHEAD) {
-               log_error("read ahead sector argument is invalid");
+       if (read_ahead != DM_READ_AHEAD_AUTO &&
+           (lv->vg->fid->fmt->features & FMT_RESTRICTED_READAHEAD) &&
+           (read_ahead < 2 || read_ahead > 120)) {
+               log_error("Metadata only supports readahead values between 2 and 120.");
                return 0;
        }
-********/
 
        if (lv->read_ahead == read_ahead) {
                log_error("Read ahead is already %u for \"%s\"",

diff --git a/tools/lvcreate.c b/tools/lvcreate.c
index 46573b92f5bb23d7de22afb7e62b72cccaa75ab7..184d039f924a178c4e4885e8cf38f6d920a23e27 100644 (file)
--- a/tools/lvcreate.c
+++ b/tools/lvcreate.c
@@ -548,6 +548,13 @@ static int _lvcreate(struct cmd_context *cmd, struct lvcreate_params *lp)
                return 0;
        }
 
+       if (lp->read_ahead != DM_READ_AHEAD_AUTO &&
+           (vg->fid->fmt->features & FMT_RESTRICTED_READAHEAD) &&
+           (lp->read_ahead < 2 || lp->read_ahead > 120)) {
+               log_error("Metadata only supports readahead values between 2 and 120.");
+               return 0;
+       }
+
        /*
         * Create the pv list.
         */

diff --git a/tools/lvmcmdline.c b/tools/lvmcmdline.c
index 94575f382be3dcc8ffcf3a6eb156b3caeb1abde1..ca77e242c8da6713624e8eb9d9b388238864da7b 100644 (file)
--- a/tools/lvmcmdline.c
+++ b/tools/lvmcmdline.c
@@ -372,6 +372,27 @@ int segtype_arg(struct cmd_context *cmd, struct arg *a)
        return 1;
 }
 
+/*
+ * Positive integer, zero or "auto".
+ */
+int readahead_arg(struct cmd_context *cmd __attribute((unused)), struct arg *a)
+{
+       if (int_arg(cmd, a))
+               return 1;
+
+       if (!strcasecmp(a->value, "auto")) {
+               a->ui_value = DM_READ_AHEAD_AUTO;
+               return 1;
+       }
+
+       if (!strcasecmp(a->value, "none")) {
+               a->ui_value = DM_READ_AHEAD_NONE;
+               return 1;
+       }
+
+       return 0;
+}
+
 static void __alloc(int size)
 {
        if (!(_cmdline.commands = dm_realloc(_cmdline.commands, sizeof(*_cmdline.commands) * size))) {

diff --git a/tools/tools.h b/tools/tools.h
index 436cc9c56f25bb903f6bf41ffa6b30a270fdfd93..fdd6a81d846e7dab25cdd11d4610582cbb1b1520 100644 (file)
--- a/tools/tools.h
+++ b/tools/tools.h
@@ -147,7 +147,7 @@ int metadatatype_arg(struct cmd_context *cmd, struct arg *a);
 int units_arg(struct cmd_context *cmd, struct arg *a);
 int segtype_arg(struct cmd_context *cmd, struct arg *a);
 int alloc_arg(struct cmd_context *cmd, struct arg *a);
-
+int readahead_arg(struct cmd_context *cmd, struct arg *a);
 
 /* we use the enums to access the switches */
 unsigned int arg_count(const struct cmd_context *cmd, int a);