Commit 347c7aed authored by Henri Doreau's avatar Henri Doreau Committed by Greg Kroah-Hartman

staging: lustre: changelog: Proper record remapping

Fixed changelog_remap_rec() to correctly remap records emitted
with jobid_var=disabled, i.e. delivered by new servers but with
no jobid field.
Signed-off-by: default avatarHenri Doreau <henri.doreau@cea.fr>
Intel-bug-id: https://jira.hpdd.intel.com/browse/LU-5862
Reviewed-on: http://review.whamcloud.com/12574Reviewed-by: default avatarAndreas Dilger <andreas.dilger@intel.com>
Reviewed-by: default avatarRobert Read <robert.read@intel.com>
Signed-off-by: default avatarJames Simmons <jsimmons@infradead.org>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@linuxfoundation.org>
parent 3f062072
...@@ -881,41 +881,63 @@ static inline char *changelog_rec_sname(struct changelog_rec *rec) ...@@ -881,41 +881,63 @@ static inline char *changelog_rec_sname(struct changelog_rec *rec)
return cr_name + strlen(cr_name) + 1; return cr_name + strlen(cr_name) + 1;
} }
/* /**
* Remap a record to the desired format as specified by the crf flags. * Remap a record to the desired format as specified by the crf flags.
* The record must be big enough to contain the final remapped version. * The record must be big enough to contain the final remapped version.
* Superfluous extension fields are removed and missing ones are added
* and zeroed. The flags of the record are updated accordingly.
*
* The jobid and rename extensions can be added to a record, to match the
* format an application expects, typically. In this case, the newly added
* fields will be zeroed.
* The Jobid field can be removed, to guarantee compatibility with older
* clients that don't expect this field in the records they process.
*
* The following assumptions are being made:
* - CLF_RENAME will not be removed
* - CLF_JOBID will not be added without CLF_RENAME being added too
*
* @param[in,out] rec The record to remap.
* @param[in] crf_wanted Flags describing the desired extensions.
*/ */
static inline void changelog_remap_rec(struct changelog_rec *rec, static inline void changelog_remap_rec(struct changelog_rec *rec,
enum changelog_rec_flags crf) enum changelog_rec_flags crf_wanted)
{ {
size_t var_size; char *jid_mov, *rnm_mov;
char *var_part;
crf &= CLF_SUPPORTED; crf_wanted &= CLF_SUPPORTED;
if ((rec->cr_flags & CLF_SUPPORTED) == crf) if ((rec->cr_flags & CLF_SUPPORTED) == crf_wanted)
return; return;
if ((crf & CLF_JOBID) && rec->cr_flags & CLF_JOBID) { /* First move the variable-length name field */
var_part = (char *)changelog_rec_jobid(rec); memmove((char *)rec + changelog_rec_offset(crf_wanted),
var_size = rec->cr_namelen + sizeof(struct changelog_ext_jobid); changelog_rec_name(rec), rec->cr_namelen);
} else {
var_part = changelog_rec_name(rec); /* Locations of jobid and rename extensions in the remapped record */
var_size = rec->cr_namelen; jid_mov = (char *)rec +
} changelog_rec_offset(crf_wanted & ~CLF_JOBID);
rnm_mov = (char *)rec +
changelog_rec_offset(crf_wanted & ~(CLF_JOBID | CLF_RENAME));
/* Move the extension fields to the desired positions */
if ((crf_wanted & CLF_JOBID) && (rec->cr_flags & CLF_JOBID))
memmove(jid_mov, changelog_rec_jobid(rec),
sizeof(struct changelog_ext_jobid));
memmove((char *)rec + changelog_rec_offset(crf & ~CLF_JOBID), var_part, if ((crf_wanted & CLF_RENAME) && (rec->cr_flags & CLF_RENAME))
var_size); memmove(rnm_mov, changelog_rec_rename(rec),
sizeof(struct changelog_ext_rename));
if ((crf & CLF_RENAME) && !(rec->cr_flags & CLF_RENAME)) /* Clear newly added fields */
memset(changelog_rec_rename(rec), 0, if ((crf_wanted & CLF_JOBID) && !(rec->cr_flags & CLF_JOBID))
sizeof(struct changelog_ext_rename)); memset(jid_mov, 0, sizeof(struct changelog_ext_jobid));
if ((crf & CLF_JOBID) && !(rec->cr_flags & CLF_JOBID)) if ((crf_wanted & CLF_RENAME) && !(rec->cr_flags & CLF_RENAME))
memset(changelog_rec_jobid(rec), 0, memset(rnm_mov, 0, sizeof(struct changelog_ext_rename));
sizeof(struct changelog_ext_jobid));
rec->cr_flags = (rec->cr_flags & CLF_FLAGMASK) | crf; /* Update the record's flags accordingly */
rec->cr_flags = (rec->cr_flags & CLF_FLAGMASK) | crf_wanted;
} }
struct ioc_changelog { struct ioc_changelog {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment