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

cleanup: cleanup internal interface to acquire segment status

Browse Source 
- Add separate lv_status fn (if we're interested only in seg status,
   but not lv info at the same time as it is with existing
   lv_info_with_seg_status fn). So we 3 fns:

     - lv_info (existing one, runs only info ioctl, fills in struct lvinfo only)

     - lv_status (new one, runs status ioctl, fills in struct lv_seg_status only)

     - lv_info_with_seg_status (existing one, runs status ioctl, fills
       in struct lvinfo as well as lv_seg_status)

 - Add more comments in the code explaining the difference between lv_info,
   lv_status and lv_info_with_seg_status and their return values.

 - Move decision whether lv_info_with_seg_status needs to call only
   status ioctl (in case the segment for which we require status is from
   the LV for which we require info) or separate status and info ioctl
   (in case the segment for which we require status is from different
    LV that the one for which we require info) into
   lv_info_with_seg_status fn so caller doesn't need to bother about
   this at all.

 - Cleanup internal interface for this seg status so it's more readable.
This commit is contained in:
Peter Rajnoha 2014-11-13 11:41:49 +01:00
parent efe5245e47
commit 83308fdff9
3 changed files with 84 additions and 49 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
lib/activate/activate.c
View File

@ -618,7 +618,8 @@ int target_present(struct cmd_context *cmd, const char *target_name,
} }
static int _lv_info(struct cmd_context *cmd, const struct logical_volume *lv, static int _lv_info(struct cmd_context *cmd, const struct logical_volume *lv,
int use_layer, struct lvinfo *info, struct lv_seg_status *seg_status, int use_layer, struct lvinfo *info,
struct lv_segment *seg, struct lv_seg_status *seg_status,
int with_open_count, int with_read_ahead) int with_open_count, int with_read_ahead)
{ {
struct dm_info dminfo; struct dm_info dminfo;
@ -640,6 +641,9 @@ static int _lv_info(struct cmd_context *cmd, const struct logical_volume *lv,
if (!use_layer && lv_is_new_thin_pool(lv)) if (!use_layer && lv_is_new_thin_pool(lv))
use_layer = 1; use_layer = 1;
if (seg_status)
seg_status->seg = seg;
if (!dev_manager_info(cmd->mem, lv, if (!dev_manager_info(cmd->mem, lv,
(use_layer) ? lv_layer(lv) : NULL, (use_layer) ? lv_layer(lv) : NULL,
with_open_count, with_read_ahead, with_open_count, with_read_ahead,
@ -672,7 +676,7 @@ int lv_info(struct cmd_context *cmd, const struct logical_volume *lv, int use_la
if (!activation()) if (!activation())
return 0; return 0;
return _lv_info(cmd, lv, use_layer, info, NULL, with_open_count, with_read_ahead); return _lv_info(cmd, lv, use_layer, info, NULL, NULL, with_open_count, with_read_ahead);
} }
int lv_info_by_lvid(struct cmd_context *cmd, const char *lvid_s, int use_layer, int lv_info_by_lvid(struct cmd_context *cmd, const char *lvid_s, int use_layer,
@ -690,19 +694,53 @@ int lv_info_by_lvid(struct cmd_context *cmd, const char *lvid_s, int use_layer,
return r; return r;
} }
int lv_info_with_seg_status(struct cmd_context *cmd, const struct logical_volume *lv, /*
const struct lv_segment *lv_seg, int use_layer, * Returns 1 if lv_seg_status structure populated,
struct lv_with_info_and_seg_status *lvdm, * else 0 on failure or if device not active locally.
int with_open_count, int with_read_ahead) */
int lv_status(struct cmd_context *cmd, struct lv_segment *lv_seg,
struct lv_seg_status *lv_seg_status)
{ {
if (!activation()) if (!activation())
return 0; return 0;
if (!_lv_info(cmd, lv, use_layer, lvdm->info, lvdm->seg_status, return _lv_info(cmd, lv_seg->lv, 0, NULL, lv_seg, lv_seg_status, 0, 0);
with_open_count, with_read_ahead)) }
/*
* Returns 1 if lv_with_info_and_seg_status structure populated,
* else 0 on failure or if device not active locally.
*
* This is the same as calling lv_info and lv_status,
* but* it's done in one go with one ioctl if possible!
*/
int lv_info_with_seg_status(struct cmd_context *cmd, const struct logical_volume *lv,
struct lv_segment *lv_seg, int use_layer,
struct lvinfo *lvinfo, struct lv_seg_status *lv_seg_status,
int with_open_count, int with_read_ahead)
{
int r = 0;
if (!activation())
return 0; return 0;
return 1; if (lv == lv_seg->lv) {
r = _lv_info(cmd, lv, use_layer, lvinfo, lv_seg, lv_seg_status,
with_open_count, with_read_ahead);
goto out;
}
/*
* If the info is requested for an LV and segment
* status for segment that belong to another LV,
* we need to acquire info and status separately!
*/
return _lv_info(cmd, lv, use_layer, lvinfo, NULL, NULL, with_open_count, with_read_ahead) &&
_lv_info(cmd, lv_seg->lv, use_layer, NULL, lv_seg, lv_seg_status, 0, 0);
r = 1;
out:
return r;
} }
#define OPEN_COUNT_CHECK_RETRIES 25 #define OPEN_COUNT_CHECK_RETRIES 25

21
lib/activate/activate.h
View File

@ -111,16 +111,31 @@ int lv_deactivate(struct cmd_context *cmd, const char *lvid_s, const struct logi
int lv_mknodes(struct cmd_context *cmd, const struct logical_volume *lv); int lv_mknodes(struct cmd_context *cmd, const struct logical_volume *lv);
/* /*
* Returns 1 if info structure has been populated, else 0. * Returns 1 if info structure has been populated, else 0 on failure.
* When lvinfo* is NULL, it returns 1 if the device is locally active, 0 otherwise.
*/ */
int lv_info(struct cmd_context *cmd, const struct logical_volume *lv, int use_layer, int lv_info(struct cmd_context *cmd, const struct logical_volume *lv, int use_layer,
struct lvinfo *info, int with_open_count, int with_read_ahead); struct lvinfo *info, int with_open_count, int with_read_ahead);
int lv_info_by_lvid(struct cmd_context *cmd, const char *lvid_s, int use_layer, int lv_info_by_lvid(struct cmd_context *cmd, const char *lvid_s, int use_layer,
struct lvinfo *info, int with_open_count, int with_read_ahead); struct lvinfo *info, int with_open_count, int with_read_ahead);
/*
* Returns 1 if lv_seg_status structure has been populated,
* else 0 on failure or if device not active locally.
*/
int lv_status(struct cmd_context *cmd, struct lv_segment *lv_seg,
struct lv_seg_status *lv_seg_status);
/*
* Returns 1 if lv_info_and_seg_status structure has been populated,
* else 0 on failure or if device not active locally.
*
* lv_info_with_seg_status is the same as calling lv_info and then lv_seg_status,
* but this fn tries to do that with one ioctl if possible.
*/
int lv_info_with_seg_status(struct cmd_context *cmd, const struct logical_volume *lv, int lv_info_with_seg_status(struct cmd_context *cmd, const struct logical_volume *lv,
const struct lv_segment *lv_seg, int use_layer, struct lv_segment *lv_seg, int use_layer,
struct lv_with_info_and_seg_status *lvdm, struct lvinfo *lvinfo, struct lv_seg_status *lv_seg_status,
int with_open_count, int with_read_ahead); int with_open_count, int with_read_ahead);
int lv_check_not_in_use(const struct logical_volume *lv); int lv_check_not_in_use(const struct logical_volume *lv);

56
tools/reporter.c
View File

@ -57,10 +57,13 @@ static void _get_lv_info_for_report(struct cmd_context *cmd,
} }
static void _get_lv_info_with_segment_status_for_report(struct cmd_context *cmd, static void _get_lv_info_with_segment_status_for_report(struct cmd_context *cmd,
struct lv_with_info_and_seg_status *lvdm) struct logical_volume *lv,
struct lvinfo *lvinfo,
struct lv_segment *lv_seg,
struct lv_seg_status *lv_seg_status)
{ {
if (!lv_info_with_seg_status(cmd, lvdm->seg_status->seg->lv, lvdm->seg_status->seg, 0, lvdm, 1, 1)) if (!lv_info_with_seg_status(cmd, lv, lv_seg, 0, lvinfo, lv_seg_status, 1, 1))
lvdm->info->exists = 0; lvinfo->exists = 0;
} }
static int _lvs_with_info_single(struct cmd_context *cmd, struct logical_volume *lv, static int _lvs_with_info_single(struct cmd_context *cmd, struct logical_volume *lv,
@ -75,7 +78,7 @@ static int _lvs_with_info_single(struct cmd_context *cmd, struct logical_volume
return ECMD_PROCESSED; return ECMD_PROCESSED;
} }
static void _choose_lv_segment_for_status_report(struct lv_with_info_and_seg_status *lvdm) static void _choose_lv_segment_for_status_report(struct logical_volume *lv, struct lv_segment **lv_seg)
{ {
/* /*
* By default, take the first LV segment to report status for. * By default, take the first LV segment to report status for.
@ -84,46 +87,29 @@ static void _choose_lv_segment_for_status_report(struct lv_with_info_and_seg_sta
* to lvdm->seg_status->seg. This is the segment whose * to lvdm->seg_status->seg. This is the segment whose
* status line will be used for report exactly. * status line will be used for report exactly.
*/ */
lvdm->seg_status->seg = first_seg(lvdm->lv); *lv_seg = first_seg(lv);
} }
static int _lvs_with_status_single(struct cmd_context *cmd, struct logical_volume *lv, static int _lvs_with_status_single(struct cmd_context *cmd, struct logical_volume *lv,
void *handle) void *handle)
{ {
struct lvinfo lvinfo; struct lvinfo lvinfo;
struct lv_segment *lv_seg;
struct lv_seg_status lv_seg_status = { .mem = lv->vg->vgmem, struct lv_seg_status lv_seg_status = { .mem = lv->vg->vgmem,
.type = SEG_STATUS_NONE, .type = SEG_STATUS_NONE,
.status = NULL }; .status = NULL };
struct lv_with_info_and_seg_status lvdm = { .lv = lv,
.seg_status = &lv_seg_status };
int r = ECMD_FAILED; int r = ECMD_FAILED;
_choose_lv_segment_for_status_report(&lvdm); _choose_lv_segment_for_status_report(lv, &lv_seg);
_get_lv_info_with_segment_status_for_report(cmd, lv, &lvinfo, lv_seg, &lv_seg_status);
if (lvdm.seg_status->seg->lv != lv) { if (!report_object(handle, lv->vg, lv, NULL, NULL, NULL, &lvinfo, &lv_seg_status, NULL))
/*
* If the info is requested on one LV and segment
* status on another LV, we need to call these separately.
*/
_get_lv_info_for_report(cmd, lv, &lvinfo);
lvdm.info = NULL;
_get_lv_info_with_segment_status_for_report(cmd, &lvdm);
} else {
/*
* If the info is requested on the same LV as status,
* we can get info and status in one go!
*/
lvdm.info = &lvinfo;
_get_lv_info_with_segment_status_for_report(cmd, &lvdm);
}
if (!report_object(handle, lv->vg, lv, NULL, NULL, NULL, &lvinfo, lvdm.seg_status, NULL))
goto out; goto out;
r = ECMD_PROCESSED; r = ECMD_PROCESSED;
out: out:
if (lvdm.seg_status->status) if (lv_seg_status.status)
dm_pool_free(lvdm.seg_status->mem, lvdm.seg_status->status); dm_pool_free(lv_seg_status.mem, lv_seg_status.status);
return r; return r;
} }
@ -152,23 +138,19 @@ static int _segs_with_lv_status_single(struct cmd_context *cmd __attribute__((un
struct lv_segment *seg, void *handle) struct lv_segment *seg, void *handle)
{ {
struct lvinfo lvinfo; struct lvinfo lvinfo;
struct lv_seg_status lv_seg_status = { .seg = seg, struct lv_seg_status lv_seg_status = { .mem = seg->lv->vg->vgmem,
.mem = seg->lv->vg->vgmem,
.type = SEG_STATUS_NONE, .type = SEG_STATUS_NONE,
.status = NULL }; .status = NULL };
struct lv_with_info_and_seg_status lvdm = { .lv = seg->lv,
.info = &lvinfo,
.seg_status = &lv_seg_status };
int r = ECMD_FAILED; int r = ECMD_FAILED;
_get_lv_info_with_segment_status_for_report(cmd, &lvdm); _get_lv_info_with_segment_status_for_report(cmd, seg->lv, &lvinfo, seg, &lv_seg_status);
if (!report_object(handle, seg->lv->vg, seg->lv, NULL, seg, NULL, lvdm.info, lvdm.seg_status, NULL)) if (!report_object(handle, seg->lv->vg, seg->lv, NULL, seg, NULL, &lvinfo, &lv_seg_status, NULL))
goto_out; goto_out;
r = ECMD_PROCESSED; r = ECMD_PROCESSED;
out: out:
if (lvdm.seg_status->status) if (lv_seg_status.status)
dm_pool_free(lvdm.seg_status->mem, lvdm.seg_status->status); dm_pool_free(lv_seg_status.mem, lv_seg_status.status);
return r; return r;
} }