Commit 73efe4a4 authored by Dave Chinner's avatar Dave Chinner Committed by Alex Elder

xfs: prevent NMI timeouts in cmn_err

We currently have a global error message buffer in cmn_err that is
protected by a spin lock that disables interrupts.  Recently there
have been reports of NMI timeouts occurring when the console is
being flooded by SCSI error reports due to cmn_err() getting stuck
trying to print to the console while holding this lock (i.e. with
interrupts disabled). The NMI watchdog is seeing this CPU as
non-responding and so is triggering a panic.  While the trigger for
the reported case is SCSI errors, pretty much anything that spams
the kernel log could cause this to occur.

Realistically the only reason that we have the intemediate message
buffer is to prepend the correct kernel log level prefix to the log
message. The only reason we have the lock is to protect the global
message buffer and the only reason the message buffer is global is
to keep it off the stack. Hence if we can avoid needing a global
message buffer we avoid needing the lock, and we can do this with a
small amount of cleanup and some preprocessor tricks:

	1. clean up xfs_cmn_err() panic mask functionality to avoid
	   needing debug code in xfs_cmn_err()
	2. remove the couple of "!" message prefixes that still exist that
	   the existing cmn_err() code steps over.
	3. redefine CE_* levels directly to KERN_*
	4. redefine cmn_err() and friends to use printk() directly
	   via variable argument length macros.

By doing this, we can completely remove the cmn_err() code and the
lock that is causing the problems, and rely solely on printk()
serialisation to ensure that we don't get garbled messages.

