/**** changelogs ****/
-DECLARE_CHANGELOG_NAMES;
-
-const char *changelog_bit2str(int bit)
-{
- if (bit < CL_LAST)
- return changelog_str[bit];
- return NULL;
-}
-
static int lprocfs_rd_changelog_mask(char *page, char **start, off_t off,
int count, int *eof, void *data)
{
while (i < CL_LAST) {
if (mdd->mdd_cl.mc_mask & (1 << i))
rc += snprintf(page + rc, count - rc, "%s ",
- changelog_str[i]);
+ changelog_type2str(i));
i++;
}
return rc;
GOTO(out, rc = -EFAULT);
kernbuf[count] = 0;
- rc = libcfs_str2mask(kernbuf, changelog_bit2str, &mdd->mdd_cl.mc_mask,
+ rc = libcfs_str2mask(kernbuf, changelog_type2str, &mdd->mdd_cl.mc_mask,
CHANGELOG_MINMASK, CHANGELOG_ALLMASK);
if (rc == 0)
rc = count;
if (kernbuf[count - 1] == '\n')
kernbuf[count - 1] = '\0';
+ /* Forced on/off/purge rec, independent of changelog users! */
if (strcmp(kernbuf, "on") == 0) {
- LCONSOLE_INFO("changelog on\n");
- if (mdd->mdd_cl.mc_flags & CLM_ERR) {
- CERROR("Changelogs cannot be enabled due to error "
- "condition.\n");
- } else {
- spin_lock(&mdd->mdd_cl.mc_lock);
- mdd->mdd_cl.mc_flags |= CLM_ON;
- spin_unlock(&mdd->mdd_cl.mc_lock);
- rc = mdd_changelog_write_header(mdd, CLM_START);
- if (rc)
- return rc;
- }
+ rc = mdd_changelog_on(mdd, 1);
} else if (strcmp(kernbuf, "off") == 0) {
- LCONSOLE_INFO("changelog off\n");
- rc = mdd_changelog_write_header(mdd, CLM_FINI);
- if (rc)
- return rc;
- spin_lock(&mdd->mdd_cl.mc_lock);
- mdd->mdd_cl.mc_flags &= ~CLM_ON;
- spin_unlock(&mdd->mdd_cl.mc_lock);
+ rc = mdd_changelog_on(mdd, 0);
} else {
/* purge to an index */
long long unsigned endrec;
LCONSOLE_INFO("changelog purge to %llu\n", endrec);
rc = mdd_changelog_llog_cancel(mdd, endrec);
- if (rc < 0)
- return rc;
}
+ if (rc < 0)
+ return rc;
return count;
out_usage:
}
#endif
+static int lprocfs_rd_sync_perm(char *page, char **start, off_t off,
+ int count, int *eof, void *data)
+{
+ struct mdd_device *mdd = data;
+
+ LASSERT(mdd != NULL);
+ return snprintf(page, count, "%d\n", mdd->mdd_sync_permission);
+}
+
+static int lprocfs_wr_sync_perm(struct file *file, const char *buffer,
+ unsigned long count, void *data)
+{
+ struct mdd_device *mdd = data;
+ int val, rc;
+
+ LASSERT(mdd != NULL);
+ rc = lprocfs_write_helper(buffer, count, &val);
+ if (rc)
+ return rc;
+
+ mdd->mdd_sync_permission = !!val;
+ return count;
+}
+
static struct lprocfs_vars lprocfs_mdd_obd_vars[] = {
{ "atime_diff", lprocfs_rd_atime_diff, lprocfs_wr_atime_diff, 0 },
{ "changelog_mask", lprocfs_rd_changelog_mask,
{ "quota_type", mdd_lprocfs_quota_rd_type,
mdd_lprocfs_quota_wr_type, 0 },
#endif
+ { "sync_permission", lprocfs_rd_sync_perm, lprocfs_wr_sync_perm, 0 },
{ 0 }
};