A series of followup patches is really needed to clean up all the
cmn_err() calls and related messages properly, but that results in a
series that is not easily back portable to enterprise kernels. Hence
this initial fix is only to address the direct problem in the lowest
impact way possible.
Signed-off-by: default avatarDave Chinner <dchinner@redhat.com>
Reviewed-by: default avatarChristoph Hellwig <hch@lst.de>
Signed-off-by: default avatarAlex Elder <aelder@sgi.com>
parent 65a84a0f
...@@ -18,6 +18,7 @@ ...@@ -18,6 +18,7 @@
#include "xfs.h" #include "xfs.h"
#include <linux/sysctl.h> #include <linux/sysctl.h>
#include <linux/proc_fs.h> #include <linux/proc_fs.h>
#include "xfs_error.h"
static struct ctl_table_header *xfs_table_header; static struct ctl_table_header *xfs_table_header;
...@@ -51,6 +52,26 @@ xfs_stats_clear_proc_handler( ...@@ -51,6 +52,26 @@ xfs_stats_clear_proc_handler(
return ret; return ret;
} }
STATIC int
xfs_panic_mask_proc_handler(
ctl_table *ctl,
int write,
void __user *buffer,
size_t *lenp,
loff_t *ppos)
{
int ret, *valp = ctl->data;
ret = proc_dointvec_minmax(ctl, write, buffer, lenp, ppos);
if (!ret && write) {
xfs_panic_mask = *valp;
#ifdef DEBUG
xfs_panic_mask |= (XFS_PTAG_SHUTDOWN_CORRUPT | XFS_PTAG_LOGRES);
#endif
}
return ret;
}
#endif /* CONFIG_PROC_FS */ #endif /* CONFIG_PROC_FS */
static ctl_table xfs_table[] = { static ctl_table xfs_table[] = {
...@@ -77,7 +98,7 @@ static ctl_table xfs_table[] = { ...@@ -77,7 +98,7 @@ static ctl_table xfs_table[] = {
.data = &xfs_params.panic_mask.val, .data = &xfs_params.panic_mask.val,
.maxlen = sizeof(int), .maxlen = sizeof(int),
.mode = 0644, .mode = 0644,
.proc_handler = proc_dointvec_minmax, .proc_handler = xfs_panic_mask_proc_handler,
.extra1 = &xfs_params.panic_mask.min, .extra1 = &xfs_params.panic_mask.min,
.extra2 = &xfs_params.panic_mask.max .extra2 = &xfs_params.panic_mask.max
}, },
......
...@@ -25,80 +25,71 @@ ...@@ -25,80 +25,71 @@
#include "xfs_mount.h" #include "xfs_mount.h"
#include "xfs_error.h" #include "xfs_error.h"
static char message[1024]; /* keep it off the stack */
static DEFINE_SPINLOCK(xfs_err_lock);
/* Translate from CE_FOO to KERN_FOO, err_level(CE_FOO) == KERN_FOO */
#define XFS_MAX_ERR_LEVEL 7
#define XFS_ERR_MASK ((1 << 3) - 1)
static const char * const err_level[XFS_MAX_ERR_LEVEL+1] =
{KERN_EMERG, KERN_ALERT, KERN_CRIT,
KERN_ERR, KERN_WARNING, KERN_NOTICE,
KERN_INFO, KERN_DEBUG};
void void
cmn_err(register int level, char *fmt, ...) cmn_err(
const char *lvl,
const char *fmt,
...)
{ {
char *fp = fmt; struct va_format vaf;
int len; va_list args;
ulong flags;
va_list ap; va_start(args, fmt);
vaf.fmt = fmt;
level &= XFS_ERR_MASK; vaf.va = &args;
if (level > XFS_MAX_ERR_LEVEL)
level = XFS_MAX_ERR_LEVEL; printk("%s%pV", lvl, &vaf);
spin_lock_irqsave(&xfs_err_lock,flags); va_end(args);
va_start(ap, fmt);
if (*fmt == '!') fp++; BUG_ON(strncmp(lvl, KERN_EMERG, strlen(KERN_EMERG)) == 0);
len = vsnprintf(message, sizeof(message), fp, ap);
if (len >= sizeof(message))
len = sizeof(message) - 1;
if (message[len-1] == '\n')
message[len-1] = 0;
printk("%s%s\n", err_level[level], message);
va_end(ap);
spin_unlock_irqrestore(&xfs_err_lock,flags);
BUG_ON(level == CE_PANIC);
} }
void void
xfs_fs_vcmn_err( xfs_fs_cmn_err(
int level, const char *lvl,
struct xfs_mount *mp, struct xfs_mount *mp,
char *fmt, const char *fmt,
va_list ap) ...)
{ {
unsigned long flags; struct va_format vaf;
int len = 0; va_list args;
level &= XFS_ERR_MASK; va_start(args, fmt);
if (level > XFS_MAX_ERR_LEVEL) vaf.fmt = fmt;
level = XFS_MAX_ERR_LEVEL; vaf.va = &args;
spin_lock_irqsave(&xfs_err_lock,flags); printk("%sFilesystem %s: %pV", lvl, mp->m_fsname, &vaf);
va_end(args);
if (mp) { BUG_ON(strncmp(lvl, KERN_EMERG, strlen(KERN_EMERG)) == 0);
len = sprintf(message, "Filesystem \"%s\": ", mp->m_fsname); }
/* All callers to xfs_cmn_err use CE_ALERT, so don't bother testing lvl */
void
xfs_cmn_err(
int panic_tag,
const char *lvl,
struct xfs_mount *mp,
const char *fmt,
...)
{
struct va_format vaf;
va_list args;
int panic = 0;
/* if (xfs_panic_mask && (xfs_panic_mask & panic_tag)) {
* Skip the printk if we can't print anything useful printk(KERN_ALERT "XFS: Transforming an alert into a BUG.");
* due to an over-long device name. panic = 1;
*/
if (len >= sizeof(message))
goto out;
} }
len = vsnprintf(message + len, sizeof(message) - len, fmt, ap); va_start(args, fmt);
if (len >= sizeof(message)) vaf.fmt = fmt;
len = sizeof(message) - 1; vaf.va = &args;
if (message[len-1] == '\n')
message[len-1] = 0;
printk("%s%s\n", err_level[level], message); printk(KERN_ALERT "Filesystem %s: %pV", mp->m_fsname, &vaf);
out: va_end(args);
spin_unlock_irqrestore(&xfs_err_lock,flags);
BUG_ON(level == CE_PANIC); BUG_ON(panic);
} }
void void
......
...@@ -20,15 +20,22 @@ ...@@ -20,15 +20,22 @@
#include <stdarg.h> #include <stdarg.h>
#define CE_DEBUG 7 /* debug */ struct xfs_mount;
#define CE_CONT 6 /* continuation */
#define CE_NOTE 5 /* notice */ #define CE_DEBUG KERN_DEBUG
#define CE_WARN 4 /* warning */ #define CE_CONT KERN_INFO
#define CE_ALERT 1 /* alert */ #define CE_NOTE KERN_NOTICE
#define CE_PANIC 0 /* panic */ #define CE_WARN KERN_WARNING
#define CE_ALERT KERN_ALERT
extern void cmn_err(int, char *, ...) #define CE_PANIC KERN_EMERG
__attribute__ ((format (printf, 2, 3)));
void cmn_err(const char *lvl, const char *fmt, ...)
__attribute__ ((format (printf, 2, 3)));
void xfs_fs_cmn_err( const char *lvl, struct xfs_mount *mp,
const char *fmt, ...) __attribute__ ((format (printf, 3, 4)));
void xfs_cmn_err( int panic_tag, const char *lvl, struct xfs_mount *mp,
const char *fmt, ...) __attribute__ ((format (printf, 4, 5)));
extern void assfail(char *expr, char *f, int l); extern void assfail(char *expr, char *f, int l);
#define ASSERT_ALWAYS(expr) \ #define ASSERT_ALWAYS(expr) \
......
...@@ -152,37 +152,6 @@ xfs_errortag_clearall(xfs_mount_t *mp, int loud) ...@@ -152,37 +152,6 @@ xfs_errortag_clearall(xfs_mount_t *mp, int loud)
} }
#endif /* DEBUG */ #endif /* DEBUG */
void
xfs_fs_cmn_err(int level, xfs_mount_t *mp, char *fmt, ...)
{
va_list ap;
va_start(ap, fmt);
xfs_fs_vcmn_err(level, mp, fmt, ap);
va_end(ap);
}
void
xfs_cmn_err(int panic_tag, int level, xfs_mount_t *mp, char *fmt, ...)
{
va_list ap;
#ifdef DEBUG
xfs_panic_mask |= (XFS_PTAG_SHUTDOWN_CORRUPT | XFS_PTAG_LOGRES);
#endif
if (xfs_panic_mask && (xfs_panic_mask & panic_tag)
&& (level & CE_ALERT)) {
level &= ~CE_ALERT;
level |= CE_PANIC;
cmn_err(CE_ALERT, "XFS: Transforming an alert into a BUG.");
}
va_start(ap, fmt);
xfs_fs_vcmn_err(level, mp, fmt, ap);
va_end(ap);
}
void void
xfs_error_report( xfs_error_report(
const char *tag, const char *tag,
......
...@@ -136,8 +136,8 @@ extern int xfs_error_test(int, int *, char *, int, char *, unsigned long); ...@@ -136,8 +136,8 @@ extern int xfs_error_test(int, int *, char *, int, char *, unsigned long);
xfs_error_test((tag), (mp)->m_fixedfsid, "expr", __LINE__, __FILE__, \ xfs_error_test((tag), (mp)->m_fixedfsid, "expr", __LINE__, __FILE__, \
(rf)))) (rf))))
extern int xfs_errortag_add(int error_tag, xfs_mount_t *mp); extern int xfs_errortag_add(int error_tag, struct xfs_mount *mp);
extern int xfs_errortag_clearall(xfs_mount_t *mp, int loud); extern int xfs_errortag_clearall(struct xfs_mount *mp, int loud);
#else #else
#define XFS_TEST_ERROR(expr, mp, tag, rf) (expr) #define XFS_TEST_ERROR(expr, mp, tag, rf) (expr)
#define xfs_errortag_add(tag, mp) (ENOSYS) #define xfs_errortag_add(tag, mp) (ENOSYS)
...@@ -162,21 +162,15 @@ extern int xfs_errortag_clearall(xfs_mount_t *mp, int loud); ...@@ -162,21 +162,15 @@ extern int xfs_errortag_clearall(xfs_mount_t *mp, int loud);
struct xfs_mount; struct xfs_mount;
extern void xfs_fs_vcmn_err(int level, struct xfs_mount *mp,
char *fmt, va_list ap)
__attribute__ ((format (printf, 3, 0)));
extern void xfs_cmn_err(int panic_tag, int level, struct xfs_mount *mp,
char *fmt, ...)
__attribute__ ((format (printf, 4, 5)));
extern void xfs_fs_cmn_err(int level, struct xfs_mount *mp, char *fmt, ...)
__attribute__ ((format (printf, 3, 4)));
extern void xfs_hex_dump(void *p, int length); extern void xfs_hex_dump(void *p, int length);
#define xfs_fs_repair_cmn_err(level, mp, fmt, args...) \ #define xfs_fs_repair_cmn_err(level, mp, fmt, args...) \
xfs_fs_cmn_err(level, mp, fmt " Unmount and run xfs_repair.", ## args) xfs_fs_cmn_err(level, mp, fmt " Unmount and run xfs_repair.", ## args)
#define xfs_fs_mount_cmn_err(f, fmt, args...) \ #define xfs_fs_mount_cmn_err(f, fmt, args...) \
((f & XFS_MFSI_QUIET)? (void)0 : cmn_err(CE_WARN, "XFS: " fmt, ## args)) do { \
if (!(f & XFS_MFSI_QUIET)) \
cmn_err(CE_WARN, "XFS: " fmt, ## args); \
} while (0)
#endif /* __XFS_ERROR_H__ */ #endif /* __XFS_ERROR_H__ */
...@@ -377,7 +377,7 @@ xfs_log_mount( ...@@ -377,7 +377,7 @@ xfs_log_mount(
cmn_err(CE_NOTE, "XFS mounting filesystem %s", mp->m_fsname); cmn_err(CE_NOTE, "XFS mounting filesystem %s", mp->m_fsname);
else { else {
cmn_err(CE_NOTE, cmn_err(CE_NOTE,
"!Mounting filesystem \"%s\" in no-recovery mode. Filesystem will be inconsistent.", "Mounting filesystem \"%s\" in no-recovery mode. Filesystem will be inconsistent.",
mp->m_fsname); mp->m_fsname);
ASSERT(mp->m_flags & XFS_MOUNT_RDONLY); ASSERT(mp->m_flags & XFS_MOUNT_RDONLY);
} }
......
...@@ -3800,7 +3800,7 @@ xlog_recover_finish( ...@@ -3800,7 +3800,7 @@ xlog_recover_finish(
log->l_flags &= ~XLOG_RECOVERY_NEEDED; log->l_flags &= ~XLOG_RECOVERY_NEEDED;
} else { } else {
cmn_err(CE_DEBUG, cmn_err(CE_DEBUG,
"!Ending clean XFS mount for filesystem: %s\n", "Ending clean XFS mount for filesystem: %s\n",
log->l_mp->m_fsname); log->l_mp->m_fsname);
} }
return 0; return 0;
......
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